Skip to content

Commit 93e2a30

Browse files
fix
1 parent 2324092 commit 93e2a30

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

Diff for: config/seatunnel.yaml

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ seatunnel:
2424
print-execution-info-interval: 60
2525
print-job-metrics-info-interval: 60
2626
print-job-event-info-interval: 30
27-
job-event-queue-size: 100
27+
job-event-queue-size: 128
2828
slot-service:
2929
dynamic-slot: true
3030
checkpoint:

Diff for: seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/ServerConfigOptions.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -94,8 +94,8 @@ public static class MasterServerConfigOptions {
9494
public static final Option<Integer> JOB_EVENT_QUEUE_SIZE =
9595
Options.key("job-event-queue-size")
9696
.intType()
97-
.defaultValue(100)
98-
.withDescription("Queue size for storing events");
97+
.defaultValue((int) Math.pow(2, 7))
98+
.withDescription("Queue size for storing events, default: 128");
9999

100100
public static final Option<Integer> JOB_METRICS_BACKUP_INTERVAL =
101101
Options.key("job-metrics-backup-interval")

0 commit comments

Comments
 (0)