This is an automated email from the ASF dual-hosted git repository.
zhouyao2023 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 901cf0a751 [Fix] Fix document build error (#7546)
add e224bda652 [Feature][Zeta] Support slf4j mdc tracing job id output
into logs (#7491)
No new revisions were added by this update.
Summary of changes:
config/log4j2.properties | 6 +-
.../sink/multitablesink/MultiTableSinkWriter.java | 27 ++--
.../apache/seatunnel/api/tracing/MDCCallable.java | 35 +++--
.../apache/seatunnel/api/tracing/MDCContext.java | 122 +++++++++++++++++
.../apache/seatunnel/api/tracing/MDCExecutor.java | 23 ++--
.../seatunnel/api/tracing/MDCExecutorService.java | 121 +++++++++++++++++
.../apache/seatunnel/api/tracing/MDCRunnable.java | 29 ++--
.../api/tracing/MDCScheduledExecutorService.java | 63 +++++++++
.../apache/seatunnel/api/tracing/MDCTracer.java | 126 +++++++++++++++++
.../seatunnel/api/tracing/MDCTracerTest.java | 149 +++++++++++++++++++++
.../src/main/bin/seatunnel-cluster.cmd | 1 +
.../src/main/bin/seatunnel-cluster.sh | 1 +
.../src/main/resources/log4j2.properties | 4 +-
.../src/test/resources/log4j2.properties | 4 +-
.../connector-seatunnel-e2e-base/pom.xml | 10 ++
.../engine/e2e/ClusterSeaTunnelContainer.java | 19 +++
.../log4j2-test.properties | 4 +-
.../log4j2.properties | 4 +-
.../log4j2-test.properties | 4 +-
.../log4j2.properties | 4 +-
.../log4j2-test.properties | 4 +-
.../log4j2.properties | 4 +-
.../src/test/resources/log4j2-test.properties | 4 +-
.../src/test/resources/log4j2.properties | 4 +-
.../src/test/resources/log4j2-test.properties | 4 +-
.../engine/server/CoordinatorService.java | 9 +-
.../engine/server/TaskExecutionService.java | 10 +-
.../server/checkpoint/CheckpointCoordinator.java | 2 +
.../CheckpointBarrierTriggerOperation.java | 2 +-
.../operation/CheckpointEndOperation.java | 2 +-
.../operation/CheckpointErrorReportOperation.java | 2 +-
.../operation/CheckpointFinishedOperation.java | 2 +-
.../operation/NotifyTaskRestoreOperation.java | 2 +-
.../operation/NotifyTaskStartOperation.java | 2 +-
.../operation/TaskAcknowledgeOperation.java | 9 +-
.../operation/TaskReportStatusOperation.java | 9 +-
...riggerSchemaChangeAfterCheckpointOperation.java | 8 +-
...iggerSchemaChangeBeforeCheckpointOperation.java | 6 +-
.../opeartion/ReleaseSlotOperation.java | 8 +-
.../opeartion/RequestSlotOperation.java | 8 +-
.../server/task/operation/CancelTaskOperation.java | 5 +-
.../CheckTaskGroupIsExecutingOperation.java | 5 +-
.../operation/CleanTaskGroupContextOperation.java | 5 +-
.../server/task/operation/DeployTaskOperation.java | 5 +-
.../operation/GetTaskGroupAddressOperation.java | 6 +-
.../task/operation/NotifyTaskStatusOperation.java | 6 +-
.../server/task/operation/TaskOperation.java | 5 +-
.../{TaskOperation.java => TracingOperation.java} | 39 +++---
.../operation/checkpoint/BarrierFlowOperation.java | 2 +-
.../checkpoint/CloseRequestOperation.java | 6 +-
.../operation/sink/SinkPrepareCommitOperation.java | 2 +-
.../task/operation/sink/SinkRegisterOperation.java | 6 +-
.../operation/source/AssignSplitOperation.java | 8 +-
.../operation/source/CloseIdleReaderOperation.java | 9 +-
.../source/LastCheckpointNotifyOperation.java | 9 +-
.../operation/source/RequestSplitOperation.java | 6 +-
.../operation/source/RestoredSplitOperation.java | 2 +-
.../source/SourceNoMoreElementOperation.java | 7 +-
.../source/SourceReaderEventOperation.java | 2 +-
.../operation/source/SourceRegisterOperation.java | 7 +-
.../src/test/resources/log4j2-test.properties | 4 +-
.../src/test/resources/log4j2-test.properties | 4 +-
62 files changed, 840 insertions(+), 167 deletions(-)
copy
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplitReaderContext.java
=>
seatunnel-api/src/main/java/org/apache/seatunnel/api/tracing/MDCCallable.java
(54%)
create mode 100644
seatunnel-api/src/main/java/org/apache/seatunnel/api/tracing/MDCContext.java
copy
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplitReaderContext.java
=>
seatunnel-api/src/main/java/org/apache/seatunnel/api/tracing/MDCExecutor.java
(62%)
create mode 100644
seatunnel-api/src/main/java/org/apache/seatunnel/api/tracing/MDCExecutorService.java
copy
seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplitReaderContext.java
=>
seatunnel-api/src/main/java/org/apache/seatunnel/api/tracing/MDCRunnable.java
(58%)
create mode 100644
seatunnel-api/src/main/java/org/apache/seatunnel/api/tracing/MDCScheduledExecutorService.java
create mode 100644
seatunnel-api/src/main/java/org/apache/seatunnel/api/tracing/MDCTracer.java
create mode 100644
seatunnel-api/src/test/java/org/apache/seatunnel/api/tracing/MDCTracerTest.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/{TaskOperation.java
=> TracingOperation.java} (63%)
