This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from d11453ef95 [Fix][Flink] Process same-timestamp schema restore events
(#12306)
add d53da7091a [Test][E2E] Add MqttSourceIT covering the MQTT source on
Zeta (#12408)
No new revisions were added by this update.
Summary of changes:
.../seatunnel/e2e/connector/mqtt/MqttSourceIT.java | 358 +++++++++++++++++++++
.../{mqtt_sink_e2e.conf => mqtt_source_e2e.conf} | 25 +-
2 files changed, 374 insertions(+), 9 deletions(-)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mqtt-e2e/src/test/java/org/apache/seatunnel/e2e/connector/mqtt/MqttSourceIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-mqtt-e2e/src/test/resources/{mqtt_sink_e2e.conf
=> mqtt_source_e2e.conf} (57%)