[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #10455: [FLINK-15089][connectors] Puslar catalog

flinkbot edited a comment on issue #10455: [FLINK-15089][connectors] Puslar catalog URL: https://github.com/apache/flink/pull/10455#issuecomment-562462991 ## CI report: * 206bb09e47ff4f36514a93c96f7cadc30f62cd4b : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/13965

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354702929 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] flinkbot commented on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

flinkbot commented on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562472069 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pul

[GitHub] [flink] TsReaper commented on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List

TsReaper commented on issue #10306: [FLINK-13943][table-api] Provide utility method to convert Flink table to Java List URL: https://github.com/apache/flink/pull/10306#issuecomment-562471647 Travis passed: https://travis-ci.com/TsReaper/flink/builds/139638323 --

[GitHub] [flink] wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354702467 ## File path: flink-core/src/main/java/org/apache/flink/configuration

[jira] [Updated] (FLINK-14815) Expose network metric in IOMetricsInfo

[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14815: --- Labels: pull-request-available (was: ) > Expose network metric in IOMetricsInfo > -

[GitHub] [flink] jinglining opened a new pull request #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

jinglining opened a new pull request #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458 ## What is the purpose of the change - Expose network metric in IOMetricsInfo - JobVertex exposes is-backpressed、out-

[GitHub] [flink] flinkbot edited a comment on issue #10422: [FLINK-15057][tests] Set JM and TM memory config in flink-conf.yaml

flinkbot edited a comment on issue #10422: [FLINK-15057][tests] Set JM and TM memory config in flink-conf.yaml URL: https://github.com/apache/flink/pull/10422#issuecomment-561743112 ## CI report: * 88f6f7790d8bb0b517958be4446e95146605c369 : FAILURE [Build](https://travis-ci.com/

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354701520 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResource

[jira] [Commented] (FLINK-15087) JobManager is forced to shutdown JVM due to temporary loss of zookeeper connection

[ https://issues.apache.org/jira/browse/FLINK-15087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989482#comment-16989482 ] lamber-ken commented on FLINK-15087: hi, this may be is a duplicate of FLINK-10052.

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354672644 ## File path: flink-clients/src/main/java/org/apache/

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354685811 ## File path: flink-python/pyflink/common/tests/test_p

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354660340 ## File path: flink-clients/src/main/java/org/apache/

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354669358 ## File path: flink-clients/src/main/java/org/apache/

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354672690 ## File path: flink-clients/src/main/java/org/apache/

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354675266 ## File path: flink-python/pyflink/common/dependency_m

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354672570 ## File path: flink-clients/src/main/java/org/apache/

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354677710 ## File path: flink-python/src/main/java/org/apache/f

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354671048 ## File path: flink-clients/src/main/java/org/apache/

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354671362 ## File path: flink-clients/src/main/java/org/apache/

[GitHub] [flink] dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies.

dianfu commented on a change in pull request #10430: [FLINK-14019][python][cli] Add command-line options for managing Python UDF environment and dependencies. URL: https://github.com/apache/flink/pull/10430#discussion_r354674349 ## File path: flink-clients/src/main/java/org/apache/

[GitHub] [flink] flinkbot edited a comment on issue #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py

flinkbot edited a comment on issue #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py URL: https://github.com/apache/flink/pull/10389#issuecomment-560984209 ## CI report: * ebc6a4396f71fda053e32ed71994

[GitHub] [flink] flinkbot edited a comment on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner

flinkbot edited a comment on issue #10315: [FLINK-14552][table] Enable partition statistics in blink planner URL: https://github.com/apache/flink/pull/10315#issuecomment-558221318 ## CI report: * 05b30617c280796e80e8569dae48b726cddb23d8 : FAILURE [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot commented on issue #10456: [FLINK-15091][table-planner-blink] Fix memory overused in SortMergeJoinOperator

flinkbot commented on issue #10456: [FLINK-15091][table-planner-blink] Fix memory overused in SortMergeJoinOperator URL: https://github.com/apache/flink/pull/10456#issuecomment-562468186 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] TisonKun closed pull request #10457: !FOR TESTING!

TisonKun closed pull request #10457: !FOR TESTING! URL: https://github.com/apache/flink/pull/10457 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink] TisonKun opened a new pull request #10457: !FOR TESTING!

TisonKun opened a new pull request #10457: !FOR TESTING! URL: https://github.com/apache/flink/pull/10457 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-15091) JoinITCase.testFullJoinWithNonEquiJoinPred failed in travis

[ https://issues.apache.org/jira/browse/FLINK-15091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15091: --- Labels: pull-request-available (was: ) > JoinITCase.testFullJoinWithNonEquiJoinPred failed

[GitHub] [flink] JingsongLi opened a new pull request #10456: [FLINK-15091][table-planner-blink] Fix memory overused in SortMergeJoinOperator

JingsongLi opened a new pull request #10456: [FLINK-15091][table-planner-blink] Fix memory overused in SortMergeJoinOperator URL: https://github.com/apache/flink/pull/10456 ## What is the purpose of the change In SortMergeJoinOperator, we should check if it is a full join, then w

[GitHub] [flink] KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient

KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient URL: https://github.com/apache/flink/pull/10454#discussion_r354685477 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/clien

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354697346 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354697070 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354697186 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354696896 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354696517 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] JingsongLi commented on a change in pull request #10452: [FLINK-15035][table-planner-blink] Introduce unknown memory setting to table in blink planner

JingsongLi commented on a change in pull request #10452: [FLINK-15035][table-planner-blink] Introduce unknown memory setting to table in blink planner URL: https://github.com/apache/flink/pull/10452#discussion_r354681473 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354695465 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] lamber-ken commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

lamber-ken commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-562464972 @flinkbot run travis This is an automated message from the Apache Git

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354694048 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354693688 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] flinkbot commented on issue #10455: [FLINK-15089][connectors] Puslar catalog

flinkbot commented on issue #10455: [FLINK-15089][connectors] Puslar catalog URL: https://github.com/apache/flink/pull/10455#issuecomment-562462991 ## CI report: * 206bb09e47ff4f36514a93c96f7cadc30f62cd4b : UNKNOWN Bot commands The @flinkbot bot supports the follow

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354693480 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354692195 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354692195 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResou

[GitHub] [flink] flinkbot edited a comment on issue #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties

flinkbot edited a comment on issue #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties URL: https://github.com/apache/flink/pull/10403#issuecomment-561208418 ## CI report: * 038052c833940fbaef3111ed92525216f13edee2 : FAIL

[GitHub] [flink] flinkbot edited a comment on issue #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py

flinkbot edited a comment on issue #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py URL: https://github.com/apache/flink/pull/10389#issuecomment-560984209 ## CI report: * ebc6a4396f71fda053e32ed71994

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354691495 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] wuchong commented on a change in pull request #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties

wuchong commented on a change in pull request #10403: [FLINK-14645][table] Support to keep nullability and precision when converting DataTypes to properties URL: https://github.com/apache/flink/pull/10403#discussion_r354691466 ## File path: flink-table/flink-table-api-java-bridge/

[GitHub] [flink] wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

wsry commented on a change in pull request #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#discussion_r354691010 ## File path: flink-core/src/main/java/org/apache/flink/configuration

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354690468 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354690623 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/Activ

[GitHub] [flink] flinkbot edited a comment on issue #10246: [FLINK-10937][dist] Add kubernetes-entry.sh and kubernetes-session.sh.

flinkbot edited a comment on issue #10246: [FLINK-10937][dist] Add kubernetes-entry.sh and kubernetes-session.sh. URL: https://github.com/apache/flink/pull/10246#issuecomment-555375256 ## CI report: * 9f06575f29a7cb1102357c8919b57b3471dc80fd : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354690086 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

wangyang0918 commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354689980 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/Activ

[jira] [Created] (FLINK-15091) JoinITCase.testFullJoinWithNonEquiJoinPred failed in travis

Kurt Young created FLINK-15091: -- Summary: JoinITCase.testFullJoinWithNonEquiJoinPred failed in travis Key: FLINK-15091 URL: https://issues.apache.org/jira/browse/FLINK-15091 Project: Flink Issu

[GitHub] [flink] wangxlong commented on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns

wangxlong commented on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns URL: https://github.com/apache/flink/pull/10369#issuecomment-562458580 > > > @wangxlong thanks for your contribution. Changes look good to me. It

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354689510 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] wangxlong closed pull request #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns

wangxlong closed pull request #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns URL: https://github.com/apache/flink/pull/10369 This is an automated message

[jira] [Closed] (FLINK-14552) Enable partition statistics in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14552. -- Fix Version/s: 1.10.0 Resolution: Fixed master: 0d6b43959bb6a576c95549e845f7db5e51229740 > Ena

[GitHub] [flink] WeiZhong94 commented on issue #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py

WeiZhong94 commented on issue #10389: [FLINK-14198][python] Add "type" and "rtype" options to flink python API docstrings of table.py and table_environment.py URL: https://github.com/apache/flink/pull/10389#issuecomment-562457573 @sunjincheng121 Thanks for your review! I have addressed you

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354687863 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] flinkbot commented on issue #10455: [FLINK-15089][connectors] Puslar catalog

flinkbot commented on issue #10455: [FLINK-15089][connectors] Puslar catalog URL: https://github.com/apache/flink/pull/10455#issuecomment-562457258 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] KurtYoung merged pull request #10315: [FLINK-14552][table] Enable partition statistics in blink planner

KurtYoung merged pull request #10315: [FLINK-14552][table] Enable partition statistics in blink planner URL: https://github.com/apache/flink/pull/10315 This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-15089) Pulsar Catalog

[ https://issues.apache.org/jira/browse/FLINK-15089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15089: --- Labels: pull-request-available (was: ) > Pulsar Catalog > -- > >

[GitHub] [flink] yjshen opened a new pull request #10455: [FLINK-15089][connectors] Puslar catalog

yjshen opened a new pull request #10455: [FLINK-15089][connectors] Puslar catalog URL: https://github.com/apache/flink/pull/10455 ## What is the purpose of the change This PR implements Pulsar catalog which is part of [FLIP-72](https://cwiki.apache.org/confluence/display/FLINK/FLIP-

[jira] [Updated] (FLINK-15090) Reverse the dependency from flink-streaming-java to flink-client

[ https://issues.apache.org/jira/browse/FLINK-15090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-15090: -- Description: After FLIP-73 the dependencies are minor. Tasks I can find are 1. Move {{StreamGraphTran

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354687863 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResource

[jira] [Updated] (FLINK-15090) Reverse the dependency from flink-streaming-java to flink-client

[ https://issues.apache.org/jira/browse/FLINK-15090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-15090: -- Description: After FLIP-73 the dependencies are minor. Tasks I can find are 1. Move {{StreamGraphTran

[jira] [Created] (FLINK-15090) Reverse the dependency from flink-streaming-java to flink-client

Zili Chen created FLINK-15090: - Summary: Reverse the dependency from flink-streaming-java to flink-client Key: FLINK-15090 URL: https://issues.apache.org/jira/browse/FLINK-15090 Project: Flink I

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354682702 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354682441 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354680696 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ActiveRe

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354685294 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354672522 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ActiveRe

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354685039 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354682932 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r354685940 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResource

[GitHub] [flink] KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient

KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient URL: https://github.com/apache/flink/pull/10454#discussion_r354682103 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/clien

[GitHub] [flink] KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient

KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient URL: https://github.com/apache/flink/pull/10454#discussion_r354685477 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/clien

[GitHub] [flink] KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient

KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient URL: https://github.com/apache/flink/pull/10454#discussion_r354684030 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/clien

[GitHub] [flink] KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient

KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient URL: https://github.com/apache/flink/pull/10454#discussion_r354684496 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/clien

[GitHub] [flink] KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient

KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient URL: https://github.com/apache/flink/pull/10454#discussion_r354684576 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/clien

[GitHub] [flink] KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient

KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient URL: https://github.com/apache/flink/pull/10454#discussion_r354683491 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/clien

[jira] [Commented] (FLINK-14952) Yarn containers can exceed physical memory limits when using BoundedBlockingSubpartition.

[ https://issues.apache.org/jira/browse/FLINK-14952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989448#comment-16989448 ] Yingjie Cao commented on FLINK-14952: - [~gjy] By "FILE-FILE" mode, I mean using Boun

[GitHub] [flink] KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient

KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient URL: https://github.com/apache/flink/pull/10454#discussion_r354684829 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/clien

[GitHub] [flink] KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient

KurtYoung commented on a change in pull request #10454: [FLINK-13195][sql-client] Add create(drop) table support for SqlClient URL: https://github.com/apache/flink/pull/10454#discussion_r354683869 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/clien

[GitHub] [flink] flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

flinkbot edited a comment on issue #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#issuecomment-545881191 ## CI report: * 802ebf37e3d932169f9826b40df483bb5e9ac064 : SUCCESS [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot edited a comment on issue #10453: [FLINK-14026][python] Manage the resource of Python worker properly

flinkbot edited a comment on issue #10453: [FLINK-14026][python] Manage the resource of Python worker properly URL: https://github.com/apache/flink/pull/10453#issuecomment-562427019 ## CI report: * 3204767d620e3f8469819ef3155a6cc559745860 : CANCELED [Build](https://travis-ci.com

[jira] [Created] (FLINK-15089) Pulsar Catalog

Yijie Shen created FLINK-15089: -- Summary: Pulsar Catalog Key: FLINK-15089 URL: https://issues.apache.org/jira/browse/FLINK-15089 Project: Flink Issue Type: Sub-task Components: Connect

[GitHub] [flink] flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle.

flinkbot edited a comment on issue #10375: [FLINK-14845][runtime] Introduce data compression to reduce disk and network IO of shuffle. URL: https://github.com/apache/flink/pull/10375#issuecomment-560214201 ## CI report: * af7ab17308bafebf22198881ad59ec4516da43e2 : SUCCESS [Build

[GitHub] [flink] cshuo commented on a change in pull request #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute

cshuo commented on a change in pull request #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute URL: https://github.com/apache/flink/pull/10316#discussion_r354680497 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table

[GitHub] [flink] cshuo commented on a change in pull request #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute

cshuo commented on a change in pull request #10316: [FLINK-14624][table-blink] Support computed column as rowtime attribute URL: https://github.com/apache/flink/pull/10316#discussion_r354677891 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/tabl

[GitHub] [flink] JingsongLi commented on a change in pull request #10452: [FLINK-15035][table-planner-blink] Introduce unknown memory setting to table in blink planner

JingsongLi commented on a change in pull request #10452: [FLINK-15035][table-planner-blink] Introduce unknown memory setting to table in blink planner URL: https://github.com/apache/flink/pull/10452#discussion_r354681473 ## File path: flink-table/flink-table-planner-blink/src/main

[GitHub] [flink] flinkbot edited a comment on issue #10449: [FLINK-7289][state-backend] Integrate RocksDB memory use with managed memory

flinkbot edited a comment on issue #10449: [FLINK-7289][state-backend] Integrate RocksDB memory use with managed memory URL: https://github.com/apache/flink/pull/10449#issuecomment-562311621 ## CI report: * 354f5dcf865b2de3b8b426ae40f6633ff1755e4a : FAILURE [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #10453: [FLINK-14026][python] Manage the resource of Python worker properly

flinkbot edited a comment on issue #10453: [FLINK-14026][python] Manage the resource of Python worker properly URL: https://github.com/apache/flink/pull/10453#issuecomment-562427019 ## CI report: * 3204767d620e3f8469819ef3155a6cc559745860 : CANCELED [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #10445: [FLINK-14407][yarn] Retry S3 tests on failure

flinkbot edited a comment on issue #10445: [FLINK-14407][yarn] Retry S3 tests on failure URL: https://github.com/apache/flink/pull/10445#issuecomment-562177526 ## CI report: * 9709c3ce629fb1ee84c180a92b9077dc56a18ab0 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/

[GitHub] [flink] TisonKun edited a comment on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns

TisonKun edited a comment on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns URL: https://github.com/apache/flink/pull/10369#issuecomment-562445489 > > @wangxlong thanks for your contribution. Changes look good to me

[GitHub] [flink] TisonKun commented on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns

TisonKun commented on issue #10369: [FLINK-14893][flink-core]Try child classLoader when parent classLoader could not load in parentFirstPatterns URL: https://github.com/apache/flink/pull/10369#issuecomment-562445489 > > @wangxlong thanks for your contribution. Changes look good to me. It w

[GitHub] [flink] xintongsong edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

xintongsong edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-562425217 PR updatesd. As discussed with Andrey and Till offline, we removed the changes t

  1   2   3   4   5   6   7   8   9   10   >