You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@seatunnel.apache.org by ga...@apache.org on 2023/04/18 14:19:38 UTC

[incubator-seatunnel] branch dev updated (cc021bd2c -> 93471c9ad)

This is an automated email from the ASF dual-hosted git repository.

gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


    from cc021bd2c [Zeta] [Fix] Fix some operation didn't use classloader which belong task (#4611)
     add 93471c9ad [hotfix][e2e][kafka] Fix the job not stopping (#4600)

No new revisions were added by this update.

Summary of changes:
 .../kafka/source/KafkaSourceSplitEnumerator.java   |  8 +-
 .../seatunnel/e2e/connector/kafka/KafkaIT.java     |  4 +
 .../kafka/kafkasource_earliest_to_console.conf     | 61 +++++++-------
 ...ce_format_error_handle_way_fail_to_console.conf | 97 ++++++++++-----------
 ...ce_format_error_handle_way_skip_to_console.conf | 98 +++++++++++-----------
 .../kafka/kafkasource_group_offset_to_console.conf | 62 +++++++-------
 .../kafka/kafkasource_latest_to_console.conf       | 62 +++++++-------
 .../kafkasource_specific_offsets_to_console.conf   | 66 ++++++++-------
 .../kafka/kafkasource_timestamp_to_console.conf    | 64 +++++++-------
 .../resources/kafkasource_json_to_console.conf     | 95 +++++++++++----------
 .../resources/kafkasource_text_to_console.conf     | 95 +++++++++++----------
 11 files changed, 376 insertions(+), 336 deletions(-)