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 7d0cda3d1..463da8a40 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
@@ -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 ---------------