[GitHub] [flink] flinkbot edited a comment on pull request #17771: [FLINK-24813][table-planner]Improve ImplicitTypeConversionITCase

flinkbot edited a comment on pull request #17771: URL: https://github.com/apache/flink/pull/17771#issuecomment-966899848 ## CI report: * 7598282e780de754cad4a9b425ac6e7c008e4b9e Azure:

[GitHub] [flink] shenzhu commented on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

shenzhu commented on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-969977283 @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 specific

[GitHub] [flink] snuyanzin commented on a change in pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

snuyanzin commented on a change in pull request #17786: URL: https://github.com/apache/flink/pull/17786#discussion_r74741 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/MapAndMultisetToStringCastRule.java ## @@

[GitHub] [flink] shenzhu commented on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

shenzhu commented on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-969976164 > ## CI report: > * [b59b4a5](https://github.com/apache/flink/commit/b59b4a592c14990f7d916fa116d0a1cc8f5ed085) Azure:

[jira] [Updated] (FLINK-24664) Support merge for JSON_ARRAYAGG

[ https://issues.apache.org/jira/browse/FLINK-24664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24664: --- Parent: (was: FLINK-9477) Issue Type: New Feature (was: Sub-task) > Support

[jira] [Updated] (FLINK-24311) Support expression reduction for JSON construction functions

[ https://issues.apache.org/jira/browse/FLINK-24311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24311: --- Parent: (was: FLINK-9477) Issue Type: New Feature (was: Sub-task) > Support

[jira] [Closed] (FLINK-24642) Implements unified iteration to support algorithms in flink-ml

[ https://issues.apache.org/jira/browse/FLINK-24642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24642. --- Resolution: Fixed > Implements unified iteration to support algorithms in flink-ml >

[jira] [Updated] (FLINK-24853) Report errors if jobs using iteration has runtime mode set to BATCH

[ https://issues.apache.org/jira/browse/FLINK-24853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24853: Parent: (was: FLINK-24642) Issue Type: Improvement (was: Sub-task) > Report errors if jobs

[jira] [Assigned] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-20188: -- Assignee: ZhuoYu Chen > Add Documentation for new File Source >

[jira] [Assigned] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-20188: -- Assignee: (was: ZhuoYu Chen) > Add Documentation for new File Source >

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444331#comment-17444331 ] Martijn Visser commented on FLINK-20188: [~monster#12] Yes, those files indeed contain the

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17786: [FLINK-24889][table] Flink SQL Client should print correсtly multisets

slinkydeveloper commented on a change in pull request #17786: URL: https://github.com/apache/flink/pull/17786#discussion_r749995285 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/MapAndMultisetToStringCastRule.java

[jira] [Closed] (FLINK-24810) Add Estimator and Model for the k-means clustering algorithm

[ https://issues.apache.org/jira/browse/FLINK-24810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24810. --- Fix Version/s: 0.1.0 Assignee: Dong Lin Resolution: Fixed > Add Estimator and Model for the

[jira] [Commented] (FLINK-24810) Add Estimator and Model for the k-means clustering algorithm

[ https://issues.apache.org/jira/browse/FLINK-24810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444329#comment-17444329 ] Yun Gao commented on FLINK-24810: - Fix on master via 212be99e5aaebabfc42ec74a9814dd1e8bde0b84 > Add

[jira] [Commented] (FLINK-24802) Improve cast ROW to STRING

[ https://issues.apache.org/jira/browse/FLINK-24802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444328#comment-17444328 ] Francesco Guardiani commented on FLINK-24802: - That's all yours, thank you! If you need any

[jira] [Commented] (FLINK-24918) Support to specify the data dir for state benchmark

[ https://issues.apache.org/jira/browse/FLINK-24918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444327#comment-17444327 ] Aitozi commented on FLINK-24918: Hi [~yunta] , do you have some inputs for this ? > Support to specify

[GitHub] [flink-ml] gaoyunhaii closed pull request #27: [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

gaoyunhaii closed pull request #27: URL: https://github.com/apache/flink-ml/pull/27 -- 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] [Assigned] (FLINK-24802) Improve cast ROW to STRING

[ https://issues.apache.org/jira/browse/FLINK-24802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-24802: --- Assignee: Shen Zhu > Improve cast ROW to STRING >

[jira] [Created] (FLINK-24918) Support to specify the data dir for state benchmark

Aitozi created FLINK-24918: -- Summary: Support to specify the data dir for state benchmark Key: FLINK-24918 URL: https://issues.apache.org/jira/browse/FLINK-24918 Project: Flink Issue Type:

[GitHub] [flink-ml] lindong28 commented on pull request #27: [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

lindong28 commented on pull request #27: URL: https://github.com/apache/flink-ml/pull/27#issuecomment-969968812 Thanks for your review @gaoyunhaii @yunfengzhou-hub! All comments have been addressed. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-ml] lindong28 commented on a change in pull request #27: [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

lindong28 commented on a change in pull request #27: URL: https://github.com/apache/flink-ml/pull/27#discussion_r749986813 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/param/HasFeaturesCol.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] flinkbot edited a comment on pull request #17803: [FLINK-24839][fs-connector] Increase Timeout of FsStreamingSinkITCaseBase to 240

flinkbot edited a comment on pull request #17803: URL: https://github.com/apache/flink/pull/17803#issuecomment-969724257 ## CI report: * 3835826766a03449d004fe4b3893c89dbba05392 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

flinkbot edited a comment on pull request #17666: URL: https://github.com/apache/flink/pull/17666#issuecomment-960514675 ## CI report: * 9420e4053db0f66aae31958cf0487a413016a5d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17806: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot edited a comment on pull request #17806: URL: https://github.com/apache/flink/pull/17806#issuecomment-969962850 ## CI report: * 582c7a86a1deb13ec8fd0ac4223c21ca3c551fdd Azure:

[GitHub] [flink] beyond1920 commented on a change in pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

beyond1920 commented on a change in pull request #17666: URL: https://github.com/apache/flink/pull/17666#discussion_r749980934 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/SqlWindowTableFunction.java ## @@ -275,16

[GitHub] [flink] flinkbot edited a comment on pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

flinkbot edited a comment on pull request #17666: URL: https://github.com/apache/flink/pull/17666#issuecomment-960514675 ## CI report: * 9420e4053db0f66aae31958cf0487a413016a5d3 Azure:

[GitHub] [flink] flinkbot commented on pull request #17806: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot commented on pull request #17806: URL: https://github.com/apache/flink/pull/17806#issuecomment-969963516 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #17806: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot commented on pull request #17806: URL: https://github.com/apache/flink/pull/17806#issuecomment-969962850 ## CI report: * 582c7a86a1deb13ec8fd0ac4223c21ca3c551fdd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] fsk119 opened a new pull request #17806: [FLINK-24708][planner] Fix wrong results of the IN operator

fsk119 opened a new pull request #17806: URL: https://github.com/apache/flink/pull/17806 ## What is the purpose of the change *Fix the wrong results of the IN opreator. The reason behind is it uses the type of the first element in the SEARCH argument as the type of the other

[GitHub] [flink] flinkbot edited a comment on pull request #17771: [FLINK-24813][table-planner]Improve ImplicitTypeConversionITCase

flinkbot edited a comment on pull request #17771: URL: https://github.com/apache/flink/pull/17771#issuecomment-966899848 ## CI report: * 1412805a2c87c8eb9dd02e0bbc8f9c704e899730 Azure:

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444320#comment-17444320 ] Arvid Heise commented on FLINK-21214: - On master, we bumped Kafka to 2.8.1 but we can't backport it

[jira] [Assigned] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-18634: --- Assignee: Fabian Paul (was: Arvid Heise) >

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444319#comment-17444319 ] Arvid Heise commented on FLINK-18634: - This seems to prevail even after we bumped Kafka to 2.8.1. >

[jira] [Commented] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444317#comment-17444317 ] Yun Gao commented on FLINK-20950: - Very thanks [~arvid] !  >

[GitHub] [flink] flinkbot edited a comment on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot edited a comment on pull request #17805: URL: https://github.com/apache/flink/pull/17805#issuecomment-969943622 ## CI report: * 067f050f59f186f274c40bc349d74aadd34a23bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17788: [FLINK-15826][Tabel SQL/API] Add renameFunction() to Catalog

flinkbot edited a comment on pull request #17788: URL: https://github.com/apache/flink/pull/17788#issuecomment-968179643 ## CI report: * b59b4a592c14990f7d916fa116d0a1cc8f5ed085 Azure:

[GitHub] [flink] flinkbot commented on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot commented on pull request #17805: URL: https://github.com/apache/flink/pull/17805#issuecomment-969945631 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444316#comment-17444316 ] Arvid Heise commented on FLINK-20950: - I can also take a look. >

[jira] [Created] (FLINK-24917) YARNSessionFIFOSecuredITCase hangs on azure

Yun Gao created FLINK-24917: --- Summary: YARNSessionFIFOSecuredITCase hangs on azure Key: FLINK-24917 URL: https://issues.apache.org/jira/browse/FLINK-24917 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

flinkbot commented on pull request #17805: URL: https://github.com/apache/flink/pull/17805#issuecomment-969943622 ## CI report: * 067f050f59f186f274c40bc349d74aadd34a23bd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #32: [FLINK-24817] Add Naive Bayes implementation

yunfengzhou-hub commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r749965528 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayes.java ## @@ -0,0 +1,333 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

flinkbot edited a comment on pull request #17793: URL: https://github.com/apache/flink/pull/17793#issuecomment-968529898 ## CI report: * 9c928c5f1a881c6851160bd209db056696ad619f Azure:

[GitHub] [flink] fsk119 opened a new pull request #17805: [FLINK-24708][planner] Fix wrong results of the IN operator

fsk119 opened a new pull request #17805: URL: https://github.com/apache/flink/pull/17805 ## What is the purpose of the change *Fix the wrong results of the IN opreator. The reason behind is it uses the type of the first element in the SEARCH argument as the type of the other

[jira] [Commented] (FLINK-24895) SqlTimestampSerializer#deserialize forgets to fully read from source when the record is null.

[ https://issues.apache.org/jira/browse/FLINK-24895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444312#comment-17444312 ] Timo Walther commented on FLINK-24895: -- Thanks, we will find someone who can fix this. >

[GitHub] [flink] beyond1920 commented on a change in pull request #17733: [FLINK-24835][table-planner] Fix bug in `RelTimeIndicatorConverter` when materialize time attribute fields of regular join's i

beyond1920 commented on a change in pull request #17733: URL: https://github.com/apache/flink/pull/17733#discussion_r749961893 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowJoinUtil.scala ## @@ -60,7 +61,11 @@

[GitHub] [flink] beyond1920 commented on a change in pull request #17733: [FLINK-24835][table-planner] Fix bug in `RelTimeIndicatorConverter` when materialize time attribute fields of regular join's i

beyond1920 commented on a change in pull request #17733: URL: https://github.com/apache/flink/pull/17733#discussion_r749961611 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/IntervalJoinUtil.scala ## @@ -450,15 +452,26

[jira] [Commented] (FLINK-24764) pyflink/table/tests/test_udf.py hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-24764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444309#comment-17444309 ] Yun Gao commented on FLINK-24764: -

[jira] [Assigned] (FLINK-24495) Python installdeps hangs

[ https://issues.apache.org/jira/browse/FLINK-24495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-24495: Assignee: Huang Xingbo > Python installdeps hangs > > >

[jira] [Commented] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444307#comment-17444307 ] Yun Gao commented on FLINK-21214: -

[jira] [Updated] (FLINK-21214) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed

[ https://issues.apache.org/jira/browse/FLINK-21214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-21214: Affects Version/s: 1.13.3 > FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed >

[jira] [Updated] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

[ https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22342: Affects Version/s: 1.13.3 > FlinkKafkaProducerITCase fails with producer leak >

[jira] [Updated] (FLINK-22342) FlinkKafkaProducerITCase fails with producer leak

[ https://issues.apache.org/jira/browse/FLINK-22342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-22342: Affects Version/s: (was: 1.11.3) > FlinkKafkaProducerITCase fails with producer leak >

[GitHub] [flink] flinkbot edited a comment on pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

flinkbot edited a comment on pull request #17613: URL: https://github.com/apache/flink/pull/17613#issuecomment-955719048 ## CI report: * d2fb15cc1d92c0ecd9428869d6e94bbbea9f4a04 Azure:

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #32: [FLINK-24817] Add Naive Bayes implementation

yunfengzhou-hub commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r749958347 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayesParams.java ## @@ -0,0 +1,49 @@ +/* + * Licensed

[jira] [Commented] (FLINK-24789) IllegalStateException with CheckpointCleaner being closed already

[ https://issues.apache.org/jira/browse/FLINK-24789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444304#comment-17444304 ] Yun Gao commented on FLINK-24789: -

[GitHub] [flink] XComp commented on a change in pull request #17781: [FLINK-24875][ci] Split E2E job

XComp commented on a change in pull request #17781: URL: https://github.com/apache/flink/pull/17781#discussion_r749950868 ## File path: tools/azure-pipelines/e2e-template.yml ## @@ -0,0 +1,131 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +#

[GitHub] [flink] flinkbot edited a comment on pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

flinkbot edited a comment on pull request #17613: URL: https://github.com/apache/flink/pull/17613#issuecomment-955719048 ## CI report: * d2fb15cc1d92c0ecd9428869d6e94bbbea9f4a04 Azure:

[GitHub] [flink-ml] lindong28 commented on a change in pull request #27: [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

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

[jira] [Commented] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444302#comment-17444302 ] Yun Gao commented on FLINK-24801: -

[GitHub] [flink-ml] lindong28 commented on a change in pull request #27: [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

lindong28 commented on a change in pull request #27: URL: https://github.com/apache/flink-ml/pull/27#discussion_r749956301 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/MapPartitionFunctionWrapper.java ## @@ -0,0 +1,79 @@ +/* + * Licensed to

[GitHub] [flink-ml] lindong28 commented on a change in pull request #27: [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

lindong28 commented on a change in pull request #27: URL: https://github.com/apache/flink-ml/pull/27#discussion_r749956101 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/param/HasFeaturesCol.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] beyond1920 commented on a change in pull request #17734: [FLINK-23305][table]Support semi/anti interval joins

beyond1920 commented on a change in pull request #17734: URL: https://github.com/apache/flink/pull/17734#discussion_r749956116 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/interval/SemiAntiTimeIntervalJoin.java ##

[GitHub] [flink-ml] lindong28 commented on a change in pull request #27: [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

lindong28 commented on a change in pull request #27: URL: https://github.com/apache/flink-ml/pull/27#discussion_r749956004 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseVectorSerializer.java ## @@ -0,0 +1,133 @@ +/* + * Licensed to the

[GitHub] [flink-ml] lindong28 commented on a change in pull request #27: [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

lindong28 commented on a change in pull request #27: URL: https://github.com/apache/flink-ml/pull/27#discussion_r749955817 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/distance/DistanceMeasure.java ## @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444300#comment-17444300 ] Yun Gao commented on FLINK-18634: -

[GitHub] [flink] hililiwei commented on pull request #17613: [FLINK-24536][Table SQL/Planner] flink sql support bang equal '!='

hililiwei commented on pull request #17613: URL: https://github.com/apache/flink/pull/17613#issuecomment-969931865 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-24495) Python installdeps hangs

[ https://issues.apache.org/jira/browse/FLINK-24495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444298#comment-17444298 ] Yun Gao commented on FLINK-24495: -

[jira] [Commented] (FLINK-24583) ElasticsearchWriterITCase.testWriteOnBulkIntervalFlush timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-24583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444299#comment-17444299 ] Yun Gao commented on FLINK-24583: -

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444296#comment-17444296 ] Yun Gao commented on FLINK-23944: -

[jira] [Comment Edited] (FLINK-24495) Python installdeps hangs

[ https://issues.apache.org/jira/browse/FLINK-24495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444298#comment-17444298 ] Yun Gao edited comment on FLINK-24495 at 11/16/21, 6:55 AM:

[jira] [Comment Edited] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444296#comment-17444296 ] Yun Gao edited comment on FLINK-23944 at 11/16/21, 6:52 AM:

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #27: [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

yunfengzhou-hub commented on a change in pull request #27: URL: https://github.com/apache/flink-ml/pull/27#discussion_r749952767 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/param/HasFeaturesCol.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-24914) Support implicit type conversion in SQL like "select int_field = varchar_field"

[ https://issues.apache.org/jira/browse/FLINK-24914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444294#comment-17444294 ] liwei li commented on FLINK-24914: -- +1 > Support implicit type conversion in SQL like "select

[jira] [Updated] (FLINK-24916) AvroExternalJarProgramITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-24916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24916: Labels: test-stability (was: ) > AvroExternalJarProgramITCase JVM crash on Azure >

[jira] [Commented] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444292#comment-17444292 ] Yun Gao commented on FLINK-20950: -

[jira] [Updated] (FLINK-24911) Enable line numbers in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-24911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-24911: Component/s: Table SQL / Client > Enable line numbers in SQL Client >

[jira] [Reopened] (FLINK-20950) SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with "AssertionError"

[ https://issues.apache.org/jira/browse/FLINK-20950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-20950: - > SinkITCase.writerAndGlobalCommitterExecuteInStreamingMode test failed with > "AssertionError" >

[jira] [Updated] (FLINK-24910) Propagate the Calcite parser config to SQL Client

[ https://issues.apache.org/jira/browse/FLINK-24910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-24910: Component/s: Table SQL / Client > Propagate the Calcite parser config to SQL Client >

[jira] [Updated] (FLINK-24909) SQL syntax highlighting in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-24909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-24909: Component/s: Table SQL / Client > SQL syntax highlighting in SQL Client >

[jira] [Created] (FLINK-24916) AvroExternalJarProgramITCase JVM crash on Azure

Yun Gao created FLINK-24916: --- Summary: AvroExternalJarProgramITCase JVM crash on Azure Key: FLINK-24916 URL: https://issues.apache.org/jira/browse/FLINK-24916 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-24916) AvroExternalJarProgramITCase JVM crash on Azure

[ https://issues.apache.org/jira/browse/FLINK-24916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444291#comment-17444291 ] Yun Gao commented on FLINK-24916: - The maven log does not show additional exceptions. >

[jira] [Updated] (FLINK-24908) Improve SQL Error description for SQL Client

[ https://issues.apache.org/jira/browse/FLINK-24908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-24908: Component/s: Table SQL / Client > Improve SQL Error description for SQL Client >

[jira] [Updated] (FLINK-24893) SQL Client prompt customisation

[ https://issues.apache.org/jira/browse/FLINK-24893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-24893: Component/s: Table SQL / Client > SQL Client prompt customisation >

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * 6a2564f49bc2fb8d3f82190184bea34fad523e2b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

flinkbot edited a comment on pull request #17749: URL: https://github.com/apache/flink/pull/17749#issuecomment-965029957 ## CI report: * 7274c72e7c23ac670a39bf6bac0eacbe881db110 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17749: [FLINK-24758][Connectors / FileSystem] filesystem sink: add partitiontime-extractor.formatter-pattern to allow user to speify DateTi

flinkbot edited a comment on pull request #17749: URL: https://github.com/apache/flink/pull/17749#issuecomment-965029957 ## CI report: * 7274c72e7c23ac670a39bf6bac0eacbe881db110 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

flinkbot edited a comment on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-965189525 ## CI report: * 6a2564f49bc2fb8d3f82190184bea34fad523e2b Azure:

[GitHub] [flink] gaurav726 commented on a change in pull request #17754: [FLINK-24861][connector][jdbc] Fix false cache lookup for empty data

gaurav726 commented on a change in pull request #17754: URL: https://github.com/apache/flink/pull/17754#discussion_r749949235 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcRowDataLookupFunction.java ## @@ -146,10

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #27: [FLINK-24810] Add Estimator and Model for the k-means clustering algorithm

gaoyunhaii commented on a change in pull request #27: URL: https://github.com/apache/flink-ml/pull/27#discussion_r749940719 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeansModel.java ## @@ -0,0 +1,214 @@ +/* + * Licensed to the Apache

[GitHub] [flink] RocMarshal commented on a change in pull request #17802: [FLINK-24635][examples] Clean up flink-examples

RocMarshal commented on a change in pull request #17802: URL: https://github.com/apache/flink/pull/17802#discussion_r749942475 ## File path: flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/util/SimpleSource.java ## @@ -0,0 +1,59

[GitHub] [flink] RocMarshal edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-966782262 @twalthr @sjwiesman @Airblader @AHeise @tisonkun @fsk119 Excuse me, Could you help me to check it if you have free time ? Thanks a lot. -- This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-24864][metrics] Release TaskManagerJobMetricGroup with the last slot rather than task

flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 1a458e189a85566571b071fd0bc54df9317d2db3 Azure:

[GitHub] [flink] RocMarshal edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-966782262 @twalthr @sjwiesman @Airblader @AHeise @tisonkun @gaoyunhaii Excuse me, Could you help me to check it if you have free time ? Thanks a lot. -- This is an automated

[GitHub] [flink-ml] lindong28 commented on a change in pull request #32: [FLINK-24817] Add Naive Bayes implementation

lindong28 commented on a change in pull request #32: URL: https://github.com/apache/flink-ml/pull/32#discussion_r749901463 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayesParams.java ## @@ -0,0 +1,49 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-24914) Support implicit type conversion in SQL like "select int_field = varchar_field"

[ https://issues.apache.org/jira/browse/FLINK-24914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444282#comment-17444282 ] xuyang commented on FLINK-24914: Hi, [~qingru zhang] . In a sense, it is, but FLIP-154 have not been

[GitHub] [flink] JingsongLi commented on a change in pull request #17655: [FLINK-24728][tests] Add tests to ensure SQL file sink closes all created files

JingsongLi commented on a change in pull request #17655: URL: https://github.com/apache/flink/pull/17655#discussion_r749933893 ## File path: flink-core/src/test/java/org/apache/flink/testutils/TestFileSystem.java ## @@ -37,28 +43,45 @@ public static final String SCHEME

[GitHub] [flink] JingsongLi commented on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

JingsongLi commented on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-969890963 @slinkydeveloper @JingGe @fapaul Do you have other comments? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444280#comment-17444280 ] Guowei Ma commented on FLINK-24767: --- I think it might be that in the Batch execution mode FLINK will

[jira] [Comment Edited] (FLINK-23466) UnalignedCheckpointITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-23466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444279#comment-17444279 ] Yingjie Cao edited comment on FLINK-23466 at 11/16/21, 5:59 AM: Nov 10

[jira] [Commented] (FLINK-23466) UnalignedCheckpointITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-23466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444279#comment-17444279 ] Yingjie Cao commented on FLINK-23466: - Nov 10 16:13:03 Starting

  1   2   3   4   5   6   7   8   >