[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539467530 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6 URL: https://github.com/apache/flink/pull/9906#issuecomment-542230286 ## CI report: * dd8cbf2ca3d1515420b09362d0a2df938208c2eb : SU

[GitHub] [flink] TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-17 Thread GitBox
TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-543040002 Since we fence different leader epoch with different Dispatcher instance, I think `waitForTerminatingJobManager` should be on

[GitHub] [flink] flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537039262 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[GitHub] [flink] TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-17 Thread GitBox
TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-543040672 > Since we fence different leader epoch with different Dispatcher instance, I think `waitForTerminatingJobManager` should be

[GitHub] [flink] flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537039262 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335831094 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335823155 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335839358 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335825685 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335835438 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335838306 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335822784 ## File path: flink-python/pyflink/table/environment_settings.py ## @@ -

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335833796 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335841309 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335825962 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335831867 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335827352 ## File path: flink-python/pyflink/testing/test_case_utils.py ## @@ -149

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335832432 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335827393 ## File path: flink-python/pyflink/testing/test_case_utils.py ## @@ -149

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335836806 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335840910 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335825863 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335836443 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335836969 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] flinkbot edited a comment on issue #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#issuecomment-541416833 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the comm

[GitHub] [flink] flinkbot edited a comment on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build URL: https://github.com/apache/flink/pull/9783#issuecomment-535848177 ## CI report: * 5d9e3113e10bbf0220b4f8e080ecd1cddd9c9059 : FAILURE [Build](http

[GitHub] [flink] ifndef-SleePy commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

2019-10-17 Thread GitBox
ifndef-SleePy commented on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-543044286 Hi @pnowojski , thanks for feedback. I have updated the PR to address review comments, except the comm

[jira] [Commented] (FLINK-14364) Allow comments fail when not ignore parse errors in CsvRowDeserializationSchema

2019-10-17 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953467#comment-16953467 ] Timo Walther commented on FLINK-14364: -- [~wind_ljy] we can also use {{objectReader.

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539467530 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335838306 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539472188 ## CI report: * b10f5603fc55999adb8d5334a3d142d20322de5b : SUCCESS [Build](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6 URL: https://github.com/apache/flink/pull/9906#issuecomment-542230286 ## CI report: * dd8cbf2ca3d1515420b09362d0a2df938208c2eb : SU

[jira] [Closed] (FLINK-14427) 批流融合

2019-10-17 Thread qinkaixin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qinkaixin closed FLINK-14427. - Resolution: Fixed > 批流融合 > > > Key: FLINK-14427 > URL: https://issu

[jira] [Created] (FLINK-14427) 批流融合

2019-10-17 Thread qinkaixin (Jira)
qinkaixin created FLINK-14427: - Summary: 批流融合 Key: FLINK-14427 URL: https://issues.apache.org/jira/browse/FLINK-14427 Project: Flink Issue Type: Improvement Environment: 批流融合

[GitHub] [flink] flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex URL: https://github.com/apache/flink/pull/9798#issuecomment-536254451 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revie

[GitHub] [flink] flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex URL: https://github.com/apache/flink/pull/9798#issuecomment-536254451 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revie

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539472188 ## CI report: * b10f5603fc55999adb8d5334a3d142d20322de5b : SUCCESS [Build](https://travis-ci.co

[jira] [Commented] (FLINK-11491) Support all TPC-DS queries

2019-10-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953478#comment-16953478 ] Kurt Young commented on FLINK-11491: I think sub-task-4 is unnecessary. For sub-task

[GitHub] [flink] flinkbot edited a comment on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6 URL: https://github.com/apache/flink/pull/9906#issuecomment-542230286 ## CI report: * dd8cbf2ca3d1515420b09362d0a2df938208c2eb : SU

[jira] [Updated] (FLINK-14428) Non-consistency key access in KeyedProcessFunction when use keyed state api in both processElement and onTimer method

2019-10-17 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-14428: - Summary: Non-consistency key access in KeyedProcessFunction when use keyed state api in both processElem

[jira] [Created] (FLINK-14428) Non-consistency key access in KeyedProcessFunction when use keyed state in both processElement and onTimer method

2019-10-17 Thread vinoyang (Jira)
vinoyang created FLINK-14428: Summary: Non-consistency key access in KeyedProcessFunction when use keyed state in both processElement and onTimer method Key: FLINK-14428 URL: https://issues.apache.org/jira/browse/FLIN

[jira] [Updated] (FLINK-14428) Non-consistency key access in KeyedProcessFunction when use keyed state api in both processElement and onTimer method

2019-10-17 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-14428: - Description: Scenario: In {{KeyedProcessFunction}}, uses keyed state API in both {{processElement}} an

[jira] [Updated] (FLINK-14428) Non-consistency key access in KeyedProcessFunction when use keyed state api in both processElement and onTimer method

2019-10-17 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-14428: - Description: Scenario: In {{KeyedProcessFunction}}, uses keyed state API in both {{processElement}} an

[jira] [Commented] (FLINK-14428) Non-consistency key access in KeyedProcessFunction when use keyed state api in both processElement and onTimer method

2019-10-17 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953481#comment-16953481 ] vinoyang commented on FLINK-14428: -- [~aljoscha] and [~trohrmann] WDYT? > Non-consisten

[jira] [Commented] (FLINK-14427) 批流融合

2019-10-17 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953483#comment-16953483 ] vinoyang commented on FLINK-14427: -- [~qinkaixin] It would be better to use English to d

[GitHub] [flink] flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex URL: https://github.com/apache/flink/pull/9798#issuecomment-536255109 ## CI report: * 7231b0df07d82c5c758d744f51401251f6449ea9 : FAILURE [Build](https://travis-ci.com/flink-c

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335825962 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335825863 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[jira] [Assigned] (FLINK-13867) Write file only once when doing blocking broadcast shuffle

2019-10-17 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13867: -- Assignee: Yun Gao > Write file only once when doing blocking broadcast shuffle >

[jira] [Updated] (FLINK-14425) ensure all tpc-ds tests can pass

2019-10-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14425: --- Summary: ensure all tpc-ds tests can pass (was: Pick necessary commits gently that tpc-ds tests nee

[jira] [Updated] (FLINK-14425) Ensure all tpc-ds tests can pass

2019-10-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14425: --- Summary: Ensure all tpc-ds tests can pass (was: ensure all tpc-ds tests can pass) > Ensure all tpc

[jira] [Commented] (FLINK-14412) Rename ML Pipeline to MLPipeline

2019-10-17 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953516#comment-16953516 ] Zili Chen commented on FLINK-14412: --- I can see the background to move FLIP-73 {{Pipeli

[GitHub] [flink] flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex URL: https://github.com/apache/flink/pull/9798#issuecomment-536255109 ## CI report: * 7231b0df07d82c5c758d744f51401251f6449ea9 : FAILURE [Build](https://travis-ci.com/flink-c

[jira] [Comment Edited] (FLINK-14412) Rename ML Pipeline to MLPipeline

2019-10-17 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953516#comment-16953516 ] Zili Chen edited comment on FLINK-14412 at 10/17/19 8:42 AM: -

[jira] [Comment Edited] (FLINK-14412) Rename ML Pipeline to MLPipeline

2019-10-17 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953516#comment-16953516 ] Zili Chen edited comment on FLINK-14412 at 10/17/19 8:43 AM: -

[GitHub] [flink] TisonKun commented on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient

2019-10-17 Thread GitBox
TisonKun commented on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient URL: https://github.com/apache/flink/pull/9820#issuecomment-543072788 Thanks for your update Aljoscha. I am proceeding now. --

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539472188 ## CI report: * b10f5603fc55999adb8d5334a3d142d20322de5b : SUCCESS [Build](https://travis-ci.co

[GitHub] [flink] flinkbot edited a comment on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex URL: https://github.com/apache/flink/pull/9601#issuecomment-527401073 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review yo

[GitHub] [flink] flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient URL: https://github.com/apache/flink/pull/9820#issuecomment-536448665 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Created] (FLINK-14429) Wrong app final status when running yarn-cluster in non-detached mode

2019-10-17 Thread liupengcheng (Jira)
liupengcheng created FLINK-14429: Summary: Wrong app final status when running yarn-cluster in non-detached mode Key: FLINK-14429 URL: https://issues.apache.org/jira/browse/FLINK-14429 Project: Flink

[jira] [Updated] (FLINK-14429) Wrong app final status when running batch job on yarn with non-detached mode

2019-10-17 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liupengcheng updated FLINK-14429: - Summary: Wrong app final status when running batch job on yarn with non-detached mode (was: Wro

[GitHub] [flink] zentol commented on issue #9867: [FLINK-7958][metrics] Reporters provide default delimiter

2019-10-17 Thread GitBox
zentol commented on issue #9867: [FLINK-7958][metrics] Reporters provide default delimiter URL: https://github.com/apache/flink/pull/9867#issuecomment-543075504 Again, the config option _already exists_, this PR just _documents_ it. An _existing_ feature, that is _actually evaluated_ shoul

[GitHub] [flink] flinkbot edited a comment on issue #9867: [FLINK-7958][metrics] Reporters provide default delimiter

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9867: [FLINK-7958][metrics] Reporters provide default delimiter URL: https://github.com/apache/flink/pull/9867#issuecomment-539966502 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review you

[jira] [Closed] (FLINK-14263) Extract static method from ClusterClient to ClientUtils

2019-10-17 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-14263. - Resolution: Fixed fixed as side effect of FLINK-14290. > Extract static method from ClusterClient to Cl

[GitHub] [flink] zentol commented on issue #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

2019-10-17 Thread GitBox
zentol commented on issue #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#issuecomment-543077224 Having a default implementation makes sense, will add it. This is a

[GitHub] [flink] TisonKun closed pull request #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils

2019-10-17 Thread GitBox
TisonKun closed pull request #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils URL: https://github.com/apache/flink/pull/9792 This is an automated message from the Apache Git Service. To re

[GitHub] [flink] TisonKun commented on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils

2019-10-17 Thread GitBox
TisonKun commented on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils URL: https://github.com/apache/flink/pull/9792#issuecomment-543077002 closed as side effect of #9820 This is an

[jira] [Commented] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

2019-10-17 Thread Jaryzhen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953521#comment-16953521 ] Jaryzhen commented on FLINK-13148: -- [~klion26] [~kkl0u] Hi, This feature has been a lon

[GitHub] [flink] TisonKun closed pull request #9793: [FLINK-14130][client] Remove ClusterClient.run() methods

2019-10-17 Thread GitBox
TisonKun closed pull request #9793: [FLINK-14130][client] Remove ClusterClient.run() methods URL: https://github.com/apache/flink/pull/9793 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils URL: https://github.com/apache/flink/pull/9792#issuecomment-536149907 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commun

[GitHub] [flink] TisonKun commented on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods

2019-10-17 Thread GitBox
TisonKun commented on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods URL: https://github.com/apache/flink/pull/9793#issuecomment-543077958 close and rebase on current master. This is an automated messag

[GitHub] [flink] flinkbot edited a comment on issue #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#issuecomment-539986810 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your p

[GitHub] [flink] yanghua commented on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6

2019-10-17 Thread GitBox
yanghua commented on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6 URL: https://github.com/apache/flink/pull/9906#issuecomment-543078937 @flinkbot run travis --

[GitHub] [flink] flinkbot edited a comment on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods URL: https://github.com/apache/flink/pull/9793#issuecomment-536152879 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex URL: https://github.com/apache/flink/pull/9798#issuecomment-536254451 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revie

[jira] [Updated] (FLINK-14425) Add decimal support and transformation clear ensure all tpc-ds tests can pass

2019-10-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14425: --- Summary: Add decimal support and transformation clear ensure all tpc-ds tests can pass (was: Ensure

[jira] [Created] (FLINK-14430) BaseArraySerializerTest.testDuplicate fails on travis

2019-10-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-14430: --- Summary: BaseArraySerializerTest.testDuplicate fails on travis Key: FLINK-14430 URL: https://issues.apache.org/jira/browse/FLINK-14430 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-14430) BaseArraySerializerTest.testDuplicate fails on travis

2019-10-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14430: Affects Version/s: 1.10.0 > BaseArraySerializerTest.testDuplicate fails on travis > --

[jira] [Commented] (FLINK-14430) BaseArraySerializerTest.testDuplicate fails on travis

2019-10-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953525#comment-16953525 ] Jark Wu commented on FLINK-14430: - cc [~lzljs3620320] > BaseArraySerializerTest.testDu

[GitHub] [flink] wuchong merged pull request #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex

2019-10-17 Thread GitBox
wuchong merged pull request #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex URL: https://github.com/apache/flink/pull/9798 This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [flink] flinkbot edited a comment on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6 URL: https://github.com/apache/flink/pull/9906#issuecomment-542220479 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Resolved] (FLINK-14176) add taskmanager link in vertex‘s page of taskmanager

2019-10-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14176. - Fix Version/s: 1.10.0 Resolution: Resolved 1.10.0: 60b5698aa2b9fe9ae233957688bd67a63325b7db > ad

[GitHub] [flink] zentol commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

2019-10-17 Thread GitBox
zentol commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#discussion_r335890034 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java

[GitHub] [flink] zentol commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

2019-10-17 Thread GitBox
zentol commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#discussion_r335889976 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/FrontMetricGroup.java #

[GitHub] [flink] flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex URL: https://github.com/apache/flink/pull/9798#issuecomment-536254451 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revie

[jira] [Updated] (FLINK-14425) Resolve flink-13611 and Flink-13708 ensure all tpc-ds tests can pass

2019-10-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-14425: --- Summary: Resolve flink-13611 and Flink-13708 ensure all tpc-ds tests can pass (was: Add decimal sup

[GitHub] [flink] flinkbot edited a comment on issue #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#issuecomment-539986810 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your p

[GitHub] [flink] flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex URL: https://github.com/apache/flink/pull/9798#issuecomment-536255109 ## CI report: * 7231b0df07d82c5c758d744f51401251f6449ea9 : FAILURE [Build](https://travis-ci.com/flink-c

[GitHub] [flink] flinkbot edited a comment on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex URL: https://github.com/apache/flink/pull/9601#issuecomment-527404637 ## CI report: * 13d895349390698404a375fb4362a41b736ab0c6 : SUCCESS [Build](https://travis-ci.com/flink-ci/fl

[jira] [Commented] (FLINK-12848) Method equals() in RowTypeInfo should consider fieldsNames

2019-10-17 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953529#comment-16953529 ] Timo Walther commented on FLINK-12848: -- This is not the first time that this topic

[GitHub] [flink] flinkbot edited a comment on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6

2019-10-17 Thread GitBox
flinkbot edited a comment on issue #9906: [FLINK-14395] Refactor ES 6 connector to split table-specific code into flink-sql-connector-elasticsearch6 URL: https://github.com/apache/flink/pull/9906#issuecomment-542230286 ## CI report: * dd8cbf2ca3d1515420b09362d0a2df938208c2eb : SU

[GitHub] [flink] aljoscha commented on issue #7519: FLINK-11378 - Allow writing to Hadoop compatible Filesystems via Hado…

2019-10-17 Thread GitBox
aljoscha commented on issue #7519: FLINK-11378 - Allow writing to Hadoop compatible Filesystems via Hado… URL: https://github.com/apache/flink/pull/7519#issuecomment-543085273 Ok, what's the plan then? Should we close this PR and the accompanying Jira Issue until you want to contribute som

[GitHub] [flink] Fokko commented on issue #7519: FLINK-11378 - Allow writing to Hadoop compatible Filesystems via Hado…

2019-10-17 Thread GitBox
Fokko commented on issue #7519: FLINK-11378 - Allow writing to Hadoop compatible Filesystems via Hado… URL: https://github.com/apache/flink/pull/7519#issuecomment-543085934 Sounds as a plan to me, WDYT @martijnvdgrift This i

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335823155 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] aljoscha commented on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter

2019-10-17 Thread GitBox
aljoscha commented on issue #9882: [FLINK-14380][Flink-Core] Type Extractor Setter URL: https://github.com/apache/flink/pull/9882#issuecomment-543086033 @ElliotVilhelm please see my comment on the Jira issue. (https://issues.apache.org/jira/browse/FLINK-14380)

[GitHub] [flink] dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF

2019-10-17 Thread GitBox
dianfu commented on a change in pull request #9890: [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF URL: https://github.com/apache/flink/pull/9890#discussion_r335825685 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[jira] [Commented] (FLINK-14380) Type Extractor POJO setter check does not allow for Immutable Case Class

2019-10-17 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953536#comment-16953536 ] Aljoscha Krettek commented on FLINK-14380: -- [~elliotvilhelm] could you please p

[GitHub] [flink] zentol commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

2019-10-17 Thread GitBox
zentol commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#discussion_r335896857 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/FrontMetricGroup.java #

[GitHub] [flink] zentol commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

2019-10-17 Thread GitBox
zentol commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#discussion_r335897808 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/FrontMetricGroup.java #

  1   2   3   4   5   6   7   >