[GitHub] [flink] zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284687035 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284689769 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284697765 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284695496 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284689364 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284684706 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284689201 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284697592 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284695717 ## File path:

[jira] [Assigned] (FLINK-11560) Translate "Flink Applications" page into Chinese

2019-05-16 Thread Zhou Yumin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhou Yumin reassigned FLINK-11560: -- Assignee: Zhou Yumin > Translate "Flink Applications" page into Chinese >

[GitHub] [flink] zhuzhurk commented on a change in pull request #8430: [FLINK-12068] [runtime] Backtrack failover regions if intermediate results are unavailable

2019-05-16 Thread GitBox
zhuzhurk commented on a change in pull request #8430: [FLINK-12068] [runtime] Backtrack failover regions if intermediate results are unavailable URL: https://github.com/apache/flink/pull/8430#discussion_r284602469 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8430: [FLINK-12068] [runtime] Backtrack failover regions if intermediate results are unavailable

2019-05-16 Thread GitBox
zhuzhurk commented on a change in pull request #8430: [FLINK-12068] [runtime] Backtrack failover regions if intermediate results are unavailable URL: https://github.com/apache/flink/pull/8430#discussion_r284684306 ## File path:

[GitHub] [flink] dianfu commented on issue #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
dianfu commented on issue #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#issuecomment-493052179 @WeiZhong94 Thanks a lot for the updated. LGTM. +1 to merge.

[GitHub] [flink] zhuzhurk commented on a change in pull request #8430: [FLINK-12068] [runtime] Backtrack failover regions if intermediate results are unavailable

2019-05-16 Thread GitBox
zhuzhurk commented on a change in pull request #8430: [FLINK-12068] [runtime] Backtrack failover regions if intermediate results are unavailable URL: https://github.com/apache/flink/pull/8430#discussion_r284599683 ## File path:

[GitHub] [flink] dianfu edited a comment on issue #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
dianfu edited a comment on issue #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#issuecomment-493052179 @WeiZhong94 Thanks a lot for the update. LGTM. +1 to merge.

[jira] [Updated] (FLINK-12512) TableSourceTest#testNestedProject test failed

2019-05-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12512: - Priority: Critical (was: Major) > TableSourceTest#testNestedProject test failed >

[jira] [Updated] (FLINK-12512) TableSourceTest#testNestedProject test failed

2019-05-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12512: - Issue Type: Bug (was: Improvement) > TableSourceTest#testNestedProject test failed >

[jira] [Updated] (FLINK-12512) TableSourceTest#testNestedProject test failed

2019-05-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12512: - Priority: Blocker (was: Critical) > TableSourceTest#testNestedProject test failed >

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284682569 ## File path: flink-python/pyflink/table/table_environment.py ## @@ -153,9

[GitHub] [flink] flinkbot edited a comment on issue #8465: [FLINK-12534][travis][python] Reduce the test cost for Python API

2019-05-16 Thread GitBox
flinkbot edited a comment on issue #8465: [FLINK-12534][travis][python] Reduce the test cost for Python API URL: https://github.com/apache/flink/pull/8465#issuecomment-493037224 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] sunjincheng121 commented on issue #8465: [FLINK-12534][travis][python] Reduce the test cost for Python API

2019-05-16 Thread GitBox
sunjincheng121 commented on issue #8465: [FLINK-12534][travis][python] Reduce the test cost for Python API URL: https://github.com/apache/flink/pull/8465#issuecomment-493047188 @flinkbot attention @zentol This is an

[GitHub] [flink] zzchun edited a comment on issue #8372: [FLINK-12354] [table] Add REVERSE function for table/sql API

2019-05-16 Thread GitBox
zzchun edited a comment on issue #8372: [FLINK-12354] [table] Add REVERSE function for table/sql API URL: https://github.com/apache/flink/pull/8372#issuecomment-492262212 cc @xccui @twalthr @fhueske , can you help me to review this MR, thank you.

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284678324 ## File path: flink-python/pyflink/table/table_config.py ## @@ -38,24 +44,76 @@

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284678283 ## File path: flink-python/pyflink/table/table_config.py ## @@ -38,24 +44,76 @@

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284678079 ## File path: flink-python/pyflink/table/table.py ## @@ -96,16 +105,413 @@ def

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284678208 ## File path: flink-python/pyflink/table/table.py ## @@ -96,16 +105,413 @@ def

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284678253 ## File path: flink-python/pyflink/table/table.py ## @@ -96,16 +105,413 @@ def

[GitHub] [flink] WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
WeiZhong94 commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284678155 ## File path: flink-python/pyflink/table/query_config.py ## @@ -0,0 +1,112 @@

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284670894 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284655543 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284672498 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284667951 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284656335 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284660153 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284667365 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284672050 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284668096 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284658421 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment

2019-05-16 Thread GitBox
zentol commented on a change in pull request #8416: [FLINK-12331] Introduce partition/gate setup to decouple task registration with NetworkEnvironment URL: https://github.com/apache/flink/pull/8416#discussion_r284659459 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks URL: https://github.com/apache/flink/pull/8442#discussion_r284674239 ## File path:

[jira] [Commented] (FLINK-12303) Scala 2.12 lambdas does not work in event classes inside streams.

2019-05-16 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841258#comment-16841258 ] Aljoscha Krettek commented on FLINK-12303: -- Hi [~snilard], yes you're right, this wasn't the

[GitHub] [flink] dawidwys commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs

2019-05-16 Thread GitBox
dawidwys commented on a change in pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs URL: https://github.com/apache/flink/pull/8404#discussion_r284671140 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks URL: https://github.com/apache/flink/pull/8442#discussion_r284670626 ## File path:

[GitHub] [flink] zentol commented on issue #8414: [FLINK-12477][Build] Enforce maven version 3.1.1

2019-05-16 Thread GitBox
zentol commented on issue #8414: [FLINK-12477][Build] Enforce maven version 3.1.1 URL: https://github.com/apache/flink/pull/8414#issuecomment-493037451 Finally you also have to update the ` cron-master-maven_compat` branch to no longer check for maven 3.0.X compatibility

[jira] [Updated] (FLINK-12534) Reduce the test cost for Python API

2019-05-16 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12534: --- Labels: pull-request-available (was: ) > Reduce the test cost for Python API >

[GitHub] [flink] flinkbot commented on issue #8465: [FLINK-12534][travis][python] Reduce the test cost for Python API

2019-05-16 Thread GitBox
flinkbot commented on issue #8465: [FLINK-12534][travis][python] Reduce the test cost for Python API URL: https://github.com/apache/flink/pull/8465#issuecomment-493037224 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] WeiZhong94 opened a new pull request #8465: [FLINK-12534][travis][python] Reduce the test cost for Python API

2019-05-16 Thread GitBox
WeiZhong94 opened a new pull request #8465: [FLINK-12534][travis][python] Reduce the test cost for Python API URL: https://github.com/apache/flink/pull/8465 ## What is the purpose of the change *This pull request removes all jars except flink-dist.jar, flink-table.jar and

[jira] [Commented] (FLINK-12384) Rolling the etcd servers causes "Connected to an old server; r-o mode will be unavailable"

2019-05-16 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841245#comment-16841245 ] Gary Yao commented on FLINK-12384: -- If you are running ZK behind an LB, there are additional

[GitHub] [flink] StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks URL: https://github.com/apache/flink/pull/8442#discussion_r284669437 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks URL: https://github.com/apache/flink/pull/8442#discussion_r284668961 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks URL: https://github.com/apache/flink/pull/8442#discussion_r284668779 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks URL: https://github.com/apache/flink/pull/8442#discussion_r284668589 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks URL: https://github.com/apache/flink/pull/8442#discussion_r284668074 ## File path:

[jira] [Updated] (FLINK-12039) Remove ASSIGNED_SLOT_UPDATER in Execution.tryAssignResource

2019-05-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-12039: - Priority: Minor (was: Major) > Remove ASSIGNED_SLOT_UPDATER in Execution.tryAssignResource >

[jira] [Comment Edited] (FLINK-12384) Rolling the etcd servers causes "Connected to an old server; r-o mode will be unavailable"

2019-05-16 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841209#comment-16841209 ] Gary Yao edited comment on FLINK-12384 at 5/16/19 11:49 AM: [~haf] I checked

[jira] [Updated] (FLINK-12528) Remove progressLock in ExecutionGraph

2019-05-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-12528: - Priority: Minor (was: Major) > Remove progressLock in ExecutionGraph >

[GitHub] [flink] StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8442: [FLINK-12483] Support (legacy) SourceFunction as special case in the mailbox model for stream tasks URL: https://github.com/apache/flink/pull/8442#discussion_r284667461 ## File path:

[jira] [Updated] (FLINK-12527) Remove GLOBAL_VERSION_UPDATER in ExecutionGraph

2019-05-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-12527: - Priority: Minor (was: Major) > Remove GLOBAL_VERSION_UPDATER in ExecutionGraph >

[jira] [Commented] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

2019-05-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841244#comment-16841244 ] vinoyang commented on FLINK-10855: -- OK [~till.rohrmann] thanks. [~richtesn] can you still want to be my

[jira] [Commented] (FLINK-12526) Remove STATE_UPDATER in ExecutionGraph

2019-05-16 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841243#comment-16841243 ] vinoyang commented on FLINK-12526: -- [~till.rohrmann] OK, thanks for the notice, I have not started it.

[GitHub] [flink] StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409#discussion_r284665683 ## File path:

[GitHub] [flink] StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409#discussion_r284664043 ## File path:

[jira] [Commented] (FLINK-5621) Flink should provide a mechanism to prevent scheduling tasks on TaskManagers with operational issues

2019-05-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841238#comment-16841238 ] Till Rohrmann commented on FLINK-5621: -- I think this issue is tightly related to a general

[GitHub] [flink] StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa…

2019-05-16 Thread GitBox
StefanRRichter commented on a change in pull request #8409: [FLINK-12478] Decompose monolithic run-loops in StreamTask implementa… URL: https://github.com/apache/flink/pull/8409#discussion_r284663084 ## File path:

[jira] [Commented] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

2019-05-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841233#comment-16841233 ] Till Rohrmann commented on FLINK-10855: --- I guess that a regular clean up task could do the trick

[jira] [Commented] (FLINK-12526) Remove STATE_UPDATER in ExecutionGraph

2019-05-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841232#comment-16841232 ] Till Rohrmann commented on FLINK-12526: --- Let's do it step by step and only change the

[jira] [Updated] (FLINK-12526) Remove STATE_UPDATER in ExecutionGraph

2019-05-16 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-12526: -- Priority: Minor (was: Major) > Remove STATE_UPDATER in ExecutionGraph >

[jira] [Updated] (FLINK-12476) [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

2019-05-16 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-12476: Description: At the moment we have two efficient background cleanup strategies: 

[jira] [Updated] (FLINK-12476) [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

2019-05-16 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-12476: Description: At the moment we have two efficient background cleanup strategies: 

[GitHub] [flink] aljoscha commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

2019-05-16 Thread GitBox
aljoscha commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#discussion_r284659324 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

2019-05-16 Thread GitBox
azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#discussion_r284658756 ## File path:

[GitHub] [flink] zhijiangW commented on issue #8428: [FLINK-12497][network] Refactor the start method of ConnectionManager

2019-05-16 Thread GitBox
zhijiangW commented on issue #8428: [FLINK-12497][network] Refactor the start method of ConnectionManager URL: https://github.com/apache/flink/pull/8428#issuecomment-493024930 Thanks for the review @azagrebin ! This is an

[jira] [Commented] (FLINK-12384) Rolling the etcd servers causes "Connected to an old server; r-o mode will be unavailable"

2019-05-16 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841209#comment-16841209 ] Gary Yao commented on FLINK-12384: -- [~haf] I checked the ZK client code and the warning is not

[jira] [Commented] (FLINK-12533) Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

2019-05-16 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841207#comment-16841207 ] sunjincheng commented on FLINK-12533: - +1 for this change! [~hequn8128] > Introduce

[jira] [Assigned] (FLINK-12534) Reduce the test cost for Python API

2019-05-16 Thread Wei Zhong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong reassigned FLINK-12534: - Assignee: Wei Zhong > Reduce the test cost for Python API >

[jira] [Created] (FLINK-12534) Reduce the test cost for Python API

2019-05-16 Thread sunjincheng (JIRA)
sunjincheng created FLINK-12534: --- Summary: Reduce the test cost for Python API Key: FLINK-12534 URL: https://issues.apache.org/jira/browse/FLINK-12534 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12533) Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type

2019-05-16 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-12533: --- Summary: Introduce TABLE_AGGREGATE_FUNCTION FunctionDefinition.Type Key: FLINK-12533 URL: https://issues.apache.org/jira/browse/FLINK-12533 Project: Flink

[jira] [Created] (FLINK-12532) Upgrade Avro to version 1.9.0

2019-05-16 Thread JIRA
Ismaël Mejía created FLINK-12532: Summary: Upgrade Avro to version 1.9.0 Key: FLINK-12532 URL: https://issues.apache.org/jira/browse/FLINK-12532 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on issue #8428: [FLINK-12497][network] Refactor the start method of ConnectionManager

2019-05-16 Thread GitBox
flinkbot edited a comment on issue #8428: [FLINK-12497][network] Refactor the start method of ConnectionManager URL: https://github.com/apache/flink/pull/8428#issuecomment-491750033 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] azagrebin commented on issue #8428: [FLINK-12497][network] Refactor the start method of ConnectionManager

2019-05-16 Thread GitBox
azagrebin commented on issue #8428: [FLINK-12497][network] Refactor the start method of ConnectionManager URL: https://github.com/apache/flink/pull/8428#issuecomment-493004991 @flinkbot approve all This is an automated

[GitHub] [flink] azagrebin commented on a change in pull request #8428: [FLINK-12497][network] Refactor the start method of ConnectionManager

2019-05-16 Thread GitBox
azagrebin commented on a change in pull request #8428: [FLINK-12497][network] Refactor the start method of ConnectionManager URL: https://github.com/apache/flink/pull/8428#discussion_r284632408 ## File path:

[GitHub] [flink] flinkbot commented on issue #8464: [hotfix] fix typos.

2019-05-16 Thread GitBox
flinkbot commented on issue #8464: [hotfix] fix typos. URL: https://github.com/apache/flink/pull/8464#issuecomment-493004237 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to

[GitHub] [flink] mr-cloud opened a new pull request #8464: [hotfix] fix typos.

2019-05-16 Thread GitBox
mr-cloud opened a new pull request #8464: [hotfix] fix typos. URL: https://github.com/apache/flink/pull/8464 1. [flink-core] below -> above in TypeInformation methods 2. [flink-streaming-java] CLusterUtil -> ClusterUtil in LocalStreamEnvironment methods ## What is the

[jira] [Closed] (FLINK-10466) flink-yarn-tests should depend flink-dist

2019-05-16 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10466. Resolution: Fixed Fix Version/s: 1.9.0 master:

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

2019-05-16 Thread GitBox
eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r284630476 ## File path:

[GitHub] [flink] zentol merged pull request #8398: [FLINK-10466][build] Add flink-dist dependency to yarn-test

2019-05-16 Thread GitBox
zentol merged pull request #8398: [FLINK-10466][build] Add flink-dist dependency to yarn-test URL: https://github.com/apache/flink/pull/8398 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284618858 ## File path: flink-python/pyflink/table/table_config.py ## @@ -38,24 +44,76 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284615878 ## File path: flink-python/pyflink/table/table.py ## @@ -96,16 +105,413 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284617719 ## File path: flink-python/pyflink/table/table_config.py ## @@ -38,24 +44,76 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284612580 ## File path: flink-python/pyflink/table/query_config.py ## @@ -0,0 +1,112 @@

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284615491 ## File path: flink-python/pyflink/table/table.py ## @@ -96,16 +105,413 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284622626 ## File path: flink-python/pyflink/table/table_environment.py ## @@ -153,9 +240,51

[GitHub] [flink] dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API.

2019-05-16 Thread GitBox
dianfu commented on a change in pull request #8401: [FLINK-12407][python] Add all table operators align Java Table API. URL: https://github.com/apache/flink/pull/8401#discussion_r284614157 ## File path: flink-python/pyflink/table/table.py ## @@ -96,16 +105,413 @@ def

[GitHub] [flink] flinkbot edited a comment on issue #8398: [FLINK-10466][build] Add flink-dist dependency to yarn-test

2019-05-16 Thread GitBox
flinkbot edited a comment on issue #8398: [FLINK-10466][build] Add flink-dist dependency to yarn-test URL: https://github.com/apache/flink/pull/8398#issuecomment-491180514 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] azagrebin commented on issue #8398: [FLINK-10466][build] Add flink-dist dependency to yarn-test

2019-05-16 Thread GitBox
azagrebin commented on issue #8398: [FLINK-10466][build] Add flink-dist dependency to yarn-test URL: https://github.com/apache/flink/pull/8398#issuecomment-492999241 @flinkbot approve all This is an automated message from

[jira] [Updated] (FLINK-12530) Move Task.inputGatesById to NetworkEnvironment

2019-05-16 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-12530: Summary: Move Task.inputGatesById to NetworkEnvironment (was: Move Task#inputGatesById

[GitHub] [flink] yanghua commented on issue #8461: [FLINK-12422] Remove IN_TESTS for make test code and production code consistent

2019-05-16 Thread GitBox
yanghua commented on issue #8461: [FLINK-12422] Remove IN_TESTS for make test code and production code consistent URL: https://github.com/apache/flink/pull/8461#issuecomment-492994671 cc @tillrohrmann This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment

2019-05-16 Thread GitBox
flinkbot edited a comment on issue #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment URL: https://github.com/apache/flink/pull/8463#issuecomment-492991609 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] azagrebin commented on issue #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment

2019-05-16 Thread GitBox
azagrebin commented on issue #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment URL: https://github.com/apache/flink/pull/8463#issuecomment-492992119 @flinkbot attention @zhijiangW This is an

[GitHub] [flink] flinkbot commented on issue #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment

2019-05-16 Thread GitBox
flinkbot commented on issue #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment URL: https://github.com/apache/flink/pull/8463#issuecomment-492991609 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

<    1   2   3   4   5   >