This is an automated email from the ASF dual-hosted git repository.
davidzollo pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from bd5a19a6c5 [Fix][Connector-V2] Flush Doris load before schema change
(#11156)
add 1c4ed90dd2 [Improve][Connector-V2][Socket] Migrate Socket Sink
validation to declarative OptionRule (#11214)
No new revisions were added by this update.
Summary of changes:
.../seatunnel/socket/sink/SocketSinkFactory.java | 8 +-
.../seatunnel/socket/SocketFactoryTest.java | 57 ++++++-
.../pom.xml | 7 +-
.../e2e/connector/socket/SocketSinkIT.java | 165 +++++++++++++++++++++
.../src/test/resources/fake_to_socket.conf} | 20 +--
seatunnel-e2e/seatunnel-connector-v2-e2e/pom.xml | 1 +
6 files changed, 241 insertions(+), 17 deletions(-)
copy seatunnel-e2e/seatunnel-connector-v2-e2e/{connector-fake-e2e =>
connector-socket-e2e}/pom.xml (91%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-socket-e2e/src/test/java/org/apache/seatunnel/e2e/connector/socket/SocketSinkIT.java
copy
seatunnel-e2e/{seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/pending_jobs_streaming.conf
=>
seatunnel-connector-v2-e2e/connector-socket-e2e/src/test/resources/fake_to_socket.conf}
(81%)
