diff options
| author | chaoc <[email protected]> | 2023-12-04 17:08:53 +0800 |
|---|---|---|
| committer | chaoc <[email protected]> | 2023-12-04 17:08:53 +0800 |
| commit | 35247d7414cf5eb83fefe44806716c2647031e53 (patch) | |
| tree | 097cf3aabb0551bff0dff0eadc24eea280656660 | |
| parent | 64f19b528e76cb6dce272ef4caa5219870974fb8 (diff) | |
fix: update field name
| -rw-r--r-- | src/main/java/com/zdjizhi/flink/voip/CorrelateApp.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/main/java/com/zdjizhi/flink/voip/CorrelateApp.java b/src/main/java/com/zdjizhi/flink/voip/CorrelateApp.java index 5b699f3..8701891 100644 --- a/src/main/java/com/zdjizhi/flink/voip/CorrelateApp.java +++ b/src/main/java/com/zdjizhi/flink/voip/CorrelateApp.java @@ -59,7 +59,7 @@ public class CorrelateApp { .<ObjectNode>forBoundedOutOfOrderness(Duration.ofSeconds(5)) .withTimestampAssigner((SerializableTimestampAssigner<ObjectNode>) (element, recordTimestamp) -> - element.get("common_start_timestamp_ms").asLong())); + element.get("start_timestamp_ms").asLong())); final ErrorHandler errorHandler = new ErrorHandler(config); |