[jira] [Updated] (FLINK-5386) Refacturing Window Clause

2016-12-21 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-5386: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-4557 > Refacturing Window Clause >

[jira] [Created] (FLINK-5386) Refacturing Window Clause

2016-12-21 Thread sunjincheng (JIRA)
sunjincheng created FLINK-5386: -- Summary: Refacturing Window Clause Key: FLINK-5386 URL: https://issues.apache.org/jira/browse/FLINK-5386 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-5384) clean up jira issues

2016-12-21 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: https://issues.apache.org/jira/browse/FLINK-37 -> from stratosphere;

[jira] [Updated] (FLINK-5384) clean up jira issues

2016-12-21 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5384: - Description: must be closed: https://issues.apache.org/jira/browse/FLINK-37 -> from stratosphere;

[jira] [Commented] (FLINK-5385) Add a help function to create Row

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15769222#comment-15769222 ] ASF GitHub Bot commented on FLINK-5385: --- GitHub user wuchong opened a pull request:

[GitHub] flink pull request #3038: [FLINK-5385] [core] Add a help function to create ...

2016-12-21 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/3038 [FLINK-5385] [core] Add a help function to create Row Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If

[jira] [Created] (FLINK-5385) Add a help function to create Row

2016-12-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-5385: -- Summary: Add a help function to create Row Key: FLINK-5385 URL: https://issues.apache.org/jira/browse/FLINK-5385 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15769103#comment-15769103 ] ASF GitHub Bot commented on FLINK-5348: --- Github user wuchong commented on the issue:

[GitHub] flink issue #3020: [FLINK-5348] [core] Support custom field names for RowTyp...

2016-12-21 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/3020 Thank you @fhueske , I think your points are very good. And I changed my code according to your suggestions. --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

2016-12-21 Thread liuyuzhong
Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2439 @StephanEwen I use new githup account make a new pull request #3037, help me to review it please.Thanks. --- If your project is set up for it, you can reply to this email and have your reply

[GitHub] flink pull request #3037: Flink-4450 update storm version to 1.0

2016-12-21 Thread liuyuzhong7
GitHub user liuyuzhong7 opened a pull request: https://github.com/apache/flink/pull/3037 Flink-4450 update storm version to 1.0 @StephanEwen @mxm The old pull request #2439 was wrong , I use this account make a new pull request. Please me to review this pull request.

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93566506 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -54,6 +76,152 @@ public RowTypeInfo(TypeInformation... types)

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15769075#comment-15769075 ] ASF GitHub Bot commented on FLINK-5348: --- Github user wuchong commented on a diff in the pull

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15769058#comment-15769058 ] ASF GitHub Bot commented on FLINK-5348: --- Github user wuchong commented on a diff in the pull

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93566058 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -54,6 +76,152 @@ public RowTypeInfo(TypeInformation... types)

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15768746#comment-15768746 ] ASF GitHub Bot commented on FLINK-4450: --- Github user liuyuzhong commented on the issue:

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

2016-12-21 Thread liuyuzhong
Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2439 @StephanEwen Sorry, I can't continue with this pull request. I will use another githup account to pull. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Closed] (FLINK-5175) StreamExecutionEnvironment's set function return `this` instead of void

2016-12-21 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui closed FLINK-5175. Resolution: Won't Fix > StreamExecutionEnvironment's set function return `this` instead of void >

[jira] [Updated] (FLINK-5370) build failure for unit test of FileInputFormatTest and GlobFilePathFilterTest

2016-12-21 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-5370: - Description: mvn clean package head commit 4a27d2105dd08f323c0be26e79a55986aa97e7bd on windows: Results

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2016-12-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767649#comment-15767649 ] Fabian Hueske commented on FLINK-5256: -- The feature can be tested with the following test case:

[jira] [Created] (FLINK-5384) clean up jira issues

2016-12-21 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5384: Summary: clean up jira issues Key: FLINK-5384 URL: https://issues.apache.org/jira/browse/FLINK-5384 Project: Flink Issue Type: Improvement

[GitHub] flink pull request #3033: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3033#discussion_r93469241 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetJoinRule.scala --- @@ -40,10 +41,17 @@ class

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767567#comment-15767567 ] ASF GitHub Bot commented on FLINK-5256: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5256) Extend DataSetSingleRowJoin to support Left and Right joins

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767566#comment-15767566 ] ASF GitHub Bot commented on FLINK-5256: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3033: [FLINK-5256] Extend DataSetSingleRowJoin to suppor...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3033#discussion_r93472610 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/DataSetSingleRowJoinRule.scala --- @@ -35,16 +35,7 @@ class

[jira] [Assigned] (FLINK-3150) Make YARN container invocation configurable

2016-12-21 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-3150: -- Assignee: Nico Kruber (was: Robert Metzger) > Make YARN container invocation configurable >

[jira] [Closed] (FLINK-4339) Implement Slot Pool Core

2016-12-21 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-4339. > Implement Slot Pool Core > > > Key: FLINK-4339 >

[jira] [Closed] (FLINK-4987) Harden slot pool logic

2016-12-21 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-4987. > Harden slot pool logic > -- > > Key: FLINK-4987 >

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93465353 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -54,6 +76,152 @@ public RowTypeInfo(TypeInformation... types)

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93405538 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/RowTypeInfoTest.java --- @@ -18,12 +18,86 @@ package

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93405238 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -54,6 +76,152 @@ public RowTypeInfo(TypeInformation... types)

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93466347 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -54,6 +76,152 @@ public RowTypeInfo(TypeInformation... types)

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93404965 --- Diff: flink-core/src/test/java/org/apache/flink/api/java/typeutils/RowTypeInfoTest.java --- @@ -18,12 +18,86 @@ package

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767434#comment-15767434 ] ASF GitHub Bot commented on FLINK-5348: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93405114 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -54,6 +76,152 @@ public RowTypeInfo(TypeInformation... types)

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767437#comment-15767437 ] ASF GitHub Bot commented on FLINK-5348: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767432#comment-15767432 ] ASF GitHub Bot commented on FLINK-5348: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767431#comment-15767431 ] ASF GitHub Bot commented on FLINK-5348: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767435#comment-15767435 ] ASF GitHub Bot commented on FLINK-5348: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767433#comment-15767433 ] ASF GitHub Bot commented on FLINK-5348: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767438#comment-15767438 ] ASF GitHub Bot commented on FLINK-5348: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93466144 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -54,6 +76,152 @@ public RowTypeInfo(TypeInformation... types)

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767436#comment-15767436 ] ASF GitHub Bot commented on FLINK-5348: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93465385 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -54,6 +76,152 @@ public RowTypeInfo(TypeInformation... types)

[GitHub] flink pull request #3020: [FLINK-5348] [core] Support custom field names for...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3020#discussion_r93405183 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -54,6 +76,152 @@ public RowTypeInfo(TypeInformation... types)

[jira] [Commented] (FLINK-5348) Support custom field names for RowTypeInfo

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767430#comment-15767430 ] ASF GitHub Bot commented on FLINK-5348: --- Github user fhueske commented on a diff in the pull

[jira] [Created] (FLINK-5383) TaskManager fails with SIGBUS when loading RocksDB

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5383: - Summary: TaskManager fails with SIGBUS when loading RocksDB Key: FLINK-5383 URL: https://issues.apache.org/jira/browse/FLINK-5383 Project: Flink Issue

[jira] [Created] (FLINK-5382) Taskmanager log download button causes 404

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5382: - Summary: Taskmanager log download button causes 404 Key: FLINK-5382 URL: https://issues.apache.org/jira/browse/FLINK-5382 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5381) Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config)

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5381: - Summary: Scrolling in some web interface pages doesn't work (taskmanager details, jobmanager config) Key: FLINK-5381 URL: https://issues.apache.org/jira/browse/FLINK-5381

[jira] [Updated] (FLINK-1439) Enable all YARN tests on Travis

2016-12-21 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-1439: - Description: (was: Currently blocked by https://issues.apache.org/jira/browse/YARN-3086) >

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767311#comment-15767311 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767308#comment-15767308 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767309#comment-15767309 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767300#comment-15767300 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767307#comment-15767307 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767306#comment-15767306 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767297#comment-15767297 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767315#comment-15767315 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767303#comment-15767303 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767305#comment-15767305 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767301#comment-15767301 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767314#comment-15767314 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767310#comment-15767310 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93437996 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/CalcValidationTest.scala --- @@ -0,0 +1,111 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93440307 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/SortValidationTest.scala --- @@ -0,0 +1,55 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93440355 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/CalcValidationTest.scala --- @@ -0,0 +1,111 @@ +/* + *

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767312#comment-15767312 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767298#comment-15767298 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767313#comment-15767313 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93438060 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/CastingPlanTest.scala --- @@ -0,0 +1,130 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93440071 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/AggregationsValidationTest.scala --- @@ -0,0 +1,148 @@ +/*

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767299#comment-15767299 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767316#comment-15767316 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767302#comment-15767302 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5084) Replace Java Table API integration tests by unit tests

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767304#comment-15767304 ] ASF GitHub Bot commented on FLINK-5084: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93440247 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/JoinPlanTest.scala --- @@ -0,0 +1,283 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93440286 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/SetOperatorsValidationTest.scala --- @@ -0,0 +1,128 @@ +/*

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93438092 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/JoinPlanTest.scala --- @@ -0,0 +1,283 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93438204 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/SortValidationTest.scala --- @@ -0,0 +1,55 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93448930 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/AggregationsITCase.scala --- @@ -400,5 +342,23 @@ class

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93440266 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/JoinValidationTest.scala --- @@ -0,0 +1,197 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93438117 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/JoinValidationTest.scala --- @@ -0,0 +1,197 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93438154 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/SetOperatorsValidationTest.scala --- @@ -0,0 +1,128 @@ +/*

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93437942 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/AggregationsValidationTest.scala --- @@ -0,0 +1,148 @@ +/*

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93436582 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/CalcPlanTest.scala --- @@ -0,0 +1,394 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93440220 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/CastingPlanTest.scala --- @@ -0,0 +1,130 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93436751 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/CalcPlanTest.scala --- @@ -0,0 +1,394 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93437895 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/AggregationsPlanTest.scala --- @@ -0,0 +1,350 @@ +/* + *

[GitHub] flink pull request #2977: [FLINK-5084] Replace Java Table API integration te...

2016-12-21 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r93438663 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/CalcITCase.scala --- @@ -424,6 +425,19 @@ class CalcITCase(

[jira] [Updated] (FLINK-5380) Number of outgoing records not reported in web interface

2016-12-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5380: -- Attachment: outRecordsNotreported.png > Number of outgoing records not reported in web

[jira] [Created] (FLINK-5380) Number of outgoing records not reported in web interface

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5380: - Summary: Number of outgoing records not reported in web interface Key: FLINK-5380 URL: https://issues.apache.org/jira/browse/FLINK-5380 Project: Flink

[jira] [Updated] (FLINK-5379) Flink CliFrontend does not return when not logged in with kerberos

2016-12-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5379: -- Description: In pre 1.2 versions, Flink immediately fails when trying to deploy it on YARN and

[jira] [Created] (FLINK-5379) Flink CliFrontend does not return when not logged in with kerberos

2016-12-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5379: - Summary: Flink CliFrontend does not return when not logged in with kerberos Key: FLINK-5379 URL: https://issues.apache.org/jira/browse/FLINK-5379 Project: Flink

[jira] [Updated] (FLINK-1583) TaskManager reregistration in case of a restart

2016-12-21 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-1583: - Description: Currently, the {{InstanceManager}} identifies {{Instance}}s based on their

[jira] [Updated] (FLINK-1583) TaskManager reregistration in case of a restart

2016-12-21 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-1583: - Description: Currently, the {{InstanceManager}} identifies {{Instance}} s based on their

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2016-12-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767065#comment-15767065 ] Till Rohrmann commented on FLINK-5364: -- Hi [~eronwright], I think you're right and we should

[jira] [Updated] (FLINK-1583) TaskManager reregistration in case of a restart

2016-12-21 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-1583: - Description: Currently, the {{InstanceManager}} identifies {{Instance}}'s based on their

[jira] [Commented] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints

2016-12-21 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767058#comment-15767058 ] Till Rohrmann commented on FLINK-5086: -- Hi [~roman_maier], what's your plan to solve this problem? >

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15766974#comment-15766974 ] Jark Wu commented on FLINK-5280: Thank you [~fhueske] for summarizing this, make sense to me :) > Extend

[jira] [Commented] (FLINK-5368) Let Kafka consumer show something when it fails to read one topic out of topic list

2016-12-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15766884#comment-15766884 ] ASF GitHub Bot commented on FLINK-5368: --- Github user DieBauer commented on the issue:

  1   2   >