[GitHub] [flink] zhengcanbin edited a comment on pull request #12003: [FLINK-10934] Support application mode for kubernetes

zhengcanbin edited a comment on pull request #12003: URL: https://github.com/apache/flink/pull/12003#issuecomment-625639474 > @zhengcanbin Thanks for chiming in and give your suggestion. When the application finished, the K8s resources will be destroyed automatically via

[GitHub] [flink] flinkbot commented on pull request #12027: [FLINK-17564][checkpointing] Fix buffer disorder issue of RemoteInputChannel for unaligned checkpoint

flinkbot commented on pull request #12027: URL: https://github.com/apache/flink/pull/12027#issuecomment-625644178 ## CI report: * 0e3ac198efdf799e34ffc78d2c2e5996d9e2d326 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.10.1

[ https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17565: - Description: Currently, we are using a version of 4.5.2, it's better that we upgrade it to

[GitHub] [flink] flinkbot edited a comment on pull request #12003: [FLINK-10934] Support application mode for kubernetes

flinkbot edited a comment on pull request #12003: URL: https://github.com/apache/flink/pull/12003#issuecomment-624416714 ## CI report: * 57b669055ef7388e1a70ed54263e9fca1b2f9fc8 Azure:

[jira] [Created] (FLINK-17565) Bump fabric8 version from 4.5.2 to 4.10.1

Canbin Zheng created FLINK-17565: Summary: Bump fabric8 version from 4.5.2 to 4.10.1 Key: FLINK-17565 URL: https://issues.apache.org/jira/browse/FLINK-17565 Project: Flink Issue Type:

[GitHub] [flink] wangyang0918 edited a comment on pull request #12003: [FLINK-10934] Support application mode for kubernetes

wangyang0918 edited a comment on pull request #12003: URL: https://github.com/apache/flink/pull/12003#issuecomment-625643363 @zhengcanbin I also find this issue when i test the K8s application mode. After adding small `sleep`(or any other command) via

[GitHub] [flink] wangyang0918 commented on pull request #12003: [FLINK-10934] Support application mode for kubernetes

wangyang0918 commented on pull request #12003: URL: https://github.com/apache/flink/pull/12003#issuecomment-625643363 @zhengcanbin I also find this issue when i test the K8s application mode. After add i small sleep(or any other command) via `kubernetes.container-start-command-template`.

[GitHub] [flink] wangyang0918 edited a comment on pull request #12003: [FLINK-10934] Support application mode for kubernetes

wangyang0918 edited a comment on pull request #12003: URL: https://github.com/apache/flink/pull/12003#issuecomment-625642618 @kl0u I am afraid that we could reuse`jarsOnClasspath` because it means the jar is located in the classpath. However, for K8s application, user could specify an

[GitHub] [flink] wangyang0918 commented on pull request #12003: [FLINK-10934] Support application mode for kubernetes

wangyang0918 commented on pull request #12003: URL: https://github.com/apache/flink/pull/12003#issuecomment-625642618 @kl0u I am afraid that we could reuse`jarsOnClasspath` because it means the jar is located in the classpath. However, for K8s application, user could specify an arbitrary

[GitHub] [flink] flinkbot commented on pull request #12027: [FLINK-17564][checkpointing] Fix buffer disorder issue of RemoteInputChannel for unaligned checkpoint

flinkbot commented on pull request #12027: URL: https://github.com/apache/flink/pull/12027#issuecomment-625639653 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] zhengcanbin edited a comment on pull request #12003: [FLINK-10934] Support application mode for kubernetes

zhengcanbin edited a comment on pull request #12003: URL: https://github.com/apache/flink/pull/12003#issuecomment-625639474 > @zhengcanbin Thanks for chiming in and give your suggestion. When the application finished, the K8s resources will be destroyed automatically via

[GitHub] [flink] zhengcanbin commented on pull request #12003: [FLINK-10934] Support application mode for kubernetes

zhengcanbin commented on pull request #12003: URL: https://github.com/apache/flink/pull/12003#issuecomment-625639474 > @zhengcanbin Thanks for chiming in and give your suggestion. When the application finished, the K8s resources will be destroyed automatically via

[jira] [Updated] (FLINK-17564) Inflight data of incoming channel may be disordered for unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-17564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17564: --- Labels: pull-request-available (was: ) > Inflight data of incoming channel may be

[GitHub] [flink] leonardBang commented on pull request #11897: [FLINK-16104] Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese

leonardBang commented on pull request #11897: URL: https://github.com/apache/flink/pull/11897#issuecomment-625639050 @chadnickbok Thanks very much for your contribution, LGTM now +1 to merge cc @wuchong This is an

[GitHub] [flink] wsry opened a new pull request #12027: [FLINK-17564][checkpointing] Fix buffer disorder issue of RemoteInputChannel for unaligned checkpoint

wsry opened a new pull request #12027: URL: https://github.com/apache/flink/pull/12027 ## What is the purpose of the change For unaligned checkpoint, when checkpointing the inflight data of incoming channel, both task thread and Netty thread may add data to the channel state

[GitHub] [flink] flinkbot edited a comment on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

flinkbot edited a comment on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-616956896 ## CI report: * b62fcd03a583ef204f21a313f6969c8aaa4ee61d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11950: [FLINK-17030] Add primary key syntax to DDL

flinkbot edited a comment on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621585318 ## CI report: * 3c28fb79878dfbbf4ed1c0aa21794793b76c3de5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11867: [FLINK-17309][e2e tests]TPC-DS fail to run data generator due to network issues

flinkbot edited a comment on pull request #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 24716ff4aefeed3998fab285e98f3605b282d5d6 Azure:

[GitHub] [flink] wangyang0918 commented on pull request #12003: [FLINK-10934] Support application mode for kubernetes

wangyang0918 commented on pull request #12003: URL: https://github.com/apache/flink/pull/12003#issuecomment-625636603 @zhengcanbin Thanks for chiming in and give your suggestion. When the application finished, the K8s resources will be destroyed automatically via

[GitHub] [flink] wangyang0918 commented on a change in pull request #12003: [FLINK-10934] Support application mode for kubernetes

wangyang0918 commented on a change in pull request #12003: URL: https://github.com/apache/flink/pull/12003#discussion_r421943976 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java ## @@ -222,6 +223,25 @@

[GitHub] [flink] becketqin commented on a change in pull request #12002: [FLINK-16845][connector/common] Add SourceOperator which runs the Source

becketqin commented on a change in pull request #12002: URL: https://github.com/apache/flink/pull/12002#discussion_r421942734 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -0,0 +1,192 @@ +/* + * Licensed to

[GitHub] [flink] becketqin commented on pull request #12002: [FLINK-16845][connector/common] Add SourceOperator which runs the Source

becketqin commented on pull request #12002: URL: https://github.com/apache/flink/pull/12002#issuecomment-625634506 @StephanEwen Thanks for the review. I only have one concern about the second comment on `withOperatorCoordinator`. > We need to attach the provider to the JobGraph in

[GitHub] [flink] wangyang0918 commented on a change in pull request #12003: [FLINK-10934] Support application mode for kubernetes

wangyang0918 commented on a change in pull request #12003: URL: https://github.com/apache/flink/pull/12003#discussion_r421924703 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -179,6 +187,22 @@ public static String

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

flinkbot edited a comment on pull request #12012: URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148 ## CI report: * 9eb4f7614554c10d94ca26461a79f34e2d4c4faa UNKNOWN * de9045a08d88f9142eca37e477dcb510c960cee2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12005: [hotfix][runtime] Remove never thrown IOException in ContinuousFileMnitoringFunction

flinkbot edited a comment on pull request #12005: URL: https://github.com/apache/flink/pull/12005#issuecomment-624580456 ## CI report: * 86a0e04b0e1108673aef8083dc9beb5c51aed0f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11950: [FLINK-17030] Add primary key syntax to DDL

flinkbot edited a comment on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621585318 ## CI report: * 6c17a82c89c97246c70a785fb9f2e4f61090a2f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11867: [FLINK-17309][e2e tests]TPC-DS fail to run data generator due to network issues

flinkbot edited a comment on pull request #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 24716ff4aefeed3998fab285e98f3605b282d5d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

flinkbot edited a comment on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-613965719 ## CI report: * abbd96a3ab0c75a09234ea792f5b9cf45df96e5e Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/164608033) Azure:

[GitHub] [flink] leonardBang commented on pull request #11867: [FLINK-17309][e2e tests]TPC-DS fail to run data generator due to network issues

leonardBang commented on pull request #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-625626884 Improve according to @dawidwys 's suggestion. This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

flinkbot edited a comment on pull request #12012: URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148 ## CI report: * 9eb4f7614554c10d94ca26461a79f34e2d4c4faa UNKNOWN * de9045a08d88f9142eca37e477dcb510c960cee2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11950: [FLINK-17030] Add primary key syntax to DDL

flinkbot edited a comment on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621585318 ## CI report: * 6c17a82c89c97246c70a785fb9f2e4f61090a2f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * 629b3b09009d667ed96fd41dff2e4d2b88323589 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

flinkbot edited a comment on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-616956896 ## CI report: * e69e1972a5934aed08c7fa655babd53365243ad9 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161778295) Azure:

[GitHub] [flink] xintongsong commented on a change in pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

xintongsong commented on a change in pull request #11920: URL: https://github.com/apache/flink/pull/11920#discussion_r421922013 ## File path: flink-external-resources/flink-external-resource-gpu/src/main/java/org/apache/flink/externalresource/gpu/GPUInfo.java ## @@ -0,0 +1,74

[jira] [Updated] (FLINK-16985) Specify job names for Stateful Functions examples

[ https://issues.apache.org/jira/browse/FLINK-16985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16985: --- Labels: pull-request-available (was: ) > Specify job names for Stateful Functions examples

[jira] [Closed] (FLINK-17561) Table program cannot be compiled

[ https://issues.apache.org/jira/browse/FLINK-17561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17561. --- Resolution: Duplicate Thanks for the verification, I will close this issue then. > Table program cannot

[GitHub] [flink] zhengcanbin commented on pull request #12003: [FLINK-10934] Support application mode for kubernetes

zhengcanbin commented on pull request #12003: URL: https://github.com/apache/flink/pull/12003#issuecomment-625621280 Thanks for raising this PR, @wangyang0918 @kl0u! I glanced at this PR quickly and a question comes to mind: is there an automatic way to clean up the K8s resources once

[jira] [Assigned] (FLINK-17564) Inflight data of incoming channel may be disordered for unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-17564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17564: Assignee: Yingjie Cao > Inflight data of incoming channel may be disordered for unaligned

[GitHub] [flink] flinkbot edited a comment on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

flinkbot edited a comment on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-616956896 ## CI report: * e69e1972a5934aed08c7fa655babd53365243ad9 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161778295) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * 629b3b09009d667ed96fd41dff2e4d2b88323589 Azure:

[jira] [Created] (FLINK-17564) Inflight data of incoming channel may be disordered for unaligned checkpoint

Yingjie Cao created FLINK-17564: --- Summary: Inflight data of incoming channel may be disordered for unaligned checkpoint Key: FLINK-17564 URL: https://issues.apache.org/jira/browse/FLINK-17564 Project:

[GitHub] [flink] wangyang0918 commented on a change in pull request #12003: [FLINK-10934] Support application mode for kubernetes

wangyang0918 commented on a change in pull request #12003: URL: https://github.com/apache/flink/pull/12003#discussion_r421924703 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -179,6 +187,22 @@ public static String

[GitHub] [flink] wangyang0918 commented on a change in pull request #12003: [FLINK-10934] Support application mode for kubernetes

wangyang0918 commented on a change in pull request #12003: URL: https://github.com/apache/flink/pull/12003#discussion_r421923571 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java ## @@ -146,8 +148,38 @@ public String

[GitHub] [flink] flinkbot edited a comment on pull request #12013: [FLINK-17256] Suppport keyword arguments in the PyFlink Descriptor API.

flinkbot edited a comment on pull request #12013: URL: https://github.com/apache/flink/pull/12013#issuecomment-625012004 ## CI report: * f944068753b75ad2e89e849877055f2f31739704 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

flinkbot edited a comment on pull request #12012: URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148 ## CI report: * 9eb4f7614554c10d94ca26461a79f34e2d4c4faa UNKNOWN * de9045a08d88f9142eca37e477dcb510c960cee2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

flinkbot edited a comment on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-613965719 ## CI report: * 7b08a28c34fb43dbea4d0c280fffc8e6bdcbb8b5 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162649700) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11897: [FLINK-16104] Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese

flinkbot edited a comment on pull request #11897: URL: https://github.com/apache/flink/pull/11897#issuecomment-618812841 ## CI report: * 67027fc17a69ef4edc8300e4b82a9e1233b016ee UNKNOWN * 836c6bce67b366939d524f928f0796a18abbf3ec Travis:

[GitHub] [flink-statefun] abc863377 commented on pull request #106: Stateful Functions Examples have their specific job names

abc863377 commented on pull request #106: URL: https://github.com/apache/flink-statefun/pull/106#issuecomment-625615368 @tzulitai Can you please review it? This is an automated message from the Apache Git Service. To

[GitHub] [flink] wangyang0918 commented on a change in pull request #12003: [FLINK-10934] Support application mode for kubernetes

wangyang0918 commented on a change in pull request #12003: URL: https://github.com/apache/flink/pull/12003#discussion_r421920149 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ClassPathPackagedProgramRetriever.java ## @@ -75,16 +75,21

[jira] [Commented] (FLINK-17491) Translate Training page on project website

[ https://issues.apache.org/jira/browse/FLINK-17491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102213#comment-17102213 ] Li Ying commented on FLINK-17491: - Hi [~alpinegizmo] , I can help translate this page. Could you please

[GitHub] [flink] wuchong commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

wuchong commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421916467 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/DynamicTableSourceITCase.scala ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #11996: [hotfix][runtime] Fix code style in ZooKeeperJobGraphStore

flinkbot edited a comment on pull request #11996: URL: https://github.com/apache/flink/pull/11996#issuecomment-624002854 ## CI report: * c20850191e2ceb572a83863c0d0d252dbf01ee51 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12005: [hotfix][runtime] Remove never thrown IOException in ContinuousFileMnitoringFunction

flinkbot edited a comment on pull request #12005: URL: https://github.com/apache/flink/pull/12005#issuecomment-624580456 ## CI report: * 912ca2eda8585788975c062b1d6bd78cb012d8d8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

flinkbot edited a comment on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-613965719 ## CI report: * 7b08a28c34fb43dbea4d0c280fffc8e6bdcbb8b5 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162649700) Azure:

[GitHub] [flink] danny0405 commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

danny0405 commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421915899 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/DynamicTableSourceITCase.scala ##

[GitHub] [flink] wuchong commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

wuchong commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421915497 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalTableSourceScan.scala

[GitHub] [flink] wuchong commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

wuchong commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421914970 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/CatalogSourceTable.scala ## @@ -226,4

[GitHub] [flink] wuchong commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

wuchong commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421914394 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/CatalogSourceTable.scala ## @@ -226,4

[GitHub] [flink] wuchong commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

wuchong commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421914078 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/trait/UpdateKindTrait.scala ## @@ -95,4 +98,17 @@

[GitHub] [flink] wuchong commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

wuchong commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421913683 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala

[jira] [Commented] (FLINK-17561) Table program cannot be compiled

[ https://issues.apache.org/jira/browse/FLINK-17561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102201#comment-17102201 ] linweijiang commented on FLINK-17561: - Hi Jark Wu, I have try on the latset 1.10.1 RC, this

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r421912378 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/shuffle/KafkaShuffleITCase.java ## @@ -0,0

[GitHub] [flink] danny0405 commented on a change in pull request #11950: [FLINK-17030] Add primary key syntax to DDL

danny0405 commented on a change in pull request #11950: URL: https://github.com/apache/flink/pull/11950#discussion_r421912499 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/catalog/CatalogTableITCase.scala ## @@ -919,6

[jira] [Created] (FLINK-17563) YARN Setup page has a broken link

AT-Fieldless created FLINK-17563: Summary: YARN Setup page has a broken link Key: FLINK-17563 URL: https://issues.apache.org/jira/browse/FLINK-17563 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 42953325bb1d6a447ef53e020d3cc311a8c986c6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12005: [hotfix][runtime] Remove never thrown IOException in ContinuousFileMnitoringFunction

flinkbot edited a comment on pull request #12005: URL: https://github.com/apache/flink/pull/12005#issuecomment-624580456 ## CI report: * 912ca2eda8585788975c062b1d6bd78cb012d8d8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

flinkbot edited a comment on pull request #12012: URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148 ## CI report: * 9eb4f7614554c10d94ca26461a79f34e2d4c4faa UNKNOWN * de9045a08d88f9142eca37e477dcb510c960cee2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12025: [FLINK-17435] [hive] Hive non-partitioned source supports streaming read

flinkbot edited a comment on pull request #12025: URL: https://github.com/apache/flink/pull/12025#issuecomment-625292121 ## CI report: * 536fe9b624ee00e02522c57cb904a4c795d425c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

flinkbot edited a comment on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-619909940 ## CI report: * 1d4794e9372856fd254b6aa958e9c5c340e9885b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11996: [hotfix][runtime] Fix code style in ZooKeeperJobGraphStore

flinkbot edited a comment on pull request #11996: URL: https://github.com/apache/flink/pull/11996#issuecomment-624002854 ## CI report: * c20850191e2ceb572a83863c0d0d252dbf01ee51 Azure:

[GitHub] [flink] danny0405 commented on a change in pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

danny0405 commented on a change in pull request #11985: URL: https://github.com/apache/flink/pull/11985#discussion_r421898493 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalTableSourceScan.scala

[GitHub] [flink] flinkbot edited a comment on pull request #11897: [FLINK-16104] Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese

flinkbot edited a comment on pull request #11897: URL: https://github.com/apache/flink/pull/11897#issuecomment-618812841 ## CI report: * 67027fc17a69ef4edc8300e4b82a9e1233b016ee UNKNOWN * 836c6bce67b366939d524f928f0796a18abbf3ec Travis:

[GitHub] [flink] jinglining commented on a change in pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

jinglining commented on a change in pull request #11752: URL: https://github.com/apache/flink/pull/11752#discussion_r421909272 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/SubtaskAllExecutionAttemptsDetailsHandlerTest.java ## @@ -0,0

[GitHub] [flink] jinglining commented on a change in pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

jinglining commented on a change in pull request #11752: URL: https://github.com/apache/flink/pull/11752#discussion_r421908677 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskAllExecutionAttemptsDetailsInfo.java ## @@ -0,0 +1,69 @@

[GitHub] [flink] jinglining commented on a change in pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

jinglining commented on a change in pull request #11752: URL: https://github.com/apache/flink/pull/11752#discussion_r421908677 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskAllExecutionAttemptsDetailsInfo.java ## @@ -0,0 +1,69 @@

[jira] [Updated] (FLINK-17562) Monitoring REST API page has duplicate items

[ https://issues.apache.org/jira/browse/FLINK-17562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] AT-Fieldless updated FLINK-17562: - Description: Monitoring REST API has two */jars/:jarid/plan* column and there descriptions are

[jira] [Created] (FLINK-17562) Monitoring REST API page has duplicate items

AT-Fieldless created FLINK-17562: Summary: Monitoring REST API page has duplicate items Key: FLINK-17562 URL: https://issues.apache.org/jira/browse/FLINK-17562 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-17561) Table program cannot be compiled

[ https://issues.apache.org/jira/browse/FLINK-17561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102193#comment-17102193 ] Jark Wu commented on FLINK-17561: - I think this is related to FLINK-16662 and is fixed in 1.10.1. Could

[jira] [Commented] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

[ https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102192#comment-17102192 ] Xintong Song commented on FLINK-17560: -- Hi [~josson], Could you provide the complete logs for this

[GitHub] [flink] jinglining commented on a change in pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

jinglining commented on a change in pull request #11752: URL: https://github.com/apache/flink/pull/11752#discussion_r421907421 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtaskAllExecutionAttemptsDetailsHandler.java ## @@ -0,0 +1,90

[jira] [Commented] (FLINK-17561) Table program cannot be compiled

[ https://issues.apache.org/jira/browse/FLINK-17561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102188#comment-17102188 ] linweijiang commented on FLINK-17561: - This job is running well on local idea environment > Table

[jira] [Created] (FLINK-17561) Table program cannot be compiled

linweijiang created FLINK-17561: --- Summary: Table program cannot be compiled Key: FLINK-17561 URL: https://issues.apache.org/jira/browse/FLINK-17561 Project: Flink Issue Type: Bug

[GitHub] [flink] klion26 commented on a change in pull request #11961: [FLINK-16097] Translate "SQL Client" page of "Table API & SQL" into Chinese

klion26 commented on a change in pull request #11961: URL: https://github.com/apache/flink/pull/11961#discussion_r421903374 ## File path: docs/dev/table/sqlClient.zh.md ## @@ -98,26 +97,28 @@ In *changelog mode*, the visualized changelog should be similar to: + Bob, 2 {%

[jira] [Comment Edited] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102173#comment-17102173 ] Yang Wang edited comment on FLINK-17416 at 5/8/20, 2:35 AM: [~wangxiyuan] 

[GitHub] [flink] xintongsong commented on pull request #11300: [FLINK-16406] Increase default value for JVM Metaspace to minimise its OutOfMemoryError

xintongsong commented on pull request #11300: URL: https://github.com/apache/flink/pull/11300#issuecomment-625595730 @DestyNova, Flink does not provide class loading/unloading tracing. However, you can do that by manually specifiying JVM options. You can add `-XX:+TraceClassLoading

[GitHub] [flink-web] wuchong commented on pull request #335: Add Blog: "Flink SQL Demo: Building an End to End Streaming Application"

wuchong commented on pull request #335: URL: https://github.com/apache/flink-web/pull/335#issuecomment-625595264 Hi @tweise , what you said makes sense. I'm also fine to dockerize the Flink cluster and update the blog. I'm currently working on the 1.11 remaining things, will find some

[jira] [Updated] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17416: -- Attachment: log.k8s.session.8u252 > Flink-kubernetes doesn't work on java 8 8u252 >

[GitHub] [flink] flinkbot edited a comment on pull request #12025: [FLINK-17435] [hive] Hive non-partitioned source supports streaming read

flinkbot edited a comment on pull request #12025: URL: https://github.com/apache/flink/pull/12025#issuecomment-625292121 ## CI report: * 30dd6061f66d0c4e0935a9b3537a608ee3db69cd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

flinkbot edited a comment on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-619909940 ## CI report: * b881303266261a94d9a8b204d6a8e74627351af5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11897: [FLINK-16104] Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese

flinkbot edited a comment on pull request #11897: URL: https://github.com/apache/flink/pull/11897#issuecomment-618812841 ## CI report: * 67027fc17a69ef4edc8300e4b82a9e1233b016ee UNKNOWN * da909ac1e2831251bf60375a080cc192e4e4a0c8 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 4223a26640c7243a61135e803aa1dd21888114a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12013: [FLINK-17256] Suppport keyword arguments in the PyFlink Descriptor API.

flinkbot edited a comment on pull request #12013: URL: https://github.com/apache/flink/pull/12013#issuecomment-625012004 ## CI report: * bf3e52bd65e83f2b101a2f2949c27d1fcf1fca82 Azure:

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17553: --- Fix Version/s: 1.11.0 > Constant exists in group window key leads to error: Unsupported call: >

[GitHub] [flink] flinkbot edited a comment on pull request #11666: [FLINK-17038][API/DataStream] Decouple resolving Type from creating TypeInformation process

flinkbot edited a comment on pull request #11666: URL: https://github.com/apache/flink/pull/11666#issuecomment-610769013 ## CI report: * d91f3fbd578442d8ce7498df6cec11d809156105 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/164601275) Azure:

[GitHub] [flink] liying919 commented on a change in pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

liying919 commented on a change in pull request #12012: URL: https://github.com/apache/flink/pull/12012#discussion_r421899397 ## File path: docs/training/etl.zh.md ## @@ -231,13 +200,9 @@ DataStream> minutesByStartCell = enrichedNYCRides }); {% endhighlight %} -Now it

[GitHub] [flink] liying919 commented on a change in pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

liying919 commented on a change in pull request #12012: URL: https://github.com/apache/flink/pull/12012#discussion_r421897573 ## File path: docs/training/etl.zh.md ## @@ -262,65 +227,51 @@ The output stream now contains a record for each key every time the duration rea

[GitHub] [flink] liying919 commented on a change in pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

liying919 commented on a change in pull request #12012: URL: https://github.com/apache/flink/pull/12012#discussion_r421897573 ## File path: docs/training/etl.zh.md ## @@ -262,65 +227,51 @@ The output stream now contains a record for each key every time the duration rea

[GitHub] [flink] flinkbot edited a comment on pull request #12012: [FLINK-17289][docs]Translate tutorials/etl.md to Chinese

flinkbot edited a comment on pull request #12012: URL: https://github.com/apache/flink/pull/12012#issuecomment-624987148 ## CI report: * 9eb4f7614554c10d94ca26461a79f34e2d4c4faa UNKNOWN * de9045a08d88f9142eca37e477dcb510c960cee2 UNKNOWN *

  1   2   3   4   5   >