[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752853592 ## File path: flink-ml-lib/pom.xml ## @@ -106,6 +112,11 @@ under the License. jar test + + com.google.code.gson +

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752930662 ## File path: flink-ml-lib/pom.xml ## @@ -106,6 +112,11 @@ under the License. jar test + + com.google.code.gson +

[GitHub] [flink] flinkbot edited a comment on pull request #17831: [FLINK-15825][Table SQL/API] Add renameDatabase() to Catalog

flinkbot edited a comment on pull request #17831: URL: https://github.com/apache/flink/pull/17831#issuecomment-973310719 ## CI report: * a7e983255a689ff59abd268ca0711d43b74a246b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17834: [FLINK-24941][datadog] Support Boolean gauges

flinkbot edited a comment on pull request #17834: URL: https://github.com/apache/flink/pull/17834#issuecomment-973836525 ## CI report: * da938cbcc8379d3692e66b674db85a790663f8f8 Azure:

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

flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * d50d09006bb41b1c8ab87b868aa796637c27cce6 Azure:

[GitHub] [flink] flinkbot commented on pull request #17834: [FLINK-24941][datadog] Support Boolean gauges

flinkbot commented on pull request #17834: URL: https://github.com/apache/flink/pull/17834#issuecomment-973837022 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 #17834: [FLINK-24941][datadog] Support Boolean gauges

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

[jira] [Updated] (FLINK-24941) Cannot report backpressure with DatadogReporter

[ https://issues.apache.org/jira/browse/FLINK-24941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24941: --- Labels: pull-request-available (was: ) > Cannot report backpressure with DatadogReporter >

[GitHub] [flink] oripwk opened a new pull request #17834: [FLINK-24941][datadog] Support Boolean gauges

oripwk opened a new pull request #17834: URL: https://github.com/apache/flink/pull/17834 ## What is the purpose of the change Supporting Boolean values for Datadog metrics reporter. ## Brief change log - `DGauge` is now parameterized in type `T` and will map

[GitHub] [flink] dawidwys commented on pull request #17755: [FLINK-24858][core] Prevent version mismatches in TypeSerializers

dawidwys commented on pull request #17755: URL: https://github.com/apache/flink/pull/17755#issuecomment-973833069 Could you add an additional note in release notes of 1.14 to upgrade directly to 1.14.1 when migrating from 1.13? -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-24858) TypeSerializer version mismatch during eagerly restore

[ https://issues.apache.org/jira/browse/FLINK-24858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24858: - Fix Version/s: 1.15.0 1.14.1 1.13.4 >

[GitHub] [flink] SteNicholas commented on pull request #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default

SteNicholas commented on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-973831379 @Myasuka , could you please take a look at this pull request? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

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

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

flinkbot edited a comment on pull request #17822: URL: https://github.com/apache/flink/pull/17822#issuecomment-971696959 ## CI report: * dfa47afcc103ce68babb7e2967afacfdecb01886 Azure:

[jira] [Commented] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

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

[GitHub] [flink] flinkbot commented on pull request #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default

flinkbot commented on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-973809509 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 edited a comment on pull request #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default

flinkbot edited a comment on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-973807642 ## CI report: * 4be3984d373b3cf1bbb6573f9d73e01c02f306ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * a3a776d1264735d38b9f5d979a617d65e5c5069a Azure:

[GitHub] [flink] flinkbot commented on pull request #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default

flinkbot commented on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-973807642 ## CI report: * 4be3984d373b3cf1bbb6573f9d73e01c02f306ab UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-24785) Relocate RocksDB's log under flink log directory by default

[ https://issues.apache.org/jira/browse/FLINK-24785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24785: --- Labels: pull-request-available (was: ) > Relocate RocksDB's log under flink log directory

[GitHub] [flink] SteNicholas opened a new pull request #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default

SteNicholas opened a new pull request #17833: URL: https://github.com/apache/flink/pull/17833 ## What is the purpose of the change *Previously, RocksDB's log locates at its own DB folder, which makes the debuging RocksDB not so easy. We could let RocksDB's log stay in Flink's log

[jira] [Commented] (FLINK-24935) Python module failed to compile due to "Could not create local repository"

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

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557- add knn algorithm to flink-ml

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752903128 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/distance/EuclideanDistance.java ## @@ -0,0 +1,259 @@ +package

[jira] [Commented] (FLINK-24763) ParquetFileSystemITCase.testLimitableBulkFormat failed on Azure

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

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

[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446318#comment-17446318 ] Yun Gao commented on FLINK-24960: - Hi [~chesnay]  could you help to have a look at this issue~? >

[jira] [Created] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hang

Yun Gao created FLINK-24960: --- Summary: YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hangs on azure Key:

[GitHub] [flink] Aitozi commented on pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

Aitozi commented on pull request #17554: URL: https://github.com/apache/flink/pull/17554#issuecomment-973793867 @wangyang0918 Thanks for your comments, I will address it this weekend . -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Created] (FLINK-24959) Add a BitMap function to FlinkSQL

ZhuoYu Chen created FLINK-24959: --- Summary: Add a BitMap function to FlinkSQL Key: FLINK-24959 URL: https://issues.apache.org/jira/browse/FLINK-24959 Project: Flink Issue Type: New Feature

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752892098 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModelData.java ## @@ -0,0 +1,223 @@ +package

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752891995 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/DenseMatrix.java ## @@ -0,0 +1,161 @@ +package

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752892347 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/Knn.java ## @@ -0,0 +1,220 @@ +package

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

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

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752889883 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,343 @@ +package

[GitHub] [flink-ml] HuangXingBo commented on pull request #36: [FLINK-24933][ML] Support ML Python API to implement FLIP-173 and FLP-174

HuangXingBo commented on pull request #36: URL: https://github.com/apache/flink-ml/pull/36#issuecomment-973787987 @lindong28 Thanks a lot for the review. I have addressed the comments at the latest commit. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #17822: Release 1.14 kafka3.0 bug

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

[jira] [Updated] (FLINK-24835) "group by" in the interval join will throw a exception

[ https://issues.apache.org/jira/browse/FLINK-24835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24835: --- Fix Version/s: (was: 1.13.4) > "group by" in the interval join will throw a exception >

[GitHub] [flink-ml] HuangXingBo commented on a change in pull request #36: [FLINK-24933][ML] Support ML Python API

HuangXingBo commented on a change in pull request #36: URL: https://github.com/apache/flink-ml/pull/36#discussion_r752814620 ## File path: flink-ml-python/apache_flink_ml/mllib/__init__.py ## @@ -0,0 +1,17 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17831: [FLINK-15825][Table SQL/API] Add renameDatabase() to Catalog

flinkbot edited a comment on pull request #17831: URL: https://github.com/apache/flink/pull/17831#issuecomment-973310719 ## CI report: * cf69d827d81b781bc21b2faf0badb552aa884415 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17832: [FLINK-24958][docs]correct the example and link for temporal table fu…

flinkbot edited a comment on pull request #17832: URL: https://github.com/apache/flink/pull/17832#issuecomment-973714890 ## CI report: * 5b2208841608db9795796828f11c82060392a777 Azure:

[jira] [Commented] (FLINK-24216) org.apache.flink.test.scheduling.AdaptiveSchedulerITCase#testStopWithSavepointFailOnFirstSavepointSucceedOnSecond blocked on azure

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #36: [FLINK-24933][ML] Support ML Python API

lindong28 commented on a change in pull request #36: URL: https://github.com/apache/flink-ml/pull/36#discussion_r752877803 ## File path: flink-ml-python/apache_flink_ml/ml/api/core.py ## @@ -0,0 +1,221 @@

[GitHub] [flink-ml] lindong28 commented on a change in pull request #36: [FLINK-24933][ML] Support ML Python API

lindong28 commented on a change in pull request #36: URL: https://github.com/apache/flink-ml/pull/36#discussion_r752877279 ## File path: flink-ml-python/apache_flink_ml/ml/api/core.py ## @@ -0,0 +1,221 @@

[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: * Unknown: [CANCELED](TBD) * 3c13e34acd0884702aec4ded14bba94b62a6ba22 Azure:

[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: * Unknown: [CANCELED](TBD) * 3c13e34acd0884702aec4ded14bba94b62a6ba22 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] xuyangzhong commented on pull request #17771: [FLINK-24813][table-planner]Improve ImplicitTypeConversionITCase

xuyangzhong commented on pull request #17771: URL: https://github.com/apache/flink/pull/17771#issuecomment-973767628 @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-24958) correct the example and link for temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446284#comment-17446284 ] zoucao commented on FLINK-24958: Thanks for your reminder, [~leonard], the change is minor and simple,

[GitHub] [flink] flinkbot edited a comment on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-953241058 ## CI report: * 3eb296e77182671d24dab3c29b9d874860165725 Azure:

[GitHub] [flink] RocMarshal commented on a change in pull request #15755: [FLINK-22318][table] Support RENAME column name for ALTER TABLE state…

RocMarshal commented on a change in pull request #15755: URL: https://github.com/apache/flink/pull/15755#discussion_r752861919 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java ## @@ -144,6

[GitHub] [flink] flinkbot edited a comment on pull request #17830: [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

flinkbot edited a comment on pull request #17830: URL: https://github.com/apache/flink/pull/17830#issuecomment-973131002 ## CI report: * 63ddba017e24c798b2f75f773b645ecaa22b5bc3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752855277 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModelData.java ## @@ -0,0 +1,223 @@ +package

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752856546 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnUtil.java ## @@ -0,0 +1,428 @@ +package

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752856415 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/Knn.java ## @@ -0,0 +1,220 @@ +package

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752856110 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModel.java ## @@ -0,0 +1,343 @@ +package

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752855277 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnModelData.java ## @@ -0,0 +1,223 @@ +package

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752855026 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/EuclideanDistance.java ## @@ -0,0 +1,272 @@ +package

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752853592 ## File path: flink-ml-lib/pom.xml ## @@ -106,6 +112,11 @@ under the License. jar test + + com.google.code.gson +

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752853041 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/DenseMatrix.java ## @@ -0,0 +1,161 @@ +package

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: Flink 24557

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752851858 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/linalg/Vector.java ## @@ -29,6 +29,10 @@ /** Gets the value of the ith element. */

[jira] [Commented] (FLINK-24958) correct the example and link for temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446275#comment-17446275 ] Leonard Xu commented on FLINK-24958: Thanks [~zoucao] for report this, I assign this ticket to you

[GitHub] [flink] flinkbot edited a comment on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-953241058 ## CI report: * 99fa2e362ef929e2549e5aa76ef2c11b7b39891d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-953241058 ## CI report: * 99fa2e362ef929e2549e5aa76ef2c11b7b39891d Azure:

[jira] [Assigned] (FLINK-24958) correct the example and link for temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-24958: -- Assignee: zoucao > correct the example and link for temporal table function documentation >

[GitHub] [flink] viirya commented on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

viirya commented on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-973717126 @gyfora I addressed your two previous comments. Thanks. I'll see if I can add a test for it. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #17832: [FLINK-24958][docs]correct the example and link for temporal table fu…

flinkbot edited a comment on pull request #17832: URL: https://github.com/apache/flink/pull/17832#issuecomment-973714890 ## CI report: * 5b2208841608db9795796828f11c82060392a777 Azure:

[GitHub] [flink] viirya commented on a change in pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

viirya commented on a change in pull request #17582: URL: https://github.com/apache/flink/pull/17582#discussion_r752848360 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java ## @@ -171,23 +181,25 @@ public void

[GitHub] [flink] flinkbot commented on pull request #17832: [FLINK-24958][docs]correct the example and link for temporal table fu…

flinkbot commented on pull request #17832: URL: https://github.com/apache/flink/pull/17832#issuecomment-973715452 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 #17832: [FLINK-24958][docs]correct the example and link for temporal table fu…

flinkbot commented on pull request #17832: URL: https://github.com/apache/flink/pull/17832#issuecomment-973714890 ## CI report: * 5b2208841608db9795796828f11c82060392a777 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-24958) correct the example and link for temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446273#comment-17446273 ] zoucao commented on FLINK-24958: cc [~Leonard] > correct the example and link for temporal table

[jira] [Updated] (FLINK-24958) correct the example and link for temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-24958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24958: --- Labels: pull-request-available (was: ) > correct the example and link for temporal table

[GitHub] [flink] zoucao opened a new pull request #17832: [FLINK-24958][docs]correct the example and link for temporal table fu…

zoucao opened a new pull request #17832: URL: https://github.com/apache/flink/pull/17832 …nction documentation ## What is the purpose of the change correct the example and link for temporal table function documentation. ## Brief change log *(for

[jira] [Created] (FLINK-24958) correct the example and link for temporal table function documentation

zoucao created FLINK-24958: -- Summary: correct the example and link for temporal table function documentation Key: FLINK-24958 URL: https://issues.apache.org/jira/browse/FLINK-24958 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17831: [FLINK-15825][Table SQL/API] Add renameDatabase() to Catalog

flinkbot edited a comment on pull request #17831: URL: https://github.com/apache/flink/pull/17831#issuecomment-973310719 ## CI report: * cf69d827d81b781bc21b2faf0badb552aa884415 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17831: [FLINK-15825][Table SQL/API] Add renameDatabase() to Catalog

flinkbot edited a comment on pull request #17831: URL: https://github.com/apache/flink/pull/17831#issuecomment-973310719 ## CI report: * cf69d827d81b781bc21b2faf0badb552aa884415 Azure:

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

zhipeng93 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752817357 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #24: Flink 24557

yunfengzhou-hub commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r752833908 ## File path: flink-ml-lib/pom.xml ## @@ -106,6 +112,11 @@ under the License. jar test + + com.google.code.gson +

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[jira] [Commented] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446258#comment-17446258 ] Biao Geng commented on FLINK-24897: --- Hi [~trohrmann] , would you mind giving any comments on if we

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink-ml] weibozhao commented on pull request #24: Flink 24557

weibozhao commented on pull request #24: URL: https://github.com/apache/flink-ml/pull/24#issuecomment-973691985 update the latest code already. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[jira] [Created] (FLINK-24957) show `host:port` information in `subtasks` tab

Xianxun Ye created FLINK-24957: -- Summary: show `host:port` information in `subtasks` tab Key: FLINK-24957 URL: https://issues.apache.org/jira/browse/FLINK-24957 Project: Flink Issue Type:

[jira] [Closed] (FLINK-24835) "group by" in the interval join will throw a exception

[ https://issues.apache.org/jira/browse/FLINK-24835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24835. -- Resolution: Fixed Fixed in 1.15.0: 8aa74d5ad7026734bdd98eabbc9cbbb243bbe8b0 1.14.1:

[jira] [Commented] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding

[ https://issues.apache.org/jira/browse/FLINK-24951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446253#comment-17446253 ] Yang Wang commented on FLINK-24951: --- I am afraid some old K8s version does not support bookmark and

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

zhipeng93 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752825779 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

zhipeng93 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752817357 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

zhipeng93 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752825161 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

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

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

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

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

[GitHub] [flink-ml] HuangXingBo commented on a change in pull request #36: [FLINK-24933][ML] Support ML Python API

HuangXingBo commented on a change in pull request #36: URL: https://github.com/apache/flink-ml/pull/36#discussion_r752820431 ## File path: flink-ml-python/apache_flink_ml/ml/api/core.py ## @@ -0,0 +1,221 @@

[GitHub] [flink] xuyangzhong commented on a change in pull request #17771: [FLINK-24813][table-planner]Improve ImplicitTypeConversionITCase

xuyangzhong commented on a change in pull request #17771: URL: https://github.com/apache/flink/pull/17771#discussion_r752820224 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/SqlExpressionTest.scala ## @@ -302,23 +145,6

[jira] [Comment Edited] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding

[ https://issues.apache.org/jira/browse/FLINK-24951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446247#comment-17446247 ] Yangze Guo edited comment on FLINK-24951 at 11/19/21, 2:33 AM: --- With

[GitHub] [flink-ml] HuangXingBo commented on a change in pull request #36: [FLINK-24933][ML] Support ML Python API

HuangXingBo commented on a change in pull request #36: URL: https://github.com/apache/flink-ml/pull/36#discussion_r752819246 ## File path: flink-ml-python/apache_flink_ml/ml/tests/test_stage.py ## @@ -0,0 +1,211 @@

[jira] [Commented] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding

[ https://issues.apache.org/jira/browse/FLINK-24951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446247#comment-17446247 ] Yangze Guo commented on FLINK-24951: Fabric8 5.5.0 can enable this feature, but it cannot handle

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

zhipeng93 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752817357 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

zhipeng93 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r752817089 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/allreduce/AllReduceUtils.java ## @@ -0,0 +1,314 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-24951) Allow watch bookmarks to mitigate frequent watcher rebuilding

[ https://issues.apache.org/jira/browse/FLINK-24951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446244#comment-17446244 ] Yang Wang commented on FLINK-24951: --- Does fabric8 Kubernetes-client 5.5.0 support bookmarks? Maybe we

[GitHub] [flink-ml] HuangXingBo commented on a change in pull request #36: [FLINK-24933][ML] Support ML Python API

HuangXingBo commented on a change in pull request #36: URL: https://github.com/apache/flink-ml/pull/36#discussion_r752814620 ## File path: flink-ml-python/apache_flink_ml/mllib/__init__.py ## @@ -0,0 +1,17 @@

  1   2   3   4   5   >