[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16195159#comment-16195159 ] Vishnu Viswanath commented on FLINK-3655: - was looking for this feature. why wasn't this ever

[jira] [Commented] (FLINK-4660) HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop

[ https://issues.apache.org/jira/browse/FLINK-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16180517#comment-16180517 ] Vishnu Viswanath commented on FLINK-4660: - in which version is this fixed? I am using 1.3.1 and

[jira] [Created] (FLINK-7299) Write GenericRecord using AvroOutputFormat

Vishnu Viswanath created FLINK-7299: --- Summary: Write GenericRecord using AvroOutputFormat Key: FLINK-7299 URL: https://issues.apache.org/jira/browse/FLINK-7299 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6726) Allow setting Timers in ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-6726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16031263#comment-16031263 ] Vishnu Viswanath commented on FLINK-6726: - Hi [~aljoscha], I have implemented the changes and had

[jira] [Updated] (FLINK-6726) Allow setting Timers in ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-6726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vishnu viswanath updated FLINK-6726: Description: Allow registration of timers in ProcessWindowFunction. {code} public abstract

[jira] [Created] (FLINK-6726) Allow setting Timers in ProcessWindowFunction

vishnu viswanath created FLINK-6726: --- Summary: Allow setting Timers in ProcessWindowFunction Key: FLINK-6726 URL: https://issues.apache.org/jira/browse/FLINK-6726 Project: Flink Issue

[jira] [Commented] (FLINK-5053) Incremental / lightweight snapshots for checkpoints

[ https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16006987#comment-16006987 ] vishnu viswanath commented on FLINK-5053: - is this task complete, I see all the pull requests for

[jira] [Created] (FLINK-6372) change-scala-version.sh does not change version for flink-gelly-examples

vishnu viswanath created FLINK-6372: --- Summary: change-scala-version.sh does not change version for flink-gelly-examples Key: FLINK-6372 URL: https://issues.apache.org/jira/browse/FLINK-6372

[jira] [Commented] (FLINK-4369) EvictingWindowOperator Must Actually Evict Elements

[ https://issues.apache.org/jira/browse/FLINK-4369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15667309#comment-15667309 ] vishnu viswanath commented on FLINK-4369: - Fixed by [FLINK-4174] > EvictingWindowOperator Must

[jira] [Closed] (FLINK-4174) Enhance Window Evictor

[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vishnu viswanath closed FLINK-4174. --- Resolution: Fixed > Enhance Window Evictor > -- > > Key:

[jira] [Closed] (FLINK-4369) EvictingWindowOperator Must Actually Evict Elements

[ https://issues.apache.org/jira/browse/FLINK-4369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vishnu viswanath closed FLINK-4369. --- Resolution: Fixed > EvictingWindowOperator Must Actually Evict Elements >

[jira] [Assigned] (FLINK-4174) Enhance Window Evictor

[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vishnu viswanath reassigned FLINK-4174: --- Assignee: vishnu viswanath > Enhance Window Evictor > -- > >

[jira] [Updated] (FLINK-4174) Enhance Window Evictor

[ https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vishnu viswanath updated FLINK-4174: Description: Enhance the current functionality of Evictor as per this [design

[jira] [Created] (FLINK-4174) Enhance Window Evictor

vishnu viswanath created FLINK-4174: --- Summary: Enhance Window Evictor Key: FLINK-4174 URL: https://issues.apache.org/jira/browse/FLINK-4174 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-3962) JMXReporter doesn't properly register/deregister metrics

[ https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347222#comment-15347222 ] vishnu viswanath commented on FLINK-3962: - I am getting this exception in Local execution aswell.