From c89ae6b1c4fb89edb5370fbb3e14e32f8d86067c Mon Sep 17 00:00:00 2001 From: Jianyun Zhao Date: Fri, 3 Dec 2021 23:35:48 +0800 Subject: [PATCH] fix expected data for test --- .../connectors/pulsar/table/UpsertPulsarTableITCase.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/pulsar-flink-connector/src/test/java/org/apache/flink/streaming/connectors/pulsar/table/UpsertPulsarTableITCase.java b/pulsar-flink-connector/src/test/java/org/apache/flink/streaming/connectors/pulsar/table/UpsertPulsarTableITCase.java index 7d0cda3d..cfb7828a 100644 --- a/pulsar-flink-connector/src/test/java/org/apache/flink/streaming/connectors/pulsar/table/UpsertPulsarTableITCase.java +++ b/pulsar-flink-connector/src/test/java/org/apache/flink/streaming/connectors/pulsar/table/UpsertPulsarTableITCase.java @@ -28,7 +28,6 @@ import org.apache.flink.types.Row; import org.junit.Before; -import org.junit.Ignore; import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.Parameterized; @@ -83,9 +82,7 @@ public void setup() { env.getConfig().setRestartStrategy(RestartStrategies.noRestart()); } - /** The fix is in release-1.13. */ @Test - @Ignore public void testAggregate() throws Exception { String topic = WORD_COUNT_TOPIC + "_" + format; createTestTopic(topic, 4); @@ -411,7 +408,7 @@ private void wordCountToUpsertPulsar(String wordCountTable) throws Exception { private void wordFreqToUpsertPulsar(String wordCountTable) throws Exception { // ------------- test data --------------- - final List expectedData = Arrays.asList("3,1", "2,1"); + final List expectedData = Arrays.asList("+[3,1]", "+[2,1]"); // ------------- create table ---------------