This is an automated email from the ASF dual-hosted git repository.
liugddx pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 00e0ce9e2 [e2e] kafka e2e error (#5200)
00e0ce9e2 is described below
commit 00e0ce9e221ec4abde133ebe92db345638e17702
Author: XiaoJiang521 <[email protected]>
AuthorDate: Wed Aug 2 19:00:49 2023 +0800
[e2e] kafka e2e error (#5200)
---
.../seatunnel/e2e/connector/kafka/DebeziumToKafkaIT.java | 11 +++++++++++
.../src/test/resources/kafkasource_debezium_cdc_to_pgsql.conf | 4 ++--
2 files changed, 13 insertions(+), 2 deletions(-)
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/DebeziumToKafkaIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/DebeziumToKafkaIT.java
index e76a44599..da1ee1371 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/DebeziumToKafkaIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/java/org/apache/seatunnel/e2e/connector/kafka/DebeziumToKafkaIT.java
@@ -314,6 +314,17 @@ public class DebeziumToKafkaIT extends TestSuiteBase
implements TestResource {
108, "jacket", "water resistent black
wind breaker", "0.1"))
.collect(Collectors.toSet());
Assertions.assertIterableEquals(expected, actual);
+
+ try (Connection connection =
+ DriverManager.getConnection(
+ POSTGRESQL_CONTAINER.getJdbcUrl(),
+ POSTGRESQL_CONTAINER.getUsername(),
+ POSTGRESQL_CONTAINER.getPassword())) {
+ try (Statement statement = connection.createStatement()) {
+ statement.execute("truncate table sink");
+ LOG.info("testDebeziumFormatKafkaCdcToPgsql truncate table
sink");
+ }
+ }
}
public void initializeSourceTableData() throws Exception {
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/resources/kafkasource_debezium_cdc_to_pgsql.conf
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/resources/kafkasource_debezium_cdc_to_pgsql.conf
index a0531b234..2d56fb787 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/resources/kafkasource_debezium_cdc_to_pgsql.conf
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e/src/test/resources/kafkasource_debezium_cdc_to_pgsql.conf
@@ -55,8 +55,8 @@ sink {
user = test
password = test
generate_sink_sql = true
- database = public
- table = sink
+ database = test
+ table = public.sink
primary_keys = ["id"]
}
}
\ No newline at end of file
