fix UT

vernedeng · Jun 27, 2024 · 515da06 · 515da06
1 parent cddb7e3
commit 515da06
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...sdk/src/test/java/org/apache/inlong/sdk/sort/impl/pulsar/InLongPulsarFetcherImplTest.java b/...sdk/src/test/java/org/apache/inlong/sdk/sort/impl/pulsar/InLongPulsarFetcherImplTest.java
@@ -81,6 +81,7 @@ public void setUp() throws Exception {
 
         when(clientContext.getConfig()).thenReturn(sortClientConfig);
         when(sortClientConfig.getSortTaskId()).thenReturn("sortTaskId");
+        when(sortClientConfig.getSubscription()).thenReturn("sortTaskId");
 
     }