Fix issue with updated method signature

airbytehq · Jun 14, 2022 · e1ae1f7 · e1ae1f7
1 parent 410151f
commit e1ae1f7
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/...source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlCdcStateHandler.java b/...source-mssql/src/main/java/io/airbyte/integrations/source/mssql/MssqlCdcStateHandler.java
@@ -41,7 +41,11 @@ public AirbyteMessage saveState(final Map<String, String> offset, final String d
 
     final CdcState cdcState = new CdcState().withState(asJson);
     stateManager.getCdcStateManager().setCdcState(cdcState);
-    final AirbyteStateMessage stateMessage = stateManager.emit();
+    /*
+     * Namespace pair is ignored by global state manager, but is needed for satisfy the API contract.
+     * Therefore, it doesn't matter what we pass here, as it will be ignored.
+     */
+    final AirbyteStateMessage stateMessage = stateManager.emit(null);
     return new AirbyteMessage().withType(Type.STATE).withState(stateMessage);
   }
 

diff --git a/...source-mysql/src/main/java/io/airbyte/integrations/source/mysql/MySqlCdcStateHandler.java b/...source-mysql/src/main/java/io/airbyte/integrations/source/mysql/MySqlCdcStateHandler.java
@@ -42,7 +42,11 @@ public AirbyteMessage saveState(final Map<String, String> offset, final String d
 
     final CdcState cdcState = new CdcState().withState(asJson);
     stateManager.getCdcStateManager().setCdcState(cdcState);
-    final AirbyteStateMessage stateMessage = stateManager.emit();
+    /*
+     * Namespace pair is ignored by global state manager, but is needed for satisfy the API contract.
+     * Therefore, it doesn't matter what we pass here, as it will be ignored.
+     */
+    final AirbyteStateMessage stateMessage = stateManager.emit(null);
     return new AirbyteMessage().withType(Type.STATE).withState(stateMessage);
   }