[GitHub] [flink] flinkbot edited a comment on pull request #19163: [hotfix][bp-1.15][docs] Fix doc for interval of years

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

[GitHub] [flink] flinkbot edited a comment on pull request #19164: [hotfix][bp-1.14][docs] Fix doc for interval of years

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

[GitHub] [flink] flinkbot edited a comment on pull request #19156: decouple-hive-planer

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

[GitHub] [flink] flinkbot commented on pull request #19164: [hotfix][docs] Fix doc for interval of years

2022-03-18 Thread GitBox
flinkbot commented on pull request #19164: URL: https://github.com/apache/flink/pull/19164#issuecomment-1072952190 ## CI report: * 0eddc1b3c70bbc98d9b47dd50b1d51e563c9c2df UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #19163: [hotfix][docs] Fix doc for interval of years

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

[GitHub] [flink] flinkbot edited a comment on pull request #19156: decouple-hive-planer

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

[GitHub] [flink] yittg commented on pull request #19164: [hotfix][docs] Fix doc for interval of years

2022-03-18 Thread GitBox
yittg commented on pull request #19164: URL: https://github.com/apache/flink/pull/19164#issuecomment-1072951889 cc @MartijnVisser -- 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 co

[GitHub] [flink] yittg opened a new pull request #19164: [hotfix][docs] Fix doc for interval of years

2022-03-18 Thread GitBox
yittg opened a new pull request #19164: URL: https://github.com/apache/flink/pull/19164 ## What is the purpose of the change Backport of #18936 for 1.14. ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on job creation tim

[GitHub] [flink] yittg commented on pull request #19163: [hotfix][docs] Fix doc for interval of years

2022-03-18 Thread GitBox
yittg commented on pull request #19163: URL: https://github.com/apache/flink/pull/19163#issuecomment-1072951663 cc @MartijnVisser -- 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 co

[GitHub] [flink] yittg opened a new pull request #19163: [hotfix][docs] Fix doc for interval of years

2022-03-18 Thread GitBox
yittg opened a new pull request #19163: URL: https://github.com/apache/flink/pull/19163 ## What is the purpose of the change Backport of #18936 for 1.15. ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on job creation tim

[GitHub] [flink] MartijnVisser merged pull request #19127: [hotfix][docs] Fix the broken link for late events/lateness

2022-03-18 Thread GitBox
MartijnVisser merged pull request #19127: URL: https://github.com/apache/flink/pull/19127 -- 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-u

[jira] [Reopened] (FLINK-26270) Flink SQL write data to kafka by CSV format , decimal type was converted to scientific notation

2022-03-18 Thread fengjk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fengjk reopened FLINK-26270: > Flink SQL write data to kafka by CSV format , decimal type was converted to > scientific notation > ---

[jira] [Resolved] (FLINK-26270) Flink SQL write data to kafka by CSV format , decimal type was converted to scientific notation

2022-03-18 Thread fengjk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fengjk resolved FLINK-26270. Fix Version/s: 1.12.4 Resolution: Fixed > Flink SQL write data to kafka by CSV format , decimal typ

[GitHub] [flink] hongshuboy closed pull request #19046: [hotfix][docs] Fix syntax errors in java doc

2022-03-18 Thread GitBox
hongshuboy closed pull request #19046: URL: https://github.com/apache/flink/pull/19046 -- 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 #19162: [FLINK-26578][BP-1.15][docs-zh] Translate new Project Configuration section to Chinese

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

[jira] [Commented] (FLINK-26655) Improve the observe logic in SessionObserver

2022-03-18 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509168#comment-17509168 ] Biao Geng commented on FLINK-26655: --- I rewrite this jira after our previous discussion

[GitHub] [flink] flinkbot edited a comment on pull request #19162: [FLINK-26578][BP-1.15][docs-zh] Translate new Project Configuration section to Chinese

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

[GitHub] [flink] liyubin117 commented on pull request #19162: [FLINK-26578][BP-1.15][docs-zh] Translate new Project Configuration section to Chinese

2022-03-18 Thread GitBox
liyubin117 commented on pull request #19162: URL: https://github.com/apache/flink/pull/19162#issuecomment-1072943092 @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] [Updated] (FLINK-26655) Improve the observe logic in SessionObserver

2022-03-18 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26655: -- Description: -We now consider that JM pod can have 2 possible states after launching:- # -JM is launc

[jira] [Updated] (FLINK-26655) Improve the observe logic in SessionObserver

2022-03-18 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26655: -- Description: -We now consider that JM pod can have 2 possible states after launching:- # -JM is launc

[jira] [Updated] (FLINK-26605) Check if JM can serve rest api calls every time before reconcile

2022-03-18 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26605: -- Summary: Check if JM can serve rest api calls every time before reconcile (was: Improve the observe l

[jira] [Updated] (FLINK-26655) Improve the observe logic in SessionObserver

2022-03-18 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26655: -- Summary: Improve the observe logic in SessionObserver (was: Merge isJobManagerPortReady and isJobMana

[jira] [Updated] (FLINK-26605) Improve the observe logic in SessionObserver

2022-03-18 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26605: -- Summary: Improve the observe logic in SessionObserver (was: JobManagerDeploymentStatus.READY does not

[jira] [Updated] (FLINK-26655) Merge isJobManagerPortReady and isJobManagerServing to check if JM pod can work correctly

2022-03-18 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26655: -- Description: -We now consider that JM pod can have 2 possible states after launching:- # -JM is launc

[GitHub] [flink] flinkbot edited a comment on pull request #19162: [FLINK-26578][BP-1.15][docs-zh] Translate new Project Configuration section to Chinese

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

[GitHub] [flink] realdengziqi commented on pull request #18982: [FLINK-26334][datastream] Fix getWindowStartWithOffset in TimeWindow.java

2022-03-18 Thread GitBox
realdengziqi commented on pull request #18982: URL: https://github.com/apache/flink/pull/18982#issuecomment-1072939994 @fapaul Thanks for the guidance, we rebased it to the latest master branch of the community and force pushed it recently. We also created backport PRs for the release1.14

[GitHub] [flink] flinkbot edited a comment on pull request #19156: decouple-hive-planer

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

[GitHub] [flink] flinkbot edited a comment on pull request #19156: decouple-hive-planer

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

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

2022-03-18 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509151#comment-17509151 ] Leonard Xu commented on FLINK-26618: Fixed: master(1.16):1b041dbd9a781ef7a3927df45

[GitHub] [flink] leonardBang commented on pull request #19133: [BP-1.15][FLINK-26618] Fix pipeline.jars not aligned with remove-jar statement

2022-03-18 Thread GitBox
leonardBang commented on pull request #19133: URL: https://github.com/apache/flink/pull/19133#issuecomment-1072932785 @link3280 You may also need rebase current branch to latest `release-1.15` to avoid the failure case. -- This is an automated message from the Apache Git Service.

[GitHub] [flink] leonardBang commented on pull request #19132: [BP-1.14][FLINK-26618] Fix pipeline.jars not aligned with remove-jar statement

2022-03-18 Thread GitBox
leonardBang commented on pull request #19132: URL: https://github.com/apache/flink/pull/19132#issuecomment-1072932740 @link3280 You may also need rebase current branch to latest `release-1.14` to avoid the failure case. -- This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] leonardBang commented on pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

2022-03-18 Thread GitBox
leonardBang commented on pull request #19070: URL: https://github.com/apache/flink/pull/19070#issuecomment-1072932511 Thanks @link3280 for the continuous work, the Github infrastructure broken recently which influenced many project 😂. -- This is an automated message from the Apache Git S

[GitHub] [flink] leonardBang merged pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

2022-03-18 Thread GitBox
leonardBang merged pull request #19070: URL: https://github.com/apache/flink/pull/19070 -- 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-uns

[GitHub] [flink] flinkbot edited a comment on pull request #19152: [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source

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

[GitHub] [flink] flinkbot edited a comment on pull request #19152: [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source

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

[GitHub] [flink] link3280 commented on pull request #19070: [FLINK-26618][sql-client] Fix Remove-Jar statement not effective

2022-03-18 Thread GitBox
link3280 commented on pull request #19070: URL: https://github.com/apache/flink/pull/19070#issuecomment-1072930238 @leonardBang CI finally turns green. Could you merge this PR if possible? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] liyubin117 commented on pull request #19162: [FLINK-26578][BP-1.15][docs-zh] Translate new Project Configuration section to Chinese

2022-03-18 Thread GitBox
liyubin117 commented on pull request #19162: URL: https://github.com/apache/flink/pull/19162#issuecomment-1072929938 @MartijnVisser I have cherried pick related commits to the new branch based on release-1.15 and no conflicts, given Nifi connector still exists in 1.15, I have retained the

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

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

[jira] [Commented] (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-18 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 commented on FLINK-26565: --- Hi [~jark]  ,  done . You can review this pr,   

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

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

[GitHub] [flink] RocMarshal commented on pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

2022-03-18 Thread GitBox
RocMarshal commented on pull request #18928: URL: https://github.com/apache/flink/pull/18928#issuecomment-1072927408 Thanks for the @RyanSkraba review and @zentol research. I updated it based on your suggestions. PTAL. -- This is an automated message from the Apache Git Service. To r

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

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

[GitHub] [flink] flinkbot edited a comment on pull request #19162: [FLINK-26578][BP-1.15][docs-zh] Translate new Project Configuration section to Chinese

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

[GitHub] [flink] flinkbot commented on pull request #19162: [FLINK-26578][BP-1.15][docs-zh] Translate new Project Configuration section to Chinese

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

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

[GitHub] [flink] liyubin117 opened a new pull request #19162: [FLINK-26578][BP-1.15][docs-zh] Translate new Project Configuration section to Chinese

2022-03-18 Thread GitBox
liyubin117 opened a new pull request #19162: URL: https://github.com/apache/flink/pull/19162 1.15 BP for parent PR https://github.com/apache/flink/pull/19100 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

2022-03-18 Thread GitBox
lindong28 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r830429315 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasDecayFactor.java ## @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #70: [FLINK-26313] Support Online KMeans in Flink ML

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

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

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

[GitHub] [flink] flinkbot edited a comment on pull request #19152: [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source

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

[GitHub] [flink] liyubin117 commented on pull request #19100: [FLINK-26578][docs-zh] Translate new Project Configuration section to Chinese

2022-03-18 Thread GitBox
liyubin117 commented on pull request #19100: URL: https://github.com/apache/flink/pull/19100#issuecomment-1072916331 @MartijnVisser sure, I'm doing this -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #19152: [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source

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

[GitHub] [flink] flinkbot edited a comment on pull request #19159: [FLINK-26334][datastream] for 1.15.0 . Modified getWindowStartWithOff…

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

[GitHub] [flink] flinkbot edited a comment on pull request #19154: [FLINK-26690][BP-1.15][runtime] Makes globalCleanupAsync call the removal even if the JobGraph is not put into the JobGraphStore, yet

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

[GitHub] [flink] flinkbot edited a comment on pull request #19159: [FLINK-26334][datastream] for 1.15.0 . Modified getWindowStartWithOff…

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

[GitHub] [flink] flinkbot edited a comment on pull request #19159: [FLINK-26334][datastream] for 1.15.0 . Modified getWindowStartWithOff…

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

[GitHub] [flink] realdengziqi commented on pull request #19159: [FLINK-26334][datastream] for 1.15.0 . Modified getWindowStartWithOff…

2022-03-18 Thread GitBox
realdengziqi commented on pull request #19159: URL: https://github.com/apache/flink/pull/19159#issuecomment-1072909559 @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 spe

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

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

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

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

[GitHub] [flink] wanglijie95 commented on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

2022-03-18 Thread GitBox
wanglijie95 commented on pull request #18757: URL: https://github.com/apache/flink/pull/18757#issuecomment-1072907768 @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 spec

[GitHub] [flink] flinkbot edited a comment on pull request #19154: [FLINK-26690][BP-1.15][runtime] Makes globalCleanupAsync call the removal even if the JobGraph is not put into the JobGraphStore, yet

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

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

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

[GitHub] [flink] flinkbot edited a comment on pull request #19154: [FLINK-26690][BP-1.15][runtime] Makes globalCleanupAsync call the removal even if the JobGraph is not put into the JobGraphStore, yet

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

[GitHub] [flink] gaoyunhaii commented on pull request #19154: [FLINK-26690][BP-1.15][runtime] Makes globalCleanupAsync call the removal even if the JobGraph is not put into the JobGraphStore, yet

2022-03-18 Thread GitBox
gaoyunhaii commented on pull request #19154: URL: https://github.com/apache/flink/pull/19154#issuecomment-1072901979 @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] RocMarshal commented on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

2022-03-18 Thread GitBox
RocMarshal commented on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-1072899598 Please let me know what is your expectation in the jira. thx a lot. -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] flinkbot edited a comment on pull request #19145: [hotfix][streaming] fix visibility of the instance variable and fix some typos

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

[GitHub] [flink] flinkbot edited a comment on pull request #19158: [FLINK-26334][datastream] for 1.14.0 . Modified getWindowStartWithOff…

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

[GitHub] [flink] flinkbot edited a comment on pull request #19151: [FLINK-26733][table-api-java][python] Deprecate TableConfig ctor and options

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

[GitHub] [flink] flinkbot edited a comment on pull request #19145: [hotfix][streaming] fix visibility of the instance variable and fix some typos

2022-03-18 Thread GitBox
flinkbot edited a comment on pull request #19145: URL: https://github.com/apache/flink/pull/19145#issuecomment-107225 ## CI report: * f21c64d64e3b391f7259931f97799de607afae84 Azure: [PENDING](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-18 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 #19145: [hotfix][streaming] fix visibility of the instance variable and fix some typos

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

[jira] [Commented] (FLINK-25797) Translate datastream/formats/parquet.md page into Chinese.

2022-03-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509102#comment-17509102 ] Martijn Visser commented on FLINK-25797: Fixed in master: 0f4b17c534ca092b290115

[jira] [Updated] (FLINK-25797) Translate datastream/formats/parquet.md page into Chinese.

2022-03-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25797: --- Fix Version/s: 1.16.0 > Translate datastream/formats/parquet.md page into Chinese. > ---

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

2022-03-18 Thread GitBox
MartijnVisser commented on pull request #18646: URL: https://github.com/apache/flink/pull/18646#issuecomment-1072869657 @wangzhiwubigdata Thanks for the PR - Can you also create the backport to release-1.15 branch? -- This is an automated message from the Apache Git Service. To respond t

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

2022-03-18 Thread GitBox
MartijnVisser merged pull request #18646: URL: https://github.com/apache/flink/pull/18646 -- 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-u

[GitHub] [flink] MartijnVisser commented on pull request #19145: [hotfix][streaming] fix visibility of the instance variable and fix some typos

2022-03-18 Thread GitBox
MartijnVisser commented on pull request #19145: URL: https://github.com/apache/flink/pull/19145#issuecomment-1072868814 @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 sp

[jira] [Commented] (FLINK-26381) Wrong document order of Chinese version

2022-03-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509101#comment-17509101 ] Martijn Visser commented on FLINK-26381: Fixed in master: 48cf55c36fe7c35c827f06

[jira] [Updated] (FLINK-26381) Wrong document order of Chinese version

2022-03-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26381: --- Fix Version/s: 1.16.0 > Wrong document order of Chinese version > --

[GitHub] [flink] flinkbot edited a comment on pull request #19159: [FLINK-26334][datastream] for 1.15.0 . Modified getWindowStartWithOff…

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

[GitHub] [flink] MartijnVisser commented on pull request #19010: [FLINK-26381][docs] Wrong document order of Chinese version

2022-03-18 Thread GitBox
MartijnVisser commented on pull request #19010: URL: https://github.com/apache/flink/pull/19010#issuecomment-1072868174 Thanks for the PR @paul8263 - Do you also want to create backports to release-1.15 and release-1.14? -- This is an automated message from the Apache Git Service. To res

[jira] [Assigned] (FLINK-26381) Wrong document order of Chinese version

2022-03-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-26381: -- Assignee: Yao Zhang (was: Kent Yao) > Wrong document order of Chinese version >

[GitHub] [flink] MartijnVisser merged pull request #19010: [FLINK-26381][docs] Wrong document order of Chinese version

2022-03-18 Thread GitBox
MartijnVisser merged pull request #19010: URL: https://github.com/apache/flink/pull/19010 -- 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-u

[jira] [Assigned] (FLINK-26381) Wrong document order of Chinese version

2022-03-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-26381: -- Assignee: Kent Yao > Wrong document order of Chinese version > --

[jira] [Closed] (FLINK-26716) Migrate PostgreSQL tests to Testcontainers

2022-03-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26716. -- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master: 0b09d340e26550cc044b8dc91b30f6

[GitHub] [flink] MartijnVisser merged pull request #19139: [FLINK-26716][test][connectors/jdbc] Migrate PostgreSQL tests to Testcontainers

2022-03-18 Thread GitBox
MartijnVisser merged pull request #19139: URL: https://github.com/apache/flink/pull/19139 -- 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-u

[GitHub] [flink] flinkbot edited a comment on pull request #19010: [FLINK-26381][docs] Wrong document order of Chinese version

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

[GitHub] [flink] flinkbot edited a comment on pull request #19010: [FLINK-26381][docs] Wrong document order of Chinese version

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

[GitHub] [flink] MartijnVisser commented on pull request #19010: [FLINK-26381][docs] Wrong document order of Chinese version

2022-03-18 Thread GitBox
MartijnVisser commented on pull request #19010: URL: https://github.com/apache/flink/pull/19010#issuecomment-1072849978 @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 sp

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

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

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

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

[GitHub] [flink] flinkbot edited a comment on pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-03-18 Thread GitBox
flinkbot edited a comment on pull request #19113: URL: https://github.com/apache/flink/pull/19113#issuecomment-1068976231 ## CI report: * b46ded17741b2d0d4c59885da62e218417c32603 UNKNOWN * 9500030cc0a1f697f8fd12543ca793b9fa936614 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19152: [FLINK-26692][e2e] migrate TpcdsTestProgram.java to new source

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

[GitHub] [flink] flinkbot edited a comment on pull request #19145: [hotfix][streaming] fix visibility of the instance variable and fix some typos

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

  1   2   3   4   5   6   7   8   9   >