[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=17511028#comment-17511028 ] Yangze Guo commented on FLINK-26281: 1.15: d480fec487ce2b3d86338b9a09e88bfcfccd49e2 > Test

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

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

[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

[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

[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

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

[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=17511017#comment-17511017 ] Jingsong Lee commented on FLINK-26805: -- release-1.15: 6e63e6c2ab074f070389a0eae181269cfbc82772 >

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

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

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

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

[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

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

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

[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

[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

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

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

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

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

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

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

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

[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=17510998#comment-17510998 ] Feifan Wang commented on FLINK-26700: - Hi [~yunta] , [pull

[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

[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

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

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

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

[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

[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

[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=17510267#comment-17510267 ] Jianhui Dong edited comment on FLINK-26738 at 3/23/22, 3:41 AM: "it will

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

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

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

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

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

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

[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=17510991#comment-17510991 ] Aitozi commented on FLINK-26807: Get it, I will look over that discussion, Closing this one as

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

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

[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

[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

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

[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

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

[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

[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

[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

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

[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=17510985#comment-17510985 ] Xin Hao commented on FLINK-26806: - I just opened a PR for this

[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

[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

[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

[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

[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

[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

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

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

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

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

[jira] [Resolved] (FLINK-25527) Add StringIndexer in FlinkML

2022-03-22 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-25527. --- Fix Version/s: ml-2.0.1 Assignee: Zhipeng Zhang Resolution: Fixed fixed on

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

2022-03-22 Thread GitBox
KarmaGYZ commented on pull request #19202: URL: https://github.com/apache/flink/pull/19202#issuecomment-1075854079 @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] hailiangyuan commented on pull request #19053: [FLINK-26595][flink-connector-jdbc][postgreSQL]Improve the PostgresDi…

2022-03-22 Thread GitBox
hailiangyuan commented on pull request #19053: URL: https://github.com/apache/flink/pull/19053#issuecomment-1075853771 I have the same problem ! but i Met with failure when i recompiled flink-connector-JDBC.Where to get it recompiled flink-connector-JDBC -- This is an automated

[jira] [Commented] (FLINK-26706) Introduce Ingress URL templating

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510976#comment-17510976 ] Yang Wang commented on FLINK-26706: --- Fixed via: main: 68b9186049e486f4568b4d7999f90f6bae8c190b >

[jira] [Closed] (FLINK-26706) Introduce Ingress URL templating

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-26706. - Resolution: Fixed > Introduce Ingress URL templating > > >

[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_r832765505 ## 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] KarmaGYZ commented on pull request #19108: [FLINK-26675][runtime] Parallelized heavy serialization in StreamingJ…

2022-03-22 Thread GitBox
KarmaGYZ commented on pull request #19108: URL: https://github.com/apache/flink/pull/19108#issuecomment-1075851256 Thanks for the review and valuable comments @zentol . I'm still working on the next version of this PR and will take your comments into account. -- This is an automated

[GitHub] [flink] KarmaGYZ commented on a change in pull request #19108: [FLINK-26675][runtime] Parallelized heavy serialization in StreamingJ…

2022-03-22 Thread GitBox
KarmaGYZ commented on a change in pull request #19108: URL: https://github.com/apache/flink/pull/19108#discussion_r832790149 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java ## @@ -144,6 +151,18 @@ public

[GitHub] [flink-ml] lindong28 commented on pull request #52: [FLINK-25527] Add Transformer and Estimator for StringIndexer

2022-03-22 Thread GitBox
lindong28 commented on pull request #52: URL: https://github.com/apache/flink-ml/pull/52#issuecomment-1075850626 Thanks for the update! The PR has been merged to the master branch. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-ml] lindong28 merged pull request #52: [FLINK-25527] Add Transformer and Estimator for StringIndexer

2022-03-22 Thread GitBox
lindong28 merged pull request #52: URL: https://github.com/apache/flink-ml/pull/52 -- 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-table-store] LadyForest commented on a change in pull request #54: [FLINK-26753] PK constraint should include partition keys if table is partitioned

2022-03-22 Thread GitBox
LadyForest commented on a change in pull request #54: URL: https://github.com/apache/flink-table-store/pull/54#discussion_r832789552 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStore.java ## @@ -171,6 +183,35 @@ private

[GitHub] [flink] dianfu commented on pull request #19086: [FLINK-26767][python] Update code to use the changes for TableConfig

2022-03-22 Thread GitBox
dianfu commented on pull request #19086: URL: https://github.com/apache/flink/pull/19086#issuecomment-1075848783 Closed via aa28cd73e4467968af9df70701fbd48541403bdb -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] dianfu closed pull request #19086: [FLINK-26767][python] Update code to use the changes for TableConfig

2022-03-22 Thread GitBox
dianfu closed pull request #19086: URL: https://github.com/apache/flink/pull/19086 -- 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] [Commented] (FLINK-25963) FLIP-212: Introduce Flink Kubernetes Operator

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510973#comment-17510973 ] Yang Wang commented on FLINK-25963: --- Do you think we need to create another umbrella ticket for phase2

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

[jira] [Commented] (FLINK-26742) DefaultCompletedCheckpointStore.shutdown does not clean the checkpoints atomically

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510971#comment-17510971 ] Yang Wang commented on FLINK-26742: --- I appreciate for your explanation. >

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

[jira] [Commented] (FLINK-26812) Flink native k8s integration should support owner reference

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510969#comment-17510969 ] Yang Wang commented on FLINK-26812: --- I am not sure which orphaned resources you are talking about.

[GitHub] [flink] flinkbot edited a comment on pull request #19072: [FLINK-11388][fs] Add Aliyun OSS recoverable writer

2022-03-22 Thread GitBox
flinkbot edited a comment on pull request #19072: URL: https://github.com/apache/flink/pull/19072#issuecomment-1066471341 ## CI report: * 5715ca8ed70256fb4c1f9303a2e7b04d1b8d8ebd Azure:

[jira] [Commented] (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:comment-tabpanel=17510968#comment-17510968 ] Yang Wang commented on FLINK-26806: --- [~haoxin] Would you like to work on this ticket and share how to

[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_r832775815 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/util/InMemorySourceFunction.java ## @@ -0,0 +1,92 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #52: [FLINK-25527] Add Transformer and Estimator for StringIndexer

2022-03-22 Thread GitBox
zhipeng93 commented on a change in pull request #52: URL: https://github.com/apache/flink-ml/pull/52#discussion_r832775562 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/feature/stringindexer/IndexToStringModelTest.java ## @@ -0,0 +1,165 @@ +/* + * Licensed to

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

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

2022-03-22 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510967#comment-17510967 ] Yang Wang commented on FLINK-26807: --- FLINK-24113 is very useful in such scenario. Actually, we already

[jira] [Updated] (FLINK-26813) Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE

2022-03-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26813: --- Labels: pull-request-available (was: ) > Supports ADD/MODIFY column/watermark/constraint

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

[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_r832772257 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/util/InMemorySinkFunction.java ## @@ -0,0 +1,86 @@ +/* + * Licensed to the Apache

[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_r832772257 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/util/InMemorySinkFunction.java ## @@ -0,0 +1,86 @@ +/* + * Licensed to the Apache

  1   2   3   4   5   6   7   >