[jira] [Commented] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506716#comment-17506716 ] Yingjie Cao commented on FLINK-26568: - Thanks, I will take a look. >

[GitHub] [flink] flinkbot edited a comment on pull request #19091: [BP-1.15][docs] Update wrong links in the datastream/execution_mode.md page.

flinkbot edited a comment on pull request #19091: URL: https://github.com/apache/flink/pull/19091#issuecomment-1067583598 ## CI report: * f55e9d61327da4033c0f45b13cbdfbe7a84417fa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19090: [BP-1.14][docs] Update wrong links in the datastream/execution_mode.md page.

flinkbot edited a comment on pull request #19090: URL: https://github.com/apache/flink/pull/19090#issuecomment-1067583371 ## CI report: * 11ef66762336f4bb29cc8a9d47df859aa0cab1f9 Azure:

[GitHub] [flink] flinkbot commented on pull request #19091: [BP-1.15][docs] Update wrong links in the datastream/execution_mode.md page.

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

[GitHub] [flink] flinkbot commented on pull request #19090: [BP-1.14][docs] Update wrong links in the datastream/execution_mode.md page.

flinkbot commented on pull request #19090: URL: https://github.com/apache/flink/pull/19090#issuecomment-1067583371 ## CI report: * 11ef66762336f4bb29cc8a9d47df859aa0cab1f9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] RocMarshal commented on pull request #18491: [FLINK-25800][docs] Update wrong links in the datastream/execution_mode.md page.

RocMarshal commented on pull request #18491: URL: https://github.com/apache/flink/pull/18491#issuecomment-1067581926 @MartijnVisser I created [BP-1.14](https://github.com/apache/flink/pull/19090) & [BP-1.15](https://github.com/apache/flink/pull/19091). PTAL. Thank you very much. --

[GitHub] [flink] RocMarshal opened a new pull request #19091: [BP-1.15][docs] Update wrong links in the datastream/execution_mode.md page.

RocMarshal opened a new pull request #19091: URL: https://github.com/apache/flink/pull/19091 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[GitHub] [flink] RocMarshal opened a new pull request #19090: [BP-1.14][docs] Update wrong links in the datastream/execution_mode.md page.

RocMarshal opened a new pull request #19090: URL: https://github.com/apache/flink/pull/19090 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[GitHub] [flink] flinkbot edited a comment on pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

flinkbot edited a comment on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062931101 ## CI report: * 67d5ec6c01c800d61a20f278ad2b9d33ba8354af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

flinkbot edited a comment on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062931101 ## CI report: * 67d5ec6c01c800d61a20f278ad2b9d33ba8354af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18646: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

flinkbot edited a comment on pull request #18646: URL: https://github.com/apache/flink/pull/18646#issuecomment-1031503295 ## CI report: * cb7d3ffbe8d6e057a68a473747998c3a646e9ce7 UNKNOWN * Unknown: [CANCELED](TBD) * 5219c94d1e14bb5f9c717caf685ad39760b7b539 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * afdaf43f43e70634a9df988f9a141144fb9b0918 Azure:

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

ChengkaiYang2022 commented on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1067558346 @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

[GitHub] [flink] flinkbot edited a comment on pull request #19089: [FLINK-26607][python] There are multiple MAX_LONG_VALUE value errors in pyflink code

flinkbot edited a comment on pull request #19089: URL: https://github.com/apache/flink/pull/19089#issuecomment-1067544609 ## CI report: * 146e605acf068b9dcdcb4913fc7fc6e805cfd8af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18646: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

flinkbot edited a comment on pull request #18646: URL: https://github.com/apache/flink/pull/18646#issuecomment-1031503295 ## CI report: * cb7d3ffbe8d6e057a68a473747998c3a646e9ce7 UNKNOWN * Unknown: [CANCELED](TBD) * 5219c94d1e14bb5f9c717caf685ad39760b7b539 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

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

[jira] [Updated] (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:all-tabpanel ] ASF GitHub Bot updated FLINK-26605: --- Labels: pull-request-available (was: ) > JobManagerDeploymentStatus.READY does not

[GitHub] [flink] flinkbot commented on pull request #19089: [FLINK-26607][python] There are multiple MAX_LONG_VALUE value errors in pyflink code

flinkbot commented on pull request #19089: URL: https://github.com/apache/flink/pull/19089#issuecomment-1067544609 ## CI report: * 146e605acf068b9dcdcb4913fc7fc6e805cfd8af UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

RocMarshal commented on a change in pull request #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r826563563 ## 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 #19053: [FLINK-26595][flink-connector-jdbc][postgreSQL]Improve the PostgresDi…

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

[jira] [Created] (FLINK-26642) Pulsar sink fails with non-partitioned topic

goldenyang created FLINK-26642: -- Summary: Pulsar sink fails with non-partitioned topic Key: FLINK-26642 URL: https://issues.apache.org/jira/browse/FLINK-26642 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18816: [FLINK-26027][pulsar] add sink metrics to pulsar sink

flinkbot edited a comment on pull request #18816: URL: https://github.com/apache/flink/pull/18816#issuecomment-1042851613 ## CI report: * 271648472e6f8e46df9945f09a65d34f762c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18646: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

flinkbot edited a comment on pull request #18646: URL: https://github.com/apache/flink/pull/18646#issuecomment-1031503295 ## CI report: * Unknown: [CANCELED](TBD) * cb7d3ffbe8d6e057a68a473747998c3a646e9ce7 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * fad5d9cf60fda4a391a398a465510b803a5331be Azure:

[GitHub] [flink] wangzhiwubigdata edited a comment on pull request #18646: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

wangzhiwubigdata edited a comment on pull request #18646: URL: https://github.com/apache/flink/pull/18646#issuecomment-1067531677 > i have resolved the conflicts. plz check. @RocMarshal -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] wangzhiwubigdata commented on pull request #18646: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

wangzhiwubigdata commented on pull request #18646: URL: https://github.com/apache/flink/pull/18646#issuecomment-1067531677 > i have resolved the conflicts. plz check. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] wangzhiwubigdata commented on pull request #18646: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

wangzhiwubigdata commented on pull request #18646: URL: https://github.com/apache/flink/pull/18646#issuecomment-1067531462 @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

[GitHub] [flink] flinkbot edited a comment on pull request #19053: [FLINK-26595][flink-connector-jdbc][postgreSQL]Improve the PostgresDi…

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

[jira] [Updated] (FLINK-26607) There are multiple MAX_LONG_VALUE value errors in pyflink code

[ https://issues.apache.org/jira/browse/FLINK-26607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26607: --- Labels: pull-request-available (was: ) > There are multiple MAX_LONG_VALUE value errors in

[GitHub] [flink] cun8cun8 opened a new pull request #19089: [FLINK-26607][python] Fix MAX_LONG_VALUE value

cun8cun8 opened a new pull request #19089: URL: https://github.com/apache/flink/pull/19089 ## What is the purpose of the change This PR is mainly to repair MAX_LONG_VALUE value MAX_LONG_VALUE = sys.maxsize maxsize attribute of the sys module fetches the largest

[GitHub] [flink] flinkbot edited a comment on pull request #18816: [FLINK-26027][pulsar] add sink metrics to pulsar sink

flinkbot edited a comment on pull request #18816: URL: https://github.com/apache/flink/pull/18816#issuecomment-1042851613 ## CI report: * 271648472e6f8e46df9945f09a65d34f762c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * fad5d9cf60fda4a391a398a465510b803a5331be Azure:

[GitHub] [flink] imaffe closed pull request #18974: Flink 26028 sink documentation 2

imaffe closed pull request #18974: URL: https://github.com/apache/flink/pull/18974 -- 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-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_r826542180 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/feature/MinMaxScalerTest.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] flinkbot edited a comment on pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

flinkbot edited a comment on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062931101 ## CI report: * 67d5ec6c01c800d61a20f278ad2b9d33ba8354af 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_r826541447 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/feature/MinMaxScalerTest.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the Apache Software

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

ChengkaiYang2022 commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r826540950 ## 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-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_r826540271 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -84,14 +109,15 @@

[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_r826540199 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/feature/MinMaxScalerTest.java ## @@ -0,0 +1,204 @@ +/* + * Licensed to the Apache Software

[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_r826539650 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScaler.java ## @@ -0,0 +1,198 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-26641) Optimize the time of fetching job status in the job submission of session cluster

Yangze Guo created FLINK-26641: -- Summary: Optimize the time of fetching job status in the job submission of session cluster Key: FLINK-26641 URL: https://issues.apache.org/jira/browse/FLINK-26641

[GitHub] [flink] flinkbot edited a comment on pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

flinkbot edited a comment on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062931101 ## CI report: * 67d5ec6c01c800d61a20f278ad2b9d33ba8354af 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_r826538436 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScaler.java ## @@ -0,0 +1,198 @@ +/* + * Licensed to the Apache

[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_r826537120 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScaler.java ## @@ -0,0 +1,198 @@ +/* + * Licensed to the Apache

[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_r826536751 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScaler.java ## @@ -0,0 +1,198 @@ +/* + * Licensed to the Apache

[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_r826536318 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/minmaxscaler/MinMaxScalerModel.java ## @@ -0,0 +1,179 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * bf6a9fbe9ce3fedd00b1f0b8bbf978e0caf5eeff Azure:

[jira] [Commented] (FLINK-26330) Test Adaptive Batch Scheduler manually

[ https://issues.apache.org/jira/browse/FLINK-26330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506669#comment-17506669 ] kangTwang commented on FLINK-26330: --- [~wanglijie95]    -> You can see  [Blocking

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

LadyForest commented on a change in pull request #41: URL: https://github.com/apache/flink-table-store/pull/41#discussion_r826534273 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -84,14 +109,15 @@

[jira] [Commented] (FLINK-23252) Support recovery (from checkpoints) after disabling changelog backend

[ https://issues.apache.org/jira/browse/FLINK-23252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506668#comment-17506668 ] Hangxiang Yu commented on FLINK-23252: -- I'd like to work on it. Would you mind to assign this

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * bf6a9fbe9ce3fedd00b1f0b8bbf978e0caf5eeff Azure:

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

LadyForest commented on a change in pull request #41: URL: https://github.com/apache/flink-table-store/pull/41#discussion_r826533232 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -129,6 +155,85 @@

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

LadyForest commented on a change in pull request #41: URL: https://github.com/apache/flink-table-store/pull/41#discussion_r826532696 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -84,14 +109,15 @@

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * 29cade383a72c2b682060a1e95abbda9158aea78 Azure:

[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_r826527466 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -184,9 +286,42 @@

[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_r826526318 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -184,9 +286,42 @@

[jira] [Commented] (FLINK-26634) Update Chinese version of Elasticsearch connector docs

[ https://issues.apache.org/jira/browse/FLINK-26634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506665#comment-17506665 ] chenzihao commented on FLINK-26634: --- Hi, [~alexanderpreuss] . Should I open a new PR after this

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

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

[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_r826525653 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -129,6 +155,85 @@

[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_r826525388 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -129,6 +155,85 @@

[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_r826524928 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -129,6 +155,85 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

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

[GitHub] [flink] flinkbot edited a comment on pull request #18983: [FLINK-25543][flink-yarn] [JUnit5 Migration] Module: flink-yarn

flinkbot edited a comment on pull request #18983: URL: https://github.com/apache/flink/pull/18983#issuecomment-1059740356 ## CI report: * 6352c8bf4468c666c5340e887500b68434c7529e Azure:

[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_r826523559 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -84,14 +109,15 @@

[jira] [Commented] (FLINK-26618) Remove jar statement not aligned with pipleline.jars

[ https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506662#comment-17506662 ] Paul Lin commented on FLINK-26618: -- cc [~jark][~twalthr] > Remove jar statement not aligned with

[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: * ab5b2d1c9a5792cd1018668e9ab225d91eac8f0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18983: [FLINK-25543][flink-yarn] [JUnit5 Migration] Module: flink-yarn

flinkbot edited a comment on pull request #18983: URL: https://github.com/apache/flink/pull/18983#issuecomment-1059740356 ## CI report: * 6352c8bf4468c666c5340e887500b68434c7529e Azure:

[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: * ab5b2d1c9a5792cd1018668e9ab225d91eac8f0d Azure:

[jira] [Commented] (FLINK-23830) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506661#comment-17506661 ] Hangxiang Yu commented on FLINK-23830: --

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

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

[GitHub] [flink] RocMarshal commented on pull request #18491: [FLINK-25800][docs] Update wrong links in the datastream/execution_mode.md page.

RocMarshal commented on pull request #18491: URL: https://github.com/apache/flink/pull/18491#issuecomment-1067481864 > @RocMarshal Thanks again for the PR. Can you also create backports to the release-1.15 and release-1.14 branches? @MartijnVisser Thanks for the operation. I'm glad

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

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

[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: Parent: FLINK-26477 Issue Type: Sub-task (was: Improvement) > Add document for the window

[GitHub] [flink] flinkbot edited a comment on pull request #19077: drop flink-sql-parser-hive module

flinkbot edited a comment on pull request #19077: URL: https://github.com/apache/flink/pull/19077#issuecomment-1066739670 ## CI report: * 2a07ed207e222b6a9a1f8b283e6549da42dac890 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19077: drop flink-sql-parser-hive module

flinkbot edited a comment on pull request #19077: URL: https://github.com/apache/flink/pull/19077#issuecomment-1066739670 ## CI report: * 2a07ed207e222b6a9a1f8b283e6549da42dac890 Azure:

[jira] [Assigned] (FLINK-26609) Support sum operation in KeyedStream

[ https://issues.apache.org/jira/browse/FLINK-26609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-26609: --- Assignee: CaoYu > Support sum operation in KeyedStream > > >

[jira] [Commented] (FLINK-26330) Test Adaptive Batch Scheduler manually

[ https://issues.apache.org/jira/browse/FLINK-26330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506659#comment-17506659 ] Lijie Wang commented on FLINK-26330: [~kingWang] Currently, each partition will be divided into

[jira] [Updated] (FLINK-26609) Support sum operation in KeyedStream

[ https://issues.apache.org/jira/browse/FLINK-26609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26609: Fix Version/s: 1.16.0 > Support sum operation in KeyedStream > > >

[jira] [Updated] (FLINK-26609) Support sum operation in KeyedStream

[ https://issues.apache.org/jira/browse/FLINK-26609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26609: Summary: Support sum operation in KeyedStream (was: Add a "sum" operator In PyFlink KeyedStream API) >

[jira] [Commented] (FLINK-26609) Add a "sum" operator In PyFlink KeyedStream API

[ https://issues.apache.org/jira/browse/FLINK-26609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506658#comment-17506658 ] Dian Fu commented on FLINK-26609: - [~javacaoyu] Sure, thanks for the contribution~ > Add a "sum"

[jira] [Closed] (FLINK-26506) Support StreamExecutionEnvironment.registerCachedFile in Python DataStream API

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

[GitHub] [flink] dianfu closed pull request #19011: [FLINK-26506][python] Support StreamExecutionEnvironment.registerCachedFile in Python DataStream API

dianfu closed pull request #19011: URL: https://github.com/apache/flink/pull/19011 -- 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:

[jira] [Closed] (FLINK-26444) Add a few commonly used window assigners in PyFlink DataStream API

[ https://issues.apache.org/jira/browse/FLINK-26444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-26444. --- Resolution: Fixed Merged to master via c3244c3786f1c3342ea34439eaa170c9ab460ed5 > Add a few commonly used

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

dianfu closed pull request #18957: URL: https://github.com/apache/flink/pull/18957 -- 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] syhily edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

syhily edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1064890584 * 1st run: [SUCCESS](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32872=results) * 2nd run:

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 0c50e74cf63c7d037b5e6eeb7ee39d969157d985 Azure:

[GitHub] [flink-training] victorunique commented on a change in pull request #46: [FLINK-26382]Add Chinese documents for flink-training exercises

victorunique commented on a change in pull request #46: URL: https://github.com/apache/flink-training/pull/46#discussion_r826470737 ## File path: README_zh.md ## @@ -0,0 +1,274 @@ + + +# Apache Flink 实践练习 + +与文档中实践练习内容相关的练习。 + +## 目录 +

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

flinkbot edited a comment on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1064736520 ## CI report: * f6f49ca5f2d7cd8ca05a51c286979a89e2f1d652 Azure:

  1   2   3   4   5   6   >