14 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (270:316, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (592:638, 2%) 10 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (375:412, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (700:740, 1%) 9 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (915:942, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (1742:1768, 1%) 8 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (963:972, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (1802:1811, 1%) 8 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (424:431, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (795:802, 1%) 8 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (414:421, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (784:791, 1%) 7 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (172:188, 2%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (218:234, 1%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java (176:182, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputUdfOperator.java (298:305, 4%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java (329:336, 5%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java (106:111, 13%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java (178:183, 7%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java (176:182, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java (176:182, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java (176:182, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/MultipleParameterTool.java (114:120, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/MultipleParameterTool.java (114:120, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/MultipleParameterTool.java (114:120, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java (230:237, 6%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java (329:336, 5%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java (176:182, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java (176:182, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/MultipleParameterTool.java (114:120, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/MultipleParameterTool.java (114:120, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java (341:365, 1%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java (657:686, 1%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java (176:182, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/MultipleParameterTool.java (114:120, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java (176:182, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java (143:149, 13%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java (220:226, 7%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java (176:182, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/MultipleParameterTool.java (114:120, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/MultipleParameterTool.java (114:120, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%) 6 duplicated lines in: - flink-java/src/main/java/org/apache/flink/api/java/utils/MultipleParameterTool.java (114:120, 5%) - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%)