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

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 mes

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

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. Will

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

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] wangyang0918 removed a comment on issue #10898: [FLINK-15632][kubernetes] Make zookeeper HA service could work for active kubernetes integration

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

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 comment

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

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: [PENDING](https://travis-c

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

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019881#comment-17019881 ] Yang Wang edited comment on FLINK-14460 at 1/21/20 7:41 AM:

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

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: [FAILURE](https://travis-

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019907#comment-17019907 ] Jiangjie Qin commented on FLINK-15670: -- [~maguowei] Yes, that would be an option. H

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

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: [FA

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

[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019906#comment-17019906 ] Yu Li commented on FLINK-15611: --- [~banmoy] Please take a look at the state side problem. T

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

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: [FAILUR

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

[ 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-15682) Flink native kubernetes Could not run

[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019905#comment-17019905 ] Yang Wang commented on FLINK-15682: --- [~yuzhaojing] So i will close this ticket with {{

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

[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019902#comment-17019902 ] yuzhaojing commented on FLINK-15682: I can run when use your image, I will found pro

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

[ https://issues.apache.org/jira/browse/FLINK-15704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019901#comment-17019901 ] Yu Li commented on FLINK-15704: --- Setting priority to Major since this seems to be the firs

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

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 Type

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

[ 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] [Commented] (FLINK-15700) Improve Python API Tutorial doc

[ https://issues.apache.org/jira/browse/FLINK-15700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019900#comment-17019900 ] Hequn Cheng commented on FLINK-15700: - Resolved in 1.11.0 via 9eda8c32b0988c2c51d82

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

[ 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 RocksDBStateBacken

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

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

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: [FAILURE](https://travis-

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

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: [FA

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

[ 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] hequn8128 closed pull request #10911: [FLINK-15700][python][doc] Improves the Python API Tutorial doc

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 th

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

[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019890#comment-17019890 ] Jiangjie Qin commented on FLINK-15611: -- Just a quick update. The log actually shows

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

[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019889#comment-17019889 ] ptmagic commented on FLINK-15692: - it ’s ok, I don’t see this task hanging under some su

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

[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019889#comment-17019889 ] ptmagic edited comment on FLINK-15692 at 1/21/20 6:52 AM: -- [~yu

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

[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019887#comment-17019887 ] Guowei Ma commented on FLINK-15670: --- >>>I am wondering how do we expose this feature t

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

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. I've

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

[ 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 t

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

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] [Commented] (FLINK-15682) Flink native kubernetes Could not run

[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019883#comment-17019883 ] Yang Wang commented on FLINK-15682: --- [~yuzhaojing] Please update the log4j configurati

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

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 +1

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

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 +1

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

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 +1

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

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 +1

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

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019881#comment-17019881 ] Yang Wang commented on FLINK-14460: --- Thanks for all the enthusiasm of you guys. Very g

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

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: [FA

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

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: [FAILUR

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

[ 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] carp84 commented on issue #10893: [FLINK-15637][state backends] Make RocksDB the default store for timers when using RocksDBStateBackend

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 will

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

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 to

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

[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019877#comment-17019877 ] Jiangjie Qin commented on FLINK-15611: -- [~gjy] sorry for the late reply. FLINK-1549

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

[ 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 m

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

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] [Commented] (FLINK-15682) Flink native kubernetes Could not run

[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019873#comment-17019873 ] Yang Wang commented on FLINK-15682: --- I have build a docker image with the lates 1.10 b

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

[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019872#comment-17019872 ] Yun Tang commented on FLINK-15692: -- [~ptmagic] since you did not take participated in a

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

[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019867#comment-17019867 ] Yang Wang commented on FLINK-15682: --- [~yuzhaojing] Thanks for you quick response. Plea

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

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019866#comment-17019866 ] Guowei Ma commented on FLINK-2646: -- I want to understand what specific scenarios the jir

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

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: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/145306

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

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: [FA

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

[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019865#comment-17019865 ] yuzhaojing commented on FLINK-15682: I do some change，sorry. I will rollback my code

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

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: [FAILUR

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

[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019864#comment-17019864 ] Yang Wang commented on FLINK-15682: --- [~yuzhaojing] Could you share your docker image?

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

[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019863#comment-17019863 ] ptmagic commented on FLINK-15692: - [~yunta] I agree with you, but I think this will be s

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

[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019861#comment-17019861 ] yuzhaojing commented on FLINK-15682: These are my execution steps： ./bin/kubernetes

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

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-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019860#comment-17019860 ] Yang Wang commented on FLINK-15687: --- Hi [~trohrmann], i agree with you that we should

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

[ 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 >

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

[ 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] [Comment Edited] (FLINK-15692) Enable limiting RocksDB memory consumption by default

[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019859#comment-17019859 ] Yun Tang edited comment on FLINK-15692 at 1/21/20 5:24 AM: --- [~

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

[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019859#comment-17019859 ] Yun Tang commented on FLINK-15692: -- [~ptmagic] please hold on a moment. As the main con

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

[ https://issues.apache.org/jira/browse/FLINK-15692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019859#comment-17019859 ] Yun Tang edited comment on FLINK-15692 at 1/21/20 5:24 AM: --- [~

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

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: [FAILURE](https://travis-

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

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: [SUCCESS](https://travis-ci.com/flin

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

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: [FA

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

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: [SUCCESS](https://travis-ci

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

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: [FAILUR

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

[ https://issues.apache.org/jira/browse/FLINK-15674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019855#comment-17019855 ] Yun Gao commented on FLINK-15674: - After moving Scala macro type extractor as a service

[jira] [Commented] (FLINK-14557) Clean up the package of py4j

[ https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019853#comment-17019853 ] Dian Fu commented on FLINK-14557: - Resolved in 1.9.2 via c9f9c547ac3fd9e421e0140b27c0818

[jira] [Updated] (FLINK-14557) Clean up the package of py4j

[ https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14557: Fix Version/s: 1.9.2 > Clean up the package of py4j > > > Key

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

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: [PENDING](https://travis-ci.com/flink-ci/flink/builds/145306

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

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: [FAILURE](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #10903: [FLINK-15549][API/DataSet] Fix Integer overflow in ResettableIterator*.

flinkbot edited a comment on issue #10903: [FLINK-15549][API/DataSet] Fix Integer overflow in ResettableIterator*. URL: https://github.com/apache/flink/pull/10903#issuecomment-576004518 ## CI report: * 42bc28f0d52652f76118922a27ca1f82c3b9030e UNKNOWN * 4289c3910b39b13938aafc13

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

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: [FA

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 Travis: [FAILURE](https://travis-ci.com/flink-c

[GitHub] [flink] ifndef-SleePy commented on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-576515234 @pnowojski , thanks for reviewing and nice suggestions. I have done the re-ordering.

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

[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019846#comment-17019846 ] Yang Wang commented on FLINK-15682: --- [~yuzhaojing] If you really want to run manually,

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

flinkbot commented on issue #10912: [hotfix][e2e] Fix e2e test re-run error URL: https://github.com/apache/flink/pull/10912#issuecomment-576510935 ## CI report: * dd3583af0f1bf8dc98e044271c4a9209a99a8aac UNKNOWN Bot commands The @flinkbot bot supports the following

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

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: [PENDING](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #10903: [FLINK-15549][API/DataSet] Fix Integer overflow in ResettableIterator*.

flinkbot edited a comment on issue #10903: [FLINK-15549][API/DataSet] Fix Integer overflow in ResettableIterator*. URL: https://github.com/apache/flink/pull/10903#issuecomment-576004518 ## CI report: * 42bc28f0d52652f76118922a27ca1f82c3b9030e UNKNOWN * 4289c3910b39b13938aafc13

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

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: [PENDING](https://travis-

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

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: [FA

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

[ https://issues.apache.org/jira/browse/FLINK-15682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019844#comment-17019844 ] Yang Wang commented on FLINK-15682: --- I am not sure why do you run the command manually

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

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: [SUCCESS](https://travis-ci

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

flinkbot commented on issue #10912: [hotfix][e2e] Fix e2e test re-run error URL: https://github.com/apache/flink/pull/10912#issuecomment-576508209 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

[GitHub] [flink] wangxiyuan opened a new pull request #10912: [hotfix][e2e] Fix e2e test re-run error

wangxiyuan opened a new pull request #10912: [hotfix][e2e] Fix e2e test re-run error URL: https://github.com/apache/flink/pull/10912 ## What is the purpose of the change If run Flink e2e test with a pre-built Flink like `./tools/travis/nightly.sh split_sticky.sh`, it will fail w

[jira] [Updated] (FLINK-15703) FlinkKafkaConsumer should enable partition discovery by default.

[ https://issues.apache.org/jira/browse/FLINK-15703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-15703: - Labels: usability (was: ) > FlinkKafkaConsumer should enable partition discovery by default. >

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

flinkbot commented 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 UNKNOWN Bot commands The

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

flinkbot commented 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 UNKNOWN Bot commands The @flinkbot b

[GitHub] [flink] flinkbot edited a comment on issue #10903: [FLINK-15549][API/DataSet] Fix Integer overflow in ResettableIterator*.

flinkbot edited a comment on issue #10903: [FLINK-15549][API/DataSet] Fix Integer overflow in ResettableIterator*. URL: https://github.com/apache/flink/pull/10903#issuecomment-576004518 ## CI report: * 42bc28f0d52652f76118922a27ca1f82c3b9030e UNKNOWN * 4289c3910b39b13938aafc13

[jira] [Created] (FLINK-15703) FlinkKafkaConsumer should enable partition discovery by default.

Jiangjie Qin created FLINK-15703: Summary: FlinkKafkaConsumer should enable partition discovery by default. Key: FLINK-15703 URL: https://issues.apache.org/jira/browse/FLINK-15703 Project: Flink

[jira] [Updated] (FLINK-15703) FlinkKafkaConsumer should enable partition discovery by default.

[ https://issues.apache.org/jira/browse/FLINK-15703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-15703: - Fix Version/s: 1.11.0 > FlinkKafkaConsumer should enable partition discovery by default. > -

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

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: [FA

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

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: [SUCCESS](https://travis-ci

[GitHub] [flink] zhijiangW commented on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories

zhijiangW commented on issue #10736: [FLINK-15010][Network] Add shutdown hook to ensure cleanup netty shuffle directories URL: https://github.com/apache/flink/pull/10736#issuecomment-576503887 Thanks for the updates @gaoyunhaii ! I left some other comments and I think it is good to merge a

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test

flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add aarch64 support for container e2e test URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 Travis: [FAILURE](https://travis-ci.com/flink-c

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

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_r368798136 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/d

  1   2   3   4   5   >