Skip to content

Commit

Permalink
Fixed last wierdness with VSCode tab formatting in StreamingJob.java
Browse files Browse the repository at this point in the history
  • Loading branch information
wmtaff committed Jan 14, 2021
1 parent cfe2aa8 commit 0e5e817
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ public static void main(String[] args) throws Exception {
//enable event time processing
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
env.getConfig().setAutoWatermarkInterval(1000L);
//get the aggregation window
//get the aggregation window
int aggregationWindowMinutes = Integer.parseInt(parameter.get("AggregationWindowMinutes", "5"));

DataStream<TimestreamPoint> input = createKinesisSource(env, parameter);
Expand Down

0 comments on commit 0e5e817

Please sign in to comment.