[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
lindong28 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832909011 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,562 @@ +/* + * Licensed to the Apache Softw

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

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062931101 ## CI report: * d3ec7878c8779c901bec0a7497b247cbe354b96e UNKNOWN * 65c05c107320acecd49d3264212cd34d1b75beb2 UNKNOWN * 62e435bd6ed42d59a24585d1a862e79b314

[GitHub] [flink] curcur opened a new pull request #19210: [FLINK-26766][Runtime/StateBackends] Fix ChangelogStateHandleStreamImpl#getIntersection

2022-03-22 Thread GitBox
curcur opened a new pull request #19210: URL: https://github.com/apache/flink/pull/19210 Cherry Pick to branch release-1.15 -- 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 comme

[jira] [Assigned] (FLINK-26791) Finish projection push down for table store

2022-03-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26791: Assignee: Jingsong Lee > Finish projection push down for table store > --

[GitHub] [flink-table-store] JingsongLi opened a new pull request #57: [FLINK-26791] Finish projection push down for table store

2022-03-22 Thread GitBox
JingsongLi opened a new pull request #57: URL: https://github.com/apache/flink-table-store/pull/57 Finish two TODOs in table store: - support projection push down for log store - support projection push down for non-primary-key -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-26791) Finish projection push down for table store

2022-03-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26791: --- Labels: pull-request-available (was: ) > Finish projection push down for table store >

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
lindong28 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832897095 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,562 @@ +/* + * Licensed to the Apache Softw

[jira] [Commented] (FLINK-26281) Test Elasticsearch connector End2End

2022-03-22 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511052#comment-17511052 ] Yangze Guo commented on FLINK-26281: master: 4e5a34d35e45154a85ad893cfbacf7d7202db41

[GitHub] [flink] KarmaGYZ closed pull request #19202: [FLINK-26281][connectors/elasticsearch] Remove unused 'connection.max-retry-timeout' option

2022-03-22 Thread GitBox
KarmaGYZ closed pull request #19202: URL: https://github.com/apache/flink/pull/19202 -- 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-unsubs

[jira] [Updated] (FLINK-26766) Fix ChangelogStateHandleStreamImpl#getIntersection

2022-03-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-26766: - Summary: Fix ChangelogStateHandleStreamImpl#getIntersection (was: Mistake in ChangelogStateHandleStream

[jira] [Commented] (FLINK-25963) FLIP-212: Introduce Flink Kubernetes Operator

2022-03-22 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511050#comment-17511050 ] Gyula Fora commented on FLINK-25963: [~wangyang0918] let's create epics for larger t

[GitHub] [flink] flinkbot edited a comment on pull request #19202: [FLINK-26281][connectors/elasticsearch] Remove unused 'connection.max-retry-timeout' option

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19202: URL: https://github.com/apache/flink/pull/19202#issuecomment-1075215093 ## CI report: * 927e80291251b906f2c34f59102a43a7df9a3a54 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26766) Mistake in ChangelogStateHandleStreamImpl#getIntersection

2022-03-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511049#comment-17511049 ] Yuan Mei commented on FLINK-26766: -- merged commit  [{{2b8b660}}|https://github.com/apac

[GitHub] [flink] curcur commented on pull request #19183: [FLINK-26766][Runtime/StateBackends] Fix ChangelogStateHandleStreamImpl#getIntersection

2022-03-22 Thread GitBox
curcur commented on pull request #19183: URL: https://github.com/apache/flink/pull/19183#issuecomment-1075976721 @zoltar9264 Thanks for the efforts, merged! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832896416 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,562 @@ +/* + * Licensed to the Apache

[GitHub] [flink] curcur merged pull request #19183: [FLINK-26766][Runtime/StateBackends] Fix ChangelogStateHandleStreamImpl#getIntersection

2022-03-22 Thread GitBox
curcur merged pull request #19183: URL: https://github.com/apache/flink/pull/19183 -- 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

[jira] [Updated] (FLINK-26806) Add deployment guide for Argo CD

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-26806: -- External issue URL: (was: https://github.com/apache/flink-kubernetes-operator/pull/98/files) > Add

[GitHub] [flink] twalthr closed pull request #19137: [FLINK-26518][table] Support BridgingSqlFunction with SqlTableFunction for Scala implicits

2022-03-22 Thread GitBox
twalthr closed pull request #19137: URL: https://github.com/apache/flink/pull/19137 -- 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-unsubsc

[jira] [Closed] (FLINK-26806) Add deployment guide for Argo CD

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-26806. - Resolution: Fixed Fixed via: main: de4670c270815aa798a3c226aab821b676d4e5b7 > Add deployment guide for

[jira] [Updated] (FLINK-26806) Add deployment guide for Argo CD

2022-03-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26806: --- Labels: pull-request-available (was: ) > Add deployment guide for Argo CD > ---

[jira] [Closed] (FLINK-26703) Introduce flink-table-store-dist module for packaging

2022-03-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26703. Fix Version/s: table-store-0.1.0 Assignee: Caizhi Weng Resolution: Fixed master: 4

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #73: [FLINK-26626] Add Transformer and Estimator for StandardScaler

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #73: URL: https://github.com/apache/flink-ml/pull/73#discussion_r832818995 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java ## @@ -32,9 +32,31 @@ public static double asum(DenseVector x) {

[jira] [Updated] (FLINK-26815) Tests in FlinkConfigBuilderTest are skipped because of NullPointerException

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-26815: -- Summary: Tests in FlinkConfigBuilderTest are skipped because of NullPointerException (was: NullPointe

[jira] [Commented] (FLINK-26281) Test Elasticsearch connector End2End

2022-03-22 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511037#comment-17511037 ] Yun Gao commented on FLINK-26281: - I'll first change the priority to critical since all

[jira] [Updated] (FLINK-26281) Test Elasticsearch connector End2End

2022-03-22 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26281: Priority: Critical (was: Blocker) > Test Elasticsearch connector End2End > --

[GitHub] [flink-table-store] JingsongLi merged pull request #50: [FLINK-26703] Introduce flink-table-store-dist module for packaging

2022-03-22 Thread GitBox
JingsongLi merged pull request #50: URL: https://github.com/apache/flink-table-store/pull/50 -- 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: issue

[jira] [Commented] (FLINK-26815) NullPointerException in FlinkConfigBuilderTest

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511036#comment-17511036 ] Yang Wang commented on FLINK-26815: --- cc [~matyas]  > NullPointerException in FlinkCon

[jira] [Created] (FLINK-26815) NullPointerException in FlinkConfigBuilderTest

2022-03-22 Thread Yang Wang (Jira)
Yang Wang created FLINK-26815: - Summary: NullPointerException in FlinkConfigBuilderTest Key: FLINK-26815 URL: https://issues.apache.org/jira/browse/FLINK-26815 Project: Flink Issue Type: Bug

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

2022-03-22 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509148#comment-17509148 ] hehuiyuan edited comment on FLINK-26565 at 3/23/22, 6:16 AM: -

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

2022-03-22 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26565 ] hehuiyuan deleted comment on FLINK-26565: --- was (Author: hehuiyuan):  [~jark] , okay. > Use lateTrigger when the window maxtimestap of data is less than > currentwatermark and it is not disca

[jira] [Assigned] (FLINK-26806) Add deployment guide for Argo CD

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-26806: - Assignee: Xin Hao > Add deployment guide for Argo CD > > >

[jira] [Commented] (FLINK-26281) Test Elasticsearch connector End2End

2022-03-22 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511028#comment-17511028 ] Yangze Guo commented on FLINK-26281: 1.15: d480fec487ce2b3d86338b9a09e88bfcfccd49e2

[GitHub] [flink] KarmaGYZ closed pull request #19203: [FLINK-26281][connectors/elasticsearch] Remove unused 'connection.max-retry-timeout' option

2022-03-22 Thread GitBox
KarmaGYZ closed pull request #19203: URL: https://github.com/apache/flink/pull/19203 -- 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-unsubs

[GitHub] [flink] flinkbot edited a comment on pull request #19209: [FLINK-26805][table] Managed table breaks legacy connector without 'connector.type'

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19209: URL: https://github.com/apache/flink/pull/19209#issuecomment-1075935081 ## CI report: * fc5332a07f7e94ce4295b2480ae2745c85614a03 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #19209: [FLINK-26805][table] Managed table breaks legacy connector without 'connector.type'

2022-03-22 Thread GitBox
flinkbot commented on pull request #19209: URL: https://github.com/apache/flink/pull/19209#issuecomment-1075935081 ## CI report: * fc5332a07f7e94ce4295b2480ae2745c85614a03 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] JingsongLi opened a new pull request #19209: [FLINK-26805][table] Managed table breaks legacy connector without 'connector.type'

2022-03-22 Thread GitBox
JingsongLi opened a new pull request #19209: URL: https://github.com/apache/flink/pull/19209 ## What is the purpose of the change Fix the bug, Managed table breaks: ``` CREATE TABLE T (a INT) WITH ('type'='legacy'); INSERT INTO T VALUES (1); ``` This case can be misint

[jira] [Updated] (FLINK-26805) Managed table breaks legacy connector without 'connector.type'

2022-03-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-26805: - Priority: Major (was: Blocker) > Managed table breaks legacy connector without 'connector.type'

[GitHub] [flink] hackergin commented on pull request #16571: [hotfix][connector/kafka] fix missing nullable annotion in createKafkaTableSink function

2022-03-22 Thread GitBox
hackergin commented on pull request #16571: URL: https://github.com/apache/flink/pull/16571#issuecomment-1075918998 @MartijnVisser Can you help have a look at this pr, if you have time. -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink] flinkbot edited a comment on pull request #19176: [FLINK-26477][python] Support WindowedStream.aggregate in Python DataStream API

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19176: URL: https://github.com/apache/flink/pull/19176#issuecomment-1073539582 ## CI report: * 17733c305d34874bf5f0d48f177552cd2360ec42 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26805) Managed table breaks legacy connector without 'connector.type'

2022-03-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17511017#comment-17511017 ] Jingsong Lee commented on FLINK-26805: -- release-1.15: 6e63e6c2ab074f070389a0eae1812

[GitHub] [flink] JingsongLi merged pull request #19201: [FLINK-26805][table] Managed table breaks legacy connector without 'connector.type'

2022-03-22 Thread GitBox
JingsongLi merged pull request #19201: URL: https://github.com/apache/flink/pull/19201 -- 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-unsu

[GitHub] [flink] flinkbot edited a comment on pull request #19161: [FLINK-26736][tests][JUnit5 migration] flink-avro-confluent-registry

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19161: URL: https://github.com/apache/flink/pull/19161#issuecomment-1072663756 ## CI report: * d47af79f7ad58d4c31fa1b392a72466e3008332e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19161: [FLINK-26736][tests][JUnit5 migration] flink-avro-confluent-registry

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19161: URL: https://github.com/apache/flink/pull/19161#issuecomment-1072663756 ## CI report: * d47af79f7ad58d4c31fa1b392a72466e3008332e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19208: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19208: URL: https://github.com/apache/flink/pull/19208#issuecomment-1075903940 ## CI report: * 2fa2c9f8f19dfaa350253977fe1c3d7d87d3d214 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #19208: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
flinkbot commented on pull request #19208: URL: https://github.com/apache/flink/pull/19208#issuecomment-1075903940 ## CI report: * 2fa2c9f8f19dfaa350253977fe1c3d7d87d3d214 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] cun8cun8 opened a new pull request #19208: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
cun8cun8 opened a new pull request #19208: URL: https://github.com/apache/flink/pull/19208 …n YARN application mode ## 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

[GitHub] [flink] flinkbot edited a comment on pull request #19193: [FLINK-26813[SQL-API] Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19193: URL: https://github.com/apache/flink/pull/19193#issuecomment-1074780636 ## CI report: * b7e8f7cce309ffac27be4d85a6788e90c26f64e3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] cun8cun8 closed pull request #19206: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
cun8cun8 closed pull request #19206: URL: https://github.com/apache/flink/pull/19206 -- 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-unsubs

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

2022-03-22 Thread GitBox
RocMarshal commented on a change in pull request #19023: URL: https://github.com/apache/flink/pull/19023#discussion_r832827432 ## File path: docs/content.zh/docs/deployment/metric_reporters.md ## @@ -221,26 +226,27 @@ metrics.reporter.stsd.port: 8125 metrics.reporter.stsd.inte

[GitHub] [flink] javacaoyu commented on pull request #19126: [FLINK-26609][python] Support sum operation in KeyedStream

2022-03-22 Thread GitBox
javacaoyu commented on pull request #19126: URL: https://github.com/apache/flink/pull/19126#issuecomment-1075892181 Hi @dianfu I have completed the modifications for this batch and test passed by pytest flake8 etc. The main modifications are: 1. Modify syntax errors in comment

[GitHub] [flink] flinkbot edited a comment on pull request #19206: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19206: URL: https://github.com/apache/flink/pull/19206#issuecomment-1075872435 ## CI report: * 146e605acf068b9dcdcb4913fc7fc6e805cfd8af Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 55dba54d849604a41e5dfcb8e8eef9fbdbc093ed Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19206: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19206: URL: https://github.com/apache/flink/pull/19206#issuecomment-1075872435 ## CI report: * 146e605acf068b9dcdcb4913fc7fc6e805cfd8af Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot commented on pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-22 Thread GitBox
flinkbot commented on pull request #19207: URL: https://github.com/apache/flink/pull/19207#issuecomment-1075886786 ## CI report: * 55dba54d849604a41e5dfcb8e8eef9fbdbc093ed UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19206: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19206: URL: https://github.com/apache/flink/pull/19206#issuecomment-1075872435 ## CI report: * 146e605acf068b9dcdcb4913fc7fc6e805cfd8af Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19201: [FLINK-26805][table] Managed table breaks legacy connector without 'connector.type'

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19201: URL: https://github.com/apache/flink/pull/19201#issuecomment-1075193107 ## CI report: * 43760bc41471b7694a2f7c61ced67d0e1ad8b8b5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19202: [FLINK-26281][connectors/elasticsearch] Remove unused 'connection.max-retry-timeout' option

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19202: URL: https://github.com/apache/flink/pull/19202#issuecomment-1075215093 ## CI report: * 927e80291251b906f2c34f59102a43a7df9a3a54 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19198: [FLINK-26783] Restore from a stop-with-savepoint if failed during committing

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19198: URL: https://github.com/apache/flink/pull/19198#issuecomment-1075044557 ## CI report: * db1d211bc42368395f186c4a0f576ba2f2bd324e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26700) Update chinese documentation regarding restore modes

2022-03-22 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510998#comment-17510998 ] Feifan Wang commented on FLINK-26700: - Hi [~yunta] , [pull request|https://github.co

[jira] [Updated] (FLINK-26700) Update chinese documentation regarding restore modes

2022-03-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26700: --- Labels: pull-request-available translation-zh (was: translation-zh) > Update chinese docume

[GitHub] [flink] zoltar9264 opened a new pull request #19207: [FLINK-26700][docs] Document restore mode in chinese

2022-03-22 Thread GitBox
zoltar9264 opened a new pull request #19207: URL: https://github.com/apache/flink/pull/19207 ## What is the purpose of the change Added chinese documentation for the RestoreMode ## Verifying this change This is a change to documentation ## Does this pull request p

[GitHub] [flink] flinkbot edited a comment on pull request #19206: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19206: URL: https://github.com/apache/flink/pull/19206#issuecomment-1075872435 ## CI report: * 146e605acf068b9dcdcb4913fc7fc6e805cfd8af Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19202: [FLINK-26281][connectors/elasticsearch] Remove unused 'connection.max-retry-timeout' option

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19202: URL: https://github.com/apache/flink/pull/19202#issuecomment-1075215093 ## CI report: * 927e80291251b906f2c34f59102a43a7df9a3a54 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19198: [FLINK-26783] Restore from a stop-with-savepoint if failed during committing

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19198: URL: https://github.com/apache/flink/pull/19198#issuecomment-1075044557 ## CI report: * db1d211bc42368395f186c4a0f576ba2f2bd324e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] gaoyunhaii commented on pull request #19202: [FLINK-26281][connectors/elasticsearch] Remove unused 'connection.max-retry-timeout' option

2022-03-22 Thread GitBox
gaoyunhaii commented on pull request #19202: URL: https://github.com/apache/flink/pull/19202#issuecomment-1075884225 @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 speci

[GitHub] [flink] gaoyunhaii commented on pull request #19198: [FLINK-26783] Restore from a stop-with-savepoint if failed during committing

2022-03-22 Thread GitBox
gaoyunhaii commented on pull request #19198: URL: https://github.com/apache/flink/pull/19198#issuecomment-1075883225 @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 speci

[jira] [Comment Edited] (FLINK-26738) Default value of StateDescriptor is valid when enable state ttl config

2022-03-22 Thread Jianhui Dong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510267#comment-17510267 ] Jianhui Dong edited comment on FLINK-26738 at 3/23/22, 3:41 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #19206: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19206: URL: https://github.com/apache/flink/pull/19206#issuecomment-1075872435 ## CI report: * 146e605acf068b9dcdcb4913fc7fc6e805cfd8af Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19202: [FLINK-26281][connectors/elasticsearch] Remove unused 'connection.max-retry-timeout' option

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19202: URL: https://github.com/apache/flink/pull/19202#issuecomment-1075215093 ## CI report: * 927e80291251b906f2c34f59102a43a7df9a3a54 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19126: [FLINK-26609][python] Support sum operation in KeyedStream

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19126: URL: https://github.com/apache/flink/pull/19126#issuecomment-1070385440 ## CI report: * a73169d7357a465b3d8b2a647c0ceaa8b435ee24 UNKNOWN * 8813e5db24962156396d853e770bb539b7c7e622 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19126: [FLINK-26609][python] Support sum operation in KeyedStream

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19126: URL: https://github.com/apache/flink/pull/19126#issuecomment-1070385440 ## CI report: * a73169d7357a465b3d8b2a647c0ceaa8b435ee24 UNKNOWN * 8813e5db24962156396d853e770bb539b7c7e622 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19206: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19206: URL: https://github.com/apache/flink/pull/19206#issuecomment-1075872435 ## CI report: * 955188123d7392041742d0313236c19e4d6a5d57 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19126: [FLINK-26609][python] Support sum operation in KeyedStream

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19126: URL: https://github.com/apache/flink/pull/19126#issuecomment-1070385440 ## CI report: * a73169d7357a465b3d8b2a647c0ceaa8b435ee24 UNKNOWN * 8813e5db24962156396d853e770bb539b7c7e622 Azure: [FAILURE](https://dev.azure.com/apache-f

[jira] [Closed] (FLINK-26807) The batch job not work well with Operator

2022-03-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-26807. -- Resolution: Duplicate > The batch job not work well with Operator > -

[jira] [Commented] (FLINK-26807) The batch job not work well with Operator

2022-03-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510991#comment-17510991 ] Aitozi commented on FLINK-26807: Get it, I will look over that discussion, Closing this

[GitHub] [flink] flinkbot edited a comment on pull request #19126: [FLINK-26609][python] Support sum operation in KeyedStream

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19126: URL: https://github.com/apache/flink/pull/19126#issuecomment-1070385440 ## CI report: * a73169d7357a465b3d8b2a647c0ceaa8b435ee24 UNKNOWN * 8813e5db24962156396d853e770bb539b7c7e622 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19206: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19206: URL: https://github.com/apache/flink/pull/19206#issuecomment-1075872435 ## CI report: * 955188123d7392041742d0313236c19e4d6a5d57 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25552) Add Estimator and Transformer for MinMaxScaler

2022-03-22 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-25552: - Summary: Add Estimator and Transformer for MinMaxScaler (was: Support MinMaxScaler in FlinkML) > Add E

[jira] [Updated] (FLINK-25527) Add Transformer and Estimator for StringIndexer

2022-03-22 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-25527: - Summary: Add Transformer and Estimator for StringIndexer (was: Add StringIndexer in FlinkML) > Add Tra

[GitHub] [flink-ml] yunfengzhou-hub commented on pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on pull request #70: URL: https://github.com/apache/flink-ml/pull/70#issuecomment-1075872552 Thanks for the comments. I have updated the PR according to these comments. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot commented on pull request #19206: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
flinkbot commented on pull request #19206: URL: https://github.com/apache/flink/pull/19206#issuecomment-1075872435 ## CI report: * 955188123d7392041742d0313236c19e4d6a5d57 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832808860 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeansParams.java ## @@ -0,0 +1,81 @@ +/* + * Licensed to the A

[jira] [Closed] (FLINK-26753) PK constraint should include partition key

2022-03-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26753. Fix Version/s: table-store-0.1.0 Resolution: Fixed master: e3a708d8ce04b9831805a818baa3d091

[jira] [Updated] (FLINK-26814) It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26814: --- Labels: pull-request-available (was: ) > It reported "should only have one jar" when submit

[GitHub] [flink] cun8cun8 opened a new pull request #19206: [FLINK-26814][Deployment / YARN]It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread GitBox
cun8cun8 opened a new pull request #19206: URL: https://github.com/apache/flink/pull/19206 ## 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 o

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832807869 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,569 @@ +/* + * Licensed to the Apache

[GitHub] [flink-table-store] JingsongLi merged pull request #54: [FLINK-26753] PK constraint should include partition keys if table is partitioned

2022-03-22 Thread GitBox
JingsongLi merged pull request #54: URL: https://github.com/apache/flink-table-store/pull/54 -- 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: issue

[jira] [Commented] (FLINK-26806) Add deployment guide for Argo CD

2022-03-22 Thread Xin Hao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510985#comment-17510985 ] Xin Hao commented on FLINK-26806: - I just opened a PR for this [https://github.com/apac

[jira] [Updated] (FLINK-26806) Add deployment guide for Argo CD

2022-03-22 Thread Xin Hao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Hao updated FLINK-26806: External issue URL: https://github.com/apache/flink-kubernetes-operator/pull/98/files > Add deployment gu

[GitHub] [flink] lsyldliu commented on pull request #19193: [FLINK-26813[SQL-API] Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE

2022-03-22 Thread GitBox
lsyldliu commented on pull request #19193: URL: https://github.com/apache/flink/pull/19193#issuecomment-1075864283 > @lsyldliu Thank you very much for your contribution. > > However, I have started working on this ticket [FLINK-22315](https://issues.apache.org/jira/browse/FLINK-22315

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
lindong28 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832803814 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/util/InMemorySourceFunction.java ## @@ -0,0 +1,92 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
lindong28 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832802109 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/OnlineKMeansTest.java ## @@ -0,0 +1,487 @@ +/* + * Licensed to the Apache Software

[jira] [Updated] (FLINK-26814) It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26814: Priority: Critical (was: Blocker) > It reported "should only have one jar" when submitting PyFlink jobs i

[jira] [Updated] (FLINK-26814) It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26814: Component/s: API / Python > It reported "should only have one jar" when submitting PyFlink jobs in YARN >

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

2022-03-22 Thread GitBox
lindong28 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r832799295 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,409 @@ +/* + * Licensed to the Apache Softw

[jira] [Updated] (FLINK-26814) It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode

2022-03-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26814: Summary: It reported "should only have one jar" when submitting PyFlink jobs in YARN application mode (wa

[jira] [Commented] (FLINK-26799) StateChangeFormat#read not seek to offset correctly

2022-03-22 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510981#comment-17510981 ] Feifan Wang commented on FLINK-26799: - Hi [~roman] , can you help confirm that ? >

[jira] [Assigned] (FLINK-26814) Solve the problem that "should only have one jar" is reported as an error when the application submits an operation in the yarn mode

2022-03-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-26814: --- Assignee: zhangjingcun > Solve the problem that "should only have one jar" is reported as an error

[jira] [Created] (FLINK-26814) Solve the problem that "should only have one jar" is reported as an error when the application submits an operation in the yarn mode

2022-03-22 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-26814: Summary: Solve the problem that "should only have one jar" is reported as an error when the application submits an operation in the yarn mode Key: FLINK-26814 URL: https://issues.

[GitHub] [flink] flinkbot edited a comment on pull request #19202: [FLINK-26281][connectors/elasticsearch] Remove unused 'connection.max-retry-timeout' option

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19202: URL: https://github.com/apache/flink/pull/19202#issuecomment-1075215093 ## CI report: * 927e80291251b906f2c34f59102a43a7df9a3a54 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

  1   2   3   4   5   6   7   >