This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a commit to branch add_canvas_job_define
in repository https://gitbox.apache.org/repos/asf/seatunnel-web.git
The following commit(s) were added to refs/heads/add_canvas_job_define by this
push:
new c8097836 [ADD][FUNCTION]Add synchronization task instance function
(#66)
c8097836 is described below
commit c80978360ef4493d87f25ea422f317ef0daf1715
Author: zhangchengming601 <[email protected]>
AuthorDate: Wed Jul 12 18:26:13 2023 +0800
[ADD][FUNCTION]Add synchronization task instance function (#66)
---
.../java/org/apache/seatunnel/datasource/DataSourceClientTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/seatunnel-datasource/seatunnel-datasource-client/src/test/java/org/apache/seatunnel/datasource/DataSourceClientTest.java
b/seatunnel-datasource/seatunnel-datasource-client/src/test/java/org/apache/seatunnel/datasource/DataSourceClientTest.java
index 1c45fe7e..09d0f5fb 100644
---
a/seatunnel-datasource/seatunnel-datasource-client/src/test/java/org/apache/seatunnel/datasource/DataSourceClientTest.java
+++
b/seatunnel-datasource/seatunnel-datasource-client/src/test/java/org/apache/seatunnel/datasource/DataSourceClientTest.java
@@ -31,19 +31,19 @@ class DataSourceClientTest {
DATA_SOURCE_CLIENT.listAllDataSources().stream()
.anyMatch(
dataSourcePluginInfo ->
- StringUtils.equalsAnyIgnoreCase(
+ StringUtils.equalsIgnoreCase(
dataSourcePluginInfo.getName(), "jdbc-mysql")));
Assertions.assertTrue(
DATA_SOURCE_CLIENT.listAllDataSources().stream()
.anyMatch(
dataSourcePluginInfo ->
- StringUtils.equalsAnyIgnoreCase(
+ StringUtils.equalsIgnoreCase(
dataSourcePluginInfo.getName(), "kafka")));
Assertions.assertTrue(
DATA_SOURCE_CLIENT.listAllDataSources().stream()
.anyMatch(
dataSourcePluginInfo ->
- StringUtils.equalsAnyIgnoreCase(
+ StringUtils.equalsIgnoreCase(
dataSourcePluginInfo.getName(), "elasticsearch")));
}
}