[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

2021-06-21 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366576#comment-17366576 ] Andrew Roberts commented on FLINK-13414: Curious if this is still being worked o

[jira] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-12 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283794#comment-17283794 ] Andrew Roberts commented on FLINK-14034: I see- re-reading that interface now, I

[jira] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-12 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283755#comment-17283755 ] Andrew Roberts commented on FLINK-14034: Nothing prevents it, but then my sink i

[jira] [Comment Edited] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-12 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283740#comment-17283740 ] Andrew Roberts edited comment on FLINK-14034 at 2/12/21, 2:57 PM:

[jira] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-12 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283740#comment-17283740 ] Andrew Roberts commented on FLINK-14034: [~pnowojski] the catch here is, ultimat

[jira] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-12 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283708#comment-17283708 ] Andrew Roberts commented on FLINK-14034: [~pnowojski] a wrapper class means re-i

[jira] [Commented] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic

2021-02-11 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17283086#comment-17283086 ] Andrew Roberts commented on FLINK-14002: It looks like perhaps this is being (or

[jira] [Comment Edited] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-10 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282743#comment-17282743 ] Andrew Roberts edited comment on FLINK-14034 at 2/10/21, 10:16 PM: ---

[jira] [Commented] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

2021-02-10 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17282743#comment-17282743 ] Andrew Roberts commented on FLINK-14034: Just to add another use case here: It i

[jira] [Commented] (FLINK-13369) Recursive closure cleaner ends up with stackOverflow in case of circular dependency

2020-02-07 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17032557#comment-17032557 ] Andrew Roberts commented on FLINK-13369: [~chesnay] can you please reopen this t

[jira] [Commented] (FLINK-13369) Recursive closure cleaner ends up with stackOverflow in case of circular dependency

2020-01-29 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17026144#comment-17026144 ] Andrew Roberts commented on FLINK-13369: {code:scala} import org.apache.flink.ap

[jira] [Comment Edited] (FLINK-13369) Recursive closure cleaner ends up with stackOverflow in case of circular dependency

2020-01-28 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025435#comment-17025435 ] Andrew Roberts edited comment on FLINK-13369 at 1/28/20 8:53 PM: -

[jira] [Commented] (FLINK-13369) Recursive closure cleaner ends up with stackOverflow in case of circular dependency

2020-01-28 Thread Andrew Roberts (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025435#comment-17025435 ] Andrew Roberts commented on FLINK-13369: I'm still seeing this behavior in Flink

[jira] [Commented] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala

2018-08-22 Thread Andrew Roberts (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589125#comment-16589125 ] Andrew Roberts commented on FLINK-10167: Interesting - I was making several assu

[jira] [Commented] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala

2018-08-21 Thread Andrew Roberts (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16587442#comment-16587442 ] Andrew Roberts commented on FLINK-10167: Can you clarify what you mean by "value

[jira] [Created] (FLINK-10183) Processing-Time based windows aren't emitted when a finite stream ends

2018-08-20 Thread Andrew Roberts (JIRA)
Andrew Roberts created FLINK-10183: -- Summary: Processing-Time based windows aren't emitted when a finite stream ends Key: FLINK-10183 URL: https://issues.apache.org/jira/browse/FLINK-10183 Project: F

[jira] [Created] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala

2018-08-17 Thread Andrew Roberts (JIRA)
Andrew Roberts created FLINK-10167: -- Summary: SessionWindows not compatible with typed DataStreams in scala Key: FLINK-10167 URL: https://issues.apache.org/jira/browse/FLINK-10167 Project: Flink

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

2018-03-20 Thread Andrew Roberts (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16406501#comment-16406501 ] Andrew Roberts commented on FLINK-7811: --- Any updates on this? Is this still likely t

[jira] [Created] (FLINK-7937) Add pagination to Flink History view

2017-10-27 Thread Andrew Roberts (JIRA)
Andrew Roberts created FLINK-7937: - Summary: Add pagination to Flink History view Key: FLINK-7937 URL: https://issues.apache.org/jira/browse/FLINK-7937 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6403) constructFlinkClassPath produces nondeterministic classpath

2017-04-27 Thread Andrew Roberts (JIRA)
Andrew Roberts created FLINK-6403: - Summary: constructFlinkClassPath produces nondeterministic classpath Key: FLINK-6403 URL: https://issues.apache.org/jira/browse/FLINK-6403 Project: Flink

[jira] [Issue Comment Deleted] (FLINK-5236) User jar classpath should come first in classpath

2017-04-27 Thread Andrew Roberts (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Roberts updated FLINK-5236: -- Comment: was deleted (was: If the user jar includes a conflicting non-compatible version of some

[jira] [Commented] (FLINK-5236) User jar classpath should come first in classpath

2017-04-27 Thread Andrew Roberts (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987052#comment-15987052 ] Andrew Roberts commented on FLINK-5236: --- If the user jar loads a conflicting non-com

[jira] [Comment Edited] (FLINK-5236) User jar classpath should come first in classpath

2017-04-27 Thread Andrew Roberts (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15987052#comment-15987052 ] Andrew Roberts edited comment on FLINK-5236 at 4/27/17 5:10 PM:

[jira] [Created] (FLINK-5005) Publish Scala 2.12 artifacts

2016-11-03 Thread Andrew Roberts (JIRA)
Andrew Roberts created FLINK-5005: - Summary: Publish Scala 2.12 artifacts Key: FLINK-5005 URL: https://issues.apache.org/jira/browse/FLINK-5005 Project: Flink Issue Type: Improvement