Skip to content

Commit b78199f

Browse files
author
nguyenaiden
committed
Add checkpointing to incremental runs for mysql CDC
1 parent ec6da09 commit b78199f

File tree

1 file changed

+1
-1
lines changed
  • airbyte-integrations/connectors/source-mysql/src/main/java/io/airbyte/integrations/source/mysql

1 file changed

+1
-1
lines changed

airbyte-integrations/connectors/source-mysql/src/main/java/io/airbyte/integrations/source/mysql/MySqlSource.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@
8686
public class MySqlSource extends AbstractJdbcSource<MysqlType> implements Source {
8787

8888
private static final Logger LOGGER = LoggerFactory.getLogger(MySqlSource.class);
89-
private static final int INTERMEDIATE_STATE_EMISSION_FREQUENCY = 1;
89+
private static final int INTERMEDIATE_STATE_EMISSION_FREQUENCY = 10_000;
9090
public static final String NULL_CURSOR_VALUE_WITH_SCHEMA_QUERY =
9191
"""
9292
SELECT (EXISTS (SELECT * from `%s`.`%s` where `%s` IS NULL LIMIT 1)) AS %s

0 commit comments

Comments
 (0)