This is an automated email from the ASF dual-hosted git repository.
jiabaosun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/master by this push:
new ed4cd40af [hotfix][cdc-composor] Adjust test of cdc composer from
junit4 to junit5
ed4cd40af is described below
commit ed4cd40afcc4e44854414d4b61d5bbdd3ac35370
Author: Hongshun Wang <[email protected]>
AuthorDate: Fri Jun 7 10:03:25 2024 +0800
[hotfix][cdc-composor] Adjust test of cdc composer from junit4 to junit5
---
.../flink/cdc/composer/flink/FlinkPipelineComposerTest.java | 12 ++++++------
.../composer/flink/translator/DataSinkTranslatorTest.java | 8 ++++----
.../composer/flink/translator/DataSourceTranslatorTest.java | 13 +++++++------
3 files changed, 17 insertions(+), 16 deletions(-)
diff --git
a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerTest.java
b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerTest.java
index 31ca3520f..0623bf501 100644
---
a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerTest.java
+++
b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposerTest.java
@@ -27,14 +27,14 @@ import
org.apache.flink.cdc.composer.utils.factory.DataSinkFactory1;
import org.apache.flink.shaded.guava31.com.google.common.collect.ImmutableMap;
-import org.junit.Assert;
-import org.junit.Test;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
/** A test for the {@link FlinkPipelineComposer}. */
-public class FlinkPipelineComposerTest {
+class FlinkPipelineComposerTest {
@Test
- public void testCreateDataSinkFromSinkDef() {
+ void testCreateDataSinkFromSinkDef() {
SinkDef sinkDef =
new SinkDef(
"data-sink-factory-1",
@@ -55,7 +55,7 @@ public class FlinkPipelineComposerTest {
new Configuration(),
Thread.currentThread().getContextClassLoader()));
- Assert.assertTrue(dataSink instanceof DataSinkFactory1.TestDataSink);
- Assert.assertEquals("0.0.0.0", ((DataSinkFactory1.TestDataSink)
dataSink).getHost());
+ Assertions.assertTrue(dataSink instanceof
DataSinkFactory1.TestDataSink);
+ Assertions.assertEquals("0.0.0.0", ((DataSinkFactory1.TestDataSink)
dataSink).getHost());
}
}
diff --git
a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslatorTest.java
b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslatorTest.java
index 1970f3dfa..d2b8206d5 100644
---
a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslatorTest.java
+++
b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslatorTest.java
@@ -29,17 +29,17 @@ import
org.apache.flink.streaming.api.transformations.OneInputTransformation;
import org.apache.flink.shaded.guava31.com.google.common.collect.Lists;
-import org.junit.Assert;
+import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import java.io.IOException;
import java.util.ArrayList;
/** A test for {@link DataSinkTranslator}. */
-public class DataSinkTranslatorTest {
+class DataSinkTranslatorTest {
@Test
- public void testPreWriteWithoutCommitSink() {
+ void testPreWriteWithoutCommitSink() {
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
ArrayList<Event> mockEvents = Lists.newArrayList(new EmptyEvent(), new
EmptyEvent());
DataStreamSource<Event> inputStream = env.fromCollection(mockEvents);
@@ -60,7 +60,7 @@ public class DataSinkTranslatorTest {
OneInputTransformation<Event, Event> oneInputTransformation =
(OneInputTransformation) env.getTransformations().get(0);
Transformation<?> reblanceTransformation =
oneInputTransformation.getInputs().get(0);
- Assert.assertEquals(uid,
reblanceTransformation.getUserProvidedNodeHash());
+ Assertions.assertEquals(uid,
reblanceTransformation.getUserProvidedNodeHash());
}
private static class EmptyEvent implements Event {}
diff --git
a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSourceTranslatorTest.java
b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSourceTranslatorTest.java
index c08c976c7..1630edfa4 100644
---
a/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSourceTranslatorTest.java
+++
b/flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/translator/DataSourceTranslatorTest.java
@@ -27,14 +27,14 @@ import
org.apache.flink.cdc.composer.utils.factory.DataSourceFactory1;
import org.apache.flink.shaded.guava31.com.google.common.collect.ImmutableMap;
-import org.junit.Assert;
-import org.junit.Test;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
/** A test for the {@link DataSourceTranslator}. */
-public class DataSourceTranslatorTest {
+class DataSourceTranslatorTest {
@Test
- public void testCreateDataSourceFromSourceDef() {
+ void testCreateDataSourceFromSourceDef() {
SourceDef sourceDef =
new SourceDef(
"data-source-factory-1",
@@ -55,7 +55,8 @@ public class DataSourceTranslatorTest {
new Configuration(),
Thread.currentThread().getContextClassLoader()));
- Assert.assertTrue(dataSource instanceof
DataSourceFactory1.TestDataSource);
- Assert.assertEquals("0.0.0.0", ((DataSourceFactory1.TestDataSource)
dataSource).getHost());
+ Assertions.assertTrue(dataSource instanceof
DataSourceFactory1.TestDataSource);
+ Assertions.assertEquals(
+ "0.0.0.0", ((DataSourceFactory1.TestDataSource)
dataSource).getHost());
}
}
