fix expected data for test

Author: jianyun8023

pulsar-flink-connector/src/test/java/org/apache/flink/streaming/connectors/pulsar/table/UpsertPulsarTableITCase.java

@@ -83,9 +83,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 +409,7 @@ private void wordCountToUpsertPulsar(String wordCountTable) throws Exception {
     private void wordFreqToUpsertPulsar(String wordCountTable) throws Exception {
         // ------------- test data ---------------
 
-        final List<String> expectedData = Arrays.asList("3,1", "2,1");
+        final List<String> expectedData = Arrays.asList("+[3,1]", "+[2,1]");
 
         // ------------- create table ---------------