Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[source-MySQL] Error while trying to run connector class 'io.debezium.connector.mysql.MySqlConnector' #32348

Closed
1 task
dimoschi opened this issue Nov 9, 2023 · 13 comments · Fixed by #35527
Closed
1 task
Assignees
Labels
area/connectors Connector related issues community connectors/source/mysql team/db-dw-sources Backlog for Database and Data Warehouse Sources team type/bug Something isn't working

Comments

@dimoschi
Copy link

dimoschi commented Nov 9, 2023

Connector Name

source-mysql

Connector Version

3.1.7

What step the error happened?

During the sync

Relevant information

There is a huge part in our binlog file for a massive update of 1.7M rows that happened in our DB. To me, it seems that the connector times out and restarts reading the binlog in the middle thus the table map is not available to the connector. In the following log file, I have removed references to the 'destination' as irrelevant.

a0117286_6815_4c3a_8575_98b3b5ac8274_job_7837_attempt_1_source.txt

Relevant log output

2023-11-09 13:10:11 source > 2023-11-09 13:10:11 INFO i.d.c.c.BaseSourceTask(lambda$start$0):138 -    snapshot.mode = when_needed
2023-11-09 13:10:11 source > 2023-11-09 13:10:11 INFO i.d.c.c.BaseSourceTask(lambda$start$0):138 -    database.include.list = hackthebox
2023-11-09 13:10:11 source > 2023-11-09 13:10:11 INFO i.d.c.CommonConnectorConfig(getSourceInfoStructMaker):1221 - Loading the custom source info struct maker plugin: io.debezium.connector.mysql.MySqlSourceInfoStructMaker
2023-11-09 13:10:11 source > 2023-11-09 13:10:11 INFO i.d.c.CommonConnectorConfig(getTopicNamingStrategy):973 - Loading the custom topic naming strategy plugin: io.debezium.schema.DefaultTopicNamingStrategy
2023-11-09 13:10:11 source > 2023-11-09 13:10:11 INFO i.d.c.c.BaseSourceTask(getPreviousOffsets):376 - Found previous partition offset MySqlPartition [sourcePartition={server=hackthebox}]: {transaction_id=null, file=mysql-binlog.010396, pos=35842144, row=2, event=1072}
2023-11-09 13:10:11 source > 2023-11-09 13:10:11 INFO i.d.c.m.MySqlConnectorTask(start):100 - Closing connection before starting schema recovery
2023-11-09 13:10:11 source > 2023-11-09 13:10:11 INFO i.d.j.JdbcConnection(lambda$doClose$4):947 - Connection gracefully closed
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.c.m.MySqlConnectorTask(start):114 - Reconnecting after finishing schema recovery
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.c.m.MySqlConnection(availableBinlogFiles):397 - Get all known binlogs from MySQL
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.c.m.MySqlConnectorTask(isBinlogAvailable):329 - MySQL has the binlog file 'mysql-binlog.010396' required by the connector
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.u.Threads(threadFactory):271 - Requested thread factory for connector MySqlConnector, id = hackthebox named = SignalProcessor
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.u.Threads(threadFactory):271 - Requested thread factory for connector MySqlConnector, id = hackthebox named = change-event-source-coordinator
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.u.Threads(threadFactory):271 - Requested thread factory for connector MySqlConnector, id = hackthebox named = blocking-snapshot
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.u.Threads$3(newThread):288 - Creating thread debezium-mysqlconnector-hackthebox-change-event-source-coordinator
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.p.s.SignalProcessor(start):105 - SignalProcessor started. Scheduling it every 5000ms
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.u.Threads$3(newThread):288 - Creating thread debezium-mysqlconnector-hackthebox-SignalProcessor
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.p.ChangeEventSourceCoordinator(lambda$start$0):131 - Metrics registered
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.p.ChangeEventSourceCoordinator(lambda$start$0):134 - Context created
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.c.m.MySqlSnapshotChangeEventSource(getSnapshottingTask):101 - A previous offset indicating a completed snapshot has been found. Neither schema nor data will be snapshotted.
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.p.ChangeEventSourceCoordinator(doSnapshot):254 - Snapshot ended with SnapshotResult [status=SKIPPED, offset=MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=mysql-binlog.010396, currentBinlogPosition=35842144, currentRowNumber=0, serverId=0, sourceTime=null, threadId=-1, currentQuery=null, tableIds=[], databaseName=null], snapshotCompleted=false, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=null, currentGtidSet=null, restartBinlogFilename=mysql-binlog.010396, restartBinlogPosition=35842144, restartRowsToSkip=2, restartEventsToSkip=1072, currentEventLengthInBytes=0, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]]
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.u.Threads(threadFactory):271 - Requested thread factory for connector MySqlConnector, id = hackthebox named = binlog-client
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.c.m.MySqlStreamingChangeEventSource(getBinlogSslSocketFactory):1070 - Enable ssl PREFERRED mode for connector hackthebox
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.p.ChangeEventSourceCoordinator(streamEvents):271 - Starting streaming
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.c.m.MySqlStreamingChangeEventSource(execute):984 - Skip 1072 events on streaming start
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.c.m.MySqlStreamingChangeEventSource(execute):988 - Skip 2 rows on streaming start
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.u.Threads$3(newThread):288 - Creating thread debezium-mysqlconnector-hackthebox-binlog-client
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.u.Threads$3(newThread):288 - Creating thread debezium-mysqlconnector-hackthebox-binlog-client
2023-11-09 13:10:13 source > Nov 09, 2023 1:10:13 PM com.github.shyiko.mysql.binlog.BinaryLogClient tryUpgradeToSSL
2023-11-09 13:10:13 source > INFO: SSL enabled
2023-11-09 13:10:13 source > Nov 09, 2023 1:10:13 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
2023-11-09 13:10:13 source > INFO: Connected to 46.101.4.87:3306 at mysql-binlog.010396/35842144 (sid:5890, cid:41919)
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.c.m.MySqlStreamingChangeEventSource$ReaderThreadLifecycleListener(onConnect):1285 - Connected to MySQL binlog at 46.101.4.87:3306, starting at MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=mysql-binlog.010396, currentBinlogPosition=35842144, currentRowNumber=0, serverId=0, sourceTime=null, threadId=-1, currentQuery=null, tableIds=[], databaseName=null], snapshotCompleted=false, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=null, currentGtidSet=null, restartBinlogFilename=mysql-binlog.010396, restartBinlogPosition=35842144, restartRowsToSkip=2, restartEventsToSkip=1072, currentEventLengthInBytes=0, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.u.Threads$3(newThread):288 - Creating thread debezium-mysqlconnector-hackthebox-binlog-client
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.c.m.MySqlStreamingChangeEventSource(execute):1005 - Waiting for keepalive thread to start
2023-11-09 13:10:13 source > 2023-11-09 13:10:13 INFO i.d.c.m.MySqlStreamingChangeEventSource(execute):1012 - Keepalive thread is running
2023-11-09 13:14:31 source > Nov 09, 2023 1:12:13 PM com.github.shyiko.mysql.binlog.BinaryLogClient$5 run
2023-11-09 13:14:31 source > INFO: Keepalive: Trying to restore lost connection to 46.101.4.87:3306
2023-11-09 13:14:31 source > 2023-11-09 13:14:31 INFO i.d.c.c.BaseSourceTask(logStatistics):215 - 15756 records sent during previous 00:04:20.004, last recorded offset of {server=hackthebox} partition is {transaction_id=null, ts_sec=1699423236, file=mysql-binlog.010396, pos=49547105, row=3, server_id=1}
2023-11-09 13:14:31 source > 2023-11-09 13:14:31 INFO i.d.u.Threads$3(newThread):288 - Creating thread debezium-mysqlconnector-hackthebox-binlog-client
2023-11-09 13:14:31 source > 2023-11-09 13:14:31 INFO i.d.c.m.MySqlStreamingChangeEventSource$ReaderThreadLifecycleListener(lambda$onDisconnect$0):1270 - Stopped reading binlog after 0 events, last recorded offset: {transaction_id=null, ts_sec=1699423236, file=mysql-binlog.010396, pos=55001289, server_id=1, event=1}
2023-11-09 13:14:31 source > Nov 09, 2023 1:14:31 PM com.github.shyiko.mysql.binlog.BinaryLogClient tryUpgradeToSSL
2023-11-09 13:14:31 source > INFO: SSL enabled
2023-11-09 13:14:31 source > Nov 09, 2023 1:14:31 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
2023-11-09 13:14:31 source > INFO: Connected to 46.101.4.87:3306 at mysql-binlog.010396/55001289 (sid:5890, cid:41937)
2023-11-09 13:14:31 source > 2023-11-09 13:14:31 INFO i.d.c.m.MySqlStreamingChangeEventSource$ReaderThreadLifecycleListener(onConnect):1285 - Connected to MySQL binlog at 46.101.4.87:3306, starting at MySqlOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.mysql.Source:STRUCT}, sourceInfo=SourceInfo [currentGtid=null, currentBinlogFilename=mysql-binlog.010396, currentBinlogPosition=54993937, currentRowNumber=8, serverId=1, sourceTime=2023-11-08T06:00:36Z, threadId=-1, currentQuery=null, tableIds=[hackthebox.users], databaseName=null], snapshotCompleted=false, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], restartGtidSet=null, currentGtidSet=null, restartBinlogFilename=mysql-binlog.010396, restartBinlogPosition=55001289, restartRowsToSkip=0, restartEventsToSkip=1, currentEventLengthInBytes=7352, inTransaction=false, transactionId=null, incrementalSnapshotContext =IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]
2023-11-09 13:14:31 source > 2023-11-09 13:14:31 ERROR i.d.c.m.MySqlStreamingChangeEventSource(logStreamingSourceState):1161 - Error during binlog processing. Last offset stored = {transaction_id=null, ts_sec=1699423236, file=mysql-binlog.010396, pos=0, server_id=2, event=1}, binlog reader near position = mysql-binlog.010396/55001289
2023-11-09 13:14:31 source > 2023-11-09 13:14:31 ERROR i.d.p.ErrorHandler(setProducerThrowable):52 - Producer failure
2023-11-09 13:14:31 source > io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4{timestamp=1699423236000, eventType=UPDATE_ROWS, serverId=1, headerLength=19, dataLength=8009, nextPosition=55009317, flags=0}
2023-11-09 13:14:31 source > 	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.wrap(MySqlStreamingChangeEventSource.java:1254) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]
2023-11-09 13:14:31 source > 	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource$ReaderThreadLifecycleListener.onEventDeserializationFailure(MySqlStreamingChangeEventSource.java:1307) [debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1064) [mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:631) [mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:932) [mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at java.base/java.lang.Thread.run(Thread.java:833) [?:?]
2023-11-09 13:14:31 source > Caused by: com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1699423236000, eventType=UPDATE_ROWS, serverId=1, headerLength=19, dataLength=8009, nextPosition=55009317, flags=0}
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:343) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:246) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource$1.nextEvent(MySqlStreamingChangeEventSource.java:233) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1051) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	... 3 more
2023-11-09 13:14:31 source > Caused by: com.github.shyiko.mysql.binlog.event.deserialization.MissingTableMapEventException: No TableMapEventData has been found for table id:26. Usually that means that you have started reading binary log 'within the logical event group' (e.g. from WRITE_ROWS and not proceeding TABLE_MAP
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.AbstractRowsEventDataDeserializer.deserializeRow(AbstractRowsEventDataDeserializer.java:109) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.UpdateRowsEventDataDeserializer.deserializeRows(UpdateRowsEventDataDeserializer.java:71) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.UpdateRowsEventDataDeserializer.deserialize(UpdateRowsEventDataDeserializer.java:58) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.UpdateRowsEventDataDeserializer.deserialize(UpdateRowsEventDataDeserializer.java:33) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:337) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:246) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource$1.nextEvent(MySqlStreamingChangeEventSource.java:233) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1051) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	... 3 more
2023-11-09 13:14:31 source > 2023-11-09 13:14:31 ERROR i.d.p.ErrorHandler(hasMoreRetries):129 - The maximum number of 0 retries has been attempted
2023-11-09 13:14:31 source > 2023-11-09 13:14:31 ERROR i.d.c.m.MySqlStreamingChangeEventSource(logStreamingSourceState):1161 - Error during binlog processing. Last offset stored = {transaction_id=null, ts_sec=1699423236, file=mysql-binlog.010396, pos=0, server_id=2, event=1}, binlog reader near position = mysql-binlog.010396/55001289
2023-11-09 13:14:31 source > 2023-11-09 13:14:31 ERROR i.d.p.ErrorHandler(setProducerThrowable):52 - Producer failure
2023-11-09 13:14:31 source > io.debezium.DebeziumException: Failed to deserialize data of EventHeaderV4{timestamp=1699423236000, eventType=UPDATE_ROWS, serverId=1, headerLength=19, dataLength=7463, nextPosition=55016799, flags=0}
2023-11-09 13:14:31 source > 	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.wrap(MySqlStreamingChangeEventSource.java:1254) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]
2023-11-09 13:14:31 source > 	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource$ReaderThreadLifecycleListener.onEventDeserializationFailure(MySqlStreamingChangeEventSource.java:1307) [debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1064) [mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:631) [mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:932) [mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at java.base/java.lang.Thread.run(Thread.java:833) [?:?]
2023-11-09 13:14:31 source > Caused by: com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1699423236000, eventType=UPDATE_ROWS, serverId=1, headerLength=19, dataLength=7463, nextPosition=55016799, flags=0}
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:343) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:246) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource$1.nextEvent(MySqlStreamingChangeEventSource.java:233) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1051) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	... 3 more
2023-11-09 13:14:31 source > Caused by: com.github.shyiko.mysql.binlog.event.deserialization.MissingTableMapEventException: No TableMapEventData has been found for table id:26. Usually that means that you have started reading binary log 'within the logical event group' (e.g. from WRITE_ROWS and not proceeding TABLE_MAP
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.AbstractRowsEventDataDeserializer.deserializeRow(AbstractRowsEventDataDeserializer.java:109) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.UpdateRowsEventDataDeserializer.deserializeRows(UpdateRowsEventDataDeserializer.java:71) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.UpdateRowsEventDataDeserializer.deserialize(UpdateRowsEventDataDeserializer.java:58) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.UpdateRowsEventDataDeserializer.deserialize(UpdateRowsEventDataDeserializer.java:33) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:337) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:246) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	at io.debezium.connector.mysql.MySqlStreamingChangeEventSource$1.nextEvent(MySqlStreamingChangeEventSource.java:233) ~[debezium-connector-mysql-2.4.0.Final.jar:2.4.0.Final]
2023-11-09 13:14:31 source > 	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1051) ~[mysql-binlog-connector-java-0.28.1.jar:0.28.1]
2023-11-09 13:14:31 source > 	... 3 more

Contribute

  • Yes, I want to contribute
@dimoschi
Copy link
Author

Downgrading the source-mysql to 3.1.1 solved the issue, so my guess is that the problem is in the recent version upgrade of Debezium to 2.4.0

@stephane-airbyte stephane-airbyte self-assigned this Feb 21, 2024
stephane-airbyte added a commit that referenced this issue Feb 23, 2024
tanawatpan pushed a commit to tanawatpan/airbyte that referenced this issue Feb 24, 2024
jatinyadav-cc added a commit to ollionorg/datapipes-airbyte that referenced this issue Feb 26, 2024
* ✨ source-surveymonkey: migrate to poetry (airbytehq#35168)

* ✨ source-monday: migrate to poetry (airbytehq#35146)

* ✨ source-salesforce: migrate to poetry (airbytehq#35147)

* ✨ source-intercom: migrate to poetry (airbytehq#35148)

* ✨ source-iterable: migrate to poetry (airbytehq#35150)

* ✨ source-mixpanel: migrate to poetry (airbytehq#35151)

* ✨ source-typeform: migrate to poetry (airbytehq#35152)

* ✨ source-twilio: migrate to poetry (airbytehq#35153)

* ✨ source-notion: migrate to poetry (airbytehq#35155)

* ✨ source-zendesk-talk: migrate to poetry (airbytehq#35156)

* ✨ source-amplitude: migrate to poetry (airbytehq#35162)

* ✨ source-jira: migrate to poetry (airbytehq#35160)

* ✨ source-google-ads: migrate to poetry (airbytehq#35158)

* 🐛 Source Slack: Join to the channels while `read` instead of `discovery` (airbytehq#35131)

* ✨ source-hubspot: migrate to poetry (airbytehq#35165)

* ✨ source-pinterest: migrate to poetry (airbytehq#35159)

* ✨ source-sentry: migrate to poetry (airbytehq#35145)

* ✨ source-chargebee: migrate to poetry (airbytehq#35169)

* source-snapchat-marketing: adopt our base image (airbytehq#35170)

* ✨ source-snapchat-marketing: migrate to poetry (airbytehq#35171)

* source-faker: adopt our base image (airbytehq#35172)

* ✨ source-faker: migrate to poetry (airbytehq#35174)

* ✨ source-amazon-ads: migrate to poetry (airbytehq#35180)

* Source Github: add integration tests  (airbytehq#34933)

* ✨ source-bing-ads: migrate to poetry (airbytehq#35179)

* ✨ source-instagram: migrate to poetry (airbytehq#35177)

* ✨ source-facebook-marketing: migrate to poetry (airbytehq#35178)

* destination-async-framework: make emission of state from FlushWorkers synchronized (airbytehq#35144)

* ✨ source-freshdesk: migrate to poetry (airbytehq#35187)

* 🐛 source-mysql Support special chars in dbname (airbytehq#34580)

* AirbyteLib: Release 0.1.0 (airbytehq#35184)

* 📚 Adjust documentation for corepack (airbytehq#35192)

* ✨ source-recharge: migrate to poetry (airbytehq#35182)

* ✨ source-tiktok-marketing: migrate to poetry (airbytehq#35161)

* Bump Airbyte version from 0.50.48 to 0.50.49

* ✨ Destination Postgres: DV2 GA (airbytehq#35042)

Co-authored-by: Marius Posta <marius@airbyte.io>
Co-authored-by: Evan Tahler <evan@airbyte.io>

* Destination snowflake: reorder auth spec options (airbytehq#35194)

* ✨ source-zendesk-chat: migrate to poetry (airbytehq#35185)

* ✨ source-sendgrid: migrate to poetry (airbytehq#35181)

* ✨ source-gitlab: migrate to poetry (airbytehq#35167)

* ✨ source-airtable: migrate to poetry (airbytehq#35149)

* ✨ source-google-search-console: migrate to poetry (airbytehq#35163)

* 🐛Source Amazon Seller Partner: add integration tests (airbytehq#33996)

* ✨ source-s3: migrate to poetry (airbytehq#35164)

* ✨ source-shopify: migrate to poetry (airbytehq#35166)

* ✨ source-file: migrate to poetry (airbytehq#35186)

* ✨ source-slack: migrate to poetry (airbytehq#35157)

* ✨ source-harvest: migrate to poetry (airbytehq#35154)

* Source Chargebee: Updates schemas for validation and missing fields errors, updates test bypass, adds expected records, adds custom error handling, adds incremental support for three streams (airbytehq#34053)

* Don't emit final state if there is an underlying stream failure (airbytehq#34869)

Co-authored-by: Xiaohan Song <xiaohan@airbyte.io>

* Remove IAM Role Setup instructions from s3.md (airbytehq#35190)

* Bump Airbyte version from 0.50.49 to 0.50.50

* airbyte-ci: run `poetry check` before `poetry install` on poetry package install (airbytehq#35212)

* ✨ Source File: add fixed width file format support (airbytehq#34678)

Co-authored-by: mgreene <michael.greene@gravie.com>
Co-authored-by: Serhii Lazebnyi <serhii.lazebnyi@globallogic.com>
Co-authored-by: Serhii Lazebnyi <53845333+lazebnyi@users.noreply.github.com>

* source-postgres: adopt CDK 0.20.4 (airbytehq#35224)

* 🐛  Set cdc record subsequent record wait time to initial wait time as a workaround (airbytehq#35114)

* AirbyteLib: docs: add Colab quicklink (airbytehq#35215)

* AirbyteLib: support secrets in dotenv files (airbytehq#35244)

* Add airbyte trace utility to emit analytics messages & emit messages for MongoDB, Postgres & MySQL (airbytehq#35036)

* AirbyteLib: Docs: fix colab badge (airbytehq#35248)

* AirbyteLib: improve json schema type detection (airbytehq#35263)

* 🏥 Source Mixpanel: update stream Funnels with custom_event_id and custom_event fields fields (airbytehq#35203)

* write logs to file in addition to stdout when running java connector tests (airbytehq#35236)

* destination-duckdb: remove superfluous build.gradle file (airbytehq#35277)

* fix `:airbyte-integrations:connectors:destination-duckdb' could not be found in project` (airbytehq#35279)

* destination-e2e-test,dev-null: use CDK 0.20.6 (airbytehq#35278)

* AirbyteLib: Add support for JSON and VARIANT types (airbytehq#35117)

Co-authored-by: Joe Reuter <joe@airbyte.io>

* Docs: add deprecation note for normalization and custom transformation (airbytehq#35275)

* 🎉 Source Intercom: Update the API Version to `2.10` (airbytehq#35176)

* 🐛 Source Harvest: Revert  poetry update (airbytehq#35296)

* AirbyteLib: Mark and deprioritize slow tests (airbytehq#35298)

* source-clickhouse: adopt CDK 0.20.4 (airbytehq#35235)

* source-cockroachdb: adopt CDK 0.20.4 (airbytehq#35234)

* source-db2: adopt CDK 0.20.4 (airbytehq#35233)

* source-dynamodb: adopt CDK 0.20.4 (airbytehq#35232)

* source-e2e-test: adopt CDK 0.20.4 (airbytehq#35231)

* source-elasticsearch: adopt CDK 0.20.4 (airbytehq#35230)

* source-kafka: adopt CDK 0.20.4 (airbytehq#35229)

* source-oracle: adopt CDK 0.20.4 (airbytehq#35225)

* source-redshift: adopt CDK 0.20.4 (airbytehq#35223)

* source-scaffold-java-jdbc: adopt CDK 0.20.4 (airbytehq#35222)

* source-sftp: adopt CDK 0.20.4 (airbytehq#35221)

* source-snowflake: adopt CDK 0.20.4 (airbytehq#35220)

* source-teradata: adopt CDK 0.20.4 (airbytehq#35219)

* source-tidb: adopt CDK 0.20.4 (airbytehq#35218)

* Throw cdc cursor error

* Revert bad commit

* AirbyteLib: suppress duckdb reflection warnings (airbytehq#35300)

* Source Google Ads: temporary patch to avoid 500 Internal server error (airbytehq#35280)

* 🐛 python cdk: mask oauth access key (airbytehq#34931)

* 🤖 Bump patch version of Python CDK

* Emit multiple error trace messages and continue syncs by default (airbytehq#35129)

* 🤖 Bump minor version of Python CDK

* ✨Source Amazon Seller Partner: add `VendorOrders` stream (airbytehq#35273)

* File-based CDK: enqueue AirbyteMessage of type record instead of sending to the message repository (airbytehq#35318)

* 🤖 Bump patch version of Python CDK

* 🚨🚨🐛 Source Gitlab fix merge_request_commits stream (airbytehq#34548)

* java CDK: improve blobstore module structure (airbytehq#35285)

* source-mysql: add and adopt TestDatabaseWithInvalidDatabaseName (airbytehq#35210)

* ✨ Source File: support ZIP file (airbytehq#32354)

Co-authored-by: Serhii Lazebnyi <53845333+lazebnyi@users.noreply.github.com>
Co-authored-by: Serhii Lazebnyi <serhii.lazebnyi@globallogic.com>

* destination-async-framework: move the state emission logic into GlobalAsyncStateManager (airbytehq#35240)

* 🐛 Source Harvest: Fix pendulum parsing error (airbytehq#35305)

Co-authored-by: Christo Grabowski <108154848+ChristoGrab@users.noreply.github.com>

* ✨ Source GitHub: updating branches schema and unpin on cloud (airbytehq#35271)

Co-authored-by: maxi297 <maxime@airbyte.io>
Co-authored-by: Maxime Carbonneau-Leclerc <3360483+maxi297@users.noreply.github.com>

* AirbyteLib: Fix no-such-table-error (airbytehq#35311)

Co-authored-by: Bindi Pankhudi <bindi@airbyte.com>
Co-authored-by: Aaron Steers <aj@airbyte.io>

* 📝 add instructions for soft reset (airbytehq#35335)

* [source-postgres] Add test for legacy version of postgres (airbytehq#35329)

* Source Klaviyo: added transform config for profile stream (airbytehq#35336)

* 🏥 Source Hubspot: updated marketing emails schema and expected records (airbytehq#35328)

* gradle: split off python cdk (airbytehq#35306)

* gradle: overall simplification (airbytehq#35307)

* docs: typos (airbytehq#35302)

* Docs: Update stripe.md (airbytehq#35142)

* Test PR to check Slack notifications (airbytehq#35363)

* airbyte-ci: remove reference to buildConnectorImage (airbytehq#35364)

* Source S3: revert rollback to 4.4.1 (airbytehq#35055)

Co-authored-by: Augustin <augustin@airbyte.io>

* 🐛 Source OpsGenie: fix parsing of updated_at timestamps from OpsGenie (airbytehq#35269)

Co-authored-by: marcosmarxm <marcosmarxm@gmail.com>

* Archive `destination-kvdb` (airbytehq#35370)

* Add `archived` as connector support level (airbytehq#35355)

* Remove `octavia-cli` (airbytehq#33950)

* Docs: update k8s instructions for upgrade (airbytehq#35108)

* Destination redshift: delete some unused files (airbytehq#35314)

* re-add destination-kvdb as archived connector (airbytehq#35377)

* destination-kvdb - publish for real (airbytehq#35379)

* Support user-specified test read limits in `connector_builder` code (airbytehq#35312)

* 🤖 Bump patch version of Python CDK

* destination-kvdb bump to publish (airbytehq#35381)

* ✨ Source Paypal Transactions: Siver Certification  (airbytehq#34510)

Co-authored-by: Alexandre Girard <alexandre@airbyte.io>
Co-authored-by: alafanechere <augustin.lafanechere@gmail.com>
Co-authored-by: Augustin <augustin@airbyte.io>

* Revamp QA checks into a battery included package (airbytehq#35322)

* 🏥 Source Pinterest: updated expected records (airbytehq#35353)

* .github: fix python CDK publish (airbytehq#35391)

* 🐛 Source Amazon Seller Partner: Fix check for Vendor accounts (airbytehq#35331)

* doc: Document our connectors QA checks (airbytehq#35324)

* airbyte-ci: use connectors-qa instead of connector_ops.qa_check (airbytehq#35325)

* Update `metadata-service` to latest version + docs (airbytehq#35419)

* Bump destination-kvdb again to test metadata for archival (airbytehq#35422)

* connectors_qa: make `CheckPublishToPyPiIsEnabled` only run on source connectors (airbytehq#35426)

* gradle: remove archived connectors (airbytehq#35423)

* ✨Source Facebook Marketing: add integration tests (airbytehq#35061)

* Delete `requirements.txt` on poetry managed connectors (airbytehq#35406)

* update doc to reference poetry (airbytehq#35414)

* 🧹 remove qa_checks.py (airbytehq#35434)

* connectors-qa: fix connector type attribute access (airbytehq#35435)

* java-connectors: add thread name as part of the log message (airbytehq#35199)

* doc: remove Node requirements on config based getting started tutorial (airbytehq#35436)

* airbyte-ci: disable telemetry with env var (airbytehq#35438)

* airbyte-ci: disable a flaky test (airbytehq#35418)

* ci: check for required reviewers on destinations (airbytehq#35428)

* destination-kvdb QA checks (airbytehq#35424)

Co-authored-by: Augustin <augustin@airbyte.io>

* Add destination-kvdb to OSS registry (airbytehq#35444)

* Normalization logs: remove json parse warnings (airbytehq#34978)

* Support archived connectors in Docs (airbytehq#35374)

* remove destination-kvdb one more time (airbytehq#35382)

* [Source-Postgres] : Add config to throw an error on invalid CDC position (airbytehq#35304)

* java-cdk:remove unused class (airbytehq#35408)

* Source S3: add filter by start date (airbytehq#35392)

* Revert "Add destination-kvdb to OSS registry" (airbytehq#35453)

* airbyte-ci: do no run QA checks on publish - only MetadataValidation (airbytehq#35437)

Co-authored-by: Ella Rohm-Ensing <erohmensing@gmail.com>

* restore kvdb to state from airbytehq#35424 (airbytehq#35454)

* 🚨🚨 Source Facebook Marketing: Add statuses filters (airbytehq#32449)

Co-authored-by: Anatolii Yatsuk <tolikyatsuk@gmail.com>

* add proper logging to junit runs (airbytehq#35394)

Basically, Junit is not logging any thing about its progress outside of the console. This is aimed at fixing that by outputing progress logs along with the standard logs. So there's going to be a line before each step of a test run, and a line after with the elapsed time. Also, exception are now part of the logs instead of being only part of the junit report.
In the process of doing that, I decided to clean up and simplify the log4j2.xml file.
I also noted a few issues with ANSI coloring, so there's a fix for that.
Finally, I'm removing empty lines from container logs (MSSQL is full of them).

The junit printing is done through an intereceptor. That interceptor uses introspection. I wanted to use a factory method, but java's ServiceLoader only allows classes that extends the service interface,  hence the need to override every method in the interceptor class, and to plop a proxy on top of that.

* Re-ignore documentation structure check for the time being (airbytehq#35458)

* [Source-mysql] : Add config to throw an error on invalid CDC position (airbytehq#35338)

* [Source-Mongodb] : Add config to throw an error on invalid CDC position (airbytehq#35375)

* pin to older version (airbytehq#35469)

* Update on-kubernetes-via-helm.md - Add GCS Logging steps (airbytehq#35455)

Co-authored-by: Sajarin <sajarindider@gmail.com>

* Airbyte CDK: add filter to RemoveFields (airbytehq#35326)

Signed-off-by: Artem Inzhyyants <artem.inzhyyants@gmail.com>

* 🤖 Bump minor version of Python CDK

* 🐛 Source Facebook Marketing: Fix error during transforming state (airbytehq#35467)

* .github: remove connector checklist (airbytehq#35484)

* connectors_qa: bump to 1.0.3 (airbytehq#35475)

* .github: tighter filtering for gradle workflow (airbytehq#35492)

* Airbyte docs: Fixed JSON schema rendering issues for dark mode (airbytehq#35489)

Co-authored-by: bindipankhudi <bindi@airbyte.com>

* Source Quickbooks: fix spec (airbytehq#35457)

* 🐛 Change null cursor value query to not use IIF sql function (airbytehq#35405)

* Source Google Ads: rollback patch 500 Internal Server Error (airbytehq#35493)

* Fix syntax error in `tools/bin/manage.sh`, used to publish airbyte cdk (airbytehq#35466)

* [DB sources] : Reduce CDC state compression limit to 1MB (airbytehq#35511)

* 🤖 Bump patch version of Python CDK

* Add ignore_stream_slicer_parameters_on_paginated_requests flag (airbytehq#35462)

* 🤖 Bump minor version of Python CDK

* Mangle unhandled MongoCommandException to prevent creating grouping o… (airbytehq#35526)

* .github: fix java cdk publish workflow (airbytehq#35533)

* [Source-mysql] : Adopt 0.21.4 and reduce cdc state compression threshold to 1MB (airbytehq#35525)

* 🏥 Source Notion: update stream schema (airbytehq#35409)

* airbyte-ci: make QA check work on strict-encrypt connectors (airbytehq#35536)

* Update docs to show archived information if connector is not in registries (airbytehq#35468)

* 🐛 Source Facebook Marketing: Add missing config migration (airbytehq#35539)

* docs: update ALB configuration docs for exposing API (airbytehq#35520)

* chore: remove upgrading-airbyte.md (airbytehq#35545)

* 📚 Add documentation for Entra ID (airbytehq#34569)

* Bump Airbyte version from 0.50.50 to 0.50.51

* gradle.yml: use a smaller runner (airbytehq#35547)

* airbyte-ci: augment the report for java connectors (airbytehq#35317)

Today we're missing the logs (both JVM and container logs) in java connector reports.
This is creating a link to test artifacts. In the CI, the link will point to a zip file, while on a local run, it will point to a directory.

In addition, we recently added the junit XML inlined with the test standard output and error, but that didn't really work as well as we'd hoped: The reports were slow to load, they were not ordered by time, the corresponding logs were lacking. There's still a possibility they'll be useful, so rather than removing them altogether, they will be bundled in the log zip (or directory).

I'm also adding a button to copy the standard output or the standard error from a step into the clipboard.
Finally, I'm reducing the max vertical size of an expanded step, so it doesn't go over 70%, which seems much cleaner to me.

Here's an example of the result (from the child PR): https://storage.cloud.google.com/airbyte-ci-reports-multi/airbyte-ci/connectors/test/pull_request/stephane_02-09-add_background_thread_to_track_mssql_container_status/1708056420/d4683bfb7f90675c6b9e7c6d4bbad3f98c7a7550/source-mssql/3.7.0/output.html

* Source SalesForce: Add Stream Slice Step option to specification (airbytehq#35421)

Signed-off-by: Artem Inzhyyants <artem.inzhyyants@gmail.com>

* Destination Clickhouse - 1.0, remove normalization (airbytehq#34637)

Co-authored-by: Aaron ("AJ") Steers <aj@airbyte.io>
Co-authored-by: Joe Reuter <joe@airbyte.io>
Co-authored-by: Obioma Anomnachi <onanomnachi@gmail.com>
Co-authored-by: Anatolii Yatsuk <35109939+tolik0@users.noreply.github.com>
Co-authored-by: Maxime Carbonneau-Leclerc <3360483+maxi297@users.noreply.github.com>
Co-authored-by: maxi297 <maxi297@users.noreply.github.com>
Co-authored-by: Ryan Waskewich <156025126+rwask@users.noreply.github.com>
Co-authored-by: Catherine Noll <clnoll@users.noreply.github.com>
Co-authored-by: Marius Posta <marius@airbyte.io>
Co-authored-by: Edward Gao <edward.gao@airbyte.io>
Co-authored-by: Marcos Marx <marcosmarxm@users.noreply.github.com>
Co-authored-by: SatishChGit <satishchinthanippu@gmail.com>
Co-authored-by: evantahler <evan@airbyte.io>
Co-authored-by: Rodi Reich Zilberman <867491+rodireich@users.noreply.github.com>
Co-authored-by: Anton Karpets <anton.karpets@globallogic.com>
Co-authored-by: Christo Grabowski <108154848+ChristoGrab@users.noreply.github.com>
Co-authored-by: Akash Kulkarni <akash@airbyte.io>
Co-authored-by: Akash Kulkarni <113392464+akashkulk@users.noreply.github.com>
Co-authored-by: Gireesh Sreepathi <gisripa@gmail.com>
Co-authored-by: Artem Inzhyyants <36314070+artem1205@users.noreply.github.com>

* Airbyte CDK: add interpolation for request options (airbytehq#35485)

Signed-off-by: Artem Inzhyyants <artem.inzhyyants@gmail.com>
Co-authored-by: Alexandre Girard <alexandre@airbyte.io>

* 🤖 Bump minor version of Python CDK

* Handle seeing uncompressed sendgrid contact data (airbytehq#35343)

* gradle.yml: use XXL runners but only if gradle related files are changed (airbytehq#35548)

* ✨ [greenhouse] [iterable] [linkedin-ads] [paypal-transactions] [pinterest] Bump cdk versions for to use continue on stream per-error reporting (airbytehq#35465)

* Airbyte CDK: add CustomRecordFilter (airbytehq#35283)

Signed-off-by: Artem Inzhyyants <artem.inzhyyants@gmail.com>

* 🤖 Bump minor version of Python CDK

* Do not add connector header to source and destination index pages (airbytehq#35553)

* gradle.yml: fix path filters (airbytehq#35554)

* Source Monday: fix gql query to support inline fragment value for the Items stream (airbytehq#35506)

* gradle.yml: checkout the repo when not PR trigger (airbytehq#35558)

* airbyte-cdk [python]: re-enable tests in CI (airbytehq#35560)

Co-authored-by: Marius Posta <marius@airbyte.io>

* ✨ [source-mssql] skip sql server agent check if EngineEdition == 8 (airbytehq#35368)

* push new source-mssql version (airbytehq#35564)

* Destinations CDK: Refactor T+D to gather required world state upfront (airbytehq#35342)

Signed-off-by: Gireesh Sreepathi <gisripa@gmail.com>

* .github: fix python_cdk_tests.yml (airbytehq#35567)

* Bump Airbyte version from 0.50.51 to 0.50.52

* add entry into JAVA_OPTS to always select log4j2.xml as our logger configuration (airbytehq#35569)

* destination-s3: bump patch version following airbytehq#35569 (airbytehq#35576)

Co-authored-by: Stephane Geneix <stephane@airbyte.io>

* destination-snowflake: bump patch version following airbytehq#35569 (airbytehq#35575)

Co-authored-by: Stephane Geneix <stephane@airbyte.io>

* destination-bigquery: bump patch version following airbytehq#35569 (airbytehq#35574)

Co-authored-by: Stephane Geneix <stephane@airbyte.io>

* source-mysql: bump patch version following airbytehq#35569 (airbytehq#35573)

Co-authored-by: Stephane Geneix <stephane@airbyte.io>

* source-postgres: bump patch version following airbytehq#35569 (airbytehq#35572)

Co-authored-by: Stephane Geneix <stephane@airbyte.io>

* source-mongodb-v2: bump patch version following airbytehq#35569 (airbytehq#35571)

Co-authored-by: Stephane Geneix <stephane@airbyte.io>

* airbyte-ci-test.yml: only run if modified internal poetry packages (airbytehq#35551)

* airbyte-ci-test.yml: checkout repo for path filters when not on PR (airbytehq#35577)

* connectors-ci: early exit when no connector changes (airbytehq#35578)

* Microsoft Entra ID for Self-Managed Enterprise (airbytehq#35585)

* Improve documentation on check command (airbytehq#35542)

Co-authored-by: Ella Rohm-Ensing <erohmensing@gmail.com>

* 🐛 Source S3: fix exception when setting CSV stream delimiter to `\t`. (airbytehq#35246)

Co-authored-by: Marcos Marx <marcosmarxm@users.noreply.github.com>
Co-authored-by: marcosmarxm <marcosmarxm@gmail.com>

* 🐛 Source BigQuery: fix error with RECORD REPEATED fields  (airbytehq#35503)

Co-authored-by: Marcos Marx <marcosmarxm@users.noreply.github.com>
Co-authored-by: marcosmarxm <marcosmarxm@gmail.com>

* re-release source mssql with logger fixes (airbytehq#35596)

* Source File: change header=0 to header=null in docs (airbytehq#35595)

CI tests failed because the version was not incremented, despite only a single line being altered in the documentation. This change is minor and can be safely merged.

* Changed tag to low code (airbytehq#35594)

CI tests failed because the version was not incremented. This change is minor and can be safely merged.

* Bump Airbyte version from 0.50.52 to 0.50.53

* Destination Postgres: CDK T+D initial state gathering (airbytehq#35385)

Signed-off-by: Gireesh Sreepathi <gisripa@gmail.com>

* Destination Snowflake: CDK T+D initial state refactor (airbytehq#35456)

Signed-off-by: Gireesh Sreepathi <gisripa@gmail.com>

* Destination Redshift: CDK T+D initial state refactor (airbytehq#35354)

Signed-off-by: Gireesh Sreepathi <gisripa@gmail.com>

* delete metadata checks workflow (airbytehq#35580)

* Source Recurly: Enable in registries with updated CDK (airbytehq#34622)

* reduce interrupt and shutdown delays to 1 minutes and 2 minutes when stopping a connector (initially set at 60minutes and 70minutes) (airbytehq#35527)

Fixes airbytehq#32348 
discussed here : https://airbytehq-team.slack.com/archives/C02U2SSHP9S/p1708552465201999

* Docs: Add depecration notices to sunsetting connectors (airbytehq#35446)

* Cleaned up PyAibyte docs (PR # 35603) (airbytehq#35603)

Co-authored-by: bindipankhudi <bindi@airbyte.com>

* Source S3: run incremental syncs with concurrency (airbytehq#34895)

* old commits added

* add file location in output stream

* file docker file

* docker file version change

* pgp docker file

* fix

* Bump gnupg version and pgp decryption changes

* fix bug

* fix: discover dtype issued and test cases added

* added files

---------

Signed-off-by: Artem Inzhyyants <artem.inzhyyants@gmail.com>
Signed-off-by: Gireesh Sreepathi <gisripa@gmail.com>
Co-authored-by: Augustin <augustin@airbyte.io>
Co-authored-by: Baz <oleksandr.bazarnov@globallogic.com>
Co-authored-by: Artem Inzhyyants <36314070+artem1205@users.noreply.github.com>
Co-authored-by: Subodh Kant Chaturvedi <subodh1810@gmail.com>
Co-authored-by: Xiaohan Song <xiaohan@airbyte.io>
Co-authored-by: Aaron ("AJ") Steers <aj@airbyte.io>
Co-authored-by: Tim Roes <tim@airbyte.io>
Co-authored-by: benmoriceau <benmoriceau@users.noreply.github.com>
Co-authored-by: Gireesh Sreepathi <gisripa@gmail.com>
Co-authored-by: Marius Posta <marius@airbyte.io>
Co-authored-by: Evan Tahler <evan@airbyte.io>
Co-authored-by: Edward Gao <edward.gao@airbyte.io>
Co-authored-by: Anton Karpets <anton.karpets@globallogic.com>
Co-authored-by: Patrick Nilan <nilan.patrick@gmail.com>
Co-authored-by: Akash Kulkarni <113392464+akashkulk@users.noreply.github.com>
Co-authored-by: Tyler B <104733644+tybernstein@users.noreply.github.com>
Co-authored-by: bgroff <bgroff@users.noreply.github.com>
Co-authored-by: mjgatz <86885812+mjgatz@users.noreply.github.com>
Co-authored-by: mgreene <michael.greene@gravie.com>
Co-authored-by: Serhii Lazebnyi <serhii.lazebnyi@globallogic.com>
Co-authored-by: Serhii Lazebnyi <53845333+lazebnyi@users.noreply.github.com>
Co-authored-by: Rodi Reich Zilberman <867491+rodireich@users.noreply.github.com>
Co-authored-by: Daryna Ishchenko <80129833+darynaishchenko@users.noreply.github.com>
Co-authored-by: Stephane Geneix <147216312+stephane-airbyte@users.noreply.github.com>
Co-authored-by: Joe Reuter <joe@airbyte.io>
Co-authored-by: Marcos Marx <marcosmarxm@users.noreply.github.com>
Co-authored-by: Maxime Carbonneau-Leclerc <3360483+maxi297@users.noreply.github.com>
Co-authored-by: Akash Kulkarni <akash@airbyte.io>
Co-authored-by: Roman Yermilov [GL] <86300758+roman-yermilov-gl@users.noreply.github.com>
Co-authored-by: Alexandre Girard <alexandre@airbyte.io>
Co-authored-by: girarda <girarda@users.noreply.github.com>
Co-authored-by: Brian Lai <51336873+brianjlai@users.noreply.github.com>
Co-authored-by: brianjlai <brianjlai@users.noreply.github.com>
Co-authored-by: Catherine Noll <clnoll@users.noreply.github.com>
Co-authored-by: midavadim <midavadim@yahoo.com>
Co-authored-by: Julien COUTAND <julien.coutand@gmail.com>
Co-authored-by: Christo Grabowski <108154848+ChristoGrab@users.noreply.github.com>
Co-authored-by: maxi297 <maxime@airbyte.io>
Co-authored-by: Bindi Pankhudi <bindi@airbyte.io>
Co-authored-by: Bindi Pankhudi <bindi@airbyte.com>
Co-authored-by: Ben Drucker <bvdrucker@gmail.com>
Co-authored-by: TornadoContre <37258495+TornadoContre@users.noreply.github.com>
Co-authored-by: Natik Gadzhi <natik@respawn.io>
Co-authored-by: Thomas Dippel <dipth@users.noreply.github.com>
Co-authored-by: marcosmarxm <marcosmarxm@gmail.com>
Co-authored-by: Alex Birdsall <ambirdsall@gmail.com>
Co-authored-by: ambirdsall <ambirdsall@users.noreply.github.com>
Co-authored-by: Jose Gerardo Pineda <jose.pineda@airbyte.io>
Co-authored-by: alafanechere <augustin.lafanechere@gmail.com>
Co-authored-by: Anatolii Yatsuk <35109939+tolik0@users.noreply.github.com>
Co-authored-by: Pedro S. Lopez <pedroslopez@me.com>
Co-authored-by: Ella Rohm-Ensing <erohmensing@gmail.com>
Co-authored-by: Siarhei Ivanou <sinusu@gmail.com>
Co-authored-by: Anatolii Yatsuk <tolikyatsuk@gmail.com>
Co-authored-by: Ryan Waskewich <156025126+rwask@users.noreply.github.com>
Co-authored-by: Sajarin <sajarindider@gmail.com>
Co-authored-by: artem1205 <artem1205@users.noreply.github.com>
Co-authored-by: perangel <perangel@gmail.com>
Co-authored-by: Joe Bell <joseph.bell@airbyte.io>
Co-authored-by: Obioma Anomnachi <onanomnachi@gmail.com>
Co-authored-by: maxi297 <maxi297@users.noreply.github.com>
Co-authored-by: SatishChGit <satishchinthanippu@gmail.com>
Co-authored-by: Brian Leonard <brian@bleonard.com>
Co-authored-by: David Wallace <dwallace0723@gmail.com>
Co-authored-by: pmossman <pmossman@users.noreply.github.com>
Co-authored-by: Stephane Geneix <stephane@airbyte.io>
Co-authored-by: Alexandre Cuoci <Hesperide@users.noreply.github.com>
Co-authored-by: Danny Tiesling <tiesling@gmail.com>
Co-authored-by: Marco Fontana <MaxwellJK@users.noreply.github.com>
Co-authored-by: rishabh-cldcvr <rishabh@cldcvr.com>
jatinyadav-cc pushed a commit to ollionorg/datapipes-airbyte that referenced this issue Feb 26, 2024
jatinyadav-cc pushed a commit to ollionorg/datapipes-airbyte that referenced this issue Feb 26, 2024
jatinyadav-cc pushed a commit to ollionorg/datapipes-airbyte that referenced this issue Feb 26, 2024
jatinyadav-cc pushed a commit to ollionorg/datapipes-airbyte that referenced this issue Feb 26, 2024
jatinyadav-cc pushed a commit to ollionorg/datapipes-airbyte that referenced this issue Feb 26, 2024
FVidalCarneiro pushed a commit to AgiData/airbyte that referenced this issue Feb 27, 2024
@DDynamic
Copy link
Contributor

DDynamic commented Mar 8, 2024

@dimoschi I am having the same issue as you and confirmed that downgrading worked. It looks like this is a known issue in Debezium 2.4.0. It looks like this fix is included in later versions: debezium/debezium#4959.

@stephane-airbyte I don't see how the linked pull requests is related to this issue?

@stephane-airbyte
Copy link
Contributor

@DDynamic thank you for pinging me on this. It looks like I mentioned the wrong issue in my PR. This current issue hasn't been fixed AFAIK. Sorry for the confusion

@DDynamic
Copy link
Contributor

@stephane-airbyte do you know the timeline for getting the Debezium version updated?

@marcosmarxm marcosmarxm changed the title MySQLSource: Error while trying to run connector class 'io.debezium.connector.mysql.MySqlConnector' [source-MySQL] Error while trying to run connector class 'io.debezium.connector.mysql.MySqlConnector' May 9, 2024
@evantahler
Copy link
Contributor

Closing this issue as we've made significant updates to the connector since this issue was filed. Can you please try again with the latest Airbyte platform and connectors?

@DDynamic
Copy link
Contributor

@evantahler still an issue as the latest connector version is still on Debezium 2.4.0

@DDynamic
Copy link
Contributor

DDynamic commented Jun 5, 2024

Hey @evantahler this is still an issue on the latest platform and MySQL connection version being on Debezium 2.4.0: https://github.com/airbytehq/airbyte/blob/master/airbyte-integrations/connectors/source-mysql/build.gradle#L27 - could you reopen?

@marcosmarxm marcosmarxm reopened this Jun 5, 2024
@marcosmarxm
Copy link
Member

@airbytehq/destinations can you check @DDynamic comments? It looks the issue wasn't solved yet.

@edgao
Copy link
Contributor

edgao commented Jun 5, 2024

redirecting to @airbytehq/dbsources 🚛 🥞

@theyueli
Copy link
Contributor

theyueli commented Jun 6, 2024

hi @DDynamic and @dimoschi , we just published development image for MySQL source connector which uses dbz 2.5.4.

https://hub.docker.com/layers/airbyte/source-mysql/3.4.8-dev.4ad54ec10f/images/sha256-5a024f2fd281f0fc3b2346591df720d43dcceeed04242011acf89168355a5b1d?context=explore

Would you be able to test this version to see if it solves the issue? You can do so by setting the version of the myssql connector to

3.4.8-dev.4ad54ec10f

in the setting page of the UI. Thanks!

@theyueli
Copy link
Contributor

hi @DDynamic and @dimoschi, do you have a chance to test this development build? thanks!

@DDynamic
Copy link
Contributor

Yes @theyueli looks good from what I can tell

theyueli added a commit that referenced this issue Jun 12, 2024
This patch attempts to fix the following issues:

airbytehq/oncall#5332
#32348
@evantahler
Copy link
Contributor

Excellent! Closing the issue then

Adorism pushed a commit that referenced this issue Jun 13, 2024
This patch attempts to fix the following issues:

airbytehq/oncall#5332
#32348
xiaohansong pushed a commit that referenced this issue Jun 14, 2024
This patch attempts to fix the following issues:

airbytehq/oncall#5332
#32348
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area/connectors Connector related issues community connectors/source/mysql team/db-dw-sources Backlog for Database and Data Warehouse Sources team type/bug Something isn't working
Projects
None yet
8 participants