[jira] [Commented] (FLINK-26532) SinkMetricsITCase.testMetrics failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506005#comment-17506005 ] Yun Gao commented on FLINK-26532: -

[GitHub] [flink] zuston commented on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

zuston commented on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1066404621 If u have time, could you help pick up this review @gaoyunhaii . [tillrohrmann](https://github.com/tillrohrmann) maybe work on other directions. -- This is an automated

[jira] [Created] (FLINK-26625) KinesisFirehoseSinkITCase failed on azure due to Could not find a valid Docker environment

Yun Gao created FLINK-26625: --- Summary: KinesisFirehoseSinkITCase failed on azure due to Could not find a valid Docker environment Key: FLINK-26625 URL: https://issues.apache.org/jira/browse/FLINK-26625

[jira] [Created] (FLINK-26624) Running HA (hashmap, async) end-to-end test failed on azure due to unable to find master logs

Yun Gao created FLINK-26624: --- Summary: Running HA (hashmap, async) end-to-end test failed on azure due to unable to find master logs Key: FLINK-26624 URL: https://issues.apache.org/jira/browse/FLINK-26624

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506003#comment-17506003 ] Yun Gao commented on FLINK-25771: - 1.13:

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506004#comment-17506004 ] Yun Gao commented on FLINK-25771: - 1.13:

[jira] [Created] (FLINK-26623) BlobsCleanupITCase failed on azure

Yun Gao created FLINK-26623: --- Summary: BlobsCleanupITCase failed on azure Key: FLINK-26623 URL: https://issues.apache.org/jira/browse/FLINK-26623 Project: Flink Issue Type: Bug

[GitHub] [flink] deadwind4 commented on pull request #19071: FLINK-25730

deadwind4 commented on pull request #19071: URL: https://github.com/apache/flink/pull/19071#issuecomment-1066399466 please squash one commit and make the commit message like other PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] deadwind4 edited a comment on pull request #19071: FLINK-25730

deadwind4 edited a comment on pull request #19071: URL: https://github.com/apache/flink/pull/19071#issuecomment-1066399466 Please squash one commit and make the commit message like other PR. -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-26569) testResumeWithWrongOffset(org.apache.flink.runtime.fs.hdfs.HadoopRecoverableWriterTest) failing

[ https://issues.apache.org/jira/browse/FLINK-26569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506000#comment-17506000 ] Yun Gao commented on FLINK-26569: - Also on 1.15:

[jira] [Updated] (FLINK-26569) testResumeWithWrongOffset(org.apache.flink.runtime.fs.hdfs.HadoopRecoverableWriterTest) failing

[ https://issues.apache.org/jira/browse/FLINK-26569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26569: Affects Version/s: 1.15.0 >

[jira] [Commented] (FLINK-26573) ChangelogPeriodicMaterializationRescaleITCase.testRescaleIn failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505999#comment-17505999 ] Yun Gao commented on FLINK-26573: -

[jira] [Created] (FLINK-26622) Azure failed due to Connection timed out

Yun Gao created FLINK-26622: --- Summary: Azure failed due to Connection timed out Key: FLINK-26622 URL: https://issues.apache.org/jira/browse/FLINK-26622 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

flinkbot edited a comment on pull request #19070: URL: https://github.com/apache/flink/pull/19070#issuecomment-1066030702 ## CI report: * 33c5cd3d90650c0c15ea4de96108ff7d39915e0f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

flinkbot edited a comment on pull request #19070: URL: https://github.com/apache/flink/pull/19070#issuecomment-1066030702 ## CI report: * 33c5cd3d90650c0c15ea4de96108ff7d39915e0f Azure:

[GitHub] [flink] link3280 commented on pull request #17320: [FLINK-24319][Tests] Fix invalid surefire work directory for flink-tests

link3280 commented on pull request #17320: URL: https://github.com/apache/flink/pull/17320#issuecomment-1066343155 ping @zentol -- 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

[GitHub] [flink] link3280 commented on pull request #17318: [hotfix][tests] Azure tests fail prematurely because timeout watchdog fails to sleep

link3280 commented on pull request #17318: URL: https://github.com/apache/flink/pull/17318#issuecomment-1066343002 ping @zentol -- 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

[GitHub] [flink] link3280 commented on pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

link3280 commented on pull request #19070: URL: https://github.com/apache/flink/pull/19070#issuecomment-1066342715 -- 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. To

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * 957bd751af7febd48c2ef941ce78a8d2c49f40c7 Azure:

[jira] [Updated] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26473: --- Labels: pull-request-available (was: ) > Observer should support JobManager deployment

[jira] [Commented] (FLINK-26538) Ability to restart deployment w/o spec change

[ https://issues.apache.org/jira/browse/FLINK-26538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505985#comment-17505985 ] Thomas Weise commented on FLINK-26538: -- Thanks, I will assign it to you! > Ability to restart

[jira] [Assigned] (FLINK-26538) Ability to restart deployment w/o spec change

[ https://issues.apache.org/jira/browse/FLINK-26538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-26538: Assignee: Aitozi > Ability to restart deployment w/o spec change >

[jira] [Commented] (FLINK-26538) Ability to restart deployment w/o spec change

[ https://issues.apache.org/jira/browse/FLINK-26538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505983#comment-17505983 ] Aitozi commented on FLINK-26538: [~thw] Are you planning to work on this, If not, Maybe I can do you a

[jira] [Commented] (FLINK-26605) JobManagerDeploymentStatus.READY does not correctly reflect the real Flink cluster status

[ https://issues.apache.org/jira/browse/FLINK-26605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505984#comment-17505984 ] Biao Geng commented on FLINK-26605: --- Hi [~wangyang0918], the simple rest call for the state check of

[jira] [Closed] (FLINK-26534) shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism

[ https://issues.apache.org/jira/browse/FLINK-26534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-26534. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 15d2239376244ecae6b52d0a365510ff1883a8a0 >

[jira] [Commented] (FLINK-26565) Use lateTrigger when the window maxtimestap of data is less than currentwatermark and it is not discarded because the allow latency parameter

[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505981#comment-17505981 ] hehuiyuan commented on FLINK-26565: ---  [~jark] , okay. > Use lateTrigger when the window maxtimestap

[GitHub] [flink] wuchong merged pull request #19006: [FLINK-26534][table-planner] shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism

wuchong merged pull request #19006: URL: https://github.com/apache/flink/pull/19006 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #19054: [FLINK-26482][python] Support WindowedStream.reduce in Python DataStream API

flinkbot edited a comment on pull request #19054: URL: https://github.com/apache/flink/pull/19054#issuecomment-1064837015 ## CI report: * 5c14b7fc09537f4959b8dccc25722140ad2e24ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18993: [FLINK-26565][TABLE][TRIGGER]use later trigger for delay window when laterTrigger is not null

flinkbot edited a comment on pull request #18993: URL: https://github.com/apache/flink/pull/18993#issuecomment-1060422581 ## CI report: * 27e11aaa18eddce327709f714cd0657911597536 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19054: [FLINK-26482][python] Support WindowedStream.reduce in Python DataStream API

flinkbot edited a comment on pull request #19054: URL: https://github.com/apache/flink/pull/19054#issuecomment-1064837015 ## CI report: * 5c14b7fc09537f4959b8dccc25722140ad2e24ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18993: [FLINK-26565][TABLE][TRIGGER]use later trigger for delay window when laterTrigger is not null

flinkbot edited a comment on pull request #18993: URL: https://github.com/apache/flink/pull/18993#issuecomment-1060422581 ## CI report: * 27e11aaa18eddce327709f714cd0657911597536 Azure:

[GitHub] [flink] wangyang0918 commented on a change in pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

wangyang0918 commented on a change in pull request #18854: URL: https://github.com/apache/flink/pull/18854#discussion_r825573905 ## File path: flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClientTest.java ## @@ -250,6 +251,41 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

flinkbot edited a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1039977246 ## CI report: * 43c56d059f1225bac673bb0d34dec42a7a648086 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

flinkbot edited a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1039977246 ## CI report: * 43c56d059f1225bac673bb0d34dec42a7a648086 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

flinkbot edited a comment on pull request #18854: URL: https://github.com/apache/flink/pull/18854#issuecomment-1046285232 ## CI report: * f307f58982b5041b451b891d819799ddc844fa9c Azure:

[GitHub] [flink] wuchong commented on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

wuchong commented on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1066310638 Hi @ZhangChaoming , Please do not use "git merge" to merge branches, otherwise the changes is hard to track. Please use "git rebase" to rebase branches instead. IntelliJ IDEA

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505973#comment-17505973 ] Jark Wu commented on FLINK-26498: - Hi [~paul8263], as I mentioned before, we can introduce a

[jira] [Commented] (FLINK-26605) JobManagerDeploymentStatus.READY does not correctly reflect the real Flink cluster status

[ https://issues.apache.org/jira/browse/FLINK-26605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505971#comment-17505971 ] Yang Wang commented on FLINK-26605: --- I think we need to do the periodically recheck or everytime

[jira] [Commented] (FLINK-26394) CheckpointCoordinator.isTriggering can not be reset if a checkpoint expires while the checkpointCoordinator task is queuing in the SourceCoordinator executor.

[ https://issues.apache.org/jira/browse/FLINK-26394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505968#comment-17505968 ] Jiangjie Qin commented on FLINK-26394: -- Good catch. We need to recycle the futures that are handled

[GitHub] [flink] flinkbot edited a comment on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flin

flinkbot edited a comment on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1046819200 ## CI report: * 8cda572f57f1ee4a969e84d51b05d1e1ba74887f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flin

flinkbot edited a comment on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1046819200 ## CI report: * 8cda572f57f1ee4a969e84d51b05d1e1ba74887f Azure:

[GitHub] [flink] shizhengchao commented on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flink1.

shizhengchao commented on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1066291471 @PatrickRen The CI didn't pass because of the timestamp format of test case. I have fixed it , could you run it again? Thanks -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #19068: [FLINK-26601][Connector/HBase]Flink HBase HBaseRowDataAsyncLookupFunc…

flinkbot edited a comment on pull request #19068: URL: https://github.com/apache/flink/pull/19068#issuecomment-1065814892 ## CI report: * e04b67a0573bf115aa3c6d6d212df01c8230a5f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

flinkbot edited a comment on pull request #18854: URL: https://github.com/apache/flink/pull/18854#issuecomment-1046285232 ## CI report: * f307f58982b5041b451b891d819799ddc844fa9c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19068: [FLINK-26601][Connector/HBase]Flink HBase HBaseRowDataAsyncLookupFunc…

flinkbot edited a comment on pull request #19068: URL: https://github.com/apache/flink/pull/19068#issuecomment-1065814892 ## CI report: * e04b67a0573bf115aa3c6d6d212df01c8230a5f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * 9ce820e79349e6184ad0e807efc1667bbb9320d9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

flinkbot edited a comment on pull request #18854: URL: https://github.com/apache/flink/pull/18854#issuecomment-1046285232 ## CI report: * f307f58982b5041b451b891d819799ddc844fa9c Azure:

[jira] [Commented] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505959#comment-17505959 ] Yang Wang commented on FLINK-26473: --- I think FLINK-25715 might be useful when the user main throws an

[GitHub] [flink] flinkbot edited a comment on pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

flinkbot edited a comment on pull request #19033: URL: https://github.com/apache/flink/pull/19033#issuecomment-1063699541 ## CI report: * 7d1dbec66de54a97fb4a1a9a9304806bbe4da9af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

flinkbot edited a comment on pull request #18966: URL: https://github.com/apache/flink/pull/18966#issuecomment-1057770962 ## CI report: * 9ce820e79349e6184ad0e807efc1667bbb9320d9 Azure:

[GitHub] [flink] maxCodeVector commented on pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

maxCodeVector commented on pull request #18854: URL: https://github.com/apache/flink/pull/18854#issuecomment-1066276175 @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] zoucao commented on a change in pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

zoucao commented on a change in pull request #18966: URL: https://github.com/apache/flink/pull/18966#discussion_r825553511 ## File path: docs/content/docs/libs/cep.md ## @@ -1528,9 +1528,9 @@ The whole processing is done with event time. {{< tabs

[jira] [Commented] (FLINK-25648) Redundant to query deployment when creating task manager pods

[ https://issues.apache.org/jira/browse/FLINK-25648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505957#comment-17505957 ] Yuan Huang commented on FLINK-25648: - Hi, [~wangyang0918]. Thank you for your advice. I updated the

[GitHub] [flink] zhisheng17 commented on pull request #19068: [FLINK-26601][Connector/HBase]Flink HBase HBaseRowDataAsyncLookupFunc…

zhisheng17 commented on pull request #19068: URL: https://github.com/apache/flink/pull/19068#issuecomment-1066274682 @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-ml] zhipeng93 closed pull request #69: [FLINK-26443] Add benchmark framework for Flink ML

zhipeng93 closed pull request #69: URL: https://github.com/apache/flink-ml/pull/69 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] Vancior commented on a change in pull request #19054: [FLINK-26482][python] Support WindowedStream.reduce in Python DataStream API

Vancior commented on a change in pull request #19054: URL: https://github.com/apache/flink/pull/19054#discussion_r825552305 ## File path: flink-python/pyflink/datastream/functions.py ## @@ -1004,15 +1010,37 @@ def process(self, key: KEY,

[GitHub] [flink-ml] weibozhao commented on a change in pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler in FlinkML

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823425316 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScalerParams.java ## @@ -0,0 +1,56 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #19033: [FLINK-21321][Runtime/StateBackends] improve RocksDB incremental rescale performance by using deleteRange operator

flinkbot edited a comment on pull request #19033: URL: https://github.com/apache/flink/pull/19033#issuecomment-1063699541 ## CI report: * 7d1dbec66de54a97fb4a1a9a9304806bbe4da9af Azure:

[GitHub] [flink-ml] weibozhao commented on a change in pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler in FlinkML

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823414741 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScalerParams.java ## @@ -0,0 +1,56 @@ +/* + * Licensed to the

[GitHub] [flink-ml] weibozhao commented on a change in pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler in FlinkML

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r825551716 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScalerParams.java ## @@ -0,0 +1,56 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-26610) FileSink can not upgrade from 1.13 if the uid of the origin sink is not set.

[ https://issues.apache.org/jira/browse/FLINK-26610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26610. --- Resolution: Fixed > FileSink can not upgrade from 1.13 if the uid of the origin sink is not set. >

[jira] [Commented] (FLINK-26610) FileSink can not upgrade from 1.13 if the uid of the origin sink is not set.

[ https://issues.apache.org/jira/browse/FLINK-26610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505956#comment-17505956 ] Yun Gao commented on FLINK-26610: - Merged on master via

[GitHub] [flink-ml] weibozhao commented on a change in pull request #54: [FLINK-25552] Add Estimator and Transformer for MinMaxScaler in FlinkML

weibozhao commented on a change in pull request #54: URL: https://github.com/apache/flink-ml/pull/54#discussion_r823412958 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasOutputCol.java ## @@ -0,0 +1,39 @@ +/* + * Licensed to the Apache Software

[jira] [Closed] (FLINK-26580) FileSink Compactor is not properly processing in-progress files.

[ https://issues.apache.org/jira/browse/FLINK-26580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26580. --- Resolution: Fixed > FileSink Compactor is not properly processing in-progress files. >

[jira] [Commented] (FLINK-26580) FileSink Compactor is not properly processing in-progress files.

[ https://issues.apache.org/jira/browse/FLINK-26580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505955#comment-17505955 ] Yun Gao commented on FLINK-26580: - Merged on master via

[GitHub] [flink] gaoyunhaii closed pull request #19061: [FLINK-26610] FileSink can not upgrade from 1.13 if the uid of the origin sink is not set

gaoyunhaii closed pull request #19061: URL: https://github.com/apache/flink/pull/19061 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

flinkbot edited a comment on pull request #19040: URL: https://github.com/apache/flink/pull/19040#issuecomment-1064026493 ## CI report: * 555dc6ab31ce27539cae8499161bd87ecee0b353 Azure:

[GitHub] [flink] ZhangChaoming commented on a change in pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

ZhangChaoming commented on a change in pull request #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r825549512 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala ## @@ -656,13 +656,48 @@ class

[GitHub] [flink] flinkbot edited a comment on pull request #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

flinkbot edited a comment on pull request #19040: URL: https://github.com/apache/flink/pull/19040#issuecomment-1064026493 ## CI report: * 555dc6ab31ce27539cae8499161bd87ecee0b353 Azure:

[GitHub] [flink] dengziming commented on pull request #19067: [FLINK-26614]Upsert Kafka SQL Connector:Support startup mode of timestamp and specific offsets

dengziming commented on pull request #19067: URL: https://github.com/apache/flink/pull/19067#issuecomment-1066266068 Maybe we should add a test case since this is a new feature. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Comment Edited] (FLINK-26391) Release Testing: Application Mode recovery does not re-trigger a job which failed during cleanup (FLINK-11813)

[ https://issues.apache.org/jira/browse/FLINK-26391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499874#comment-17499874 ] Yang Wang edited comment on FLINK-26391 at 3/14/22, 2:11 AM: - Test this

[jira] [Commented] (FLINK-26532) SinkMetricsITCase.testMetrics failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505954#comment-17505954 ] Yun Gao commented on FLINK-26532: -

[GitHub] [flink] leonardBang commented on a change in pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

leonardBang commented on a change in pull request #18966: URL: https://github.com/apache/flink/pull/18966#discussion_r825547728 ## File path: docs/content/docs/libs/cep.md ## @@ -1528,9 +1528,9 @@ The whole processing is done with event time. {{< tabs

[GitHub] [flink] flinkbot edited a comment on pull request #19061: [FLINK-26610] FileSink can not upgrade from 1.13 if the uid of the origin sink is not set

flinkbot edited a comment on pull request #19061: URL: https://github.com/apache/flink/pull/19061#issuecomment-1065059123 ## CI report: * d1ccda4b5db2b152acb6c511aaadd49ebcf9d5d8 Azure:

[GitHub] [flink] zhoulii commented on a change in pull request #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

zhoulii commented on a change in pull request #19040: URL: https://github.com/apache/flink/pull/19040#discussion_r825546683 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java ## @@ -1772,9 +1773,23 @@

[GitHub] [flink] dianfu commented on a change in pull request #19054: [FLINK-26482][python] Support WindowedStream.reduce in Python DataStream API

dianfu commented on a change in pull request #19054: URL: https://github.com/apache/flink/pull/19054#discussion_r825543942 ## File path: flink-python/pyflink/datastream/data_stream.py ## @@ -1332,6 +1337,55 @@ def allowed_lateness(self, time_ms: int):

[GitHub] [flink] zhoulii commented on a change in pull request #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

zhoulii commented on a change in pull request #19040: URL: https://github.com/apache/flink/pull/19040#discussion_r825545501 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java ## @@ -1772,9 +1773,23 @@

[jira] [Created] (FLINK-26621) flink-tests failed on azure due to Error occurred in starting fork

Yun Gao created FLINK-26621: --- Summary: flink-tests failed on azure due to Error occurred in starting fork Key: FLINK-26621 URL: https://issues.apache.org/jira/browse/FLINK-26621 Project: Flink

[GitHub] [flink] ZhangChaoming commented on a change in pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

ZhangChaoming commented on a change in pull request #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r825544559 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java ## @@ -505,10 +511,10 @@ void

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505943#comment-17505943 ] Yao Zhang commented on FLINK-26498: --- Hi [~jark] , Thank you very much for your reply. I agreed that

[jira] [Commented] (FLINK-26559) Support Customized Kubernetes Schedulers for Flink Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-26559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505942#comment-17505942 ] bo zhao commented on FLINK-26559: - [~martijnvisser] Hi, I will. I think I need to refresh some parts of

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #41: [FLINK-26535] Introduce StoreTableSource And StoreTableSink

JingsongLi commented on a change in pull request #41: URL: https://github.com/apache/flink-table-store/pull/41#discussion_r825539312 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -65,8 +69,8 @@

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #41: [FLINK-26535] Introduce StoreTableSource And StoreTableSink

JingsongLi commented on a change in pull request #41: URL: https://github.com/apache/flink-table-store/pull/41#discussion_r825538412 ## File path: flink-table-store-kafka/src/test/java/org/apache/flink/table/store/kafka/KafkaTableTestBase.java ## @@ -92,7 +92,6 @@ protected

[GitHub] [flink] RocMarshal commented on a change in pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

RocMarshal commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r825529606 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -63,60 +65,63 @@ metrics.reporter.my_other_reporter.host: 192.168.1.1

[GitHub] [flink] dianfu commented on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

dianfu commented on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1066221067 The test failure is not related and it has passed: https://dev.azure.com/dianfu/Flink/_build/results?buildId=562=results -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-26619) Add document for the window assigners in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-26619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26619: Summary: Add document for the window assigners in Python DataStream API (was: Write the window allocator

[jira] [Updated] (FLINK-26619) Write the window allocator usage document of pyflink data flow API

[ https://issues.apache.org/jira/browse/FLINK-26619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26619: Affects Version/s: (was: 1.14.4) > Write the window allocator usage document of pyflink data flow API

[jira] [Updated] (FLINK-26619) Write the window allocator usage document of pyflink data flow API

[ https://issues.apache.org/jira/browse/FLINK-26619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26619: Fix Version/s: 1.16.0 > Write the window allocator usage document of pyflink data flow API >

[jira] [Updated] (FLINK-26619) Write the window allocator usage document of pyflink data flow API

[ https://issues.apache.org/jira/browse/FLINK-26619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26619: Component/s: Documentation > Write the window allocator usage document of pyflink data flow API >

[jira] [Updated] (FLINK-26619) Write the window allocator usage document of pyflink data flow API

[ https://issues.apache.org/jira/browse/FLINK-26619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26619: Issue Type: Improvement (was: New Feature) > Write the window allocator usage document of pyflink data

[GitHub] [flink] flinkbot edited a comment on pull request #19061: [FLINK-26610] FileSink can not upgrade from 1.13 if the uid of the origin sink is not set

flinkbot edited a comment on pull request #19061: URL: https://github.com/apache/flink/pull/19061#issuecomment-1065059123 ## CI report: * 33fc1d675b975ba4e2472e792dc64d7342ee3934 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19061: [FLINK-26610] FileSink can not upgrade from 1.13 if the uid of the origin sink is not set

flinkbot edited a comment on pull request #19061: URL: https://github.com/apache/flink/pull/19061#issuecomment-1065059123 ## CI report: * 33fc1d675b975ba4e2472e792dc64d7342ee3934 Azure:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #19061: [FLINK-26610] FileSink can not upgrade from 1.13 if the uid of the origin sink is not set

gaoyunhaii commented on a change in pull request #19061: URL: https://github.com/apache/flink/pull/19061#discussion_r825520024 ## File path: flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/BatchExecutionFileSinkITCase.java ## @@ -74,7

[jira] [Commented] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505924#comment-17505924 ] Thomas Weise commented on FLINK-26473: -- The catch all would be to check deployment after list jobs

[jira] [Commented] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505920#comment-17505920 ] Thomas Weise commented on FLINK-26473: -- We should also try to identify the job submission error

[jira] [Commented] (FLINK-26554) Clean termination of FlinkDeployment

[ https://issues.apache.org/jira/browse/FLINK-26554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505916#comment-17505916 ] Thomas Weise commented on FLINK-26554: -- (it's benign, just noise in the logs) > Clean termination

[jira] [Commented] (FLINK-26554) Clean termination of FlinkDeployment

[ https://issues.apache.org/jira/browse/FLINK-26554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505915#comment-17505915 ] Thomas Weise commented on FLINK-26554: -- I wasn't able to reproduce it. The other error we see more

[GitHub] [flink-statefun] igalshilman commented on pull request #307: [FLINK-26537][statefun] Allow disabling StatefulFunctionsConfigValida…

igalshilman commented on pull request #307: URL: https://github.com/apache/flink-statefun/pull/307#issuecomment-1066179984 Hi @FilKarnicki, no problem at all, and thanks for keep working on this. If I'm not mistaken, you can set any configuration with the `-D` flag when submitting from

[jira] [Created] (FLINK-26620) Mark CRD classes experimental

Gyula Fora created FLINK-26620: -- Summary: Mark CRD classes experimental Key: FLINK-26620 URL: https://issues.apache.org/jira/browse/FLINK-26620 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot edited a comment on pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

flinkbot edited a comment on pull request #18854: URL: https://github.com/apache/flink/pull/18854#issuecomment-1046285232 ## CI report: * f307f58982b5041b451b891d819799ddc844fa9c Azure:

  1   2   >