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<String> expectedData = Arrays.asList("3,1", "2,1");
+        final List<String> expectedData = Arrays.asList("+[3,1]", "+[2,1]");
 
         // ------------- create table ---------------