[GitHub] [flink] flinkbot edited a comment on pull request #17622: [FLINK-24407][doc-zh]Pulsar connector chinese document link to Pulsar document location incorrectly.

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r766361133 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/linear/LogisticRegressionTest.java ## @@ -0,0 +1,280 @@ +/* + * Licensed to th

[GitHub] [flink] flinkbot edited a comment on pull request #17622: [FLINK-24407][doc-zh]Pulsar connector chinese document link to Pulsar document location incorrectly.

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

[jira] [Updated] (FLINK-25141) Elasticsearch connector customize sink parallelism

[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-25141: - Fix Version/s: 1.15.0 > Elasticsearch connector customize sink parallelism > ---

[jira] [Commented] (FLINK-24295) Too many requestPartitionState may jam the JobManager during task deployment

[ https://issues.apache.org/jira/browse/FLINK-24295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458147#comment-17458147 ] huntercc commented on FLINK-24295: -- I also think retrying may be a good idea. In my sol

[GitHub] [flink] wenlong88 commented on a change in pull request #18042: [FLINK-25076][table-planner] Improve operator name for sql job

wenlong88 commented on a change in pull request #18042: URL: https://github.com/apache/flink/pull/18042#discussion_r767407649 ## File path: flink-table/flink-table-planner/src/test/resources/explain/filesystem/testFileSystemTableSinkWithParallelismInStreamingSql0.out ## @@ -15

[GitHub] [flink] flinkbot edited a comment on pull request #17622: [FLINK-24407][doc-zh]Pulsar connector chinese document link to Pulsar document location incorrectly.

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

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r767400105 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseMatrixSerializer.java ## @@ -0,0 +1,134 @@ +/* + * Licensed to the Apac

[GitHub] [flink] flinkbot edited a comment on pull request #17622: [FLINK-24407][doc-zh]Pulsar connector chinese document link to Pulsar document location incorrectly.

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

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r767399762 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseMatrixSerializer.java ## @@ -0,0 +1,134 @@ +/* + * Licensed to the Apac

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r767399239 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseMatrixSerializer.java ## @@ -0,0 +1,138 @@ +/* + * Licensed to the Apac

[GitHub] [flink] godfreyhe commented on a change in pull request #18042: [FLINK-25076][table-planner] Improve operator name for sql job

godfreyhe commented on a change in pull request #18042: URL: https://github.com/apache/flink/pull/18042#discussion_r767377884 ## File path: flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/nodes/exec/operator/BatchOperatorNameTest.xml ## @

[jira] [Commented] (FLINK-25240) Update log4j2 version to 2.15.0

[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458142#comment-17458142 ] Chenyu Zheng commented on FLINK-25240: -- Hi there,  I found the new versions (1.13.

[jira] [Comment Edited] (FLINK-25240) Update log4j2 version to 2.15.0

[ https://issues.apache.org/jira/browse/FLINK-25240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458142#comment-17458142 ] Chenyu Zheng edited comment on FLINK-25240 at 12/13/21, 3:51 AM: -

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r767396443 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/knn/KnnTest.java ## @@ -0,0 +1,251 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r767395937 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java ## @@ -22,13 +22,84 @@ /** A utility class that provides BLAS routines ov

[GitHub] [flink-ml] weibozhao commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

weibozhao commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r766588987 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/knn/Knn.java ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache Software Foun

[jira] [Commented] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458140#comment-17458140 ] Liu commented on FLINK-10644: - Any progress on the feature? We have the same requirement in

[jira] [Resolved] (FLINK-23427) Translate the page of "Blocking Shuffle" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aiden Gong resolved FLINK-23427. Resolution: Fixed > Translate the page of "Blocking Shuffle" into Chinese > --

[jira] [Resolved] (FLINK-24407) Pulsar connector chinese document link to Pulsar document location incorrectly.

[ https://issues.apache.org/jira/browse/FLINK-24407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aiden Gong resolved FLINK-24407. Resolution: Fixed > Pulsar connector chinese document link to Pulsar document location > incorrec

[GitHub] [flink] leonardBang merged pull request #17661: [hotfix][jdbc][docs] - Updated key handling section text

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

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r767387752 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/BLAS.java ## @@ -22,13 +22,84 @@ /** A utility class that provides BLAS routines ov

[GitHub] [flink-ml] lindong28 commented on a change in pull request #24: [Flink 24557] - Add Estimator and Transformer for K-nearest neighbor

lindong28 commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r767387005 ## File path: flink-ml-core/src/main/java/org/apache/flink/ml/linalg/typeinfo/DenseMatrixSerializer.java ## @@ -0,0 +1,134 @@ +/* + * Licensed to the Apac

[GitHub] [flink] beyond1920 merged pull request #16957: [FLINK-23937][Documentation] Fix PQ comment in KeyGroupPartitionedPriorityQueue

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

[GitHub] [flink] imaffe commented on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…

imaffe commented on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-992065075 @JingGe Is there anything else we might missed ? I feel this PR is about ready. WDYT ? -- This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Commented] (FLINK-25265) RUNNING to FAILED with failure cause. This might indicate that the remote task manager was lost.

[ https://issues.apache.org/jira/browse/FLINK-25265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458134#comment-17458134 ] Wenlong Lyu commented on FLINK-25265: - hi， [~coco_yiyayiya] have you checked the log

[GitHub] [flink] flinkbot edited a comment on pull request #17622: [FLINK-24407][doc-zh]Pulsar connector chinese document link to Pulsar document location incorrectly.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17622: [FLINK-24407][doc-zh]Pulsar connector chinese document link to Pulsar document location incorrectly.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

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

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

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

[GitHub] [flink] mans2singh commented on pull request #17661: [hotfix][jdbc][docs] - Updated key handling section text

mans2singh commented on pull request #17661: URL: https://github.com/apache/flink/pull/17661#issuecomment-992047915 @wuchong @leonardBang - Just wanted to request you to review this minor doc PR. Thanks -- This is an automated message from the Apache Git Service. To respond to the messa

[jira] [Comment Edited] (FLINK-24813) Improve ImplicitTypeConversionITCase

[ https://issues.apache.org/jira/browse/FLINK-24813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452863#comment-17452863 ] godfrey he edited comment on FLINK-24813 at 12/13/21, 2:00 AM: ---

[GitHub] [flink] godfreyhe commented on pull request #18049: [FLINK-24813][table-planner-blink] Improve ImplicitTypeConversionITCase

godfreyhe commented on pull request #18049: URL: https://github.com/apache/flink/pull/18049#issuecomment-992040873 merged -- 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. T

[GitHub] [flink] godfreyhe closed pull request #18049: [FLINK-24813][table-planner-blink] Improve ImplicitTypeConversionITCase

godfreyhe closed pull request #18049: URL: https://github.com/apache/flink/pull/18049 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsub

[jira] [Commented] (FLINK-25262) Support to send data to lookup table for KeyGroupStreamPartitioner way for SQL

[ https://issues.apache.org/jira/browse/FLINK-25262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458120#comment-17458120 ] Yuan Zhu commented on FLINK-25262: -- I think this was proposed before. > Support to sen

[jira] [Updated] (FLINK-25267) Unable to (always) recover using checkpoint in HA setup (both Zookeeper and Kubernetes)

[ https://issues.apache.org/jira/browse/FLINK-25267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kerem Ulutaş updated FLINK-25267: - Description: My Stateful Functions job is running on Kubernetes (minikube on my local env) and

[jira] [Created] (FLINK-25267) Unable to (always) recover using checkpoint in HA setup (both Zookeeper and Kubernetes)

Kerem Ulutaş created FLINK-25267: Summary: Unable to (always) recover using checkpoint in HA setup (both Zookeeper and Kubernetes) Key: FLINK-25267 URL: https://issues.apache.org/jira/browse/FLINK-25267

[jira] [Updated] (FLINK-7947) Let ParameterTool return a dedicated GlobalJobParameters object

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

[jira] [Updated] (FLINK-4688) Optimizer hangs for hours when optimizing complex plans

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

[jira] [Updated] (FLINK-4830) Show latency statistics in web interface

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

[jira] [Updated] (FLINK-4819) Checkpoint metadata+data inspection tool (view / update)

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

[jira] [Updated] (FLINK-7919) Join with Solution Set fails with NPE if Solution Set has no entry

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

[jira] [Updated] (FLINK-4620) Automatically creating savepoints

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

[jira] [Updated] (FLINK-4902) Flink Task Chain not getting input in a distributed manner

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

[jira] [Updated] (FLINK-7935) Metrics with user supplied scope variables

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

[jira] [Updated] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

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

[jira] [Updated] (FLINK-4990) Remove JAR option from savepoint disposal

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

[jira] [Updated] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv

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

[jira] [Updated] (FLINK-4947) Make all configuration possible via flink-conf.yaml and CLI.

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

[jira] [Updated] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value

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

[jira] [Updated] (FLINK-5009) FS checkpoints leave empty directory

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

[jira] [Updated] (FLINK-4948) Consider using checksums or similar to detect bad checkpoints

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

[jira] [Updated] (FLINK-4859) Clearly Separate Responsibilities of StreamOperator and StreamTask

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

[jira] [Updated] (FLINK-7894) Improve metrics around fine-grained recovery and associated checkpointing behaviors

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

[jira] [Updated] (FLINK-19911) add read buffer for input stream

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

[jira] [Updated] (FLINK-19999) State Processor API classes leaking into savepoint

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

[jira] [Updated] (FLINK-20503) Internal cpu configuration option is leaked in logs

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

[jira] [Updated] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

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

[jira] [Comment Edited] (FLINK-20195) Jobs endpoint returns duplicated jobs

[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457913#comment-17457913 ] Chesnay Schepler edited comment on FLINK-20195 at 12/12/21, 10:01 PM:

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

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

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

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

mbalassi commented on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-991971232 @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] flinkbot edited a comment on pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

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

[jira] [Comment Edited] (FLINK-20195) Jobs endpoint returns duplicated jobs

[ https://issues.apache.org/jira/browse/FLINK-20195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457913#comment-17457913 ] Chesnay Schepler edited comment on FLINK-20195 at 12/12/21, 5:57 PM: -

[GitHub] [flink] dawidwys commented on a change in pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys commented on a change in pull request #18086: URL: https://github.com/apache/flink/pull/18086#discussion_r767303555 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java ## @@ -172,4 +174,19 @@ OperatorStateBackend createOperatorSt

[GitHub] [flink] flinkbot edited a comment on pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

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

[GitHub] [flink] flinkbot commented on pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

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

[GitHub] [flink] flinkbot commented on pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

flinkbot commented on pull request #18086: URL: https://github.com/apache/flink/pull/18086#issuecomment-991936309 ## CI report: * 702fe9f453abcd72e35cc6c66b7cc02ad16c1d8e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-25192) Implement proper no-claim mode support

[ https://issues.apache.org/jira/browse/FLINK-25192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25192: --- Labels: pull-request-available (was: ) > Implement proper no-claim mode support > -

[GitHub] [flink] dawidwys opened a new pull request #18086: [FLINK-25192][checkpointing] Implement no-claim mode support

dawidwys opened a new pull request #18086: URL: https://github.com/apache/flink/pull/18086 ## What is the purpose of the change We introduce NO_CLAIM restore mode in which we do not take ownership of the restored checkpoint. We do enforce the first, successful checkpoint after a

[jira] [Assigned] (FLINK-17971) Speed up RocksDB bulk loading with SST generation and ingestion

[ https://issues.apache.org/jira/browse/FLINK-17971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-17971: Assignee: Yuan Mei > Speed up RocksDB bulk loading with SST generation and ingestion > --

[jira] [Reopened] (FLINK-19008) Flink Job runs slow after restore + downscale from an incremental checkpoint (rocksdb)

[ https://issues.apache.org/jira/browse/FLINK-19008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reopened FLINK-19008: -- Assignee: Yuan Mei > Flink Job runs slow after restore + downscale from an incremental checkpoint >

[jira] [Comment Edited] (FLINK-19918) RocksIncrementalCheckpointRescalingTest.testScalingDown/Up fails on Windows with NPE

[ https://issues.apache.org/jira/browse/FLINK-19918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457975#comment-17457975 ] Yuan Mei edited comment on FLINK-19918 at 12/12/21, 3:25 PM: -

[jira] [Comment Edited] (FLINK-19918) RocksIncrementalCheckpointRescalingTest.testScalingDown/Up fails on Windows with NPE

[ https://issues.apache.org/jira/browse/FLINK-19918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457975#comment-17457975 ] Yuan Mei edited comment on FLINK-19918 at 12/12/21, 3:23 PM: -

[jira] [Commented] (FLINK-21352) FLIP-158: Generalized incremental checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457976#comment-17457976 ] Yuan Mei commented on FLINK-21352: -- Hey Roman, the reason I am proposing to reorganize

[jira] [Commented] (FLINK-19918) RocksIncrementalCheckpointRescalingTest.testScalingDown/Up fails on Windows with NPE

[ https://issues.apache.org/jira/browse/FLINK-19918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457975#comment-17457975 ] Yuan Mei commented on FLINK-19918: -- I can not reproduce the same error in the current m

[jira] [Updated] (FLINK-25263) KafkaSourceE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25263: - Priority: Blocker (was: Major) > KafkaSourceE2ECase is broken > ---

[jira] [Closed] (FLINK-25159) Streamline E2E surefire configuration setup

[ https://issues.apache.org/jira/browse/FLINK-25159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25159. Resolution: Fixed master: 47e6e8909aa88aef1ff15b01f069aac07f19779e > Streamline E2E suref

[GitHub] [flink] zentol merged pull request #18051: [FLINK-25159][tests] Streamline E2E surefire setup

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

[GitHub] [flink] flinkbot edited a comment on pull request #18051: [FLINK-25159][tests] Streamline E2E surefire setup

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

[GitHub] [flink] flinkbot edited a comment on pull request #18084: [hotfix][docs][connectors] Add missing semicolon to make the query valid

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

[GitHub] [flink] flinkbot edited a comment on pull request #18051: [FLINK-25159][tests] Streamline E2E surefire setup

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

[jira] [Commented] (FLINK-21352) FLIP-158: Generalized incremental checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457962#comment-17457962 ] Roman Khachatryan commented on FLINK-21352: --- Hey Yuan, thank you for your mess

[GitHub] [flink] flinkbot edited a comment on pull request #18051: [FLINK-25159][tests] Streamline E2E surefire setup

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

[GitHub] [flink] flinkbot edited a comment on pull request #18051: [FLINK-25159][tests] Streamline E2E surefire setup

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

[GitHub] [flink] flinkbot edited a comment on pull request #18051: [FLINK-25159][tests] Streamline E2E surefire setup

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

[GitHub] [flink] flinkbot edited a comment on pull request #18051: [FLINK-25159][tests] Streamline E2E surefire setup

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

[GitHub] [flink] flinkbot edited a comment on pull request #18051: [FLINK-25159][tests] Streamline E2E surefire setup

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

[jira] [Assigned] (FLINK-24350) Resuming Savepoint (hashmap, sync, scale up) end-to-end test fails due to ask timeout

[ https://issues.apache.org/jira/browse/FLINK-24350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24350: Assignee: (was: Chesnay Schepler) > Resuming Savepoint (hashmap, sync, scale

[jira] [Closed] (FLINK-24350) Resuming Savepoint (hashmap, sync, scale up) end-to-end test fails due to ask timeout

[ https://issues.apache.org/jira/browse/FLINK-24350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24350. Resolution: Cannot Reproduce > Resuming Savepoint (hashmap, sync, scale up) end-to-end tes

[GitHub] [flink] flinkbot edited a comment on pull request #18051: [FLINK-25159][tests] Streamline E2E surefire setup

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

[jira] [Closed] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18356. Fix Version/s: (was: 1.15.0) (was: 1.14.1) Resolution: Du

[jira] [Closed] (FLINK-24341) PyFlink Table test module timeout

[ https://issues.apache.org/jira/browse/FLINK-24341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24341. Resolution: Duplicate Elasticsearch tests cause memory shortage. > PyFlink Table test mod

[jira] [Closed] (FLINK-24794) AZP kills docker containers with exit code 137 (maybe OOM)

[ https://issues.apache.org/jira/browse/FLINK-24794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24794. Fix Version/s: (was: 1.15.0) (was: 1.14.1) Resolution: Du

[GitHub] [flink] flinkbot edited a comment on pull request #18084: [hotfix][docs][connectors] Add missing semicolon to make the query valid

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

[GitHub] [flink] flinkbot edited a comment on pull request #18084: [hotfix][docs][connectors] Add missing semicolon to make the query valid

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

[jira] [Commented] (FLINK-25266) StreamingKafkaITCase fails with incorrect number of messages

[ https://issues.apache.org/jira/browse/FLINK-25266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457942#comment-17457942 ] Chesnay Schepler commented on FLINK-25266: -- I have disabled the test because it

[GitHub] [flink] snuyanzin commented on pull request #18084: [hotfix][docs][connectors] Add missing semicolon to make the query valid

snuyanzin commented on pull request #18084: URL: https://github.com/apache/flink/pull/18084#issuecomment-991887747 yes, sure, done -- 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 specifi

[jira] [Closed] (FLINK-21603) SQLClientKafkaITCase failed due to unexpected end of file

[ https://issues.apache.org/jira/browse/FLINK-21603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21603. Resolution: Fixed > SQLClientKafkaITCase failed due to unexpected end of file > --

<    1   2   3   >