[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: * 0aad19c7d082cb85e069a2521e4e8d26617445b7 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] AHeise commented on pull request #18790: [FLINK-26018][connector/common] Create per-split output on split addition in SourceOperator

AHeise commented on pull request #18790: URL: https://github.com/apache/flink/pull/18790#issuecomment-1067631387 I'm [rerunning](http://codespeed.dak8s.net:8080/job/flink-benchmark-request/69) the benchmarks and would merge if there are no obvious things -- This is an automated message

[GitHub] [flink] gaoyunhaii commented on pull request #19073: [FLINK-26613][streaming] Allow setting operator uid hashes for predefined sink operators

gaoyunhaii commented on pull request #19073: URL: https://github.com/apache/flink/pull/19073#issuecomment-1067630823 Thanks @fapaul for the fix! I'll have a look~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

Yun Gao created FLINK-26644: --- Summary: python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure Key: FLINK-26644 URL: https://issues.apache.org/jira/browse/FLINK-26644

[jira] [Commented] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots ha

[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506732#comment-17506732 ] Yun Gao commented on FLINK-24960: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-24744) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on Azure because org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server do

[ https://issues.apache.org/jira/browse/FLINK-24744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506731#comment-17506731 ] Yun Gao commented on FLINK-24744: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-26115) Multiple Kafka connector tests failed due to The topic metadata failed to propagate to Kafka broker

[ https://issues.apache.org/jira/browse/FLINK-26115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506729#comment-17506729 ] Yun Gao commented on FLINK-26115: - 1.14: https://dev.azure.com/apache-flink/apache-flin

[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&focusedCommentId=17506727#comment-17506727 ] Yun Gao commented on FLINK-25771: - 1.15: https://dev.azure.com/apache-flink/apache-flin

[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: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Closed] (FLINK-26612) Create docs webpages like other Flink projects

[ https://issues.apache.org/jira/browse/FLINK-26612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26612. -- Resolution: Fixed merged: b72a61dd918d884668805a1d3e35881a040bfcc4 > Create docs webpages like other

[jira] [Closed] (FLINK-26552) Try to use @EnableKubernetesMockClient(crud = true) in controller test

[ https://issues.apache.org/jira/browse/FLINK-26552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26552. -- Resolution: Fixed merged: f4c8bae8c154650891c077e3c22033117411f82d > Try to use @EnableKubernetesMock

[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_r826619958 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala ## @@ -656,13 +656,48 @@ class T

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: * 26366818f1c6a7b29ddb063414d1b3a2eaf34408 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26643) EOFException throws when use TypeInformationKeyValueSerializationSchema to deserialize data from kafka

[ https://issues.apache.org/jira/browse/FLINK-26643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hengtai Nie updated FLINK-26643: Summary: EOFException throws when use TypeInformationKeyValueSerializationSchema to deserialize da

[jira] [Updated] (FLINK-26643) Exception occurs when use TypeInformationKeyValueSerializationSchema to deserialize data from kafka

[ https://issues.apache.org/jira/browse/FLINK-26643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hengtai Nie updated FLINK-26643: Summary: Exception occurs when use TypeInformationKeyValueSerializationSchema to deserialize data

[jira] [Commented] (FLINK-26636) EmbeddedMultiThreadDependencyTests test_add_python_file failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506718#comment-17506718 ] Huang Xingbo commented on FLINK-26636: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-26643) Exception occues when use TypeInformationKeyValueSerializationSchema to deserialize data from kafka

Hengtai Nie created FLINK-26643: --- Summary: Exception occues when use TypeInformationKeyValueSerializationSchema to deserialize data from kafka Key: FLINK-26643 URL: https://issues.apache.org/jira/browse/FLINK-26643

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

[ https://issues.apache.org/jira/browse/FLINK-26642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17506717#comment-17506717 ] Yufei Zhang commented on FLINK-26642: - Roger. I'll try to reproduce it.  > Pulsar s

[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&focusedCommentId=17506716#comment-17506716 ] Yingjie Cao commented on FLINK-26568: - Thanks, I will take a look. > BlockingShuffl

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 them

[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 re-transferr

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [PENDING

[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: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[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 the

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 correctl

[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 Tabl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 fo

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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, please

[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 an

[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 the

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 value

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: issues-unsubscr

[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 Fo

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 Fo

[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 me

[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 @@ pu

[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 Fo

[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 So

[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 Project

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 So

[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 So

[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 So

[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 Apac

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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&focusedCommentId=17506669#comment-17506669 ] kangTwang commented on FLINK-26330: --- [~wanglijie95]    -> You can see  [Blocking Sh

[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 @@ pu

[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&focusedCommentId=17506668#comment-17506668 ] Hangxiang Yu commented on FLINK-23252: -- I'd like to work on it. Would you mind to a

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 @@ pu

[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 @@ pu

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 @@ pr

[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 @@ pr

[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&focusedCommentId=17506665#comment-17506665 ] chenzihao commented on FLINK-26634: --- Hi, [~alexanderpreuss] . Should I open a new PR a

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 @@ pu

[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 @@ pu

[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 @@ pu

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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 @@ pu

[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&focusedCommentId=17506662#comment-17506662 ] Paul Lin commented on FLINK-26618: -- cc [~jark][~twalthr] > Remove jar statement not al

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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&focusedCommentId=17506661#comment-17506661 ] Hangxiang Yu commented on FLINK-23830: -- https://dev.azure.com/apache-flink/apache-f

[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 t

[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 So

[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 assigne

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[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&focusedCommentId=17506659#comment-17506659 ] Lijie Wang commented on FLINK-26330: [~kingWang] Currently, each partition will be d

[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) > S

  1   2   3   4   5   6   >