dlg99 commented on pull request #11154: URL: https://github.com/apache/pulsar/pull/11154#issuecomment-881012367
@nlu90 @eolivelli situation with this PR so far: I rebased it on latest master and "CI - Integration - Pulsar-IO Sinks and Sources" failed. Running testDebeziumMySqlSourceJson locally I can repro failures, rootcause TBD but the only suspicious thing that I see in the function log is ``` [pulsar-client-io-1-2] ERROR org.apache.pulsar.io.kafka.connect.AbstractKafkaConnectSource - Timed out waiting to flush org.apache.pulsar.io.kafka.connect.KafkaConnectSource$KafkaSourceRecord@72495bb1 offsets to storage ``` I reverted both PRs https://github.com/apache/pulsar/pull/11251 and https://github.com/apache/pulsar/pull/11056 locally; rebuilt/re-run the test and the test passed, "Timed out waiting to flush" is not logged in the function log -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
