[GitHub] flink pull request #2162: FLINK-4103: Modify CsvTableSource to implement Str...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2162 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-4103) Modify CsvTableSource to implement StreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-4103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393483#comment-15393483 ] ASF GitHub Bot commented on FLINK-4103: --- Github user asfgit closed the pull request

[jira] [Resolved] (FLINK-4103) Modify CsvTableSource to implement StreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-4103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-4103. - Resolution: Fixed Fixed in 7e309eeb5f0c6977c5c62028bfd15dd8927c62aa. > Modify CsvTableSource to i

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

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

[GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2226 I've verified locally that the kafka tests now pass. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Assigned] (FLINK-4081) FieldParsers should support empty strings

[ https://issues.apache.org/jira/browse/FLINK-4081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-4081: --- Assignee: Timo Walther > FieldParsers should support empty strings >

[GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2226 How confident are we? 😄 Should we wait for travis to finish or can we merge now? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

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

[GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2226 I think we're good. The builds passed before we moved the JMXReporter, and i scanned for usages of the JMXReporter and ran tests in the affected modules. Let me check one more time whether you

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

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

[GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2226 yep, we're good to go IMO. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

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

[GitHub] flink issue #2278: [FLINK-4239] Set Default Allowed Lateness to Zero and Mak...

Github user uce commented on the issue: https://github.com/apache/flink/pull/2278 I'm merging this now --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or i

[jira] [Commented] (FLINK-4239) Set Default Allowed Lateness to Zero and Make Triggers Non-Purging

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

[jira] [Commented] (FLINK-4067) Add version header to savepoints

[ https://issues.apache.org/jira/browse/FLINK-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393517#comment-15393517 ] ASF GitHub Bot commented on FLINK-4067: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2194: [FLINK-4067] [runtime] Add savepoint headers

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2194 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Closed] (FLINK-4067) Add version header to savepoints

[ https://issues.apache.org/jira/browse/FLINK-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4067. -- Resolution: Fixed Fixed in f0ac261 (master). > Add version header to savepoints > -

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

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

[GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2226 Ok, I think anything else we'll discover in the release testing. If any ... LGTM! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[GitHub] flink pull request #2278: [FLINK-4239] Set Default Allowed Lateness to Zero ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2278 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-4239) Set Default Allowed Lateness to Zero and Make Triggers Non-Purging

[ https://issues.apache.org/jira/browse/FLINK-4239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393523#comment-15393523 ] ASF GitHub Bot commented on FLINK-4239: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-4239) Set Default Allowed Lateness to Zero and Make Triggers Non-Purging

[ https://issues.apache.org/jira/browse/FLINK-4239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4239. -- Resolution: Fixed Fix Version/s: 1.1.0 Fixed in 0b4c04d (master). > Set Default Allowed Lateness

[GitHub] flink pull request #2286: [FLINK-4210][metrics] Move close()/isClosed() out ...

Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/2286#discussion_r72217528 --- Diff: flink-core/src/main/java/org/apache/flink/metrics/MetricGroup.java --- @@ -37,25 +37,6 @@ public interface MetricGroup { //

[jira] [Commented] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-4210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393538#comment-15393538 ] ASF GitHub Bot commented on FLINK-4210: --- Github user uce commented on a diff in the

[jira] [Assigned] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-4210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-4210: -- Assignee: Ufuk Celebi (was: Chesnay Schepler) > Move close()/isClosed() out of MetricGroup int

[jira] [Commented] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface

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

[GitHub] flink issue #2286: [FLINK-4210][metrics] Move close()/isClosed() out of Metr...

Github user uce commented on the issue: https://github.com/apache/flink/pull/2286 Looks good to merge. Following the discussion in the JIRA, I think it's nice to move it out. I had one minor inline comment and the commit message has a typo. --- If your project is set up for it, you

[jira] [Commented] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface

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

[GitHub] flink issue #2286: [FLINK-4210][metrics] Move close()/isClosed() out of Metr...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2286 I'll address the issues while merging, which I'm doing now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not hav

[jira] [Assigned] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-4210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4210: --- Assignee: Chesnay Schepler (was: Ufuk Celebi) > Move close()/isClosed() out of Metri

[GitHub] flink pull request #2286: [FLINK-4210][metrics] Move close()/isClosed() out ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2286 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Closed] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-4210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4210. --- Resolution: Fixed Implemented in e4fe89d6e454dbeef020feb6ff6c989c8cb0424c > Move close()/isCl

[jira] [Commented] (FLINK-4210) Move close()/isClosed() out of MetricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-4210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393554#comment-15393554 ] ASF GitHub Bot commented on FLINK-4210: --- Github user asfgit closed the pull request

[GitHub] flink issue #2226: [FLINK-4192] - Move Metrics API to separate module

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2226 merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feat

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

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

[jira] [Closed] (FLINK-4227) Add Heron (heronstreaming.io), Apex (http://apex.apache.org/) comparison to features page

[ https://issues.apache.org/jira/browse/FLINK-4227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4227. -- Resolution: Won't Fix > Add Heron (heronstreaming.io), Apex (http://apex.apache.org/) comparison to > f

[GitHub] flink pull request #2226: [FLINK-4192] - Move Metrics API to separate module

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2226 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-4192) Move Metrics API to separate module

[ https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393600#comment-15393600 ] ASF GitHub Bot commented on FLINK-4192: --- Github user asfgit closed the pull request

[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&focusedCommentId=15393601#comment-15393601 ] ASF GitHub Bot commented on FLINK-4152: --- Github user mxm commented on the issue:

[jira] [Closed] (FLINK-4192) Move Metrics API to separate module

[ https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4192. --- Resolution: Fixed Implemented in e3fec1f9ad737c01fc5c22bd0c327bfce91938a9 > Move Metrics API

[GitHub] flink issue #2257: [FLINK-4152] Allow re-registration of TMs at resource man...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2257 https://s3.amazonaws.com/archive.travis-ci.org/jobs/146612227/log.txt After checking the logs again, I know why Maven isn't using the installed `flink-runtime` artifact. It tries to download the

[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393704#comment-15393704 ] Gabor Gevay commented on FLINK-2237: I think we should have a separate {{setCombineHin

[GitHub] flink pull request #2257: [FLINK-4152] Allow re-registration of TMs at resou...

Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2257#discussion_r72238490 --- Diff: flink-yarn/pom.xml --- @@ -85,8 +85,20 @@ under the License. guava ${guava.version}

[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&focusedCommentId=15393716#comment-15393716 ] ASF GitHub Bot commented on FLINK-4152: --- Github user mxm commented on a diff in the

[GitHub] flink issue #1220: [FLINK-1745] Add exact k-nearest-neighbours algorithm to ...

Github user chiwanpark commented on the issue: https://github.com/apache/flink/pull/1220 Hi @thvasilo, I've checked the [FlinkML index page](https://ci.apache.org/projects/flink/flink-docs-master/apis/batch/libs/ml/index.html#supervised-learning). There is a link to k-NN page in the i

[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&focusedCommentId=15393719#comment-15393719 ] ASF GitHub Bot commented on FLINK-1745: --- Github user chiwanpark commented on the iss

[GitHub] flink issue #2257: [FLINK-4152] Allow re-registration of TMs at resource man...

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2257 Found the culprit. We must not use the `scala.binary.version` property in flink artifact names. The property is only for switching Scala dependencies. It is not resolved by Maven in artifact names during

[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&focusedCommentId=15393730#comment-15393730 ] ASF GitHub Bot commented on FLINK-4152: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-4261) Setup atomic deployment of snapshots

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

[GitHub] flink pull request #2296: [FLINK-4261][tools] retry in case of failed snapsh...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2296 [FLINK-4261][tools] retry in case of failed snapshot deployment Unfortunately, we can't deploy snapshots atomically using the Nexus repository. The staged process which leads to an atomic deployment

[jira] [Commented] (FLINK-4265) Add a NoOpOperator

[ https://issues.apache.org/jira/browse/FLINK-4265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393839#comment-15393839 ] ASF GitHub Bot commented on FLINK-4265: --- Github user greghogan commented on the issu

[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 P

[GitHub] flink pull request #2257: [FLINK-4152] Allow re-registration of TMs at resou...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2257 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[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&focusedCommentId=15393885#comment-15393885 ] ASF GitHub Bot commented on FLINK-4152: --- Github user asfgit closed the pull request

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

[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4152. - Resolution: Fixed Fix Version/s: 1.1.0 Fixed via 2648bc1a5a5faed8c2061bcab40a8949fd

[GitHub] flink pull request #2296: [FLINK-4261][tools] retry in case of failed snapsh...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2296 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-4261) Setup atomic deployment of snapshots

[ https://issues.apache.org/jira/browse/FLINK-4261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393892#comment-15393892 ] ASF GitHub Bot commented on FLINK-4261: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-4261) Setup atomic deployment of snapshots

[ https://issues.apache.org/jira/browse/FLINK-4261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393894#comment-15393894 ] Maximilian Michels commented on FLINK-4261: --- Retry via cd232e683f7aa6d7660ca2d54

[jira] [Resolved] (FLINK-4261) Setup atomic deployment of snapshots

[ https://issues.apache.org/jira/browse/FLINK-4261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4261. --- Resolution: Unresolved Unfortunately, we can't deploy snapshots atomically using the N

[GitHub] flink pull request #2297: [FLINK-4081] [core] [table] FieldParsers should su...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2297 [FLINK-4081] [core] [table] FieldParsers should support empty strings Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into considerat

[jira] [Commented] (FLINK-4081) FieldParsers should support empty strings

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

[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&focusedCommentId=15393914#comment-15393914 ] Timo Walther commented on FLINK-4247: - I think you used the Table API wrong. {{getData

[jira] [Commented] (FLINK-4246) Allow Specifying Multiple Metrics Reporters

[ https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393921#comment-15393921 ] ASF GitHub Bot commented on FLINK-4246: --- Github user aljoscha closed the pull reques

[GitHub] flink pull request #2285: [FLINK-4246] Allow Specifying Multiple Metrics Rep...

Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/2285 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is en

[GitHub] flink pull request #2298: [FLINK-4247] [table] CsvTableSource.getDataSet() e...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2298 [FLINK-4247] [table] CsvTableSource.getDataSet() expects Java ExecutionEnvironment Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list i

[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&focusedCommentId=15393949#comment-15393949 ] ASF GitHub Bot commented on FLINK-4247: --- GitHub user twalthr opened a pull request:

[jira] [Assigned] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4263: -- Assignee: Jark Wu > SQL's VALUES does not work properly > --- > >

[jira] [Commented] (FLINK-4263) SQL's VALUES does not work properly

[ https://issues.apache.org/jira/browse/FLINK-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15393950#comment-15393950 ] Jark Wu commented on FLINK-4263: It seems that ValuesInputFormat has a {{Seq[Row]}} field,

[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&focusedCommentId=15393946#comment-15393946 ] Timo Walther commented on FLINK-4247: - Unfortunately, I cannot restrict the access. I

[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&focusedCommentId=15394001#comment-15394001 ] ASF GitHub Bot commented on FLINK-1745: --- Github user thvasilo commented on the issue

[GitHub] flink issue #1220: [FLINK-1745] Add exact k-nearest-neighbours algorithm to ...

Github user thvasilo commented on the issue: https://github.com/apache/flink/pull/1220 Oh, sorry should have checked the master docs. On Jul 26, 2016 5:29 AM, "Chiwan Park" wrote: > Hi @thvasilo , I've checked the FlinkML > index page

[jira] [Commented] (FLINK-4125) Yarn CLI incorrectly calculates slotsPerTM when parallelism < task manager count

[ https://issues.apache.org/jira/browse/FLINK-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15394020#comment-15394020 ] Maximilian Michels commented on FLINK-4125: --- Hi! This has already been fixed for

[jira] [Resolved] (FLINK-4125) Yarn CLI incorrectly calculates slotsPerTM when parallelism < task manager count

[ https://issues.apache.org/jira/browse/FLINK-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4125. --- Resolution: Duplicate Fix Version/s: 1.1.0 Resolving this but feel free to open

[jira] [Resolved] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session

[ https://issues.apache.org/jira/browse/FLINK-4156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4156. --- Resolution: Fixed Fix Version/s: 1.1.0 Should be resolved with FLINK-4166. > J

[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&focusedCommentId=15394031#comment-15394031 ] Maximilian Michels commented on FLINK-4161: --- Could you reopen the pull request?

[jira] [Closed] (FLINK-4258) Potential null pointer dereference in SavepointCoordinator#onFullyAcknowledgedCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-4258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4258. - Resolution: Fixed Assignee: Maximilian Michels Fix Version/s: 1.1.0 Thanks

[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 G

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15394093#comment-15394093 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the iss

[jira] [Assigned] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

[ https://issues.apache.org/jira/browse/FLINK-4248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suneel Marthi reassigned FLINK-4248: Assignee: Suneel Marthi > CsvTableSource does not support reading SqlTimeTypeInfo types > -

[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 pull request #2277: [FLINK-4207] WindowOperator becomes very slow with...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2277 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (FLINK-4207) WindowOperator becomes very slow with allowed lateness

[ https://issues.apache.org/jira/browse/FLINK-4207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15394487#comment-15394487 ] ASF GitHub Bot commented on FLINK-4207: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-4207) WindowOperator becomes very slow with allowed lateness

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

[GitHub] flink issue #2277: [FLINK-4207] WindowOperator becomes very slow with allowe...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2277 Could you please close? And thanks for your work! 👍 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Closed] (FLINK-4207) WindowOperator becomes very slow with allowed lateness

[ https://issues.apache.org/jira/browse/FLINK-4207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-4207. - Resolution: Fixed > WindowOperator becomes very slow with allowed lateness > -

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

[ https://issues.apache.org/jira/browse/FLINK-4259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned FLINK-4259: -- Assignee: Neelesh Srinivas Salian > Unclosed FSDataOutputStream in File

[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 cons

[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&focusedCommentId=15394713#comment-15394713 ] ASF GitHub Bot commented on FLINK-4259: --- GitHub user nssalian opened a pull request:

[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 @nssalian has just reached out to me in person. I will have a look at this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your pr

[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&focusedCommentId=15394746#comment-15394746 ] ASF GitHub Bot commented on FLINK-4259: --- Github user mbalassi commented on the issue

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

Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2299 Thanks @mbalassi --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or

[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&focusedCommentId=15394759#comment-15394759 ] ASF GitHub Bot commented on FLINK-4259: --- Github user nssalian commented on the issue

[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&focusedCommentId=15394842#comment-15394842 ] ASF GitHub Bot commented on FLINK-4259: --- Github user mbalassi 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 re

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

Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2299 hi @mbalassim thank you for the review. I have kicked off a build for my flink repo. Let me observe what happens. With regards to a test, I was thinking something on the lines of FileCacheDelet

[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&focusedCommentId=15394917#comment-15394917 ] ASF GitHub Bot commented on FLINK-4259: --- Github user nssalian commented on the issue

[jira] [Closed] (FLINK-4267) Adding async I/O flat map

[ https://issues.apache.org/jira/browse/FLINK-4267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4267. Resolution: Invalid > Adding async I/O flat map > - > > Key:

[jira] [Created] (FLINK-4267) Adding async I/O flat map

Till Rohrmann created FLINK-4267: Summary: Adding async I/O flat map Key: FLINK-4267 URL: https://issues.apache.org/jira/browse/FLINK-4267 Project: Flink Issue Type: New Feature Com

[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&focusedCommentId=15395002#comment-15395002 ] ASF GitHub Bot commented on FLINK-4152: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2257: [FLINK-4152] Allow re-registration of TMs at resource man...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2257 Thanks @mxm for resolving the issue. That was definitely a tricky one. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your pro

  1   2   >