-
Notifications
You must be signed in to change notification settings - Fork 1.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[Feature][Connector-V2] Add influxDB connector source #2595
Conversation
.../src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/source/InfluxDBSource.java
Outdated
Show resolved
Hide resolved
...org/apache/seatunnel/connectors/seatunnel/influxdb/source/InfluxDBSourceSplitEnumerator.java
Outdated
Show resolved
Hide resolved
.../src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/client/InfluxDBClient.java
Outdated
Show resolved
Hide resolved
...seatunnel-flink-connector-v2-e2e/src/test/resources/influxdb/influxdb_source_to_console.conf
Outdated
Show resolved
Hide resolved
...-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/influxdb/InfluxDBSourceToConsoleIT.java
Outdated
Show resolved
Hide resolved
@hailin0 @CalvinKirs @EricJoy2048 Hi brothers, please help me review. Integration test phase fails. How to solve this problem? My local E2E can pass |
https://pipelines.actions.githubusercontent.com/serviceHosts/5f1d2e93-1249-42e2-b16d-ed31c598c5d5/_apis/pipelines/1/runs/17499/signedlogcontent/36?urlExpires=2022-09-05T12%3A40%3A16.6214641Z&urlSigningMethod=HMACV1&urlSignature=pxCWdlIluLkqSV6lJ5ns5Fi9zSQKLy5Id%2FTDwE6xljY%3D
Please check for dependency jar conflicts |
https://pipelines.actions.githubusercontent.com/serviceHosts/5f1d2e93-1249-42e2-b16d-ed31c598c5d5/_apis/pipelines/1/runs/17499/signedlogcontent/36?urlExpires=2022-09-05T12%3A40%3A16.6214641Z&urlSigningMethod=HMACV1&urlSignature=pxCWdlIluLkqSV6lJ5ns5Fi9zSQKLy5Id%2FTDwE6xljY%3D |
the `query_timeout` of the InfluxDB when you select, in seconds | ||
|
||
### connect_timeout_ms [long] | ||
the timeout for connecting to InfluxDB, in milliseconds |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please add some example for this connector. You can refer to the documentation of other connectors.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please add some example for this connector. You can refer to the documentation of other connectors.
Thank you for your suggestion, I have added in new commit
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM. @hailin0 @CalvinKirs PHAL
pom.xml
Outdated
|
||
<dependency> | ||
<groupId>org.influxdb</groupId> | ||
<artifactId>influxdb-java</artifactId> | ||
<version>${influxdb.version}</version> | ||
</dependency> |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Connector-specific dependencies are now managed under seatunnel-connectors-v2/connector-influxdb/pom.xml
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Connector-specific dependencies are now managed under seatunnel-connectors-v2/connector-influxdb/pom.xml
ok, i have fixed in new commit
#1946
Add InfluxDB Connector Source
Purpose of this pull request
Check list
New License Guide