[jira] [Comment Edited] (FLINK-7799) Improve performance of windowed joins

2017-10-15 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16204554#comment-16204554 ] Xingcan Cui edited comment on FLINK-7799 at 10/15/17 8:11 AM: --

[jira] [Reopened] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website

2017-10-15 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reopened FLINK-7686: --- > Add Flink Forward Berlin 2017 conference slides to the flink website > -

[jira] [Commented] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website

2017-10-15 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205062#comment-16205062 ] Hai Zhou UTC+8 commented on FLINK-7686: --- PR : [Update community.md|https://github.co

[jira] [Created] (FLINK-7843) Improve and enhance documentation for system metrics

2017-10-15 Thread Hai Zhou UTC+8 (JIRA)
Hai Zhou UTC+8 created FLINK-7843: - Summary: Improve and enhance documentation for system metrics Key: FLINK-7843 URL: https://issues.apache.org/jira/browse/FLINK-7843 Project: Flink Issue Ty

[jira] [Updated] (FLINK-7021) Flink Task Manager hangs on startup if one Zookeeper node is unresolvable

2017-10-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7021: Fix Version/s: 1.4.0 > Flink Task Manager hangs on startup if one Zookeeper node is unresolv

[jira] [Updated] (FLINK-7021) Flink Task Manager hangs on startup if one Zookeeper node is unresolvable

2017-10-15 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7021: Priority: Blocker (was: Major) > Flink Task Manager hangs on startup if one Zookeeper node

[jira] [Closed] (FLINK-6684) Remove AsyncCheckpointRunnable from StreamTask

2017-10-15 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-6684. --- Resolution: Invalid > Remove AsyncCheckpointRunnable from StreamTask > ---

[jira] [Commented] (FLINK-6615) tmp directory not cleaned up on shutdown

2017-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205092#comment-16205092 ] ASF GitHub Bot commented on FLINK-6615: --- Github user bowenli86 commented on the issu

[GitHub] flink issue #4787: [FLINK-6615][core] simplify FileUtils

2017-10-15 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4787 @StephanEwen Thanks for letting me know. I'll close this PR ---

[jira] [Commented] (FLINK-6615) tmp directory not cleaned up on shutdown

2017-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205093#comment-16205093 ] ASF GitHub Bot commented on FLINK-6615: --- Github user bowenli86 closed the pull reque

[GitHub] flink pull request #4787: [FLINK-6615][core] simplify FileUtils

2017-10-15 Thread bowenli86
Github user bowenli86 closed the pull request at: https://github.com/apache/flink/pull/4787 ---

[GitHub] flink issue #4787: [FLINK-6615][core] simplify FileUtils

2017-10-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4787 @bowenli86 I hope you don't mind that I pushed back a bit. It's my job to be careful about such things... ---

[jira] [Commented] (FLINK-6615) tmp directory not cleaned up on shutdown

2017-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205123#comment-16205123 ] ASF GitHub Bot commented on FLINK-6615: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal)

2017-10-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205131#comment-16205131 ] Stephan Ewen commented on FLINK-2747: - One way we can fix this is by obeying the {{ena

[jira] [Commented] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

2017-10-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205136#comment-16205136 ] Stephan Ewen commented on FLINK-7737: - Okay, I think the root cause here is that {{hfl

[jira] [Assigned] (FLINK-7798) Add support for windowed joins to Table API

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7798: Assignee: Fabian Hueske (was: Xingcan Cui) > Add support for windowed joins to Table API >

[jira] [Assigned] (FLINK-7426) Table API does not support null values in keys

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7426: Assignee: Fabian Hueske (was: Timo Walther) > Table API does not support null values in ke

[jira] [Assigned] (FLINK-6584) Support multiple consecutive windows in SQL

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6584: Assignee: Fabian Hueske (was: Timo Walther) > Support multiple consecutive windows in SQL

[GitHub] flink issue #4471: [FLINK-6094] [table] Implement stream-stream proctime non...

2017-10-15 Thread hequn8128
Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/4471 @fhueske hi fabian, sorry for the late update, i will resolve the conflicts ASAP, a busy weekend :) ---

[jira] [Updated] (FLINK-7802) Exception occur when empty field collection was pushed into CSVTableSource

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7802: - Priority: Critical (was: Major) > Exception occur when empty field collection was pushed into CSV

[jira] [Commented] (FLINK-6094) Implement stream-stream proctime non-window inner join

2017-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205147#comment-16205147 ] ASF GitHub Bot commented on FLINK-6094: --- Github user hequn8128 commented on the issu

[GitHub] flink issue #4802: [FLINK-7791] [REST][client] Integrate LIST command into R...

2017-10-15 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4802 merging. ---

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

2017-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205149#comment-16205149 ] ASF GitHub Bot commented on FLINK-7791: --- Github user zentol commented on the issue:

[jira] [Updated] (FLINK-7051) Bump up Calcite version to 1.14

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7051: - Priority: Critical (was: Major) > Bump up Calcite version to 1.14 > -

[jira] [Assigned] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7371: Assignee: Fabian Hueske (was: Timo Walther) > user defined aggregator assumes nr of argume

[jira] [Updated] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7371: - Priority: Blocker (was: Major) > user defined aggregator assumes nr of arguments smaller or equal

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205157#comment-16205157 ] Fabian Hueske commented on FLINK-7730: -- This is mainly problem in Calcite (see [this

[jira] [Updated] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-7730: - Priority: Critical (was: Major) > TableFunction LEFT OUTER joins with ON predicates are broken >

[jira] [Updated] (FLINK-7679) Upgrade maven enforcer plugin to 3.0.0-M1

2017-10-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7679: -- Description: I got the following build error against Java 9: {code} [ERROR] Failed to execute goal org.apache.m

[jira] [Commented] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

2017-10-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205179#comment-16205179 ] Ted Yu commented on FLINK-7495: --- [~aljoscha]: Can you take a look ? > AbstractUdfStreamOper

[GitHub] flink pull request #4802: [FLINK-7791] [REST][client] Integrate LIST command...

2017-10-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4802 ---

[GitHub] flink pull request #4721: [FLINK-6703][savepoint/doc] Document how to take a...

2017-10-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4721 ---

[GitHub] flink pull request #4545: [FLINK-6805] [Cassandra-Connector] Shade indirect ...

2017-10-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4545 ---

[GitHub] flink pull request #4783: [FLINK-7774][network] fix not clearing deserialize...

2017-10-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4783 ---

[jira] [Commented] (FLINK-7774) Deserializers are not cleaned up when closing input streams

2017-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205194#comment-16205194 ] ASF GitHub Bot commented on FLINK-7774: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-7791) Integrate LIST command into REST client

2017-10-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7791. --- Resolution: Fixed 1.4: e572961749dd45e3f7444664d9ba967fa438ab55 & a76de2860d2ee78e673c97fba33

[jira] [Commented] (FLINK-6703) Document how to take a savepoint on YARN

2017-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205192#comment-16205192 ] ASF GitHub Bot commented on FLINK-6703: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

2017-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205193#comment-16205193 ] ASF GitHub Bot commented on FLINK-6805: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-7791) Integrate LIST command into REST client

2017-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205195#comment-16205195 ] ASF GitHub Bot commented on FLINK-7791: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-6805) Flink Cassandra connector dependency on Netty disagrees with Flink

2017-10-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6805. --- Resolution: Fixed 1.4: 81d7c4e8b111c6bf52000f68b64c402783a6ae74 > Flink Cassandra connector d

[jira] [Closed] (FLINK-7774) Deserializers are not cleaned up when closing input streams

2017-10-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7774. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 4b6f05585bb548d1538ada43ed33149acbc9e6d4 >

[jira] [Closed] (FLINK-6703) Document how to take a savepoint on YARN

2017-10-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6703. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 89394ec8094205cb3fd3a47a95dacd1b18c31088 >

[jira] [Assigned] (FLINK-7798) Add support for windowed joins to Table API

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7798: Assignee: Xingcan Cui (was: Fabian Hueske) > Add support for windowed joins to Table API >

[jira] [Assigned] (FLINK-7426) Table API does not support null values in keys

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7426: Assignee: Timo Walther (was: Fabian Hueske) > Table API does not support null values in ke

[jira] [Assigned] (FLINK-6584) Support multiple consecutive windows in SQL

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-6584: Assignee: Timo Walther (was: Fabian Hueske) > Support multiple consecutive windows in SQL

[jira] [Assigned] (FLINK-7371) user defined aggregator assumes nr of arguments smaller or equal than number of row fields

2017-10-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-7371: Assignee: Timo Walther (was: Fabian Hueske) > user defined aggregator assumes nr of argume

[GitHub] flink pull request #4827: [FLINK-7840] [build] Shade netty in akka

2017-10-15 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/4827 [FLINK-7840] [build] Shade netty in akka ## What is the purpose of the change This change shade's Akka's dependency on Netty away. **Note:** Akka itself cannot be shaded away, t

[jira] [Commented] (FLINK-7840) Shade Akka's Netty Dependency

2017-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205220#comment-16205220 ] ASF GitHub Bot commented on FLINK-7840: --- GitHub user StephanEwen opened a pull reque

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

2017-10-15 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205239#comment-16205239 ] Xingcan Cui commented on FLINK-7730: Thanks for the discussion, [~fhueske]. I've check

[jira] [Commented] (FLINK-7051) Bump up Calcite version to 1.14

2017-10-15 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205312#comment-16205312 ] Haohui Mai commented on FLINK-7051: --- I plan to work on it this week to make sure it happ

[jira] [Created] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

2017-10-15 Thread Zhenzhong Xu (JIRA)
Zhenzhong Xu created FLINK-7844: --- Summary: Fine Grained Recovery triggers checkpoint timeout failure Key: FLINK-7844 URL: https://issues.apache.org/jira/browse/FLINK-7844 Project: Flink Issue T

[jira] [Updated] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

2017-10-15 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-7844: Attachment: screenshot-1.png > Fine Grained Recovery triggers checkpoint timeout failure > -

[jira] [Updated] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

2017-10-15 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-7844: Description: Context: We are using "individual" failover (fine-grained) recovery strategy for our

[jira] [Updated] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

2017-10-15 Thread Zhenzhong Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenzhong Xu updated FLINK-7844: Description: Context: We are using "individual" failover (fine-grained) recovery strategy for our

[jira] [Commented] (FLINK-7525) Add config option to disable Cancel functionality on UI

2017-10-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16205358#comment-16205358 ] Ted Yu commented on FLINK-7525: --- Thanks for the feedback, Chesnay. > Add config option to d

[jira] [Updated] (FLINK-7642) Upgrade maven surefire plugin to 2.19.1

2017-10-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7642: -- Description: Surefire 2.19 release introduced more useful test filters which would let us run a subset of the t