Hi Team, Trying to use Window for maintaining stre...
# troubleshooting
d
Hi Team, Trying to use Window for maintaining stream for 2 days within flink Table. I have the following code:
Copy code
environment.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); //for time based events

DataStream<JsonNode> timestampedStream = eventStateStream.assignTimestampsAndWatermarks(
                WatermarkStrategy.<JsonNode>forBoundedOutOfOrderness(Duration.ofSeconds(120)).withTimestampAssigner((event, timestamp) -> {
                    return eventTime; //calculated event time
                })
        );
AllWindowedStream<JsonNode, TimeWindow> miniEventWindowedStream = timestampedStream.windowAll(SlidingEventTimeWindows.of(Time.days(2), Time.minutes(2)));
miniEventWindowedStream.apply(//my processing logic).print()
The print() here does not print the event. The eventTime returned is within the window. Appreciate any thoughts or inputs here. Thanks