[jira] [Commented] (FLINK-5417) Fix the wrong config file name

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15803783#comment-15803783 ] ASF GitHub Bot commented on FLINK-5417: --- Github user WangTaoTheTonic commented on the issue:

[GitHub] flink issue #3071: [FLINK-5417][DOCUMENTATION]correct the wrong config file ...

2017-01-05 Thread WangTaoTheTonic
Github user WangTaoTheTonic commented on the issue: https://github.com/apache/flink/pull/3071 I use Illustrator‎ to edit svg file, which will add some header infos that cause CI failed. Is there any prefered svg editor? --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-5247) Fix incorrect check in allowedLateness() method. Make it a no-op for non-event time windows.

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15803672#comment-15803672 ] ASF GitHub Bot commented on FLINK-5247: --- Github user mindprince commented on the issue:

[GitHub] flink issue #2929: [FLINK-5247] Fix incorrect check in allowedLateness() met...

2017-01-05 Thread mindprince
Github user mindprince commented on the issue: https://github.com/apache/flink/pull/2929 Thanks for the review @kl0u I didn't do it because there was no logger defined in the file. --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request #3071: [FLINK-5417][DOCUMENTATION]correct the wrong confi...

2017-01-05 Thread WangTaoTheTonic
GitHub user WangTaoTheTonic opened a pull request: https://github.com/apache/flink/pull/3071 [FLINK-5417][DOCUMENTATION]correct the wrong config file name As the config file name is conf/flink-conf.yaml, the usage "conf/flink-config.yaml" in document is wrong and easy to confuse

[jira] [Commented] (FLINK-5417) Fix the wrong config file name

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15803507#comment-15803507 ] ASF GitHub Bot commented on FLINK-5417: --- GitHub user WangTaoTheTonic opened a pull request:

[jira] [Created] (FLINK-5417) Fix the wrong config file name

2017-01-05 Thread Tao Wang (JIRA)
Tao Wang created FLINK-5417: --- Summary: Fix the wrong config file name Key: FLINK-5417 URL: https://issues.apache.org/jira/browse/FLINK-5417 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-5414) Bump up Calcite version to 1.11

2017-01-05 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15803390#comment-15803390 ] Jark Wu commented on FLINK-5414: Unfortunately, FLINK-4864 is not only blocked by CALCITE-1461 which is

[jira] [Assigned] (FLINK-5414) Bump up Calcite version to 1.11

2017-01-05 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-5414: -- Assignee: Jark Wu > Bump up Calcite version to 1.11 > --- > >

[GitHub] flink issue #3039: [FLINK-5280] Update TableSource to support nested data

2017-01-05 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/3039 I'm fine with removing `getFieldNames` and `getFieldIndices`. The way of Scala trait is too hard to implement a custom `TableSource` for Java users who do not know this trick. --- If your project

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

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15803367#comment-15803367 ] ASF GitHub Bot commented on FLINK-5280: --- Github user wuchong commented on the issue:

[GitHub] flink issue #3054: [Flink 5404] Consolidate and update S3 documentation

2017-01-05 Thread medale
Github user medale commented on the issue: https://github.com/apache/flink/pull/3054 @tzulitai thank you for the feedback and catching those stylistic elements! I made the changes and recommitted. --- If your project is set up for it, you can reply to this email and have your reply

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

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15803228#comment-15803228 ] ASF GitHub Bot commented on FLINK-5084: --- Github user mtunique commented on the issue:

[GitHub] flink issue #2977: [FLINK-5084] Replace Java Table API integration tests by ...

2017-01-05 Thread mtunique
Github user mtunique commented on the issue: https://github.com/apache/flink/pull/2977 @fhueske I have finished all about comments and rebase. --- 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

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

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802831#comment-15802831 ] 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

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802830#comment-15802830 ] 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

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802829#comment-15802829 ] 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...

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r94872463 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/CalcITCase.scala --- @@ -109,36 +110,6 @@ class CalcITCase(

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

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r94872519 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/SortValidationTest.scala --- @@ -0,0 +1,52 @@ +/* + *

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

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2977#discussion_r94871520 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/SortValidationTest.scala --- @@ -0,0 +1,52 @@ +/* + *

[jira] [Assigned] (FLINK-5407) Savepoint for iterative Task fails.

2017-01-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-5407: - Assignee: Stefan Richter > Savepoint for iterative Task fails. >

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

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802752#comment-15802752 ] ASF GitHub Bot commented on FLINK-5280: --- Github user mushketyk commented on the issue:

[GitHub] flink issue #3039: [FLINK-5280] Update TableSource to support nested data

2017-01-05 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/3039 Hi @fhueske, @wuchong I think we can solve the problem with current `TableSource` class hierarchy in a different way. If we remove all abstract classes and move all default

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

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802730#comment-15802730 ] ASF GitHub Bot commented on FLINK-5280: --- Github user mushketyk commented on a diff in the pull

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-05 Thread mushketyk
Github user mushketyk commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r94865876 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/AbstractBatchStreamTableSource.scala --- @@ -0,0 +1,30 @@ +/*

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

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

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

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

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

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

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

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

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

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

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r94856759 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/FlinkRel.scala --- @@ -120,6 +124,7 @@ trait FlinkRel {

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

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

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r94853135 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/CommonTestData.scala --- @@ -60,4 +67,52 @@ object CommonTestData {

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r94858739 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -535,4 +511,92 @@ object TableEnvironment {

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r94851171 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala --- @@ -19,21 +19,28 @@ package

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

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

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

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

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

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

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r94859631 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -535,4 +511,92 @@ object TableEnvironment {

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r94851899 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/AbstractBatchStreamTableSource.scala --- @@ -0,0 +1,30 @@ +/* +

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r94852514 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/batch/TableSourceITCase.java --- @@ -92,4 +90,25 @@ public void

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r94859657 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala --- @@ -535,4 +511,92 @@ object TableEnvironment {

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-05 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r94857414 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -31,7 +31,7 @@ import

[jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2017-01-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2662: - Fix Version/s: (was: 1.1.4) > CompilerException: "Bug: Plan generation for Unions picked a

[jira] [Reopened] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2017-01-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-2662: -- Another special case of this was reported. > CompilerException: "Bug: Plan generation for Unions

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2017-01-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802575#comment-15802575 ] Fabian Hueske commented on FLINK-2662: -- Thanks! This seems to be a never ending story with many

[jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2017-01-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2662: - Fix Version/s: 1.1.5 1.3.0 > CompilerException: "Bug: Plan generation for

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2017-01-05 Thread Yassine Marzougui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802570#comment-15802570 ] Yassine Marzougui commented on FLINK-2662: -- 1.3-SNAPSHOT (Commit: 6ac5794) > CompilerException:

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2017-01-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802562#comment-15802562 ] Fabian Hueske commented on FLINK-2662: -- Which version? > CompilerException: "Bug: Plan generation

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2017-01-05 Thread Yassine Marzougui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802548#comment-15802548 ] Yassine Marzougui commented on FLINK-2662: -- I came across this bug again with the following code:

[jira] [Resolved] (FLINK-4967) RockDB state backend fails on Windows

2017-01-05 Thread Yassine Marzougui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui resolved FLINK-4967. -- Resolution: Resolved > RockDB state backend fails on Windows >

[jira] [Commented] (FLINK-4967) RockDB state backend fails on Windows

2017-01-05 Thread Yassine Marzougui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802523#comment-15802523 ] Yassine Marzougui commented on FLINK-4967: -- Just checked it for the 1.2 and confirm the rocksdb

[jira] [Updated] (FLINK-4967) RockDB state backend fails on Windows

2017-01-05 Thread Yassine Marzougui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-4967: - Fix Version/s: 1.2.0 > RockDB state backend fails on Windows >

[jira] [Updated] (FLINK-5407) Savepoint for iterative Task fails.

2017-01-05 Thread Yassine Marzougui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yassine Marzougui updated FLINK-5407: - Attachment: SavepointBug.java I attached a simplified version of the job reproducing the

[jira] [Commented] (FLINK-5397) Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802500#comment-15802500 ] ASF GitHub Bot commented on FLINK-5397: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph()

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802499#comment-15802499 ] ASF GitHub Bot commented on FLINK-5390: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3045: [FLINK-5390] [yarn] Fix for proper closing input a...

2017-01-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3045 --- 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

[GitHub] flink pull request #3050: [FLINK-5397] Do not replace ObjectStreamClass on d...

2017-01-05 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3050 --- 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

[jira] [Commented] (FLINK-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown()

2017-01-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802384#comment-15802384 ] Ted Yu commented on FLINK-5391: --- Make sense to me. > Unprotected access to shutdown in

[jira] [Commented] (FLINK-5400) Add accessor to folding states in RuntimeContext

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802334#comment-15802334 ] ASF GitHub Bot commented on FLINK-5400: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3053: [FLINK-5400] Add accessor to folding states in RuntimeCon...

2017-01-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3053 Looks good to me, merging 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 project does not have this feature

[jira] [Commented] (FLINK-5399) Add more information to checkpoint result of TriggerSavepointSuccess

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802324#comment-15802324 ] ASF GitHub Bot commented on FLINK-5399: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3051: [FLINK-5399] Add more information to checkpoint result of...

2017-01-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3051 I think this is good, merging 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 project does not have this feature

[jira] [Resolved] (FLINK-5408) RocksDB initialization can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5408. - Resolution: Fixed Fixed in - 1.2.0 via 91f9a1acaa899159a0d907528634bd246e6854b4 - 1.3.0 via

[jira] [Closed] (FLINK-5408) RocksDB initialization can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5408. --- > RocksDB initialization can fail with an UnsatisfiedLinkError in the presence > of multiple

[jira] [Commented] (FLINK-5397) Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802304#comment-15802304 ] Stephan Ewen commented on FLINK-5397: - Fixed in 1.2 via 3554c96d118a411906a22b1f1087de073617a4c7 >

[jira] [Commented] (FLINK-5395) support locally build distribution by script create_release_files.sh

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802301#comment-15802301 ] ASF GitHub Bot commented on FLINK-5395: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3049: [FLINK-5395] [Build System] support locally build distrib...

2017-01-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3049 Thank you for this contribution. Looks good at a first glance. Would be good if @uce or @rmetzger could take a look, they worked mostly with the release script. --- If your project is

[jira] [Closed] (FLINK-5392) flink-dist build failed when change scala version to 2.11

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5392. --- > flink-dist build failed when change scala version to 2.11 >

[jira] [Resolved] (FLINK-5392) flink-dist build failed when change scala version to 2.11

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5392. - Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in - 1.2.0 via

[GitHub] flink issue #3043: [FLINK-5392] flink-dist build failed when change scala ve...

2017-01-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3043 Thank you for creating this fix. I think this has already been subsumed by this commit https://github.com/apache/flink/commit/1358753dd9b830034593902531ed30e5557644f0 Does this

[jira] [Commented] (FLINK-5392) flink-dist build failed when change scala version to 2.11

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802289#comment-15802289 ] ASF GitHub Bot commented on FLINK-5392: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown()

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802278#comment-15802278 ] Stephan Ewen commented on FLINK-5391: - I think the access in that method is okay, there is nothing

[jira] [Commented] (FLINK-5391) Unprotected access to shutdown in AbstractNonHaServices#checkNotShutdown()

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802280#comment-15802280 ] Stephan Ewen commented on FLINK-5391: - What do you think [~tedyu] > Unprotected access to shutdown in

[jira] [Commented] (FLINK-5389) Fails #testAnswerFailureWhenSavepointReadFails

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802250#comment-15802250 ] Stephan Ewen commented on FLINK-5389: - Why not simply remove the timeout? Is there any benefit of

[jira] [Commented] (FLINK-5390) input should be closed in finally block in YarnFlinkApplicationMasterRunner#loadJobGraph()

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802256#comment-15802256 ] ASF GitHub Bot commented on FLINK-5390: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3045: [FLINK-5390] [yarn] Fix for proper closing input and outp...

2017-01-05 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3045 I think this is good, merging 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 project does not have this feature

[jira] [Commented] (FLINK-5387) Lightweight Event Time Window

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802246#comment-15802246 ] Stephan Ewen commented on FLINK-5387: - There have been a few discussions about aligned windows and

[jira] [Commented] (FLINK-5119) Last taskmanager heartbeat not showing in web frontend

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802052#comment-15802052 ] ASF GitHub Bot commented on FLINK-5119: --- GitHub user sachingoel0101 opened a pull request:

[GitHub] flink pull request #3070: [FLINK-5119][web-frontend] Fix problems in display...

2017-01-05 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/3070 [FLINK-5119][web-frontend] Fix problems in displaying TM heartbeat and path You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-5178) allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15801974#comment-15801974 ] ASF GitHub Bot commented on FLINK-5178: --- Github user NicoK commented on the issue:

[jira] [Commented] (FLINK-5178) allow BLOB_STORAGE_DIRECTORY_KEY to point to a distributed file system

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15801975#comment-15801975 ] ASF GitHub Bot commented on FLINK-5178: --- Github user NicoK closed the pull request at:

[GitHub] flink issue #2911: [FLINK-5178] allow BLOB_STORAGE_DIRECTORY_KEY to point to...

2017-01-05 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/2911 I need to adapt a few things and choose a different approach - I'll re-open later --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request #2911: [FLINK-5178] allow BLOB_STORAGE_DIRECTORY_KEY to p...

2017-01-05 Thread NicoK
Github user NicoK closed the pull request at: https://github.com/apache/flink/pull/2911 --- 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

[jira] [Commented] (FLINK-5129) make the BlobServer use a distributed file system

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15801970#comment-15801970 ] ASF GitHub Bot commented on FLINK-5129: --- Github user NicoK commented on the issue:

[GitHub] flink issue #2891: [FLINK-5129] make the BlobServer use a distributed file s...

2017-01-05 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/2891 I need to adapt a few things and choose a different approach - I'll re-open later --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] flink pull request #2891: [FLINK-5129] make the BlobServer use a distributed...

2017-01-05 Thread NicoK
Github user NicoK closed the pull request at: https://github.com/apache/flink/pull/2891 --- 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

[jira] [Commented] (FLINK-5129) make the BlobServer use a distributed file system

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15801971#comment-15801971 ] ASF GitHub Bot commented on FLINK-5129: --- Github user NicoK closed the pull request at:

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

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15801939#comment-15801939 ] Stephan Ewen commented on FLINK-5383: - Reading up un SIGBUS - it seems to occur when mapping a file

[GitHub] flink pull request #3069: [FLINK-5381][web-frontend] Fix scrolling issues

2017-01-05 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/3069 [FLINK-5381][web-frontend] Fix scrolling issues This also fixes Flink-5359, Flink-5267. These should also be marked resolved. While working on this, I also observed scrolling issues on

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

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15801932#comment-15801932 ] ASF GitHub Bot commented on FLINK-5381: --- GitHub user sachingoel0101 opened a pull request:

[jira] [Commented] (FLINK-5416) Function wrappers should support CheckpointedFunction

2017-01-05 Thread Eron Wright (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15801847#comment-15801847 ] Eron Wright commented on FLINK-5416: - To fix it, the wrapper would assumedly implement

[jira] [Closed] (FLINK-5393) Apache flink for IOT

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5393. --- Resolution: Invalid > Apache flink for IOT > > > Key: FLINK-5393

[jira] [Commented] (FLINK-5393) Apache flink for IOT

2017-01-05 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15801843#comment-15801843 ] Stephan Ewen commented on FLINK-5393: - I think this would be a question for the

[jira] [Created] (FLINK-5416) Function wrappers should support CheckpointedFunction

2017-01-05 Thread Eron Wright (JIRA)
Eron Wright created FLINK-5416: --- Summary: Function wrappers should support CheckpointedFunction Key: FLINK-5416 URL: https://issues.apache.org/jira/browse/FLINK-5416 Project: Flink Issue

[GitHub] flink issue #2442: [FLINK-4148] incorrect calculation minDist distance in Qu...

2017-01-05 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2442 I'm sorry, I completely forgot about this one. I will merge it with the next batch. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Commented] (FLINK-4148) incorrect calculation distance in QuadTree

2017-01-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15801838#comment-15801838 ] ASF GitHub Bot commented on FLINK-4148: --- Github user zentol commented on the issue:

[GitHub] flink issue #3052: Swap the pattern matching order

2017-01-05 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3052 There is already a PR open for this issue (see #2442), could you please close this one? Thanks to you I found the other though, appreciate it ;) --- If your project is set up for it,

[jira] [Created] (FLINK-5415) ContinuousFileProcessingTest failed on travis

2017-01-05 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5415: --- Summary: ContinuousFileProcessingTest failed on travis Key: FLINK-5415 URL: https://issues.apache.org/jira/browse/FLINK-5415 Project: Flink Issue

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

2017-01-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5380: Fix Version/s: 1.3.0 1.2.0 > Number of outgoing records not reported in

  1   2   3   >