[jira] [Comment Edited] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513170#comment-17513170 ] Nicholas Jiang edited comment on FLINK-22888 at 3/28/22, 6:58 AM:

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

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

[jira] [Updated] (FLINK-26879) LogStartupMode.LATEST does not work

[ https://issues.apache.org/jira/browse/FLINK-26879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26879: -- Description: We should avoid creating a hybrid source when the latest mode is enabled, o.w. we cannot

[jira] [Created] (FLINK-26880) PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition failed on azure

Yun Gao created FLINK-26880: --- Summary: PyFlinkStreamUserDefinedFunctionTests.test_udf_in_join_condition failed on azure Key: FLINK-26880 URL: https://issues.apache.org/jira/browse/FLINK-26880 Project: Flink

[jira] [Commented] (FLINK-26395) The description of RAND_INTEGER is wrong in SQL function documents

[ https://issues.apache.org/jira/browse/FLINK-26395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513189#comment-17513189 ] Martijn Visser commented on FLINK-26395: Fixed in master: adb6152b2361d58bf0de31

[jira] [Commented] (FLINK-26789) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed

[ https://issues.apache.org/jira/browse/FLINK-26789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513188#comment-17513188 ] Roman Khachatryan commented on FLINK-26789: --- Thanks [~yunta] for looking into

[jira] [Updated] (FLINK-26879) LogStartupMode.LATEST does not work

[ https://issues.apache.org/jira/browse/FLINK-26879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26879: -- Description: When creating a hybrid source, we should check the latest mode is enabled or not, o.w. we

[jira] [Reopened] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang reopened FLINK-22888: > Matches results may be wrong when using notNext as the last part of the > pattern with Wind

[jira] [Closed] (FLINK-26868) In JobLeaderIdService.java#L36 the annotation may be " Start the service with the given job leader id actions" instead of "Start the service with the given job leade

[ https://issues.apache.org/jira/browse/FLINK-26868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26868. -- Resolution: Won't Fix > In JobLeaderIdService.java#L36 the annotation may be " Start the s

[GitHub] [flink] MartijnVisser closed pull request #19248: Update JobLeaderIdService.java

MartijnVisser closed pull request #19248: URL: https://github.com/apache/flink/pull/19248 -- 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 a change in pull request #19248: Update JobLeaderIdService.java

MartijnVisser commented on a change in pull request #19248: URL: https://github.com/apache/flink/pull/19248#discussion_r836104248 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/JobLeaderIdService.java ## @@ -33,7 +33,7 @@ public interface J

[jira] [Created] (FLINK-26879) LogStartupMode.LATEST does not work

Jane Chan created FLINK-26879: - Summary: LogStartupMode.LATEST does not work Key: FLINK-26879 URL: https://issues.apache.org/jira/browse/FLINK-26879 Project: Flink Issue Type: Bug Compo

[jira] [Commented] (FLINK-26868) In JobLeaderIdService.java#L36 the annotation may be " Start the service with the given job leader id actions" instead of "Start the service with the given job le

[ https://issues.apache.org/jira/browse/FLINK-26868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513187#comment-17513187 ] Martijn Visser commented on FLINK-26868: [~liu zhuang] Thanks for opening the ti

[jira] [Updated] (FLINK-26868) In JobLeaderIdService.java#L36 the annotation may be " Start the service with the given job leader id actions" instead of "Start the service with the given job lead

[ https://issues.apache.org/jira/browse/FLINK-26868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26868: --- Fix Version/s: (was: 1.16.0) > In JobLeaderIdService.java#L36 the annotation may be

[jira] [Closed] (FLINK-26877) Introduce auto type inference for filter push down

[ https://issues.apache.org/jira/browse/FLINK-26877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26877. Resolution: Fixed master: 61dff144a4a029da25bdbfa06017cbfc3b5d2cb5 > Introduce auto type inferenc

[jira] [Commented] (FLINK-26789) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed

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

[GitHub] [flink-table-store] JingsongLi merged pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

JingsongLi merged pull request #64: URL: https://github.com/apache/flink-table-store/pull/64 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issue

[jira] [Commented] (FLINK-26818) Required Information on parsing complex nested JSON using SQL API

[ https://issues.apache.org/jira/browse/FLINK-26818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513183#comment-17513183 ] Martijn Visser commented on FLINK-26818: [~arindbha] I can only refer to the doc

[jira] [Updated] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23828: Affects Version/s: 1.14.4 > KafkaSourceITCase.testIdleReader fails on azure >

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

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

[jira] [Updated] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23828: Fix Version/s: (was: 1.15.0) > KafkaSourceITCase.testIdleReader fails on azure > -

[jira] [Reopened] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-23828: - > KafkaSourceITCase.testIdleReader fails on azure > --- > >

[GitHub] [flink] MartijnVisser commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

MartijnVisser commented on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-1080261728 @ZhangChaoming You should probably rebase your branch on the latest master to resolve those issues -- This is an automated message from the Apache Git Service. To respo

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

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

[jira] [Commented] (FLINK-26789) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed

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

[jira] [Commented] (FLINK-26800) write small data file using share write buffer manager

[ https://issues.apache.org/jira/browse/FLINK-26800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513176#comment-17513176 ] Yun Tang commented on FLINK-26800: -- [~liuyufei], RocksDBJava does not publish too many

[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

flinkbot edited a comment on pull request #19208: URL: https://github.com/apache/flink/pull/19208#issuecomment-1075903940 ## CI report: * 743339c07c0549f2774df718cf728058f30174fe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Resolved] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang resolved FLINK-22888. Resolution: Won't Fix > Matches results may be wrong when using notNext as the last part o

[jira] [Closed] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang closed FLINK-22888. -- > Matches results may be wrong when using notNext as the last part of the > pattern with Window >

[jira] [Comment Edited] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513170#comment-17513170 ] Nicholas Jiang edited comment on FLINK-22888 at 3/28/22, 6:32 AM:

[jira] [Reopened] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang reopened FLINK-22888: > Matches results may be wrong when using notNext as the last part of the > pattern with Wind

[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

flinkbot edited a comment on pull request #19208: URL: https://github.com/apache/flink/pull/19208#issuecomment-1075903940 ## CI report: * 743339c07c0549f2774df718cf728058f30174fe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #19225: [FLINK-26799][Runtime/StateBackends] fix StateChangeFormat#read and e…

flinkbot edited a comment on pull request #19225: URL: https://github.com/apache/flink/pull/19225#issuecomment-1077559112 ## CI report: * 5b98d0047303aedcb0676c34b3ac8aca98c148e9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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

[jira] [Resolved] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang resolved FLINK-22888. Resolution: Won't Fix > Matches results may be wrong when using notNext as the last part o

[jira] [Commented] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513170#comment-17513170 ] Nicholas Jiang commented on FLINK-22888: [~mayuehappy], after the offline discus

[GitHub] [flink] flinkbot edited a comment on pull request #19225: [FLINK-26799][Runtime/StateBackends] fix StateChangeFormat#read and e…

flinkbot edited a comment on pull request #19225: URL: https://github.com/apache/flink/pull/19225#issuecomment-1077559112 ## CI report: * 5b98d0047303aedcb0676c34b3ac8aca98c148e9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

zhipeng93 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836084920 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,407 @@ +/* + * Licensed to the Apache Softw

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

zhipeng93 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836084920 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,407 @@ +/* + * Licensed to the Apache Softw

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

zhipeng93 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836084920 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,407 @@ +/* + * Licensed to the Apache Softw

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

zhipeng93 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836084920 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,407 @@ +/* + * Licensed to the Apache Softw

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

zoltar9264 commented on pull request #19225: URL: https://github.com/apache/flink/pull/19225#issuecomment-1080241045 @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] [Resolved] (FLINK-26865) Fix the potential failure of loading library in Thread Mode

[ https://issues.apache.org/jira/browse/FLINK-26865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-26865. -- Resolution: Fixed Merged into master via 159b0f54a3e531bd745fa6caf24bd211a5b1fe84 Merged into

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

RocMarshal commented on a change in pull request #18386: URL: https://github.com/apache/flink/pull/18386#discussion_r836080280 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowDatabases.java ## @@ -49,8 +70,44 @@ public SqlOperato

[GitHub] [flink] HuangXingBo closed pull request #19244: [FLINK-26865][python] Fix the potential failure of loading library inThread Mode

HuangXingBo closed pull request #19244: URL: https://github.com/apache/flink/pull/19244 -- 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-ml] yunfengzhou-hub commented on a change in pull request #70: [FLINK-26313] Add Transformer and Estimator of OnlineKMeans

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

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

JingsongLi commented on a change in pull request #64: URL: https://github.com/apache/flink-table-store/pull/64#discussion_r836070760 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java ## @@ -103,50 +106,59 @@

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

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

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

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

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

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

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

JingsongLi commented on a change in pull request #64: URL: https://github.com/apache/flink-table-store/pull/64#discussion_r836070760 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java ## @@ -103,50 +106,59 @@

[jira] [Created] (FLINK-26878) get previous window values in udf

Karthik created FLINK-26878: --- Summary: get previous window values in udf Key: FLINK-26878 URL: https://issues.apache.org/jira/browse/FLINK-26878 Project: Flink Issue Type: Bug Components:

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

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

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

lindong28 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836069446 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeansModel.java ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #19179: [FLINK-26756][table-planner] Fix the deserialization error for match recognize

flinkbot edited a comment on pull request #19179: URL: https://github.com/apache/flink/pull/19179#issuecomment-1073567241 ## CI report: * 0848527f59c961f070ee43dea29d4872932cf8f9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

LadyForest commented on a change in pull request #64: URL: https://github.com/apache/flink-table-store/pull/64#discussion_r836068093 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java ## @@ -131,22 +139,28 @@

[jira] [Commented] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513150#comment-17513150 ] Feifan Wang commented on FLINK-26721: - https://dev.azure.com/apache-flink/apache-fli

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

yunfengzhou-hub commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836067127 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java ## @@ -177,11 +177,20 @@ public void testFewerDistinctPoints

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

LadyForest commented on a change in pull request #64: URL: https://github.com/apache/flink-table-store/pull/64#discussion_r836062965 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java ## @@ -131,22 +139,28 @@

[GitHub] [flink] flinkbot edited a comment on pull request #19225: [FLINK-26799][Runtime/StateBackends] fix StateChangeFormat#read and e…

flinkbot edited a comment on pull request #19225: URL: https://github.com/apache/flink/pull/19225#issuecomment-1077559112 ## CI report: * 5b98d0047303aedcb0676c34b3ac8aca98c148e9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 53861a48a63041cdb9ea4fe411d58a4489a51be9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

JingsongLi commented on a change in pull request #64: URL: https://github.com/apache/flink-table-store/pull/64#discussion_r836059005 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java ## @@ -103,50 +107,55 @@

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

JingsongLi commented on a change in pull request #64: URL: https://github.com/apache/flink-table-store/pull/64#discussion_r836058806 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java ## @@ -103,50 +107,55 @@

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

flinkbot edited a comment on pull request #19235: URL: https://github.com/apache/flink/pull/19235#issuecomment-1077732821 ## CI report: * 3ba06197d984e7dd7575b27cad17b208d23be500 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18967: [FLINK-26460][table-planner]Fix Unsupported type when convertTypeToSpec: MAP

flinkbot edited a comment on pull request #18967: URL: https://github.com/apache/flink/pull/18967#issuecomment-1057833136 ## CI report: * 4b3a3bb58bd0ee30233c9db9b3d4f6bb589227bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

JingsongLi commented on a change in pull request #64: URL: https://github.com/apache/flink-table-store/pull/64#discussion_r836056777 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java ## @@ -131,22 +139,28 @@

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

JingsongLi commented on a change in pull request #64: URL: https://github.com/apache/flink-table-store/pull/64#discussion_r836056592 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java ## @@ -131,22 +139,28 @@

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

flinkbot edited a comment on pull request #19235: URL: https://github.com/apache/flink/pull/19235#issuecomment-1077732821 ## CI report: * 3ba06197d984e7dd7575b27cad17b208d23be500 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18967: [FLINK-26460][table-planner]Fix Unsupported type when convertTypeToSpec: MAP

flinkbot edited a comment on pull request #18967: URL: https://github.com/apache/flink/pull/18967#issuecomment-1057833136 ## CI report: * 4b3a3bb58bd0ee30233c9db9b3d4f6bb589227bf Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] Tartarus0zm commented on a change in pull request #18967: [FLINK-26460][table-planner]Fix Unsupported type when convertTypeToSpec: MAP

Tartarus0zm commented on a change in pull request #18967: URL: https://github.com/apache/flink/pull/18967#discussion_r836055222 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/calcite/PreValidateReWriter.scala ## @@ -391,8 +392,19 @@

[GitHub] [flink] flinkbot edited a comment on pull request #19250: [FLINK-26726][connector][hive]Hive enumerators do not assign splits to unregistered (failed) readers.

flinkbot edited a comment on pull request #19250: URL: https://github.com/apache/flink/pull/19250#issuecomment-1079940128 ## CI report: * 382afdb7f94b42c8ab7ea721b1bfd3f415bb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19244: [FLINK-26865][python] Fix the potential failure of loading library inThread Mode

flinkbot edited a comment on pull request #19244: URL: https://github.com/apache/flink/pull/19244#issuecomment-1078865315 ## CI report: * 94d1f72f21418fdd6971f9b6b145c7ebcc88db31 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

JingsongLi commented on a change in pull request #64: URL: https://github.com/apache/flink-table-store/pull/64#discussion_r83604 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java ## @@ -106,14 +108,20 @@

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

zhipeng93 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836040424 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeansModel.java ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache

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

zhipeng93 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836041520 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,407 @@ +/* + * Licensed to the Apache Softw

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

zhipeng93 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836041520 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeans.java ## @@ -0,0 +1,407 @@ +/* + * Licensed to the Apache Softw

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

zhipeng93 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836040424 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/OnlineKMeansModel.java ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache

[jira] [Updated] (FLINK-26877) Introduce auto type inference for filter push down

[ https://issues.apache.org/jira/browse/FLINK-26877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26877: --- Labels: pull-request-available (was: ) > Introduce auto type inference for filter push down

[GitHub] [flink-table-store] LadyForest opened a new pull request #64: [FLINK-26877] Introduce auto type inference for filter push down

LadyForest opened a new pull request #64: URL: https://github.com/apache/flink-table-store/pull/64 * Add PredicateConverterTest -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comme

[jira] [Assigned] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service

[ https://issues.apache.org/jira/browse/FLINK-17231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-17231: - Assignee: liuzhuo > Deprecate possible implicit fallback from LB to NodePort When retrieving >

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

zhipeng93 commented on a change in pull request #70: URL: https://github.com/apache/flink-ml/pull/70#discussion_r836037690 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java ## @@ -177,11 +177,20 @@ public void testFewerDistinctPointsThanCl

[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

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * c52899bd7f5833f7f754c96f6b9979b1c89fdeb9 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19108: [FLINK-26675][runtime] Parallelized heavy serialization in StreamingJ…

flinkbot edited a comment on pull request #19108: URL: https://github.com/apache/flink/pull/19108#issuecomment-1068849604 ## CI report: * 7b9c57dda493e9be3c0620cc188d9daf3feba1ff UNKNOWN * 8e3393b1fd8f279c682c3bae4b882e4ddb58da71 UNKNOWN * a23af18918b2d25120b5b4550ad0ffd9616

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

wuchong commented on pull request #19193: URL: https://github.com/apache/flink/pull/19193#issuecomment-1080147916 > IMO, it seems more appropriate that we would convert the new ticket [FLINK-26813](https://issues.apache.org/jira/browse/FLINK-26813) as a sub-task of [FLINK-21634](https://is

[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

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * c52899bd7f5833f7f754c96f6b9979b1c89fdeb9 Azure: [FAILURE](https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service

[ https://issues.apache.org/jira/browse/FLINK-17231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513121#comment-17513121 ] liuzhuo commented on FLINK-17231: - If this improvement is needed, I can try to help fix

[GitHub] [flink] flinkbot edited a comment on pull request #19108: [FLINK-26675][runtime] Parallelized heavy serialization in StreamingJ…

flinkbot edited a comment on pull request #19108: URL: https://github.com/apache/flink/pull/19108#issuecomment-1068849604 ## CI report: * 7b9c57dda493e9be3c0620cc188d9daf3feba1ff UNKNOWN * 8e3393b1fd8f279c682c3bae4b882e4ddb58da71 UNKNOWN * a23af18918b2d25120b5b4550ad0ffd9616

[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

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * c52899bd7f5833f7f754c96f6b9979b1c89fdeb9 Azure: [FAILURE](https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-26789) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed

[ https://issues.apache.org/jira/browse/FLINK-26789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513120#comment-17513120 ] Yun Tang commented on FLINK-26789: -- [~roman], I checked the logs in https://dev.azure.

[jira] [Commented] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service

[ https://issues.apache.org/jira/browse/FLINK-17231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17513119#comment-17513119 ] Yang Wang commented on FLINK-17231: --- [~spoon-lz] Thanks for your attention on this tic

[GitHub] [flink] flinkbot edited a comment on pull request #19108: [FLINK-26675][runtime] Parallelized heavy serialization in StreamingJ…

flinkbot edited a comment on pull request #19108: URL: https://github.com/apache/flink/pull/19108#issuecomment-1068849604 ## CI report: * 7b9c57dda493e9be3c0620cc188d9daf3feba1ff UNKNOWN * 8e3393b1fd8f279c682c3bae4b882e4ddb58da71 UNKNOWN * a23af18918b2d25120b5b4550ad0ffd9616

[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

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * c52899bd7f5833f7f754c96f6b9979b1c89fdeb9 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19108: [FLINK-26675][runtime] Parallelized heavy serialization in StreamingJ…

flinkbot edited a comment on pull request #19108: URL: https://github.com/apache/flink/pull/19108#issuecomment-1068849604 ## CI report: * 7b9c57dda493e9be3c0620cc188d9daf3feba1ff UNKNOWN * 8e3393b1fd8f279c682c3bae4b882e4ddb58da71 UNKNOWN * a23af18918b2d25120b5b4550ad0ffd9616

[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

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * c52899bd7f5833f7f754c96f6b9979b1c89fdeb9 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19108: [FLINK-26675][runtime] Parallelized heavy serialization in StreamingJ…

flinkbot edited a comment on pull request #19108: URL: https://github.com/apache/flink/pull/19108#issuecomment-1068849604 ## CI report: * 7b9c57dda493e9be3c0620cc188d9daf3feba1ff UNKNOWN * 8e3393b1fd8f279c682c3bae4b882e4ddb58da71 UNKNOWN * a23af18918b2d25120b5b4550ad0ffd9616

[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

flinkbot edited a comment on pull request #18345: URL: https://github.com/apache/flink/pull/18345#issuecomment-1011821419 ## CI report: * 9d6f199f94a022807e2252c805bac9f8256c7924 UNKNOWN * c52899bd7f5833f7f754c96f6b9979b1c89fdeb9 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19108: [FLINK-26675][runtime] Parallelized heavy serialization in StreamingJ…

flinkbot edited a comment on pull request #19108: URL: https://github.com/apache/flink/pull/19108#issuecomment-1068849604 ## CI report: * 7b9c57dda493e9be3c0620cc188d9daf3feba1ff UNKNOWN * 8e3393b1fd8f279c682c3bae4b882e4ddb58da71 UNKNOWN * a23af18918b2d25120b5b4550ad0ffd9616

  1   2   3   >