[jira] [Commented] (FLINK-19479) Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()
[ https://issues.apache.org/jira/browse/FLINK-19479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205423#comment-17205423 ] Nicholas Jiang commented on FLINK-19479: [~aljoscha], IMO, I could also work for this issue.:D > Allow explicitly configuring time behaviour on KeyedStream.intervalJoin() > - > > Key: FLINK-19479 > URL: https://issues.apache.org/jira/browse/FLINK-19479 > Project: Flink > Issue Type: Sub-task > Components: API / DataStream >Reporter: Aljoscha Krettek >Priority: Major > > With the deprecation of > {{StreamExecutionEnvironment.setStreamTimeCharacteristic()}} in FLINK-19319 > we need a way of explicitly configuring the time behaviour of these join > operations. Currently, all join operations use the characteristic to > configure themselves. > Alternatively, we might consider removing/deprecating these join operations. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-19479) Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()
[ https://issues.apache.org/jira/browse/FLINK-19479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17205392#comment-17205392 ] Aljoscha Krettek commented on FLINK-19479: -- Yes, it's basically the same but for joins. Should I assign you as well? > Allow explicitly configuring time behaviour on KeyedStream.intervalJoin() > - > > Key: FLINK-19479 > URL: https://issues.apache.org/jira/browse/FLINK-19479 > Project: Flink > Issue Type: Sub-task > Components: API / DataStream >Reporter: Aljoscha Krettek >Priority: Major > > With the deprecation of > {{StreamExecutionEnvironment.setStreamTimeCharacteristic()}} in FLINK-19319 > we need a way of explicitly configuring the time behaviour of these join > operations. Currently, all join operations use the characteristic to > configure themselves. > Alternatively, we might consider removing/deprecating these join operations. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-19479) Allow explicitly configuring time behaviour on KeyedStream.intervalJoin()
[ https://issues.apache.org/jira/browse/FLINK-19479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204664#comment-17204664 ] Nicholas Jiang commented on FLINK-19479: [~aljoscha], does this issue similar with [FLINK-19326|https://issues.apache.org/jira/browse/FLINK-19326]? > Allow explicitly configuring time behaviour on KeyedStream.intervalJoin() > - > > Key: FLINK-19479 > URL: https://issues.apache.org/jira/browse/FLINK-19479 > Project: Flink > Issue Type: Sub-task > Components: API / DataStream >Reporter: Aljoscha Krettek >Priority: Major > > With the deprecation of > {{StreamExecutionEnvironment.setStreamTimeCharacteristic()}} in FLINK-19319 > we need a way of explicitly configuring the time behaviour of these join > operations. Currently, all join operations use the characteristic to > configure themselves. > Alternatively, we might consider removing/deprecating these join operations. -- This message was sent by Atlassian Jira (v8.3.4#803005)