-
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 sqlserver connector #2646
Conversation
89ac070
to
ade455b
Compare
是否应该是jdbc-connent |
9a9aaaa
to
40209ae
Compare
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.
hi, could you add the doc?
edb858d
to
769f2a7
Compare
...tor-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcSqlserverIT.java
Outdated
Show resolved
Hide resolved
...k-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcSqlserverIT.java
Outdated
Show resolved
Hide resolved
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.
Sort out all duplicate files. The test needs to check whether the data in the source table and the sink table are consistent
...tor-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcSqlserverIT.java
Outdated
Show resolved
Hide resolved
...k-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcSqlserverIT.java
Outdated
Show resolved
Hide resolved
...nel-e2e/seatunnel-flink-connector-v2-e2e/src/test/resources/container-license-acceptance.txt
Outdated
Show resolved
Hide resolved
.../seatunnel-flink-connector-v2-e2e/src/test/resources/jdbc/jdbc_sqlserver_source_to_sink.conf
Outdated
Show resolved
Hide resolved
...k-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcSqlserverIT.java
Outdated
Show resolved
Hide resolved
.../seatunnel-spark-connector-v2-e2e/src/test/resources/jdbc/jdbc_sqlserver_source_to_sink.conf
Outdated
Show resolved
Hide resolved
...tor-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcSqlserverIT.java
Outdated
Show resolved
Hide resolved
f481ea7
to
8c3ed2d
Compare
8c3ed2d
to
ff16d7c
Compare
PTAL @ic4y @EricJoy2048 @CalvinKirs thanks. |
|
...onnector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/container-license-acceptance.txt
Show resolved
Hide resolved
...onnector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/container-license-acceptance.txt
Show resolved
Hide resolved
LGTM @Hisoka-X |
Co-authored-by: Hisoka <fanjiaeminem@qq.com>
PTAL @CalvinKirs @TyrantLucifer @EricJoy2048 .thanks |
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.
@ashulin @TyrantLucifer @CalvinKirs @Hisoka-X @EricJoy2048 PTAL thanks. |
PTAL @CalvinKirs @TyrantLucifer @Hisoka-X .thanks |
LGTM |
@@ -32,22 +31,19 @@ | |||
* The before method will create a Flink cluster, and after method will close the Flink cluster. | |||
* You can use {@link AbstractFlinkContainer#executeJob} to submit a seatunnel config and run a seatunnel job. | |||
*/ | |||
@Slf4j |
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.
I found out that all the integration tests had failed,and the reason is log be inherited.So i fix it provisionally.
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.
I found out that all the integration tests had failed,and the reason is log be inherited.So i fix it provisionally.
@hailin0 PTAL
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.
I found out that all the integration tests had failed,and the reason is log be inherited.So i fix it provisionally.
@hailin0 @TyrantLucifer @ashulin@hailin0 PTAL
#2946 has resolved this problem, these files should be reverted.
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.
I found out that all the integration tests had failed,and the reason is log be inherited.So i fix it provisionally.
@hailin0 @TyrantLucifer @ashulin@hailin0 PTAL
#2946 has resolved this problem, these files should be reverted.
yes. I've revert.
please rerun CI thanks @TyrantLucifer |
Wait until the running workflow is finished before restarting. Please be patient. |
# Conflicts: # seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDmdbIT.java # seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcDmdbIT.java
@TyrantLucifer @Hisoka-X PTAL |
@@ -32,22 +31,19 @@ | |||
* The before method will create a Flink cluster, and after method will close the Flink cluster. | |||
* You can use {@link AbstractFlinkContainer#executeJob} to submit a seatunnel config and run a seatunnel job. | |||
*/ | |||
@Slf4j |
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 revert this file because pr #2946 has resolved problems of e2e test.
import org.junit.jupiter.api.AfterAll; | ||
import org.junit.jupiter.api.BeforeAll; | ||
import org.junit.jupiter.api.TestInstance; | ||
import org.testcontainers.containers.Container; | ||
|
||
import java.io.IOException; | ||
|
||
@Slf4j |
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 revert this file because pr #2946 has resolved problems of e2e test.
<dependency> | ||
<groupId>org.testcontainers</groupId> | ||
<artifactId>mssqlserver</artifactId> | ||
<version>1.17.3</version> |
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.
Using ${testcontainer.version}
instead of it.
<dependency> | ||
<groupId>org.testcontainers</groupId> | ||
<artifactId>mssqlserver</artifactId> | ||
<version>1.17.3</version> |
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.
Use ${testcontainer.version}
instead of it.
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.
Let's wait CI. Thank you for your contribution.
rerun CI? I don't think this mistake affects @TyrantLucifer |
CI had been optimized, so some steps will be enabled, before your pr is merged CI must run successfully. It's a community norm. There are some problems with the dependency checking step, pls check again. |
At now the dependency have some problem because st-engine bring some dependency but not update LICENSE file, we will update it later. |
1 similar comment
At now the dependency have some problem because st-engine bring some dependency but not update LICENSE file, we will update it later. |
Good, let's waiting other steps of CI. I had restarted the failed steps |
Purpose of this pull request
support sqlserver connector
Check list
New License Guide