[jira] [Commented] (FLINK-4259) Unclosed FSDataOutputStream in FileCache#copy()

[ https://issues.apache.org/jira/browse/FLINK-4259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15394917#comment-15394917 ] ASF GitHub Bot commented on FLINK-4259: --- Github user nssalian commented on the issue:

[GitHub] flink issue #2299: [FLINK-4259]: Unclosed FSDataOutputStream in FileCache#co...

Github user mbalassi commented on the issue: https://github.com/apache/flink/pull/2299 The code change is very concise and looks right, the one issue that bugs me is that there are no direct tests in place to verify it - and it is not necessarily straight forward to test as it is a

[GitHub] flink pull request #2299: [FLINK-4259]: Unclosed FSDataOutputStream in FileC...

GitHub user nssalian opened a pull request: https://github.com/apache/flink/pull/2299 [FLINK-4259]: Unclosed FSDataOutputStream in FileCache#copy(): Added a … Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Updated] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue

[ https://issues.apache.org/jira/browse/FLINK-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Philipp Grulich updated FLINK-4251: --- Affects Version/s: 1.1.0 > Add possiblity for the RMQ Streaming Sink to customize the queue >

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 Team, please let me know if any additional details are required to kick-start the review process? --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-4161) Quickstarts can exclude more flink-dist dependencies

[ https://issues.apache.org/jira/browse/FLINK-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15394031#comment-15394031 ] Maximilian Michels commented on FLINK-4161: --- Could you reopen the pull request? > Quickstarts

[jira] [Commented] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15393949#comment-15393949 ] ASF GitHub Bot commented on FLINK-4247: --- GitHub user twalthr opened a pull request:

[GitHub] flink issue #2294: [FLINK-4265] [dataset api] Add a NoOpOperator

Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2294 @StephanEwen thoughts on how to proceed? Not looking to rush this. With this simple PR I can remove the use of javassist's `ProxyFactory` from Gelly. Or we can defer consideration of this

[jira] [Commented] (FLINK-4152) TaskManager registration exponential backoff doesn't work

[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15393601#comment-15393601 ] ASF GitHub Bot commented on FLINK-4152: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15393293#comment-15393293 ] ASF GitHub Bot commented on FLINK-1745: --- Github user thvasilo commented on the issue: