[GitHub] [flink] KurtYoung merged pull request #15444: [hotfix] Create parent interface for begin/end statement set operation.

KurtYoung merged pull request #15444: URL: https://github.com/apache/flink/pull/15444 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] lindong28 commented on pull request #15405: [Flink-21976] Remove Flink ML pipeline API and library code from the Flink repo

lindong28 commented on pull request #15405: URL: https://github.com/apache/flink/pull/15405#issuecomment-810789143 @dianfu Do you have time to take a look? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] pnowojski commented on a change in pull request #15425: [FLINK-21133][connector/checkpoint] Fix the stop-with-savepoint case …

pnowojski commented on a change in pull request #15425: URL: https://github.com/apache/flink/pull/15425#discussion_r604613973 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -730,12 +730,7 @@ public final void

[GitHub] [flink-ml] becketqin commented on pull request #2: [FLINK-22013] Add Github Actions to flink-ml for every push and pull request

becketqin commented on pull request #2: URL: https://github.com/apache/flink-ml/pull/2#issuecomment-810788952 LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For

[GitHub] [flink-ml] becketqin merged pull request #2: [FLINK-22013] Add Github Actions to flink-ml for every push and pull request

becketqin merged pull request #2: URL: https://github.com/apache/flink-ml/pull/2 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[GitHub] [flink] kezhuw commented on a change in pull request #15425: [FLINK-21133][connector/checkpoint] Fix the stop-with-savepoint case …

kezhuw commented on a change in pull request #15425: URL: https://github.com/apache/flink/pull/15425#discussion_r604612731 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTask.java ## @@ -97,6 +97,11 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #15442: [FLINK-17359] [flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

flinkbot edited a comment on pull request #15442: URL: https://github.com/apache/flink/pull/15442#issuecomment-810703449 ## CI report: * 174d785d8936b9aeb3934a2892fbcff1bb29b270 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #15425: [FLINK-21133][connector/checkpoint] Fix the stop-with-savepoint case …

pnowojski commented on a change in pull request #15425: URL: https://github.com/apache/flink/pull/15425#discussion_r604611859 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTask.java ## @@ -97,6 +97,11 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

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

[GitHub] [flink] flinkbot edited a comment on pull request #15407: [FLINK-21942][coordination] Remove job from LeaderIdService when disconnecting JobManager with globally terminal state

flinkbot edited a comment on pull request #15407: URL: https://github.com/apache/flink/pull/15407#issuecomment-809165650 ## CI report: * b4c9b16b3b5a83d998f52c61280d6ae1378a6fb4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15385: [FLINK-21685][k8s] Introduce dedicated thread pool and cache for Kubernetes client

flinkbot edited a comment on pull request #15385: URL: https://github.com/apache/flink/pull/15385#issuecomment-808104280 ## CI report: * 631c28c94c2396b115d080271f18a02afce3b00c Azure:

[jira] [Created] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

xiaogang zhou created FLINK-22059: - Summary: add a new option is rocksdb statebackend to enable job threads setting Key: FLINK-22059 URL: https://issues.apache.org/jira/browse/FLINK-22059 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

flinkbot edited a comment on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805219989 ## CI report: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * a56563a6a480a6caa1645326a63abc445354bdcb UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15280: [FLINK-21714][table-api] Use TIMESTAMP_LTZ as return type for function PROCTIME()

flinkbot edited a comment on pull request #15280: URL: https://github.com/apache/flink/pull/15280#issuecomment-802654466 ## CI report: * 3b4b5fcd9d8108b51e0bf62a0bee888b4fdb5186 UNKNOWN * 2d8201e04fa3796091f0998d41accd28a93401a1 Azure:

[jira] [Updated] (FLINK-22058) Support FLIP-27 based NumberSequenceSource connector in PyFlink DataStream API

[ https://issues.apache.org/jira/browse/FLINK-22058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-22058: Parent: FLINK-20280 Issue Type: Sub-task (was: Bug) > Support FLIP-27 based NumberSequenceSource

[jira] [Created] (FLINK-22058) Support FLIP-27 based NumberSequenceSource connector in PyFlink DataStream API

Dian Fu created FLINK-22058: --- Summary: Support FLIP-27 based NumberSequenceSource connector in PyFlink DataStream API Key: FLINK-22058 URL: https://issues.apache.org/jira/browse/FLINK-22058 Project: Flink

[GitHub] [flink] kezhuw commented on a change in pull request #15425: [FLINK-21133][connector/checkpoint] Fix the stop-with-savepoint case …

kezhuw commented on a change in pull request #15425: URL: https://github.com/apache/flink/pull/15425#discussion_r604609919 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTask.java ## @@ -97,6 +97,11 @@ public void

[GitHub] [flink] becketqin commented on a change in pull request #15425: [FLINK-21133][connector/checkpoint] Fix the stop-with-savepoint case …

becketqin commented on a change in pull request #15425: URL: https://github.com/apache/flink/pull/15425#discussion_r604607406 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTask.java ## @@ -97,6 +97,11 @@ public

[jira] [Closed] (FLINK-22044) running job from Flink client(cli) from outside Flink jobmanager pod

[ https://issues.apache.org/jira/browse/FLINK-22044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi closed FLINK-22044. - Resolution: Duplicate > running job from Flink client(cli) from outside Flink jobmanager pod >

[jira] [Updated] (FLINK-22057) Client submit job remotely to Flink cluster through Loadbalancer rest service --failed

[ https://issues.apache.org/jira/browse/FLINK-22057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22057: -- Description: I am trying to submit inbuilt job thorugh LB & port on rest service.. but job is failing with

[jira] [Updated] (FLINK-22057) Client submit job remotely to Flink cluster through Loadbalancer rest service --failed

[ https://issues.apache.org/jira/browse/FLINK-22057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22057: -- Summary: Client submit job remotely to Flink cluster through Loadbalancer rest service --failed (was: Flink

[jira] [Created] (FLINK-22057) Flink client submitting Flink job remotely to Flink cluster through Loadbalancer rest service

Bhagi created FLINK-22057: - Summary: Flink client submitting Flink job remotely to Flink cluster through Loadbalancer rest service Key: FLINK-22057 URL: https://issues.apache.org/jira/browse/FLINK-22057

[GitHub] [flink] pnowojski commented on pull request #15440: [FLINK-22050][network] Recycle all buffers before failing release

pnowojski commented on pull request #15440: URL: https://github.com/apache/flink/pull/15440#issuecomment-810775223 In the PR description it’s missing if it’s fixing the problem from the Jira ticket or not. secondly please copy paste this description to the commit message as well.

[GitHub] [flink] hehuiyuan edited a comment on pull request #15427: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist or there is no conf file

hehuiyuan edited a comment on pull request #15427: URL: https://github.com/apache/flink/pull/15427#issuecomment-810773967 > Hi @hehuiyuan , the new PR looks good to me. But it's better to rebase your old PR than opening a new one. A new PR usually means it needs to be reviewed again.

[GitHub] [flink] hehuiyuan commented on pull request #15427: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist or there is no conf file

hehuiyuan commented on pull request #15427: URL: https://github.com/apache/flink/pull/15427#issuecomment-810773967 > Hi @hehuiyuan , the new PR looks good to me. But it's better to rebase your old PR than opening a new one. A new PR usually means it needs to be reviewed again. Hi

[GitHub] [flink] chenqin commented on pull request #15442: [FLINK-17359] [flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

chenqin commented on pull request #15442: URL: https://github.com/apache/flink/pull/15442#issuecomment-810773112 @flinkbot run travis @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] kezhuw commented on a change in pull request #15425: [FLINK-21133][connector/checkpoint] Fix the stop-with-savepoint case …

kezhuw commented on a change in pull request #15425: URL: https://github.com/apache/flink/pull/15425#discussion_r604601456 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTask.java ## @@ -97,6 +97,11 @@ public void

[jira] [Closed] (FLINK-21994) Support FLIP-27 based FileSource connector in PyFlink DataStream API

[ https://issues.apache.org/jira/browse/FLINK-21994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-21994. --- Resolution: Fixed Merged to master via 7dd4c331e0529e1f6fd0c3a1a01086fc93ff6da9 > Support FLIP-27 based

[GitHub] [flink] dianfu closed pull request #15443: [FLINK-21994][python] Support FLIP-27 based FileSource connector in PyFlink DataStream API

dianfu closed pull request #15443: URL: https://github.com/apache/flink/pull/15443 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please

[GitHub] [flink] flinkbot edited a comment on pull request #15442: [FLINK-17359] [flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

flinkbot edited a comment on pull request #15442: URL: https://github.com/apache/flink/pull/15442#issuecomment-810703449 ## CI report: * 174d785d8936b9aeb3934a2892fbcff1bb29b270 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15407: [FLINK-21942][coordination] Remove job from LeaderIdService when disconnecting JobManager with globally terminal state

flinkbot edited a comment on pull request #15407: URL: https://github.com/apache/flink/pull/15407#issuecomment-809165650 ## CI report: * b4c9b16b3b5a83d998f52c61280d6ae1378a6fb4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15385: [FLINK-21685][k8s] Introduce dedicated thread pool and cache for Kubernetes client

flinkbot edited a comment on pull request #15385: URL: https://github.com/apache/flink/pull/15385#issuecomment-808104280 ## CI report: * 631c28c94c2396b115d080271f18a02afce3b00c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15280: [FLINK-21714][table-api] Use TIMESTAMP_LTZ as return type for function PROCTIME()

flinkbot edited a comment on pull request #15280: URL: https://github.com/apache/flink/pull/15280#issuecomment-802654466 ## CI report: * 3b4b5fcd9d8108b51e0bf62a0bee888b4fdb5186 UNKNOWN * 2d8201e04fa3796091f0998d41accd28a93401a1 Azure:

[GitHub] [flink] kezhuw commented on a change in pull request #15425: [FLINK-21133][connector/checkpoint] Fix the stop-with-savepoint case …

kezhuw commented on a change in pull request #15425: URL: https://github.com/apache/flink/pull/15425#discussion_r604597103 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -730,12 +730,7 @@ public final void

[GitHub] [flink] kezhuw commented on a change in pull request #15425: [FLINK-21133][connector/checkpoint] Fix the stop-with-savepoint case …

kezhuw commented on a change in pull request #15425: URL: https://github.com/apache/flink/pull/15425#discussion_r604593993 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -730,12 +730,7 @@ public final void

[GitHub] [flink] flinkbot edited a comment on pull request #15442: [FLINK-17359] [flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

flinkbot edited a comment on pull request #15442: URL: https://github.com/apache/flink/pull/15442#issuecomment-810703449 ## CI report: * 174d785d8936b9aeb3934a2892fbcff1bb29b270 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

flinkbot edited a comment on pull request #15411: URL: https://github.com/apache/flink/pull/15411#issuecomment-809191175 ## CI report: * 386a106bff7eda5396dc95f088c7121bbb55a73f Azure:

[GitHub] [flink] wangyang0918 commented on pull request #15407: [FLINK-21942][coordination] Remove job from LeaderIdService when disconnecting JobManager with globally terminal state

wangyang0918 commented on pull request #15407: URL: https://github.com/apache/flink/pull/15407#issuecomment-810756322 Rebase latest master. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] wangyang0918 commented on pull request #15385: [FLINK-21685][k8s] Introduce dedicated thread pool and cache for Kubernetes client

wangyang0918 commented on pull request #15385: URL: https://github.com/apache/flink/pull/15385#issuecomment-810753548 cc @tillrohrmann The second commit has been reverted. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #15444: [hotfix] Create parent interface for begin/end statement set operation.

flinkbot edited a comment on pull request #15444: URL: https://github.com/apache/flink/pull/15444#issuecomment-810717742 ## CI report: * 10a396bf14431c498d7378202d1b025cdb614cbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15442: [FLINK-17359] [flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

flinkbot edited a comment on pull request #15442: URL: https://github.com/apache/flink/pull/15442#issuecomment-810703449 ## CI report: * 174d785d8936b9aeb3934a2892fbcff1bb29b270 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15437: [FLINK-20320][sql-client] support init sql file in sql client

flinkbot edited a comment on pull request #15437: URL: https://github.com/apache/flink/pull/15437#issuecomment-810431644 ## CI report: * 5953b3551c1530d63022252b53e3c228113ad5b9 Azure:

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312040#comment-17312040 ] Guowei Ma commented on FLINK-17274: ---

[jira] [Created] (FLINK-22056) FlinkKafkaProducerITCase failed because of "producer leak".

Guowei Ma created FLINK-22056: - Summary: FlinkKafkaProducerITCase failed because of "producer leak". Key: FLINK-22056 URL: https://issues.apache.org/jira/browse/FLINK-22056 Project: Flink Issue

[GitHub] [flink] HuangXingBo commented on a change in pull request #15443: [FLINK-21994][python] Support FLIP-27 based FileSource connector in PyFlink DataStream API

HuangXingBo commented on a change in pull request #15443: URL: https://github.com/apache/flink/pull/15443#discussion_r604570336 ## File path: flink-python/pyflink/datastream/tests/test_connectors.py ## @@ -189,3 +190,34 @@ def test_stream_file_sink(self): def

[GitHub] [flink] dianfu commented on a change in pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

dianfu commented on a change in pull request #15441: URL: https://github.com/apache/flink/pull/15441#discussion_r604566912 ## File path: flink-python/pyflink/datastream/checkpoint_storage.py ## @@ -0,0 +1,344 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15444: [hotfix] Create parent interface for begin/end statement set operation.

flinkbot edited a comment on pull request #15444: URL: https://github.com/apache/flink/pull/15444#issuecomment-810717742 ## CI report: * 10a396bf14431c498d7378202d1b025cdb614cbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15440: [FLINK-22050][network] Recycle all buffers before failing release

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

[GitHub] [flink] flinkbot edited a comment on pull request #15437: [FLINK-20320][sql-client] support init sql file in sql client

flinkbot edited a comment on pull request #15437: URL: https://github.com/apache/flink/pull/15437#issuecomment-810431644 ## CI report: * 5953b3551c1530d63022252b53e3c228113ad5b9 Azure:

[GitHub] [flink] wangyang0918 commented on a change in pull request #15385: [FLINK-21685][k8s] Introduce dedicated thread pool and cache for Kubernetes client

wangyang0918 commented on a change in pull request #15385: URL: https://github.com/apache/flink/pull/15385#discussion_r604575274 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java ## @@ -342,7 +367,22 @@ public

[jira] [Commented] (FLINK-21954) Test failures occur due to the test not waiting for the ExecutionGraph to be created

[ https://issues.apache.org/jira/browse/FLINK-21954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312033#comment-17312033 ] Guowei Ma commented on FLINK-21954: ---

[jira] [Commented] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312032#comment-17312032 ] Guowei Ma commented on FLINK-20420: ---

[jira] [Updated] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20420: -- Affects Version/s: 1.13.0 > ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds >

[GitHub] [flink] wangyang0918 commented on pull request #15385: [FLINK-21685][k8s] Introduce dedicated thread pool and cache for Kubernetes client

wangyang0918 commented on pull request #15385: URL: https://github.com/apache/flink/pull/15385#issuecomment-810737008 The reason why I introduce the `CACHE` for `Fabric8FlinkKubeClient` is about to reduce the number of threads. Also because `Fabric8FlinkKubeClient` is thread-safe, and

[jira] [Comment Edited] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312029#comment-17312029 ] xiaogang zhou edited comment on FLINK-17808 at 3/31/21, 3:39 AM: -

[jira] [Commented] (FLINK-17808) Rename checkpoint meta file to "_metadata" until it has completed writing

[ https://issues.apache.org/jira/browse/FLINK-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312029#comment-17312029 ] xiaogang zhou commented on FLINK-17808: --- [~yunta] As Steven mentioned above, between two

[jira] [Updated] (FLINK-22055) RPC main thread executor may schedule commands with wrong time unit of delay

[ https://issues.apache.org/jira/browse/FLINK-22055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22055: --- Labels: pull-request-available (was: ) > RPC main thread executor may schedule commands

[GitHub] [flink] xintongsong commented on pull request #15411: [FLINK-22055][runtime] Fix RPCEndpoint MainThreadExecutor scheduling command with wrong time unit.

xintongsong commented on pull request #15411: URL: https://github.com/apache/flink/pull/15411#issuecomment-810731296 @est08zw, I have opened FLINK-22055 for this issue and attached this PR to the ticket. Please leave a message on the ticket, so I know your jira id and can assign you

[GitHub] [flink] flinkbot edited a comment on pull request #15444: [hotfix] Create parent interface for begin/end statement set operation.

flinkbot edited a comment on pull request #15444: URL: https://github.com/apache/flink/pull/15444#issuecomment-810717742 ## CI report: * 10a396bf14431c498d7378202d1b025cdb614cbe Azure:

[jira] [Created] (FLINK-22055) RPC main thread executor may schedule commands with wrong time unit of delay

Xintong Song created FLINK-22055: Summary: RPC main thread executor may schedule commands with wrong time unit of delay Key: FLINK-22055 URL: https://issues.apache.org/jira/browse/FLINK-22055

[GitHub] [flink] xintongsong commented on a change in pull request #15411: [hotfix] fix typo, use the delay in millisecond rather than the raw parameter which may not in TimeUnit.MILLISECONDS precisio

xintongsong commented on a change in pull request #15411: URL: https://github.com/apache/flink/pull/15411#discussion_r604547989 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java ## @@ -262,4 +267,136 @@ protected ExtendedEndpoint(

[GitHub] [flink] xintongsong commented on a change in pull request #15411: [hotfix] fix typo, use the delay in millisecond rather than the raw parameter which may not in TimeUnit.MILLISECONDS precisio

xintongsong commented on a change in pull request #15411: URL: https://github.com/apache/flink/pull/15411#discussion_r604545334 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java ## @@ -262,4 +267,136 @@ protected ExtendedEndpoint(

[GitHub] [flink] flinkbot edited a comment on pull request #15444: [hotfix] Create parent interface for begin/end statement set operation.

flinkbot edited a comment on pull request #15444: URL: https://github.com/apache/flink/pull/15444#issuecomment-810717742 ## CI report: * 10a396bf14431c498d7378202d1b025cdb614cbe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15439: [FLINK-22011][table-runtime-blink] Support local global optimization for window aggregation in runtime

flinkbot edited a comment on pull request #15439: URL: https://github.com/apache/flink/pull/15439#issuecomment-810469613 ## CI report: * de081e28e7377785ea255b466988d4f0419c31f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15354: [FLINK-21927][table-planner-blink] Resolve ExpressionReducer compile fail when running long term

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

[jira] [Commented] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311997#comment-17311997 ] Yi Tang commented on FLINK-22054: - Here[1] is a demo implementation using informer, which can deal the

[jira] [Commented] (FLINK-22006) Could not run more than 20 jobs in a native K8s session when K8s HA enabled

[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311996#comment-17311996 ] Yi Tang commented on FLINK-22006: - The watching for configMap is a little different from that for pods.

[jira] [Updated] (FLINK-22054) Using a shared watcher for ConfigMap watching

[ https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22054: Description: While using K8s HA service, the watching for ConfigMap is separate for each job. As the

[jira] [Created] (FLINK-22054) Using a shared watcher for ConfigMap watching

Yi Tang created FLINK-22054: --- Summary: Using a shared watcher for ConfigMap watching Key: FLINK-22054 URL: https://issues.apache.org/jira/browse/FLINK-22054 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on pull request #15444: [hotfix] Create parent interface for begin/end statement set operation.

flinkbot commented on pull request #15444: URL: https://github.com/apache/flink/pull/15444#issuecomment-810717742 ## CI report: * 10a396bf14431c498d7378202d1b025cdb614cbe UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15442: [FLINK-17359] [flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

flinkbot edited a comment on pull request #15442: URL: https://github.com/apache/flink/pull/15442#issuecomment-810703449 ## CI report: * 174d785d8936b9aeb3934a2892fbcff1bb29b270 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15439: [FLINK-22011][table-runtime-blink] Support local global optimization for window aggregation in runtime

flinkbot edited a comment on pull request #15439: URL: https://github.com/apache/flink/pull/15439#issuecomment-810469613 ## CI report: * de081e28e7377785ea255b466988d4f0419c31f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15443: [FLINK-21994][python] Support FLIP-27 based FileSource connector in PyFlink DataStream API

flinkbot edited a comment on pull request #15443: URL: https://github.com/apache/flink/pull/15443#issuecomment-810703507 ## CI report: * 3078dbd761ef4690f41732e610c4226ea920f163 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15354: [FLINK-21927][table-planner-blink] Resolve ExpressionReducer compile fail when running long term

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

[GitHub] [flink] lirui-apache commented on pull request #15427: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist or there is no conf file

lirui-apache commented on pull request #15427: URL: https://github.com/apache/flink/pull/15427#issuecomment-810715560 Hi @hehuiyuan , the new PR looks good to me. But it's better to rebase your old PR than opening a new one. A new PR usually means it needs to be reviewed again. -- This

[jira] [Commented] (FLINK-22016) PushFilterIntoTableSourceScanRule fails to deal with NULLs

[ https://issues.apache.org/jira/browse/FLINK-22016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311974#comment-17311974 ] Caizhi Weng commented on FLINK-22016: - [~twalthr] new table sources also have this issue. I've

[jira] [Updated] (FLINK-22016) PushFilterIntoTableSourceScanRule fails to deal with NULLs

[ https://issues.apache.org/jira/browse/FLINK-22016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-22016: Description: Add the following test case to {{PushFilterIntoTableSourceScanRuleTest}} to

[jira] [Updated] (FLINK-22016) PushFilterIntoTableSourceScanRule fails to deal with NULLs

[ https://issues.apache.org/jira/browse/FLINK-22016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-22016: Summary: PushFilterIntoTableSourceScanRule fails to deal with NULLs (was:

[jira] [Closed] (FLINK-22021) PushFilterIntoLegacyTableSourceScanRule fails to deal with INTERVAL types

[ https://issues.apache.org/jira/browse/FLINK-22021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22021. Resolution: Fixed master: f22efd321614b783d1e5604bf59b0a19946d9ccc >

[GitHub] [flink] JingsongLi merged pull request #15424: [FLINK-22021][table-planner-blink] Fix exception when PushFilterIntoLegacyTableSourceScanRule is faced with INTERVAL types

JingsongLi merged pull request #15424: URL: https://github.com/apache/flink/pull/15424 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] KurtYoung commented on a change in pull request #15437: [FLINK-20320][sql-client] support init sql file in sql client

KurtYoung commented on a change in pull request #15437: URL: https://github.com/apache/flink/pull/15437#discussion_r604538126 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlClient.java ## @@ -111,6 +111,7 @@ private void

[jira] [Commented] (FLINK-22042) Fix reading bigint(20) UNSIGNED type field cannot be cast

[ https://issues.apache.org/jira/browse/FLINK-22042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311967#comment-17311967 ] jingzi commented on FLINK-22042: in flink sql ddl is   {{create table testOne( id DECIMAL(20,0)

[GitHub] [flink] TsReaper commented on pull request #15424: [FLINK-22021][table-planner-blink] Fix exception when PushFilterIntoLegacyTableSourceScanRule is faced with INTERVAL types

TsReaper commented on pull request #15424: URL: https://github.com/apache/flink/pull/15424#issuecomment-810703592 Azure passed in https://dev.azure.com/tsreaper96/Flink/_build/results?buildId=137=results -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on pull request #15442: [FLINK-17359] [flink-core] handle entropy injection metadata path in pluggable HadoopS3FileSystem

flinkbot commented on pull request #15442: URL: https://github.com/apache/flink/pull/15442#issuecomment-810703449 ## CI report: * 174d785d8936b9aeb3934a2892fbcff1bb29b270 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15443: [FLINK-21994][python] Support FLIP-27 based FileSource connector in PyFlink DataStream API

flinkbot commented on pull request #15443: URL: https://github.com/apache/flink/pull/15443#issuecomment-810703507 ## CI report: * 3078dbd761ef4690f41732e610c4226ea920f163 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15441: [FLINK-22052][python] Add FLIP-142 public classes to python API

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

[GitHub] [flink] flinkbot commented on pull request #15444: [hotfix] Create parent interface for begin/end statement set operation.

flinkbot commented on pull request #15444: URL: https://github.com/apache/flink/pull/15444#issuecomment-810703281 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] flinkbot edited a comment on pull request #15416: [FLINK-21842][python] Support user defined WindowAssigner, Trigger and ProcessWindowFunction on Python DataStream API

flinkbot edited a comment on pull request #15416: URL: https://github.com/apache/flink/pull/15416#issuecomment-809357174 ## CI report: * f706270f3ad5fe4c436732c5c1cfc9a2e4c3ed50 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

flinkbot edited a comment on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805219989 ## CI report: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * Unknown: [CANCELED](TBD) * a56563a6a480a6caa1645326a63abc445354bdcb UNKNOWN *

[GitHub] [flink] KurtYoung opened a new pull request #15444: [hotfix] Create parent interface for begin/end statement set operation.

KurtYoung opened a new pull request #15444: URL: https://github.com/apache/flink/pull/15444 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this

[jira] [Updated] (FLINK-22013) Add Github Actions to flink-ml for every push and pull request

[ https://issues.apache.org/jira/browse/FLINK-22013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22013: --- Labels: pull-request-available (was: ) > Add Github Actions to flink-ml for every push and

[GitHub] [flink] xmarker commented on a change in pull request #15354: [FLINK-21927][table-planner-blink] Resolve ExpressionReducer compile fail when running long term

xmarker commented on a change in pull request #15354: URL: https://github.com/apache/flink/pull/15354#discussion_r604544578 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala ## @@ -116,15 +116,28 @@

[GitHub] [flink] WeiZhong94 commented on pull request #15416: [FLINK-21842][python] Support user defined WindowAssigner, Trigger and ProcessWindowFunction on Python DataStream API

WeiZhong94 commented on pull request #15416: URL: https://github.com/apache/flink/pull/15416#issuecomment-810701253 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] flinkbot commented on pull request #15443: [FLINK-21994][python] Support FLIP-27 based FileSource connector in PyFlink DataStream API

flinkbot commented on pull request #15443: URL: https://github.com/apache/flink/pull/15443#issuecomment-810699413 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

[jira] [Updated] (FLINK-22013) Add Github Actions to flink-ml for every push and pull request

[ https://issues.apache.org/jira/browse/FLINK-22013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-22013: - Summary: Add Github Actions to flink-ml for every push and pull request (was: Add CI to run tests in

[jira] [Updated] (FLINK-21994) Support FLIP-27 based FileSource connector in PyFlink DataStream API

[ https://issues.apache.org/jira/browse/FLINK-21994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21994: --- Labels: pull-request-available (was: ) > Support FLIP-27 based FileSource connector in

[GitHub] [flink] dianfu opened a new pull request #15443: [FLINK-21994][python] Support FLIP-27 based FileSource connector in PyFlink DataStream API

dianfu opened a new pull request #15443: URL: https://github.com/apache/flink/pull/15443 ## What is the purpose of the change *This pull request add supports of FLIP-27 based FileSource connector in PyFlink DataStream API* ## Brief change log - *Introduce

[jira] [Closed] (FLINK-22037) Remove the redundant blocking queue from DeployingTasksBenchmarkBase

[ https://issues.apache.org/jira/browse/FLINK-22037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-22037. --- Resolution: Fixed Fixed via b89736b1dd6f350d16529def539f1a9ebac909f1 > Remove the redundant blocking queue

[GitHub] [flink] zhuzhurk merged pull request #15432: [FLINK-22037][benchmark] Remove the redundant blocking queue from DeployingTasksBenchmarkBase

zhuzhurk merged pull request #15432: URL: https://github.com/apache/flink/pull/15432 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] becketqin commented on a change in pull request #15425: [FLINK-21133][connector/checkpoint] Fix the stop-with-savepoint case …

becketqin commented on a change in pull request #15425: URL: https://github.com/apache/flink/pull/15425#discussion_r604541769 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -730,12 +730,7 @@ public final void

  1   2   3   4   5   6   7   >