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

gaurav726 commented on pull request #17754: URL: https://github.com/apache/flink/pull/17754#issuecomment-977472022 Hi @wuchong, pipeline got succeed, please review and merge -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] JingsongLi commented on pull request #17792: [FLINK-24763][fs-connector] LimitableReader should swallow exception when reached limit

JingsongLi commented on pull request #17792: URL: https://github.com/apache/flink/pull/17792#issuecomment-977471964 > Btw I'm fine to disable the test for the time being and create a follow-up blocker ticket to re-enable it. Alternatively, you can push your current fix with some more comme

[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_r755675421 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/FastDistanceMatrixData.java ## @@ -0,0 +1,93 @@ +package org.apache.flink.

[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_r755674770 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/MapPartitionFunctionWrapper.java ## @@ -0,0 +1,68 @@ +package org.apache.flink.ml.comm

[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_r755674858 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/KnnParams.java ## @@ -0,0 +1,32 @@ +package org.apache.flink.ml.classifica

[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_r755674542 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/Knn.java ## @@ -0,0 +1,255 @@ +package org.apache.flink.ml.classification.

[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_r755674684 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasFeatureColsDefaultAsNull.java ## @@ -0,0 +1,28 @@ +package org.apache.flink.m

[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_r755674205 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/util/ReadWriteUtils.java ## @@ -43,8 +46,12 @@ /** Utility methods for reading and writing

[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_r755673857 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/param/Param.java ## @@ -75,7 +75,7 @@ public String jsonEncode(T value) throws IOException {

[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_r755673679 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/param/Param.java ## @@ -64,7 +64,7 @@ public Param( * @return A json-formatted string.

[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_r755673190 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/linalg/DenseVector.java ## @@ -42,14 +45,26 @@ public double get(int i) { return val

[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_r755673036 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java ## @@ -158,10 +148,11 @@ public void testFeaturePredictionPa

[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_r755671222 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java ## @@ -83,43 +97,19 @@ public void before() { dataT

[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_r755671196 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java ## @@ -83,43 +97,19 @@ public void before() { dataT

[jira] [Commented] (FLINK-15571) Create a Redis Streams Connector for Flink

[ https://issues.apache.org/jira/browse/FLINK-15571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448340#comment-17448340 ] ZhuoYu Chen commented on FLINK-15571: - Hi [~yunta]，[~tgrall]  I am very interested i

[GitHub] [flink] Tartarus0zm commented on a change in pull request #17761: [FLINK-24862][Connectors / Hive]Fix user-defined hive udaf/udtf cannot be used normally in hive dialect

Tartarus0zm commented on a change in pull request #17761: URL: https://github.com/apache/flink/pull/17761#discussion_r755670458 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionCatalog.java ## @@ -641,7 +641,8 @@ private void

[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_r755670337 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java ## @@ -67,6 +69,18 @@ Vectors.dense(9.6

[GitHub] [flink-ml] zhipeng93 edited a comment on pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

zhipeng93 edited a comment on pull request #28: URL: https://github.com/apache/flink-ml/pull/28#issuecomment-976486651 Hi@lindong28 , thanks for the review and I have addressed your comments. -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Created] (FLINK-25028) java.lang.OutOfMemoryError: Java heap space

wangbaohua created FLINK-25028: -- Summary: java.lang.OutOfMemoryError: Java heap space Key: FLINK-25028 URL: https://issues.apache.org/jira/browse/FLINK-25028 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

flinkbot edited a comment on pull request #17874: URL: https://github.com/apache/flink/pull/17874#issuecomment-976109395 ## CI report: * 95f6020ca7df973e5a50a0eab36fa2bd1a33878c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24815) Reduce the cpu cost of calculating stateSize during state allocation

[ https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448334#comment-17448334 ] Yun Tang commented on FLINK-24815: -- Apart from calucating the state size lazily, I like

[GitHub] [flink] flinkbot edited a comment on pull request #17874: [FLINK-24046] Refactor the EmbeddedRocksDBStateBackend configuration logic

flinkbot edited a comment on pull request #17874: URL: https://github.com/apache/flink/pull/17874#issuecomment-976109395 ## CI report: * 95f6020ca7df973e5a50a0eab36fa2bd1a33878c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-25010) Speed up hive's createMRSplits by multi thread

[ https://issues.apache.org/jira/browse/FLINK-25010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448333#comment-17448333 ] Liu commented on FLINK-25010: - [~luoyuxia] Thank you. I would like to do it. > Speed up hiv

[GitHub] [flink] flinkbot edited a comment on pull request #17890: [BP-1.14][FLINK-24624][k8s] Clean up residual k8s resources when starting kubernetes session or application cluster failed

flinkbot edited a comment on pull request #17890: URL: https://github.com/apache/flink/pull/17890#issuecomment-977413087 ## CI report: * 1724c0b42250c88911e228025251ad3b764042ac Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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_r755625715 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/naivebayes/NaiveBayes.java ## @@ -0,0 +1,333 @@ +/* + * Licensed to the Apache

[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_r755192622 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/clustering/KMeansTest.java ## @@ -158,10 +148,11 @@ public void testFeaturePredictionParam()

[GitHub] [flink] flinkbot commented on pull request #17890: [BP-1.14][FLINK-24624][k8s] Clean up residual k8s resources when starting kubernetes session or application cluster failed

flinkbot commented on pull request #17890: URL: https://github.com/apache/flink/pull/17890#issuecomment-977413040 -- 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 unsubsc

[GitHub] [flink] flinkbot edited a comment on pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

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

[jira] [Assigned] (FLINK-23997) Improvement for SQL windowing table-valued function

[ https://issues.apache.org/jira/browse/FLINK-23997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang reassigned FLINK-23997: -- Assignee: Jing Zhang (was: jingzhang#1) > Improvement for SQL windowing table-valued functio

[GitHub] [flink] wangyang0918 opened a new pull request #17890: [BP-1.14][FLINK-24624][k8s] Clean up residual k8s resources when starting kubernetes session or application cluster failed

wangyang0918 opened a new pull request #17890: URL: https://github.com/apache/flink/pull/17890 Backport #17554 to 1.14. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17554: [FLINK-24624][Kubernetes]Kill cluster when starting kubernetes session or application cluster failed

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

[jira] [Comment Edited] (FLINK-25021) Source/Sink for Azure Data Explorer (ADX)

[ https://issues.apache.org/jira/browse/FLINK-25021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448317#comment-17448317 ] Xue Wang edited comment on FLINK-25021 at 11/24/21, 1:22 AM: -

[jira] [Commented] (FLINK-25021) Source/Sink for Azure Data Explorer (ADX)

[ https://issues.apache.org/jira/browse/FLINK-25021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448317#comment-17448317 ] Xue Wang commented on FLINK-25021: -- Thank you [~MartijnVisser] for the guidance. Glad t

[GitHub] [flink] flinkbot edited a comment on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

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

[GitHub] [flink] flinkbot edited a comment on pull request #17813: [FLINK-24802][Table SQL/Planner] Improve cast ROW to STRING

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

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [WIP][FLINK-24703][connectors][formats] Add FileSource support for reading CSV files.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 7e097463582d225c33b56c3d2f067a3954867a11 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [WIP][FLINK-24703][connectors][formats] Add FileSource support for reading CSV files.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 7e097463582d225c33b56c3d2f067a3954867a11 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

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

[GitHub] [flink] flinkbot edited a comment on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

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

[GitHub] [flink] flinkbot edited a comment on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

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

[GitHub] [flink] JingGe commented on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

JingGe commented on pull request #17888: URL: https://github.com/apache/flink/pull/17888#issuecomment-977279127 @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 c

[GitHub] [flink] JingGe commented on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

JingGe commented on pull request #17851: URL: https://github.com/apache/flink/pull/17851#issuecomment-977278609 @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 c

[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: * 20ea72fdf316afb968e2d35b1e71a8ab9d8f12b7 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-9760) Return a single element from extractPatterns

[ https://issues.apache.org/jira/browse/FLINK-9760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9760: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-9797) Separate state serializers from network serializers

[ https://issues.apache.org/jira/browse/FLINK-9797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9797: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-9689) Flink consumer deserialization example

[ https://issues.apache.org/jira/browse/FLINK-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9689: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-9843) Build website automatically

[ https://issues.apache.org/jira/browse/FLINK-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9843: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-9699) Add api to replace registered table

[ https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9699: -- Labels: auto-deprioritized-major pull-request-available stale-minor (was: auto-deprioritized-m

[jira] [Updated] (FLINK-9831) Too many open files for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9831: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-9802) Harden End-to-end tests against download failures

[ https://issues.apache.org/jira/browse/FLINK-9802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9802: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-9698) "case class must be static and globally accessible" is too constrained

[ https://issues.apache.org/jira/browse/FLINK-9698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9698: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-9907) add CRC32 checksum in table Api and sql

[ https://issues.apache.org/jira/browse/FLINK-9907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9907: -- Labels: auto-deprioritized-major pull-request-available stale-minor (was: auto-deprioritized-m

[jira] [Updated] (FLINK-13474) NoSuchMethodError when registering DataStream

[ https://issues.apache.org/jira/browse/FLINK-13474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13474: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-13649) Improve error message when job submission was not successful

[ https://issues.apache.org/jira/browse/FLINK-13649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13649: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-13462) Add table api examples into flink-quickstart

[ https://issues.apache.org/jira/browse/FLINK-13462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13462: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-13472) taskmanager.jvm-exit-on-oom doesn't work reliably with YARN

[ https://issues.apache.org/jira/browse/FLINK-13472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13472: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-13557) Improve failover strategy documentation with explanation of pipelined regions

[ https://issues.apache.org/jira/browse/FLINK-13557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13557: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-13556) Python profile failed on Travis with setup problem

[ https://issues.apache.org/jira/browse/FLINK-13556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13556: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-13506) flink1.6.1 can't consume the specified topic list，only a few topic was consumed

[ https://issues.apache.org/jira/browse/FLINK-13506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13506: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-9945) RocksDB state backend Checkpointing Failed

[ https://issues.apache.org/jira/browse/FLINK-9945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9945: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-13416) Refactor documentation of CLI optional for yarn cluster mode

[ https://issues.apache.org/jira/browse/FLINK-13416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13416: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-13537) Changing Kafka producer pool size and scaling out may create overlapping transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-13537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13537: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-13721) BroadcastState should support StateTTL

[ https://issues.apache.org/jira/browse/FLINK-13721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13721: --- Labels: auto-deprioritized-major auto-deprioritized-minor feature improvement newbie (was

[jira] [Updated] (FLINK-9773) Break down CEP documentation into subsections

[ https://issues.apache.org/jira/browse/FLINK-9773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9773: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17855: [FLINK-24983][build] Upgrade surefire to 3.0.5-M5

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

[GitHub] [flink] MartijnVisser commented on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

MartijnVisser commented on pull request #17851: URL: https://github.com/apache/flink/pull/17851#issuecomment-977221197 @JingGe Could it be that you need to rebase? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] flinkbot edited a comment on pull request #17856: [FLINK-24984][ci] Rename MAVEN_OPTS variable

flinkbot edited a comment on pull request #17856: URL: https://github.com/apache/flink/pull/17856#issuecomment-975393083 ## CI report: * 9c4df07c870d0067756a245eabb374c28f10b558 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17813: [FLINK-24802][Table SQL/Planner] Improve cast ROW to STRING

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

[GitHub] [flink] flinkbot edited a comment on pull request #17813: [FLINK-24802][Table SQL/Planner] Improve cast ROW to STRING

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

[GitHub] [flink] shenzhu commented on pull request #17813: [FLINK-24802][Table SQL/Planner] Improve cast ROW to STRING

shenzhu commented on pull request #17813: URL: https://github.com/apache/flink/pull/17813#issuecomment-977195115 @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] shenzhu removed a comment on pull request #17813: [FLINK-24802][Table SQL/Planner] Improve cast ROW to STRING

shenzhu removed a comment on pull request #17813: URL: https://github.com/apache/flink/pull/17813#issuecomment-976964232 @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 s

[GitHub] [flink] flinkbot edited a comment on pull request #17693: [FLINK-24789][runtime] Trigger checkpoint disposal prior completing t…

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

[jira] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419 ] Jiahui Jiang deleted comment on FLINK-16419: -- was (Author: qzhzm173227): [~fpaul] This happened in our production again today :( Does my hypothesis make sense given how Kafka generates tran

[GitHub] [flink] flinkbot edited a comment on pull request #17785: [FLINK-24580][Connectors/Kinesis] Make ConnectTimeoutException recoverable

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

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445945#comment-17445945 ] Jiahui Jiang edited comment on FLINK-16419 at 11/23/21, 9:05 PM: -

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445945#comment-17445945 ] Jiahui Jiang edited comment on FLINK-16419 at 11/23/21, 9:03 PM: -

[jira] [Comment Edited] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445945#comment-17445945 ] Jiahui Jiang edited comment on FLINK-16419 at 11/23/21, 9:00 PM: -

[GitHub] [flink] flinkbot edited a comment on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 981c38fcdf804032aa789af511d01c6c4070fe3d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24854) StateHandleSerializationTest unit test error

[ https://issues.apache.org/jira/browse/FLINK-24854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448255#comment-17448255 ] Stephan Ewen commented on FLINK-24854: -- Thanks for reporting this. It looks like [~

[GitHub] [flink] flinkbot edited a comment on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

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

[GitHub] [flink] MartijnVisser commented on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

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

[GitHub] [flink] MartijnVisser commented on pull request #17463: [Hotfix] Fix typos.

MartijnVisser commented on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-977139251 @AHeise Please merge -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the sp

[GitHub] [flink] flinkbot edited a comment on pull request #17878: [FLINK-24507][table] Cleanup DateTimeUtils

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

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17133: [FLINK-24138] Architectural tests

flinkbot edited a comment on pull request #17133: URL: https://github.com/apache/flink/pull/17133#issuecomment-912323602 ## CI report: * cfb98c4cc708adb38ced719788af16a50625a1c1 UNKNOWN * 2e9283a4b5305e894adba085bf278b40951d1beb Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #17888: [FLINK-24077][hbase2/HBaseConnectorITCase] fix sporadic ut failing

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

[GitHub] [flink] flinkbot edited a comment on pull request #17811: [FLINK-24754] Implement CHAR/VARCHAR length validation for sinks

flinkbot edited a comment on pull request #17811: URL: https://github.com/apache/flink/pull/17811#issuecomment-970441907 ## CI report: * 0b973d5f4cd91f0b20c98ec0e6671cf7efa52cdd Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached

Nico Kruber created FLINK-25027: --- Summary: Allow GC of a finished job's JobMaster before the slot timeout is reached Key: FLINK-25027 URL: https://issues.apache.org/jira/browse/FLINK-25027 Project: Flin

[GitHub] [flink] flinkbot edited a comment on pull request #17851: [FLINK-21214][kafka/IT] add retry rule for testScaleDownBeforeFirstCh…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17871: [hotfix] Add assertj in dependency management and link the code quality guide in the PR template

flinkbot edited a comment on pull request #17871: URL: https://github.com/apache/flink/pull/17871#issuecomment-975731882 ## CI report: * 986abcb5198c7d772fef99a0b076bd4818517495 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17855: [FLINK-24983][build] Upgrade surefire to 3.0.5-M5

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

[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: * 24c7450ef162ec4530af791b1ef490cd2fe0f201 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 24c7450ef162ec4530af791b1ef490cd2fe0f201 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17857: [FLINK-24985][tests] Relax assumptions of stacktrace layout

flinkbot edited a comment on pull request #17857: URL: https://github.com/apache/flink/pull/17857#issuecomment-975401663 ## CI report: * 17691f4330fb8017970c9934c8e52ea91da7cdf4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17813: [FLINK-24802][Table SQL/Planner] Improve cast ROW to STRING

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

[GitHub] [flink] flinkbot edited a comment on pull request #17701: [FLINK-24294][streaming] Register all stream task resources to one cl…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17887: [FLINK-25020] Properly forward exception

flinkbot edited a comment on pull request #17887: URL: https://github.com/apache/flink/pull/17887#issuecomment-976615140 ## CI report: * 15a77538ee4fdbc85ca6c875ae3797b0a9b2d9e5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

<    1   2   3   4   5   6   7   8   9   >