[jira] [Resolved] (FLINK-26809) ChangelogStorageMetricsTest.testAttemptsPerUpload failed

2022-03-24 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-26809. --- Resolution: Fixed Merged into 1.15 as 3c88f887de26f58cff27c87931d7a2f6928c81da,

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

2022-03-24 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r834972977 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModelParams.java ## @@ -21,27 +21,11 @@ import

[GitHub] [flink] rkhachatryan commented on pull request #19222: [FLINK-26809][tests] Assert histogram state after stopping the uploader

2022-03-24 Thread GitBox
rkhachatryan commented on pull request #19222: URL: https://github.com/apache/flink/pull/19222#issuecomment-1078679614 Thanks for the review! Merged into master and 1.15. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] rkhachatryan merged pull request #19222: [FLINK-26809][tests] Assert histogram state after stopping the uploader

2022-03-24 Thread GitBox
rkhachatryan merged pull request #19222: URL: https://github.com/apache/flink/pull/19222 -- 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] [Resolved] (FLINK-26677) Make flink-connector-base dependency consistent

2022-03-24 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li resolved FLINK-26677. -- Resolution: Fixed > Make flink-connector-base dependency consistent >

[GitHub] [flink] rkhachatryan commented on pull request #19225: [FLINK-26799][Runtime/StateBackends] fix StateChangeFormat#read and e…

2022-03-24 Thread GitBox
rkhachatryan commented on pull request #19225: URL: https://github.com/apache/flink/pull/19225#issuecomment-1078677669 Hi @zoltar9264 , indeed, test failure is unrelated. Do you mind changing the commit message so that it fits into one line and maybe better describes the change? I

[jira] [Commented] (FLINK-25867) [ZH] Add ChangelogBackend documentation

2022-03-24 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512203#comment-17512203 ] Roman Khachatryan commented on FLINK-25867: --- Hi [~Feifan Wang], sure, thanks for volunteering!

[jira] [Assigned] (FLINK-25867) [ZH] Add ChangelogBackend documentation

2022-03-24 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-25867: - Assignee: Feifan Wang > [ZH] Add ChangelogBackend documentation >

[jira] [Updated] (FLINK-26728) Support min operation in KeyedStream

2022-03-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-26728: Affects Version/s: (was: 1.14.3) > Support min operation in KeyedStream >

[jira] [Commented] (FLINK-26728) Support min operation in KeyedStream

2022-03-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512201#comment-17512201 ] Dian Fu commented on FLINK-26728: - [~javacaoyu] Yes, we should do such abstraction and avoid code

[GitHub] [flink] flinkbot edited a comment on pull request #19235: [FLINK-26848][JDBC]write data when disable flush-interval and max-rows

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19235: URL: https://github.com/apache/flink/pull/19235#issuecomment-1077732821 ## CI report: * 113821e3dad0a8cde32b8d062913cf11efa564a4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19241: [FLINK-26788][core] Add cause when AbstractDeserializationSchema throw exception

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19241: URL: https://github.com/apache/flink/pull/19241#issuecomment-1078660907 ## CI report: * d5e513797e5de12c5052cebe2148f03f48f49462 Azure:

[GitHub] [flink] flinkbot commented on pull request #19241: [FLINK-26788][core] Add cause when AbstractDeserializationSchema throw exception

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

[jira] [Updated] (FLINK-26788) AbstractDeserializationSchema should add cause when thow a FlinkRuntimeException

2022-03-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26788: --- Labels: pull-request-available (was: ) > AbstractDeserializationSchema should add cause

[GitHub] [flink] chucheng92 opened a new pull request #19241: [FLINK-26788][core] Add cause when AbstractDeserializationSchema throw exception

2022-03-24 Thread GitBox
chucheng92 opened a new pull request #19241: URL: https://github.com/apache/flink/pull/19241 ## What is the purpose of the change Add cause when `AbstractDeserializationSchema` throw exception for troubleshooting. ## Brief change log Add cause when

[GitHub] [flink] RyanSkraba commented on a change in pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

2022-03-24 Thread GitBox
RyanSkraba commented on a change in pull request #18928: URL: https://github.com/apache/flink/pull/18928#discussion_r833967920 ## File path: flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendTestBase.java ## @@ -20,10 +20,9 @@ import

[GitHub] [flink] flinkbot edited a comment on pull request #19229: [FLINK-26738]Mark StateDescriptor#defaultValue as deprecated and add doc

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19229: URL: https://github.com/apache/flink/pull/19229#issuecomment-1077649038 ## CI report: * 87ce50c59c99fdc0e7d065a38b2f02183406a947 Azure:

[GitHub] [flink] chucheng92 removed a comment on pull request #19240: [FLINK-9198][core] Add cause when AbstractDeserializationSchema throw exception

2022-03-24 Thread GitBox
chucheng92 removed a comment on pull request #19240: URL: https://github.com/apache/flink/pull/19240#issuecomment-1078647449 reopen this pr. -- 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] chucheng92 commented on pull request #19240: [FLINK-9198][core] Add cause when AbstractDeserializationSchema throw exception

2022-03-24 Thread GitBox
chucheng92 commented on pull request #19240: URL: https://github.com/apache/flink/pull/19240#issuecomment-1078647449 reopen this pr. -- 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

[jira] [Commented] (FLINK-26788) AbstractDeserializationSchema should add cause when thow a FlinkRuntimeException

2022-03-24 Thread Ryan Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512196#comment-17512196 ] Ryan Tao commented on FLINK-26788: -- Yes, add cause will help us to determine problem. i'm pleasure to

[GitHub] [flink] flinkbot edited a comment on pull request #19229: [FLINK-26738]Mark StateDescriptor#defaultValue as deprecated and add doc

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19229: URL: https://github.com/apache/flink/pull/19229#issuecomment-1077649038 ## CI report: * 87ce50c59c99fdc0e7d065a38b2f02183406a947 Azure:

[GitHub] [flink] chucheng92 closed pull request #19240: [FLINK-9198][core] Add cause when AbstractDeserializationSchema throw exception

2022-03-24 Thread GitBox
chucheng92 closed pull request #19240: URL: https://github.com/apache/flink/pull/19240 -- 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] chucheng92 opened a new pull request #19240: [FLINK-9198][core] Add cause when AbstractDeserializationSchema throw exception

2022-03-24 Thread GitBox
chucheng92 opened a new pull request #19240: URL: https://github.com/apache/flink/pull/19240 ## What is the purpose of the change Add cause when AbstractDeserializationSchema throw exception for troubleshooting. ## Brief change log Add cause when

[jira] [Updated] (FLINK-9198) Improve error messages in AbstractDeserializationSchema for type extraction

2022-03-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9198: -- Labels: pull-request-available (was: ) > Improve error messages in

[jira] [Closed] (FLINK-26855) ImportError: cannot import name 'environmentfilter' from 'jinja2'

2022-03-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-26855. --- Fix Version/s: 1.15.0 1.13.7 1.14.5 Resolution: Fixed Fixed

[jira] [Assigned] (FLINK-26855) ImportError: cannot import name 'environmentfilter' from 'jinja2'

2022-03-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-26855: --- Assignee: Juntao Hu > ImportError: cannot import name 'environmentfilter' from 'jinja2' >

[GitHub] [flink] dianfu merged pull request #19238: [FLINK-26855][python] Fix Sphinx check failure caused by Jinja2 dependency

2022-03-24 Thread GitBox
dianfu merged pull request #19238: URL: https://github.com/apache/flink/pull/19238 -- 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] dianfu commented on pull request #19238: [FLINK-26855][python] Fix Sphinx check failure caused by Jinja2 dependency

2022-03-24 Thread GitBox
dianfu commented on pull request #19238: URL: https://github.com/apache/flink/pull/19238#issuecomment-1078634121 I have verified it locally and merging this PR since all the builds are affected. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-25867) [ZH] Add ChangelogBackend documentation

2022-03-24 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512187#comment-17512187 ] Feifan Wang commented on FLINK-25867: - Hi [~roman] , I'm a chinese speaker, and I'm glad to do this

[GitHub] [flink] flinkbot edited a comment on pull request #19227: [FLINK-26847][python] Ensure command line option '-py' works in YARN application mode

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19227: URL: https://github.com/apache/flink/pull/19227#issuecomment-1077616952 ## CI report: * 8618735443118d029f9e414bfc95c5d9aa22e63a Azure:

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

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

[GitHub] [flink] Myasuka commented on a change in pull request #19229: [FLINK-26738]Mark StateDescriptor#defaultValue as deprecated and add doc

2022-03-24 Thread GitBox
Myasuka commented on a change in pull request #19229: URL: https://github.com/apache/flink/pull/19229#discussion_r834932514 ## File path: flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java ## @@ -258,7 +258,7 @@ public boolean isQueryable() {

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

2022-03-24 Thread GitBox
lindong28 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r834931138 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModelParams.java ## @@ -21,27 +21,11 @@ import

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #19239: Update elasticsearch.md

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19239: URL: https://github.com/apache/flink/pull/19239#issuecomment-1078621814 ## CI report: * fb4dce5442c4b00ab94abc52e4134068d83f6fdd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19144: [hotfix][release] Update the compatibility table for the release 1.14 and 1.15

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19144: URL: https://github.com/apache/flink/pull/19144#issuecomment-1072079715 ## CI report: * c4832a135bb8a37f298d1e7acf96a184061e68ee Azure:

[jira] [Commented] (FLINK-26214) Publish Kubernetes operator to container registry

2022-03-24 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512179#comment-17512179 ] Yang Wang commented on FLINK-26214: --- Having a "snapshot" docker artifact on ghcr.io will greatly help

[GitHub] [flink] flinkbot commented on pull request #19239: Update elasticsearch.md

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

[GitHub] [flink] flinkbot edited a comment on pull request #19144: [hotfix][release] Update the compatibility table for the release 1.14 and 1.15

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19144: URL: https://github.com/apache/flink/pull/19144#issuecomment-1072079715 ## CI report: * c4832a135bb8a37f298d1e7acf96a184061e68ee Azure:

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

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

[GitHub] [flink] jxzkin opened a new pull request #19239: Update elasticsearch.md

2022-03-24 Thread GitBox
jxzkin opened a new pull request #19239: URL: https://github.com/apache/flink/pull/19239 UPSERT instead of UPDATE/INSERT ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC.

[GitHub] [flink] gaoyunhaii commented on pull request #19101: [FLINK-26634][docs-zh] Update Chinese version of Elasticsearch connector docs

2022-03-24 Thread GitBox
gaoyunhaii commented on pull request #19101: URL: https://github.com/apache/flink/pull/19101#issuecomment-1078616202 Hi @chenzihao5 very thanks for the PR! The ElasticSearch should have been changed a bit due to some compatibility issue in the past days and the document also has been

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

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

[GitHub] [flink] gaoyunhaii closed pull request #19211: [FLINK-26638][connectors/elasticsearch] update the Chinese document accordingly

2022-03-24 Thread GitBox
gaoyunhaii closed pull request #19211: URL: https://github.com/apache/flink/pull/19211 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

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

2022-03-24 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r834922711 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModelData.java ## @@ -47,8 +47,16 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

[jira] [Commented] (FLINK-26827) FlinkSQL和hive整合报错

2022-03-24 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512175#comment-17512175 ] luoyuxia commented on FLINK-26827: -- [~zhushifeng] for hive-exec-2.1.0.jar,  when the major version of

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

[jira] [Created] (FLINK-26858) When submitting a task, an error is reported and the description is inaccurate, which will lead to misleading

2022-03-24 Thread Jira
丛鹏 created FLINK-26858: -- Summary: When submitting a task, an error is reported and the description is inaccurate, which will lead to misleading Key: FLINK-26858 URL: https://issues.apache.org/jira/browse/FLINK-26858

[GitHub] [flink] flinkbot edited a comment on pull request #19238: [FLINK-26855][python] Fix Sphinx check failure caused by Jinja2 dependency

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19238: URL: https://github.com/apache/flink/pull/19238#issuecomment-1078606426 ## CI report: * 156d46e1da6994b997bbe3f019575f8e06caaacb Azure:

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

2022-03-24 Thread GitBox
lindong28 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r834919072 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/OnlineKMeansTest.java ## @@ -0,0 +1,464 @@ +/* + * 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-24 Thread GitBox
yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r834918943 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,437 @@ +/* + * Licensed to the

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

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 6010ae984a6a90656fa47e47eeff1dbb082ab5d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #58: [FLINK-26669] Refactor ReadWriteTableITCase

2022-03-24 Thread GitBox
LadyForest commented on a change in pull request #58: URL: https://github.com/apache/flink-table-store/pull/58#discussion_r834917705 ## File path: flink-table-store-core/src/test/java/org/apache/flink/table/store/file/utils/BlockingIterator.java ## @@ -65,6 +65,15 @@ public

[GitHub] [flink] flinkbot commented on pull request #19238: [FLINK-26855][python] Fix Sphinx check failure caused by Jinja2 dependency

2022-03-24 Thread GitBox
flinkbot commented on pull request #19238: URL: https://github.com/apache/flink/pull/19238#issuecomment-1078606426 ## CI report: * 156d46e1da6994b997bbe3f019575f8e06caaacb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 6010ae984a6a90656fa47e47eeff1dbb082ab5d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

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

2022-03-24 Thread GitBox
ZhangChaoming commented on a change in pull request #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r834917235 ## File path: flink-table/flink-sql-client/src/test/resources/sql/catalog_database.q ## @@ -106,6 +122,77 @@ show databases; 2 rows in set !ok

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

2022-03-24 Thread GitBox
ZhangChaoming commented on a change in pull request #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r834916553 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowDatabases.java ## @@ -49,8 +70,44 @@ public

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

2022-03-24 Thread GitBox
ZhangChaoming commented on a change in pull request #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r834916265 ## File path: docs/content/docs/dev/table/sql/show.md ## @@ -504,10 +504,69 @@ Show current catalog. ## SHOW DATABASES ```sql -SHOW DATABASES

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

[jira] [Updated] (FLINK-26855) ImportError: cannot import name 'environmentfilter' from 'jinja2'

2022-03-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26855: --- Labels: pull-request-available (was: ) > ImportError: cannot import name

[GitHub] [flink] Vancior opened a new pull request #19238: [FLINK-26855][python] Fix Sphinx check failure caused by Jinja2 dependency

2022-03-24 Thread GitBox
Vancior opened a new pull request #19238: URL: https://github.com/apache/flink/pull/19238 ## What is the purpose of the change This PR fixes Sphinx check failure when running `dev/lint-python.sh`, which is caused by newly released Jinja2. ## Brief change log

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

2022-03-24 Thread GitBox
ZhangChaoming commented on a change in pull request #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r834913824 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowDatabases.java ## @@ -49,8 +70,44 @@ public

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

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

[jira] [Assigned] (FLINK-26856) Add ITCase for compound primary key and multi-partition

2022-03-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26856: Assignee: Jane Chan > Add ITCase for compound primary key and multi-partition >

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

[jira] [Assigned] (FLINK-26857) Add ITCase for projection and filter predicate

2022-03-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26857: Assignee: Jane Chan > Add ITCase for projection and filter predicate >

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

2022-03-24 Thread GitBox
zhipeng93 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r834912447 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java ## @@ -159,68 +161,78 @@ public IterationBodyResult process(

[jira] [Closed] (FLINK-26744) Init document for table store and introduce quickstart

2022-03-24 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26744. Resolution: Fixed master: b8d0304baf2df992bc1eb25fc1598b01955f4792 > Init document for table

[jira] [Updated] (FLINK-26857) Add ITCase for projection and filter predicate

2022-03-24 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26857: -- Description: To cover the conditions like  * filter predicate on partition fields * filter

[GitHub] [flink-table-store] JingsongLi merged pull request #53: [FLINK-26744] Init document for table store and introduce quickstart

2022-03-24 Thread GitBox
JingsongLi merged pull request #53: URL: https://github.com/apache/flink-table-store/pull/53 -- 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] gaoyunhaii commented on pull request #19211: [FLINK-26638][connectors/elasticsearch] update the Chinese document accordingly

2022-03-24 Thread GitBox
gaoyunhaii commented on pull request #19211: URL: https://github.com/apache/flink/pull/19211#issuecomment-1078599719 Thanks @KarmaGYZ @hackergin for the review! Will merge~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (FLINK-26683) Terminate the job anyway if savepoint finished when stop-with-savepoint

2022-03-24 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512165#comment-17512165 ] Liu commented on FLINK-26683: - I wonder what situations will cause the savepoint complete but fail to

[GitHub] [flink] flinkbot edited a comment on pull request #19235: [FLINK-26848][JDBC]write data when disable flush-interval and max-rows

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19235: URL: https://github.com/apache/flink/pull/19235#issuecomment-1077732821 ## CI report: * 0906a35a0d861a0675c648adf41a1a3d9aece3bc Azure:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #19211: [FLINK-26638][connectors/elasticsearch] update the Chinese document accordingly

2022-03-24 Thread GitBox
gaoyunhaii commented on a change in pull request #19211: URL: https://github.com/apache/flink/pull/19211#discussion_r834911346 ## File path: docs/content.zh/docs/connectors/table/elasticsearch.md ## @@ -130,11 +130,28 @@ CREATE TABLE myUserTable ( 用于连接 Elasticsearch

[GitHub] [flink] gaoyunhaii commented on a change in pull request #19211: [FLINK-26638][connectors/elasticsearch] update the Chinese document accordingly

2022-03-24 Thread GitBox
gaoyunhaii commented on a change in pull request #19211: URL: https://github.com/apache/flink/pull/19211#discussion_r834911346 ## File path: docs/content.zh/docs/connectors/table/elasticsearch.md ## @@ -130,11 +130,28 @@ CREATE TABLE myUserTable ( 用于连接 Elasticsearch

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

[jira] [Created] (FLINK-26857) Add ITCase for projection and filter predicate

2022-03-24 Thread Jane Chan (Jira)
Jane Chan created FLINK-26857: - Summary: Add ITCase for projection and filter predicate Key: FLINK-26857 URL: https://issues.apache.org/jira/browse/FLINK-26857 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19235: [FLINK-26848][JDBC]write data when disable flush-interval and max-rows

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19235: URL: https://github.com/apache/flink/pull/19235#issuecomment-1077732821 ## CI report: * 0906a35a0d861a0675c648adf41a1a3d9aece3bc Azure:

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #58: [FLINK-26669] Refactor ReadWriteTableITCase

2022-03-24 Thread GitBox
JingsongLi commented on a change in pull request #58: URL: https://github.com/apache/flink-table-store/pull/58#discussion_r834909824 ## File path: flink-table-store-core/src/test/java/org/apache/flink/table/store/file/utils/BlockingIterator.java ## @@ -65,6 +65,15 @@ public

[jira] [Updated] (FLINK-26856) Add ITCase for compound primary key and multi-partition

2022-03-24 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26856: -- Description: Cover the condition with  * multi-partitions like dt='2022-01-01'/region='Euro' *

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #58: [FLINK-26669] Refactor ReadWriteTableITCase

2022-03-24 Thread GitBox
JingsongLi commented on a change in pull request #58: URL: https://github.com/apache/flink-table-store/pull/58#discussion_r834909405 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/sink/SinkRecordConverter.java ## @@ -55,15 +68,31 @@ public

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #53: [FLINK-26744] Init document for table store and introduce quickstart

2022-03-24 Thread GitBox
JingsongLi commented on a change in pull request #53: URL: https://github.com/apache/flink-table-store/pull/53#discussion_r834908686 ## File path: docs/content/_index.md ## @@ -0,0 +1,57 @@ +--- +title: Apache Flink Table Store +type: docs +bookToc: false +--- + + +# Apache

[jira] [Created] (FLINK-26856) Add ITCase for compound primary key and multi-partition

2022-03-24 Thread Jane Chan (Jira)
Jane Chan created FLINK-26856: - Summary: Add ITCase for compound primary key and multi-partition Key: FLINK-26856 URL: https://issues.apache.org/jira/browse/FLINK-26856 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * a85f63f4b850c86dacf3652331b1cdd1741f3853 Azure:

[jira] [Created] (FLINK-26855) ImportError: cannot import name 'environmentfilter' from 'jinja2'

2022-03-24 Thread Dian Fu (Jira)
Dian Fu created FLINK-26855: --- Summary: ImportError: cannot import name 'environmentfilter' from 'jinja2' Key: FLINK-26855 URL: https://issues.apache.org/jira/browse/FLINK-26855 Project: Flink

[jira] [Commented] (FLINK-26854) 重定向数据库无法写入

2022-03-24 Thread jinfeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512158#comment-17512158 ] jinfeng commented on FLINK-26854: - [~MingHao Liu] I don't think this is a problem with Flink, when

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

2022-03-24 Thread GitBox
PatrickRen commented on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1078588219 @fapaul I think this bug has existed since we bumped Kafka client to 2.4.1, which was in Flink 1.11. So at least we need to backport to 1.13 and 1.14. @shizhengchao

[jira] [Created] (FLINK-26854) 重定向数据库无法写入

2022-03-24 Thread liuminghao (Jira)
liuminghao created FLINK-26854: -- Summary: 重定向数据库无法写入 Key: FLINK-26854 URL: https://issues.apache.org/jira/browse/FLINK-26854 Project: Flink Issue Type: Bug Components: API / DataSet

[GitHub] [flink] flinkbot edited a comment on pull request #19227: [FLINK-26847][python] Ensure command line option '-py' works in YARN application mode

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19227: URL: https://github.com/apache/flink/pull/19227#issuecomment-1077616952 ## CI report: * ae3e7c3cce5851c155d49501eb9802ef683a6d54 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19227: [FLINK-26847][python] Ensure command line option '-py' works in YARN application mode

2022-03-24 Thread GitBox
flinkbot edited a comment on pull request #19227: URL: https://github.com/apache/flink/pull/19227#issuecomment-1077616952 ## CI report: * ae3e7c3cce5851c155d49501eb9802ef683a6d54 Azure:

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

2022-03-24 Thread GitBox
zhipeng93 commented on a change in pull request #73: URL: https://github.com/apache/flink-ml/pull/73#discussion_r834170129 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/standardscaler/StandardScalerModel.java ## @@ -0,0 +1,185 @@ +/* + * Licensed to the

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

2022-03-24 Thread GitBox
zhipeng93 commented on a change in pull request #73: URL: https://github.com/apache/flink-ml/pull/73#discussion_r834124527 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/DenseVector.java ## @@ -68,4 +68,9 @@ public boolean equals(Object obj) {

[jira] [Closed] (FLINK-26846) Gauge metrics doesn't work in PyFlink

2022-03-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-26846. --- Fix Version/s: 1.15.0 1.13.7 1.14.5 Resolution: Fixed Fixed

  1   2   3   4   5   6   >