Skip to content

Commit 6d17c54

Browse files
update
1 parent ca3b067 commit 6d17c54

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

core/src/main/java/com/airwallex/airskiff/flink/HybridWatermarkGenerator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ public class HybridWatermarkGenerator<T> implements WatermarkGenerator<T> {
1212
private final Clock clock;
1313
private long maxTs;
1414
private long lastProcessTime;
15-
private long allowedLatency;
15+
private final long allowedLatency;
1616

1717
public HybridWatermarkGenerator(long maxDelay, EventTimeManager eventTimeManager, Clock clock) {
1818
this.maxDelay = maxDelay;

gradle.properties

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
group=com.airwallex.airskiff
22
name=core
3-
version=2.0.57
3+
version=2.0.58
44
org.gradle.daemon=true
55
org.gradle.parallel=true
66
file.encoding=utf-8

0 commit comments

Comments
 (0)