DanielLeens commented on issue #12405: URL: https://github.com/apache/seatunnel/issues/12405#issuecomment-5749738420
Thanks for the report and to @SEPURI-SAI-KRISHNA for opening #12406. The reported `NotSerializableException` on `MqttSourceConfig` is consistent with the Zeta DAG serialization path: the MQTT source retains that configuration object, so the job fails before it reaches the Jdbc sink. The issue is not fixed in `dev` yet. #12406 is the single active fix path, but its Build check is currently failing, so it needs to be corrected before this can be considered ready to merge. Please also extend the existing MQTT connector E2E module in the same PR with a Zeta source submission case. The existing coverage is sink-only, which is why a source object that cannot be serialized was not exercised. The regression should prove that a minimal MQTT source job reaches submission successfully and should keep the sink unchanged. No configuration option or authentication behavior should change as part of this fix. Please continue the implementation and CI follow-up on #12406, and keep sensitive connection values redacted in any future logs or configuration excerpts. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
