[jira] [Commented] (FLINK-15674) Let Java and Scala Type Extraction go through the same stack

2020-01-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019855#comment-17019855 ] Yun Gao commented on FLINK-15674: - After moving Scala macro type extractor as a service of

[jira] [Updated] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread yuzhaojing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzhaojing updated FLINK-15682: --- Attachment: image-2020-01-21-13-29-18-903.png > Flink native kubernetes Could not run >

[jira] [Updated] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread yuzhaojing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzhaojing updated FLINK-15682: --- Attachment: image-2020-01-21-13-30-59-731.png > Flink native kubernetes Could not run >

[GitHub] [flink] wangyang0918 commented on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration

2020-01-20 Thread GitBox
wangyang0918 commented on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration URL: https://github.com/apache/flink/pull/10898#issuecomment-576526813 @flinkbot run azure

[jira] [Commented] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread yuzhaojing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019861#comment-17019861 ] yuzhaojing commented on FLINK-15682: These are my execution steps: ./bin/kubernetes-session.sh \

[jira] [Commented] (FLINK-15692) Enable limiting RocksDB memory consumption by default

2020-01-20 Thread ptmagic (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019863#comment-17019863 ] ptmagic commented on FLINK-15692: - [~yunta] I agree with you, but I think this will be split into

[GitHub] [flink] flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-559012596 ## CI report: * 3198d4f64415b0d257733b7d214dece64c392081 Travis:

[jira] [Commented] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019864#comment-17019864 ] Yang Wang commented on FLINK-15682: --- [~yuzhaojing] Could you share your docker image? Do you build

[GitHub] [flink] flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration URL: https://github.com/apache/flink/pull/10898#issuecomment-575987880 ## CI report: * 09c6c4e6068e7d01c7c6f14370b9fbc6b0bdce69 Travis:

[jira] [Commented] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread yuzhaojing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019865#comment-17019865 ] yuzhaojing commented on FLINK-15682: I do some change,sorry. I will rollback my code and then show

[GitHub] [flink] flinkbot edited a comment on issue #10912: [hotfix][e2e] Fix e2e test re-run error

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10912: [hotfix][e2e] Fix e2e test re-run error URL: https://github.com/apache/flink/pull/10912#issuecomment-576510935 ## CI report: * dd3583af0f1bf8dc98e044271c4a9209a99a8aac Travis:

[jira] [Commented] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

2020-01-20 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019866#comment-17019866 ] Guowei Ma commented on FLINK-2646: -- I want to understand what specific scenarios the jira wants to

[jira] [Commented] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019867#comment-17019867 ] Yang Wang commented on FLINK-15682: --- [~yuzhaojing] Thanks for you quick response. Please revert your

[jira] [Commented] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019873#comment-17019873 ] Yang Wang commented on FLINK-15682: --- I have build a docker image with the lates 1.10 branch and the

[jira] [Commented] (FLINK-15692) Enable limiting RocksDB memory consumption by default

2020-01-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019872#comment-17019872 ] Yun Tang commented on FLINK-15692: -- [~ptmagic] since you did not take participated in any discussion or

[GitHub] [flink] hequn8128 opened a new pull request #10913: [FLINK-15636][python] Supports Python UDF in old planner under batch mode

2020-01-20 Thread GitBox
hequn8128 opened a new pull request #10913: [FLINK-15636][python] Supports Python UDF in old planner under batch mode URL: https://github.com/apache/flink/pull/10913 ## What is the purpose of the change Currently, Python UDF has been supported under old planner(only stream) and

[jira] [Updated] (FLINK-15636) Support Python UDF for flink planner under batch mode

2020-01-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15636: --- Labels: pull-request-available (was: ) > Support Python UDF for flink planner under batch

[GitHub] [flink] flinkbot commented on issue #10913: [FLINK-15636][python] Supports Python UDF in old planner under batch mode

2020-01-20 Thread GitBox
flinkbot commented on issue #10913: [FLINK-15636][python] Supports Python UDF in old planner under batch mode URL: https://github.com/apache/flink/pull/10913#issuecomment-576535977 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-01-20 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019877#comment-17019877 ] Jiangjie Qin commented on FLINK-15611: -- [~gjy] sorry for the late reply. FLINK-15490 ensures that

[GitHub] [flink] carp84 commented on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend

2020-01-20 Thread GitBox
carp84 commented on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend URL: https://github.com/apache/flink/pull/10893#issuecomment-576536039 Thanks for checking the performance impact @klion26. From the result we

[jira] [Updated] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread yuzhaojing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzhaojing updated FLINK-15682: --- Attachment: image-2020-01-21-14-24-46-752.png > Flink native kubernetes Could not run >

[GitHub] [flink] flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-559012596 ## CI report: * 3198d4f64415b0d257733b7d214dece64c392081 Travis:

[jira] [Commented] (FLINK-14460) Active Kubernetes integration phase2 - Advanced Features

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019881#comment-17019881 ] Yang Wang commented on FLINK-14460: --- Thanks for all the enthusiasm of you guys. Very glad to see that

[GitHub] [flink] flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration URL: https://github.com/apache/flink/pull/10898#issuecomment-575987880 ## CI report: * 09c6c4e6068e7d01c7c6f14370b9fbc6b0bdce69 Travis:

[GitHub] [flink] hequn8128 commented on a change in pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc

2020-01-20 Thread GitBox
hequn8128 commented on a change in pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc URL: https://github.com/apache/flink/pull/10911#discussion_r368829167 ## File path: docs/getting-started/walkthroughs/python_table_api.md ## @@ -142,8

[GitHub] [flink] hequn8128 commented on a change in pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc

2020-01-20 Thread GitBox
hequn8128 commented on a change in pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc URL: https://github.com/apache/flink/pull/10911#discussion_r368829682 ## File path: docs/getting-started/walkthroughs/python_table_api.md ## @@ -142,8

[GitHub] [flink] hequn8128 commented on a change in pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc

2020-01-20 Thread GitBox
hequn8128 commented on a change in pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc URL: https://github.com/apache/flink/pull/10911#discussion_r368829260 ## File path: docs/getting-started/walkthroughs/python_table_api.md ## @@ -142,8

[GitHub] [flink] hequn8128 commented on a change in pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc

2020-01-20 Thread GitBox
hequn8128 commented on a change in pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc URL: https://github.com/apache/flink/pull/10911#discussion_r368828468 ## File path: docs/getting-started/walkthroughs/python_table_api.md ## @@ -142,8

[jira] [Commented] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019883#comment-17019883 ] Yang Wang commented on FLINK-15682: --- [~yuzhaojing] Please update the log4j configuration to see why

[GitHub] [flink] carp84 merged pull request #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend

2020-01-20 Thread GitBox
carp84 merged pull request #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend URL: https://github.com/apache/flink/pull/10893 This is an automated message from the

[jira] [Updated] (FLINK-15637) For RocksDBStateBackend, make RocksDB the default store for timers

2020-01-20 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15637: -- Description: Set the {{state.backend.rocksdb.timer-service.factory}} to {{ROCKSDB}} by default. Also ensure

[jira] [Commented] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-01-20 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019887#comment-17019887 ] Guowei Ma commented on FLINK-15670: --- >>>I am wondering how do we expose this feature to the users?

[GitHub] [flink] liupc commented on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components

2020-01-20 Thread GitBox
liupc commented on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components URL: https://github.com/apache/flink/pull/10910#issuecomment-576540983 @TisonKun Thanks for reply, it's good to use `ClientUtils.buildUserCodeClassLoader` to deduplicate codes.

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-01-20 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019890#comment-17019890 ] Jiangjie Qin commented on FLINK-15611: -- Just a quick update. The log actually shows some problems. 

[jira] [Commented] (FLINK-15692) Enable limiting RocksDB memory consumption by default

2020-01-20 Thread ptmagic (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019889#comment-17019889 ] ptmagic commented on FLINK-15692: - it ’s ok, I don’t see this task hanging under some subtasks, so I

[jira] [Comment Edited] (FLINK-15692) Enable limiting RocksDB memory consumption by default

2020-01-20 Thread ptmagic (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019889#comment-17019889 ] ptmagic edited comment on FLINK-15692 at 1/21/20 6:52 AM: -- [~yunta] it ’s ok, I

[GitHub] [flink] hequn8128 closed pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc

2020-01-20 Thread GitBox
hequn8128 closed pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc URL: https://github.com/apache/flink/pull/10911 This is an automated message from the Apache Git Service. To respond to

[jira] [Assigned] (FLINK-15700) Improve Python API Tutorial doc

2020-01-20 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-15700: --- Assignee: Huang Xingbo > Improve Python API Tutorial doc > ---

[GitHub] [flink] flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration URL: https://github.com/apache/flink/pull/10898#issuecomment-575987880 ## CI report: * 09c6c4e6068e7d01c7c6f14370b9fbc6b0bdce69 Travis:

[GitHub] [flink] flinkbot commented on issue #10913: [FLINK-15636][python] Supports Python UDF in old planner under batch mode

2020-01-20 Thread GitBox
flinkbot commented on issue #10913: [FLINK-15636][python] Supports Python UDF in old planner under batch mode URL: https://github.com/apache/flink/pull/10913#issuecomment-576547242 ## CI report: * bdaf386d48c4ef0493a0c1c61a7e6aea12f148d1 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components URL: https://github.com/apache/flink/pull/10910#issuecomment-576505209 ## CI report: * 8333b02c2d8e703f9b3ef25dae0e1f6d2c43e2aa Travis:

[jira] [Updated] (FLINK-15637) For RocksDBStateBackend, make RocksDB the default store for timers

2020-01-20 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15637: -- Release Note: After FLINK-15637, we change the default timer store from heap to RocksDB for

[jira] [Commented] (FLINK-15700) Improve Python API Tutorial doc

2020-01-20 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019900#comment-17019900 ] Hequn Cheng commented on FLINK-15700: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-15700) Improve Python API Tutorial doc

2020-01-20 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15700. --- Resolution: Resolved > Improve Python API Tutorial doc > --- > >

[jira] [Created] (FLINK-15704) Kafka09ITCase.testBrokerFailure fails due to time out on travis

2020-01-20 Thread Yu Li (Jira)
Yu Li created FLINK-15704: - Summary: Kafka09ITCase.testBrokerFailure fails due to time out on travis Key: FLINK-15704 URL: https://issues.apache.org/jira/browse/FLINK-15704 Project: Flink Issue

[jira] [Commented] (FLINK-15704) Kafka09ITCase.testBrokerFailure fails due to time out on travis

2020-01-20 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019901#comment-17019901 ] Yu Li commented on FLINK-15704: --- Setting priority to Major since this seems to be the first occurrence.

[jira] [Commented] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread yuzhaojing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019902#comment-17019902 ] yuzhaojing commented on FLINK-15682: I can run when use your image, I will found problem in  my

[jira] [Commented] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019905#comment-17019905 ] Yang Wang commented on FLINK-15682: --- [~yuzhaojing] So i will close this ticket with {{Not A Problem}}.

[jira] [Closed] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-15682. - Resolution: Not A Problem > Flink native kubernetes Could not run >

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

2020-01-20 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019906#comment-17019906 ] Yu Li commented on FLINK-15611: --- [~banmoy] Please take a look at the state side problem. Thanks. >

[GitHub] [flink] flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-559012596 ## CI report: * 3198d4f64415b0d257733b7d214dece64c392081 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration URL: https://github.com/apache/flink/pull/10898#issuecomment-575987880 ## CI report: * 09c6c4e6068e7d01c7c6f14370b9fbc6b0bdce69 Travis:

[jira] [Commented] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-01-20 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019907#comment-17019907 ] Jiangjie Qin commented on FLINK-15670: -- [~maguowei] Yes, that would be an option. However, IIUC 

[jira] [Comment Edited] (FLINK-14460) Active Kubernetes integration phase2 - Advanced Features

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019881#comment-17019881 ] Yang Wang edited comment on FLINK-14460 at 1/21/20 7:41 AM: Thanks for all

[GitHub] [flink] flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components URL: https://github.com/apache/flink/pull/10910#issuecomment-576505209 ## CI report: * 8333b02c2d8e703f9b3ef25dae0e1f6d2c43e2aa Travis:

[jira] [Comment Edited] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

2020-01-20 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019907#comment-17019907 ] Jiangjie Qin edited comment on FLINK-15670 at 1/21/20 7:41 AM: ---

[GitHub] [flink] wangyang0918 removed a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration

2020-01-20 Thread GitBox
wangyang0918 removed a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration URL: https://github.com/apache/flink/pull/10898#issuecomment-576526813 @flinkbot run azure

[GitHub] [flink] wangyang0918 commented on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration

2020-01-20 Thread GitBox
wangyang0918 commented on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration URL: https://github.com/apache/flink/pull/10898#issuecomment-576557465 @zhuzhurk Thanks for the second round of review. I have addressed all your

[GitHub] [flink] flinkbot edited a comment on issue #10913: [FLINK-15636][python] Supports Python UDF in old planner under batch mode

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10913: [FLINK-15636][python] Supports Python UDF in old planner under batch mode URL: https://github.com/apache/flink/pull/10913#issuecomment-576547242 ## CI report: * bdaf386d48c4ef0493a0c1c61a7e6aea12f148d1 Travis:

[GitHub] [flink] zhuzhurk commented on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children

2020-01-20 Thread GitBox
zhuzhurk commented on issue #10867: [FLINK-14701][runtime] Fix MultiTaskSlot to not remove slots which are not its children URL: https://github.com/apache/flink/pull/10867#issuecomment-576558468 @GJL would you take a look this fix when you have time? It is needed for 1.9.2.

[GitHub] [flink] zhuzhurk commented on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration

2020-01-20 Thread GitBox
zhuzhurk commented on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration URL: https://github.com/apache/flink/pull/10898#issuecomment-576560561 Thanks for addressing the comments @wangyang0918 . The change looks good to me.

[GitHub] [flink] yanghua commented on issue #10906: [FLINK-15601] Remove useless constant field NUM_STOP_CALL_TRIES in Execution

2020-01-20 Thread GitBox
yanghua commented on issue #10906: [FLINK-15601] Remove useless constant field NUM_STOP_CALL_TRIES in Execution URL: https://github.com/apache/flink/pull/10906#issuecomment-576560669 cc @tillrohrmann This is an automated

[GitHub] [flink] JingsongLi commented on a change in pull request #10879: [FLINK-15595][table] Remove CoreMudule in ModuleManager

2020-01-20 Thread GitBox
JingsongLi commented on a change in pull request #10879: [FLINK-15595][table] Remove CoreMudule in ModuleManager URL: https://github.com/apache/flink/pull/10879#discussion_r368407930 ## File path: docs/dev/table/functions/index.md ## @@ -84,11 +84,13 @@ The resolution

[GitHub] [flink] klion26 commented on issue #10905: run e2e test for pr about 15637

2020-01-20 Thread GitBox
klion26 commented on issue #10905: run e2e test for pr about 15637 URL: https://github.com/apache/flink/pull/10905#issuecomment-576152862 @flinkbot run travis This is an automated message from the Apache Git Service. To

[jira] [Created] (FLINK-15680) testIsAvailableOrNotAfterRequestAndRecycleMultiSegments timed out

2020-01-20 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-15680: -- Summary: testIsAvailableOrNotAfterRequestAndRecycleMultiSegments timed out Key: FLINK-15680 URL: https://issues.apache.org/jira/browse/FLINK-15680 Project: Flink

[GitHub] [flink] pnowojski merged pull request #10901: [FLINK-15575] [filesystems] fix shading of azure filesystem

2020-01-20 Thread GitBox
pnowojski merged pull request #10901: [FLINK-15575] [filesystems] fix shading of azure filesystem URL: https://github.com/apache/flink/pull/10901 This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-15575) Azure Filesystem Shades Wrong Package "httpcomponents"

2020-01-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15575. -- Fix Version/s: 1.10.0 Resolution: Fixed Merged to release-1.10 as 4318a4a2cb Merged to

[jira] [Commented] (FLINK-15198) Remove deprecated mesos.resourcemanager.tasks.mem in 1.11

2020-01-20 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019288#comment-17019288 ] vinoyang commented on FLINK-15198: -- Don't we agree that configuration items marked as @deprecated

[GitHub] [flink] flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration URL: https://github.com/apache/flink/pull/10898#issuecomment-575987880 ## CI report: * 09c6c4e6068e7d01c7c6f14370b9fbc6b0bdce69 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10890: [FLINK-15198][Deployment / Mesos] remove mesos.resourcemanager.tasks.mem URL: https://github.com/apache/flink/pull/10890#issuecomment-575711704 ## CI report: * 42db346a226bf559c202c38affea6e9eef97dafe Travis:

[jira] [Comment Edited] (FLINK-15692) Enable limiting RocksDB memory consumption by default

2020-01-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019859#comment-17019859 ] Yun Tang edited comment on FLINK-15692 at 1/21/20 5:24 AM: --- [~ptmagic] please

[jira] [Commented] (FLINK-15692) Enable limiting RocksDB memory consumption by default

2020-01-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019859#comment-17019859 ] Yun Tang commented on FLINK-15692: -- [~ptmagic] please hold on a moment. As the main contributor of

[jira] [Comment Edited] (FLINK-15692) Enable limiting RocksDB memory consumption by default

2020-01-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019859#comment-17019859 ] Yun Tang edited comment on FLINK-15692 at 1/21/20 5:24 AM: --- [~ptmagic] please

[GitHub] [flink] flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-559012596 ## CI report: * 3198d4f64415b0d257733b7d214dece64c392081 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10910: [FLINK-15702][SQL]Make sqlClient classloader aligned with other components URL: https://github.com/apache/flink/pull/10910#issuecomment-576505209 ## CI report: * 8333b02c2d8e703f9b3ef25dae0e1f6d2c43e2aa Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc URL: https://github.com/apache/flink/pull/10911#issuecomment-576505237 ## CI report: * 799d30c3b6824f3e80af569711f8ab7a35a06c7d Travis:

[jira] [Commented] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019860#comment-17019860 ] Yang Wang commented on FLINK-15687: --- Hi [~trohrmann], i agree with you that we should avoid accessing

[GitHub] [flink] killxdcj commented on a change in pull request #10903: [FLINK-15549][API/DataSet] Fix Integer overflow in ResettableIterator*.

2020-01-20 Thread GitBox
killxdcj commented on a change in pull request #10903: [FLINK-15549][API/DataSet] Fix Integer overflow in ResettableIterator*. URL: https://github.com/apache/flink/pull/10903#discussion_r368414875 ## File path:

[GitHub] [flink] StephanEwen commented on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend

2020-01-20 Thread GitBox
StephanEwen commented on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend URL: https://github.com/apache/flink/pull/10893#issuecomment-576165144 Thank you for fixing this. Looks good to me, +1 to merge this...

[GitHub] [flink] gaoyunhaii commented on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-01-20 Thread GitBox
gaoyunhaii commented on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-576164824 @zhijiangW I have updated the PR based on the latest master. Very thanks for the review ! :)

[jira] [Updated] (FLINK-11333) First-class support for Protobuf types with evolvable schema

2020-01-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-11333: - Labels: pull-request-available usability (was: pull-request-available) > First-class support

[jira] [Updated] (FLINK-15681) Remove legacy ExecutionAndAllocationFuture class

2020-01-20 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-15681: -- Issue Type: Improvement (was: Wish) > Remove legacy ExecutionAndAllocationFuture class >

[jira] [Commented] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019328#comment-17019328 ] Yang Wang commented on FLINK-15682: --- If you use the docker file in the {{flink-container}} module to

[jira] [Commented] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019369#comment-17019369 ] Yang Wang commented on FLINK-15682: --- [~yuzhaojing] I use your dockerfile to build the image. It could

[GitHub] [flink] flinkbot edited a comment on issue #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10840: [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull URL: https://github.com/apache/flink/pull/10840#issuecomment-573563119 ## CI report: * 61e9e675667e05e44e9c4b5ffd7565f60aec6d62 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10908: [FLINK-15682][kubernetes]fix bug for kubernetes command

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10908: [FLINK-15682][kubernetes]fix bug for kubernetes command URL: https://github.com/apache/flink/pull/10908#issuecomment-576207636 ## CI report: * 93cfff933f307e8ded5c7d26a1ab629634e215dd Travis:

[jira] [Updated] (FLINK-15154) Change Flink binding addresses in local mode

2020-01-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-15154: - Labels: usability (was: ) > Change Flink binding addresses in local mode >

[jira] [Updated] (FLINK-13717) allow to set taskmanager.host and taskmanager.bind-host separately

2020-01-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13717: - Labels: usability (was: ) > allow to set taskmanager.host and taskmanager.bind-host separately

[GitHub] [flink] flinkbot edited a comment on issue #10905: run e2e test for pr 15637

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10905: run e2e test for pr 15637 URL: https://github.com/apache/flink/pull/10905#issuecomment-576004550 ## CI report: * bf18d1c5135b8c2d42966b95e38e36fab6d62590 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/145110843) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10904: [FLINK-15669] [sql client] fix SQL client can't cancel flink job URL: https://github.com/apache/flink/pull/10904#issuecomment-576004529 ## CI report: * dbfc485ecea3aec8bc0054ca8bacb310b417c5dc Travis:

[jira] [Commented] (FLINK-15675) Add exception and documentation that Python UDF is not supported for Flink Planner under batch mode

2020-01-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019295#comment-17019295 ] Dian Fu commented on FLINK-15675: - Fixed in: master: 360afd9fdf70484a246034b463251f36e8288130 1.10.0:

[GitHub] [flink] flinkbot edited a comment on issue #10894: [FLINK-15592][hive] Add black list for Hive built-in functions

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10894: [FLINK-15592][hive] Add black list for Hive built-in functions URL: https://github.com/apache/flink/pull/10894#issuecomment-575966596 ## CI report: * a72e031a0f93df6cf782968234f59a9ba0c40821 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10878: [FLINK-15599][table] SQL client requires both legacy and blink planner to be on the classpath

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10878: [FLINK-15599][table] SQL client requires both legacy and blink planner to be on the classpath URL: https://github.com/apache/flink/pull/10878#issuecomment-575493814 ## CI report: * 6ce81e21780883796248af5c87d2ec5f1dc5e0ef UNKNOWN *

[jira] [Comment Edited] (FLINK-15637) For RocksDBStateBackend, make RocksDB the default store for timers

2020-01-20 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019194#comment-17019194 ] Stephan Ewen edited comment on FLINK-15637 at 1/20/20 8:27 AM: --- Ran the

[GitHub] [flink] flinkbot edited a comment on issue #10905: run e2e test for pr 15637

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #10905: run e2e test for pr 15637 URL: https://github.com/apache/flink/pull/10905#issuecomment-576004550 ## CI report: * bf18d1c5135b8c2d42966b95e38e36fab6d62590 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/145110843) Azure:

[jira] [Comment Edited] (FLINK-15682) Flink native kubernetes Could not run

2020-01-20 Thread yuzhaojing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019326#comment-17019326 ] yuzhaojing edited comment on FLINK-15682 at 1/20/20 9:28 AM: - FROM

[GitHub] [flink] zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

2020-01-20 Thread GitBox
zhijiangW commented on a change in pull request #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#discussion_r368471642 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-01-20 Thread GitBox
flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407 ## CI report: * 6b12b52b99894864db993a2fa8ab2bfcce0edd5c Travis:

[jira] [Commented] (FLINK-15198) Remove deprecated mesos.resourcemanager.tasks.mem in 1.11

2020-01-20 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019373#comment-17019373 ] Andrey Zagrebin commented on FLINK-15198: - [~yanghua] Technically, this Mesos options class is

[jira] [Commented] (FLINK-15198) Remove deprecated mesos.resourcemanager.tasks.mem in 1.11

2020-01-20 Thread ptmagic (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019379#comment-17019379 ] ptmagic commented on FLINK-15198: - [~azagrebin] i found taskmanager.memory.total-process.size is

  1   2   3   4   5   >