[jira] [Commented] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082920#comment-17082920 ] Till Rohrmann commented on FLINK-13553: --- [~gjy] do you think that this issue has b

[jira] [Comment Edited] (FLINK-16750) Kerberized YARN on Docker test fails due to stalling Hadoop cluster

[ https://issues.apache.org/jira/browse/FLINK-16750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082917#comment-17082917 ] Till Rohrmann edited comment on FLINK-16750 at 4/14/20, 6:54 AM: -

[jira] [Commented] (FLINK-16750) Kerberized YARN on Docker test fails due to stalling Hadoop cluster

[ https://issues.apache.org/jira/browse/FLINK-16750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082917#comment-17082917 ] Till Rohrmann commented on FLINK-16750: --- [~fly_in_gis] I've assigned you to this t

[jira] [Assigned] (FLINK-16750) Kerberized YARN on Docker test fails due to stalling Hadoop cluster

[ https://issues.apache.org/jira/browse/FLINK-16750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-16750: - Assignee: Yang Wang > Kerberized YARN on Docker test fails due to stalling Hadoop clust

[GitHub] [flink] wsry commented on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode()

wsry commented on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode() URL: https://github.com/apache/flink/pull/11713#issuecomment-613259671 @carp84 I checked the history information and

[GitHub] [flink] flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client.

flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client. URL: https://github.com/apache/flink/pull/11702#issuecomment-612221236 ## CI report: * 592e6f6af689c4d0fa7269c90cf81feafa98cd09 Travis: [

[GitHub] [flink] flinkbot commented on issue #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context

flinkbot commented on issue #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context URL: https://github.com/apache/flink/pull/11726#issuecomment-613258923 ## CI report: * f63b3f6b25177bee8063fbcdf84224c15988a0eb UNKNOWN Bot commands The @flinkbot bo

[GitHub] [flink] flinkbot edited a comment on issue #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on issue #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * e8a76909539302fd9935d912a07fb9ddb580c905 Travis: [PENDING](https://travis-ci.com/

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN *

[GitHub] [flink] flinkbot commented on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

flinkbot commented on issue #11727: [FLINK-17106][table] Support create and drop view in Flink SQL URL: https://github.com/apache/flink/pull/11727#issuecomment-613258404 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review you

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * 64d432e8d0dd466f520b3d3819b42f5476001b08 UNKNOWN * d7614a91339e39c2cd496007a86151c40440bae1 Trav

[jira] [Updated] (FLINK-17106) Support create/drop view in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17106: --- Labels: pull-request-available (was: ) > Support create/drop view in Flink SQL > --

[GitHub] [flink] docete opened a new pull request #11727: [FLINK-17106][table] Support create and drop view in Flink SQL

docete opened a new pull request #11727: [FLINK-17106][table] Support create and drop view in Flink SQL URL: https://github.com/apache/flink/pull/11727 ## What is the purpose of the change As discussed in FLIP-71, This pr add a queryable view support in Flink SQL, that is: - `CREATE

[GitHub] [flink] flinkbot commented on issue #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context

flinkbot commented on issue #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context URL: https://github.com/apache/flink/pull/11726#issuecomment-613256260 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review you

[jira] [Closed] (FLINK-17129) 【Flink Kafka Connector】The DDL config(connector.properties.zookeeper.connect) could be optioanal

[ https://issues.apache.org/jira/browse/FLINK-17129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17129. --- Fix Version/s: (was: 1.11.0) Resolution: Duplicate > 【Flink Kafka Connector】The DDL config(connec

[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=17082909#comment-17082909 ] Yuan Mei edited comment on FLINK-15670 at 4/14/20, 6:40 AM:

[jira] [Updated] (FLINK-17128) Add isBounded to TableSinkFactory#Context

[ https://issues.apache.org/jira/browse/FLINK-17128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17128: --- Labels: pull-request-available (was: ) > Add isBounded to TableSinkFactory#Context > --

[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=17082909#comment-17082909 ] Yuan Mei commented on FLINK-15670: -- Pull Request is filed: [#11725|https://github.com/a

[GitHub] [flink] JingsongLi opened a new pull request #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context

JingsongLi opened a new pull request #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context URL: https://github.com/apache/flink/pull/11726 ## What is the purpose of the change For current table environment, the difference between batch and streaming is very clea

[jira] [Updated] (FLINK-17128) Add isBounded to TableSinkFactory#Context

[ https://issues.apache.org/jira/browse/FLINK-17128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17128: - Component/s: Table SQL / API > Add isBounded to TableSinkFactory#Context > -

[jira] [Created] (FLINK-17129) 【Flink Kafka Connector】The DDL config(connector.properties.zookeeper.connect) could be optioanal

zhisheng created FLINK-17129: Summary: 【Flink Kafka Connector】The DDL config(connector.properties.zookeeper.connect) could be optioanal Key: FLINK-17129 URL: https://issues.apache.org/jira/browse/FLINK-17129

[jira] [Updated] (FLINK-17128) Add isBounded to TableSinkFactory#Context

[ https://issues.apache.org/jira/browse/FLINK-17128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17128: - Fix Version/s: 1.11.0 > Add isBounded to TableSinkFactory#Context >

[jira] [Created] (FLINK-17128) Add isBounded to TableSinkFactory#Context

Jingsong Lee created FLINK-17128: Summary: Add isBounded to TableSinkFactory#Context Key: FLINK-17128 URL: https://issues.apache.org/jira/browse/FLINK-17128 Project: Flink Issue Type: Sub-tas

[GitHub] [flink] flinkbot commented on issue #11725: [FLINK-15670] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot commented on issue #11725: [FLINK-15670] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * e8a76909539302fd9935d912a07fb9ddb580c905 UNKNOWN Bot commands The @flinkbot bo

[GitHub] [flink] flinkbot edited a comment on issue #11640: add end-to-end-performance test

flinkbot edited a comment on issue #11640: add end-to-end-performance test URL: https://github.com/apache/flink/pull/11640#issuecomment-609448172 ## CI report: * 1e9db03f21a788a407fc320c03f1001b0aa8e763 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/16015639

[GitHub] [flink] flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config

flinkbot edited a comment on issue #11481: [FLINK-13691][Table]Remove deprecated query config URL: https://github.com/apache/flink/pull/11481#issuecomment-602174011 ## CI report: * 64d432e8d0dd466f520b3d3819b42f5476001b08 UNKNOWN * d7614a91339e39c2cd496007a86151c40440bae1 Trav

[GitHub] [flink] flinkbot edited a comment on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job

flinkbot edited a comment on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job is executed by LocalExecutor. URL: https://github.com/apache/flink/pull/11714#issuecomment-612809197 #

[GitHub] [flink] flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN * baf2c55f7bb0b9df7bdef94083c

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN *

[GitHub] [flink] carp84 commented on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode()

carp84 commented on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode() URL: https://github.com/apache/flink/pull/11713#issuecomment-613251497 Asking since the relative JIRA is marked as a bu

[GitHub] [flink] flinkbot commented on issue #11725: [FLINK-15670] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot commented on issue #11725: [FLINK-15670] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725#issuecomment-613250718 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review you

[jira] [Updated] (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:all-tabpanel ] ASF GitHub Bot updated FLINK-15670: --- Labels: pull-request-available usability (was: usability) > Provide a Kafka Source/Sink pai

[GitHub] [flink] curcur opened a new pull request #11725: [FLINK-15670] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur opened a new pull request #11725: [FLINK-15670] Provide a Kafka Source/Sink pair as KafkaShuffle URL: https://github.com/apache/flink/pull/11725 ## What is the purpose of the change This pull request is to provide a Kafka Source/Sink pair to simulate a KafkaShuffle th

[GitHub] [flink] flinkbot edited a comment on issue #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF

flinkbot edited a comment on issue #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF URL: https://github.com/apache/flink/pull/11724#issuecomment-613241606 ## CI report: * 5acec4bb31966ec054331a629ce51b616b7a020b Travis: [PENDING](https://travis-ci.

[GitHub] [flink] flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448 ## CI report: * 3161ea77da21b591ab76eaae3a5

[GitHub] [flink] flinkbot edited a comment on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job

flinkbot edited a comment on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job is executed by LocalExecutor. URL: https://github.com/apache/flink/pull/11714#issuecomment-612809197 #

[GitHub] [flink] flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode

flinkbot edited a comment on issue #11674: [FLINK-16887][table-planner-blink] Refactor retraction rules to support inferring ChangelogMode URL: https://github.com/apache/flink/pull/11674#issuecomment-611092822 ## CI report: * 27728b10f3e719b3f53fe199cf02e5b820ddfcd1 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters

flinkbot edited a comment on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters URL: https://github.com/apache/flink/pull/11708#issuecomment-612587571 ## CI report: * 55e7e81335d9fd83ce378e141f22c9ae9985b144 Travis: [SUCC

[GitHub] [flink] flinkbot edited a comment on issue #11721: [FLINK-14652] Refactor notifyCheckpointComplete to SubtaskCheckpointCoordinator

flinkbot edited a comment on issue #11721: [FLINK-14652] Refactor notifyCheckpointComplete to SubtaskCheckpointCoordinator URL: https://github.com/apache/flink/pull/11721#issuecomment-613210240 ## CI report: * 6df99687837974586fd4d9892d0fd0bab05374bc Travis: [SUCCESS](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #11640: add end-to-end-performance test

flinkbot edited a comment on issue #11640: add end-to-end-performance test URL: https://github.com/apache/flink/pull/11640#issuecomment-609448172 ## CI report: * 65542fffd9032cffe1272b48204f9bd93bee2c19 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/16007135

[GitHub] [flink] flinkbot edited a comment on issue #11719: [FLINK-17124][python] Fix The PyFlink Job runs into infinite loop if the UDF file imports job code.

flinkbot edited a comment on issue #11719: [FLINK-17124][python] Fix The PyFlink Job runs into infinite loop if the UDF file imports job code. URL: https://github.com/apache/flink/pull/11719#issuecomment-612955433 ## CI report: * da8d3dcf0cbb8d4e112f50e3001ae48ee1705f50 Travis:

[GitHub] [flink] WeiZhong94 commented on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job is e

WeiZhong94 commented on issue #11714: [FLINK-17114][python] Set the default value of 'python.executable' to the path of the python interpreter which launches the job when the job is executed by LocalExecutor. URL: https://github.com/apache/flink/pull/11714#issuecomment-613243489 @dianfu Th

[GitHub] [flink] flinkbot edited a comment on issue #11719: [FLINK-17124][python] Fix The PyFlink Job runs into infinite loop if the UDF file imports job code.

flinkbot edited a comment on issue #11719: [FLINK-17124][python] Fix The PyFlink Job runs into infinite loop if the UDF file imports job code. URL: https://github.com/apache/flink/pull/11719#issuecomment-612955433 ## CI report: * da8d3dcf0cbb8d4e112f50e3001ae48ee1705f50 Travis:

[GitHub] [flink] flinkbot commented on issue #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF

flinkbot commented on issue #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF URL: https://github.com/apache/flink/pull/11724#issuecomment-613241606 ## CI report: * 5acec4bb31966ec054331a629ce51b616b7a020b UNKNOWN Bot commands The @fl

[GitHub] [flink] flinkbot edited a comment on issue #11695: [FLINK-11523] Use OutputTag.typeInfo in harness

flinkbot edited a comment on issue #11695: [FLINK-11523] Use OutputTag.typeInfo in harness URL: https://github.com/apache/flink/pull/11695#issuecomment-611675716 ## CI report: * 978fe5a4fc36181c59a018b3af29cf82fecb7281 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #11640: add end-to-end-performance test

flinkbot edited a comment on issue #11640: add end-to-end-performance test URL: https://github.com/apache/flink/pull/11640#issuecomment-609448172 ## CI report: * 65542fffd9032cffe1272b48204f9bd93bee2c19 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/16007135

[GitHub] [flink] flinkbot commented on issue #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF

flinkbot commented on issue #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF URL: https://github.com/apache/flink/pull/11724#issuecomment-613238037 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to r

[jira] [Updated] (FLINK-16486) Add documentation for vectorized Python UDF

[ https://issues.apache.org/jira/browse/FLINK-16486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16486: --- Labels: pull-request-available (was: ) > Add documentation for vectorized Python UDF >

[GitHub] [flink] dianfu opened a new pull request #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF

dianfu opened a new pull request #11724: [FLINK-16486][python][docs] Add documentation for vectorized Python UDF URL: https://github.com/apache/flink/pull/11724 ## What is the purpose of the change *This pull request add documentation for vectorized Python UDF.* ## Brief c

[GitHub] [flink] flinkbot edited a comment on issue #11695: [FLINK-11523] Use OutputTag.typeInfo in harness

flinkbot edited a comment on issue #11695: [FLINK-11523] Use OutputTag.typeInfo in harness URL: https://github.com/apache/flink/pull/11695#issuecomment-611675716 ## CI report: * 978fe5a4fc36181c59a018b3af29cf82fecb7281 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #11723: [FLINK-16762][python] Relocate Beam dependency

flinkbot edited a comment on issue #11723: [FLINK-16762][python] Relocate Beam dependency URL: https://github.com/apache/flink/pull/11723#issuecomment-613231879 ## CI report: * f97fa4efd44756bff435f3b16f9dd1694f18a278 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink

[GitHub] [flink] zhengcanbin commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

zhengcanbin commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#discussion_r407877683 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kube

[GitHub] [flink] dianfu commented on a change in pull request #11719: [FLINK-17124][python] Fix The PyFlink Job runs into infinite loop if the UDF file imports job code.

dianfu commented on a change in pull request #11719: [FLINK-17124][python] Fix The PyFlink Job runs into infinite loop if the UDF file imports job code. URL: https://github.com/apache/flink/pull/11719#discussion_r407833239 ## File path: flink-python/pyflink/table/tests/test_dependen

[jira] [Commented] (FLINK-15959) Add min number of slots configuration to limit total number of slots

[ https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082848#comment-17082848 ] Yangze Guo commented on FLINK-15959: Hi, [~liuyufei]. Is there any progress in this

[GitHub] [flink] wangyang0918 removed a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 removed a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-613190763 @flinkbot run travis @flinkbot run azure --

[GitHub] [flink] flinkbot commented on issue #11723: [FLINK-16762][python] Relocate Beam dependency

flinkbot commented on issue #11723: [FLINK-16762][python] Relocate Beam dependency URL: https://github.com/apache/flink/pull/11723#issuecomment-613231879 ## CI report: * f97fa4efd44756bff435f3b16f9dd1694f18a278 UNKNOWN Bot commands The @flinkbot bot supports the f

[GitHub] [flink] flinkbot edited a comment on issue #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable

flinkbot edited a comment on issue #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable URL: https://github.com/apache/flink/pull/11722#issuecomment-613227820 ## CI report: * 0923302d1a1a9b672e3d6c24644bc22b476461a0 Travis: [PENDING](https://travis

[GitHub] [flink] wangyang0918 commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#discussion_r407873251 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/Kub

[GitHub] [flink] wangyang0918 edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-613191981 @azagrebin Thanks for the following fix. I am completely ok with the additional changes. And i

[jira] [Updated] (FLINK-17124) The PyFlink Job runs into infinite loop if the Python UDF imports job code

[ https://issues.apache.org/jira/browse/FLINK-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17124: Summary: The PyFlink Job runs into infinite loop if the Python UDF imports job code (was: The PyFlink Job

[jira] [Assigned] (FLINK-17124) The PyFlink Job runs into infinite loop if the UDF file imports job code.

[ https://issues.apache.org/jira/browse/FLINK-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17124: --- Assignee: Huang Xingbo > The PyFlink Job runs into infinite loop if the UDF file imports job code.

[GitHub] [flink] dianfu commented on a change in pull request #11719: [FLINK-17124][python] Fix The PyFlink Job runs into infinite loop if the UDF file imports job code.

dianfu commented on a change in pull request #11719: [FLINK-17124][python] Fix The PyFlink Job runs into infinite loop if the UDF file imports job code. URL: https://github.com/apache/flink/pull/11719#discussion_r407837285 ## File path: flink-python/pyflink/java_gateway.py

[GitHub] [flink] flinkbot commented on issue #11723: [FLINK-16762][python] Relocate Beam dependency

flinkbot commented on issue #11723: [FLINK-16762][python] Relocate Beam dependency URL: https://github.com/apache/flink/pull/11723#issuecomment-613228979 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[jira] [Updated] (FLINK-16762) Relocation Beam dependency of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-16762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16762: --- Labels: pull-request-available (was: ) > Relocation Beam dependency of PyFlink > --

[GitHub] [flink] dianfu opened a new pull request #11723: [FLINK-16762][python] Relocate Beam dependency

dianfu opened a new pull request #11723: [FLINK-16762][python] Relocate Beam dependency URL: https://github.com/apache/flink/pull/11723 ## What is the purpose of the change *This pull request relocates the Beam dependency to avoid the potential conflicts with the existing librar

[jira] [Created] (FLINK-17127) Make pod creating retry interval configurable

Yang Wang created FLINK-17127: - Summary: Make pod creating retry interval configurable Key: FLINK-17127 URL: https://issues.apache.org/jira/browse/FLINK-17127 Project: Flink Issue Type: New Featu

[GitHub] [flink] flinkbot edited a comment on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters

flinkbot edited a comment on issue #11708: [FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters URL: https://github.com/apache/flink/pull/11708#issuecomment-612587571 ## CI report: * 55e7e81335d9fd83ce378e141f22c9ae9985b144 Travis: [SUCC

[GitHub] [flink] flinkbot commented on issue #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable

flinkbot commented on issue #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable URL: https://github.com/apache/flink/pull/11722#issuecomment-613227820 ## CI report: * 0923302d1a1a9b672e3d6c24644bc22b476461a0 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN * ad481f5d846621032fe

[GitHub] [flink] flinkbot edited a comment on issue #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink

flinkbot edited a comment on issue #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink URL: https://github.com/apache/flink/pull/11716#issuecomment-612840105 ## CI report: * 47f3c03902e3740524d52d7541734837d2cf2d45 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN * ad481f5d846621032fe

[GitHub] [flink] flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014 ## CI report: * 4e5e836902c5d77944600e0fc9f3dffe3c145744 Travis: [FAILURE](htt

[GitHub] [flink] flinkbot edited a comment on issue #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory.

flinkbot edited a comment on issue #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory. URL: https://github.com/apache/flink/pull/10768#issuecomment-570915760 ## CI report: * 2139ea47ee3dac096c47b36efdf077b15e6

[jira] [Updated] (FLINK-5763) Make savepoints self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5763: -- Labels: pull-request-available usability (was: usability) > Make savepoints self-contained and

[GitHub] [flink] flinkbot commented on issue #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable

flinkbot commented on issue #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable URL: https://github.com/apache/flink/pull/11722#issuecomment-61328 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] klion26 opened a new pull request #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable

klion26 opened a new pull request #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable URL: https://github.com/apache/flink/pull/11722 ## What is the purpose of the change This pr wants to make savepoint self-contained and relocatable. ## Brief c

[GitHub] [flink] wangyang0918 edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-613191981 @azagrebin Thanks for the following fix. I am completely ok with the additional changes. And i

[GitHub] [flink] flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN * baf2c55f7bb0b9df7bdef94083c

[GitHub] [flink] flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection

flinkbot edited a comment on issue #11555: [FLINK-16576][state backends] Correct the logic of KeyGroupStateHandle#getIntersection URL: https://github.com/apache/flink/pull/11555#issuecomment-605488014 ## CI report: * 4e5e836902c5d77944600e0fc9f3dffe3c145744 Travis: [FAILURE](htt

[GitHub] [flink] godfreyhe commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

godfreyhe commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#discussion_r407859387 ## File path: flink-table/flink-table-api-java/src/main/ja

[GitHub] [flink] flinkbot edited a comment on issue #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink

flinkbot edited a comment on issue #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink URL: https://github.com/apache/flink/pull/11716#issuecomment-612840105 ## CI report: * 9affbdfd14844bd293da225a5bbc6269fd33f129 Travis:

[GitHub] [flink] godfreyhe commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

godfreyhe commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#discussion_r407858281 ## File path: flink-table/flink-table-api-java/src/main/ja

[GitHub] [flink] godfreyhe commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

godfreyhe commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#discussion_r407858281 ## File path: flink-table/flink-table-api-java/src/main/ja

[GitHub] [flink] carp84 commented on issue #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory.

carp84 commented on issue #10768: [FLINK-15012][checkpoint] Introduce shutdown to CheckpointStorageCoordinatorView to clean up checkpoint directory. URL: https://github.com/apache/flink/pull/10768#issuecomment-613216066 It seems the flinkbot command triggers build against old commit 2139ea4

[jira] [Created] (FLINK-17126) Correct the execution behavior of BatchTableEnvironment

godfrey he created FLINK-17126: -- Summary: Correct the execution behavior of BatchTableEnvironment Key: FLINK-17126 URL: https://issues.apache.org/jira/browse/FLINK-17126 Project: Flink Issue Typ

[jira] [Commented] (FLINK-17107) CheckpointCoordinatorConfiguration#isExactlyOnce() is inconsistent with StreamConfig#getCheckpointMode()

[ https://issues.apache.org/jira/browse/FLINK-17107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17082817#comment-17082817 ] Yingjie Cao commented on FLINK-17107: - Fixed via eb4a2115db91cf2908312e8c4ddc673f6c8

[jira] [Closed] (FLINK-17107) CheckpointCoordinatorConfiguration#isExactlyOnce() is inconsistent with StreamConfig#getCheckpointMode()

[ https://issues.apache.org/jira/browse/FLINK-17107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-17107. --- Resolution: Fixed > CheckpointCoordinatorConfiguration#isExactlyOnce() is inconsistent with > Strea

[GitHub] [flink] flinkbot edited a comment on issue #11721: [FLINK-14652] Refactor notifyCheckpointComplete to SubtaskCheckpointCoordinator

flinkbot edited a comment on issue #11721: [FLINK-14652] Refactor notifyCheckpointComplete to SubtaskCheckpointCoordinator URL: https://github.com/apache/flink/pull/11721#issuecomment-613210240 ## CI report: * 6df99687837974586fd4d9892d0fd0bab05374bc Travis: [PENDING](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink

flinkbot edited a comment on issue #11716: [FLINK-17116] [connectors / elasticsearch] support UsernamePasswordCredentials for elasticsearch sink URL: https://github.com/apache/flink/pull/11716#issuecomment-612840105 ## CI report: * 9affbdfd14844bd293da225a5bbc6269fd33f129 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field

flinkbot edited a comment on issue #11717: [FLINK-17093][python][table-planner][table-planner-blink] Fix Python UDF to make it work with inputs from composite field URL: https://github.com/apache/flink/pull/11717#issuecomment-612882448 ## CI report: * ec06c317b7827c2f260b8e7f7d6

[GitHub] [flink] flinkbot edited a comment on issue #11695: [FLINK-11523] Use OutputTag.typeInfo in harness

flinkbot edited a comment on issue #11695: [FLINK-11523] Use OutputTag.typeInfo in harness URL: https://github.com/apache/flink/pull/11695#issuecomment-611675716 ## CI report: * 978fe5a4fc36181c59a018b3af29cf82fecb7281 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flin

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN * ad481f5d846621032fe

[GitHub] [flink] flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN * baf2c55f7bb0b9df7bdef94083c

[GitHub] [flink] wsry commented on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode()

wsry commented on issue #11713: [FLINK-17107][checkpointing] Make CheckpointCoordinatorConfiguration#isExactlyOnce() be consistent with StreamConfig#getCheckpointMode() URL: https://github.com/apache/flink/pull/11713#issuecomment-613213116 @carp84 I am fixing this mainly because anothe

[GitHub] [flink] KurtYoung commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

KurtYoung commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#discussion_r407847079 ## File path: flink-table/flink-table-api-java/src/main/ja

[GitHub] [flink] KurtYoung commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

KurtYoung commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#discussion_r407846591 ## File path: flink-table/flink-table-api-java/src/main/ja

[GitHub] [flink] KurtYoung commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

KurtYoung commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#discussion_r407849169 ## File path: flink-table/flink-table-api-java/src/main/ja

[GitHub] [flink] KurtYoung commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

KurtYoung commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#discussion_r407845053 ## File path: flink-table/flink-table-api-java/src/main/ja

[GitHub] [flink] KurtYoung commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

KurtYoung commented on a change in pull request #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#discussion_r407844732 ## File path: flink-table/flink-table-api-java/src/main/ja

[GitHub] [flink] alexeyt820 commented on issue #11695: [FLINK-11523] Use OutputTag.typeInfo in harness

alexeyt820 commented on issue #11695: [FLINK-11523] Use OutputTag.typeInfo in harness URL: https://github.com/apache/flink/pull/11695#issuecomment-613210684 @flinkbot run travis @flinkbot run azure This is an automated mes

  1   2   3   4   5   >