[GitHub] [flink] dianfu commented on a change in pull request #17322: [FLINK-24336][python] Fix the issue that jar url may be a empty string.

dianfu commented on a change in pull request #17322: URL: https://github.com/apache/flink/pull/17322#discussion_r714518056 ## File path: flink-python/pyflink/table/table_environment.py ## @@ -1695,12 +1695,14 @@ def _add_jars_to_j_env_config(self, config_key): jar_urls

[jira] [Updated] (FLINK-24358) flink-avro-glue-schema-registry fails compiling with scala 2.12 due to dependency convergence

[ https://issues.apache.org/jira/browse/FLINK-24358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24358: - Summary: flink-avro-glue-schema-registry fails compiling with scala 2.12 due to dependency conve

[jira] [Assigned] (FLINK-24358) flink-avro-glue-schema-registry fails compiling with dependency convergence

[ https://issues.apache.org/jira/browse/FLINK-24358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-24358: Assignee: Xintong Song > flink-avro-glue-schema-registry fails compiling with dependency

[GitHub] [flink] flinkbot commented on pull request #17337: [BP-1.14][FLINK-24315][k8s] Throw exception in failing watching pods

flinkbot commented on pull request #17337: URL: https://github.com/apache/flink/pull/17337#issuecomment-925547728 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] slinkydeveloper commented on pull request #13081: [FLINK-18590][json] Support json array explode to multi messages

slinkydeveloper commented on pull request #13081: URL: https://github.com/apache/flink/pull/13081#issuecomment-925547477 Perfect! Once you're done, let me know and I'll review it. Thank you! -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 347481706d1752ab6cdef0ae207d0b286bf6daf2 UNKNOWN * 68773afc90e3de41db347b97cf884a264a7a

[GitHub] [flink] flinkbot edited a comment on pull request #17305: [hotfix][flink-avro] Use local actual schema variable

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

[GitHub] [flink] KarmaGYZ opened a new pull request #17337: [FLINK-24315][k8s] Throw exception in failing watching pods

KarmaGYZ opened a new pull request #17337: URL: https://github.com/apache/flink/pull/17337 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[GitHub] [flink] flinkbot edited a comment on pull request #16927: [FLINK-18592][Connectors/FileSystem] StreamingFileSink fails due to truncating HDFS file failure

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

[GitHub] [flink] link3280 commented on pull request #16927: [FLINK-18592][Connectors/FileSystem] StreamingFileSink fails due to truncating HDFS file failure

link3280 commented on pull request #16927: URL: https://github.com/apache/flink/pull/16927#issuecomment-925527858 @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

[jira] [Commented] (FLINK-24358) flink-avro-glue-schema-registry fails compiling with dependency convergence

[ https://issues.apache.org/jira/browse/FLINK-24358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418957#comment-17418957 ] Chesnay Schepler commented on FLINK-24358: -- Maybe there is some Scala dependenc

[GitHub] [flink] xintongsong closed pull request #17335: [FLINK-24353][scripts] Respect dynamic configurations when calculating memory sizes.

xintongsong closed pull request #17335: URL: https://github.com/apache/flink/pull/17335 -- 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

[jira] [Closed] (FLINK-24353) Bash scripts do not respect dynamic configurations when calculating memory sizes

[ https://issues.apache.org/jira/browse/FLINK-24353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-24353. Resolution: Fixed Fixed via: - master (1.15): 1d564a95581f5b4b1d8ae343676474a4fa570ffa - release-1

[jira] [Commented] (FLINK-24293) Tasks from the same job on a machine share user jar

[ https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418944#comment-17418944 ] Jark Wu commented on FLINK-24293: - Sorry [~huntercc], I'm not familiar with Coordinator

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[GitHub] [flink-ml] lindong28 commented on pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

lindong28 commented on pull request #4: URL: https://github.com/apache/flink-ml/pull/4#issuecomment-925506182 @zhipeng93 Sure. Can you explain the concern? And do you think these concern needs to be addressed in this PR? -- This is an automated message from the Apache Git Service. To res

[GitHub] [flink] akalash commented on a change in pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

akalash commented on a change in pull request #17331: URL: https://github.com/apache/flink/pull/17331#discussion_r714462624 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java ## @@ -53,6 +56,56 @@ public CheckpointFailur

[GitHub] [flink-ml] zhipeng93 commented on pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

zhipeng93 commented on pull request #4: URL: https://github.com/apache/flink-ml/pull/4#issuecomment-925490704 > @zhipeng93 Thanks for the review :) > > Can we delay the review/code of the save/load and also related implementation of Pipeline/PipelineModel to a later PR? The code/test

[jira] [Commented] (FLINK-24293) Tasks from the same job on a machine share user jar

[ https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418915#comment-17418915 ] huntercc commented on FLINK-24293: -- hi [~jark], I have added some meaningful content an

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[jira] [Commented] (FLINK-24358) flink-avro-glue-schema-registry fails compiling with dependency convergence

[ https://issues.apache.org/jira/browse/FLINK-24358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418923#comment-17418923 ] Xintong Song commented on FLINK-24358: -- It's wired this does not fail other stages.

[jira] [Created] (FLINK-24358) flink-avro-glue-schema-registry fails compiling with dependency convergence

Xintong Song created FLINK-24358: Summary: flink-avro-glue-schema-registry fails compiling with dependency convergence Key: FLINK-24358 URL: https://issues.apache.org/jira/browse/FLINK-24358 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #17336: [BP-1.13][FLINK-24315][k8s] Throw exception in failing watching pods

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

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 347481706d1752ab6cdef0ae207d0b286bf6daf2 UNKNOWN * 765eb79602d0d359ad2267f97cc578566301

[GitHub] [flink] xuyangzhong commented on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

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

[GitHub] [flink] flinkbot commented on pull request #17336: [BP-1.13][FLINK-24315][k8s] Throw exception in failing watching pods

flinkbot commented on pull request #17336: URL: https://github.com/apache/flink/pull/17336#issuecomment-925471041 ## CI report: * 80706fc5e305518c2060dfdf6341f88fc6f61ff1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 347481706d1752ab6cdef0ae207d0b286bf6daf2 UNKNOWN * 765eb79602d0d359ad2267f97cc578566301

[GitHub] [flink-ml] lindong28 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

lindong28 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r714439455 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java ## @@ -19,241 +19,102 @@ package org.apache.flink.ml.api.core; import

[GitHub] [flink-ml] lindong28 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

lindong28 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r714438174 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java ## @@ -19,241 +19,102 @@ package org.apache.flink.ml.api.core; import

[GitHub] [flink-ml] lindong28 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

lindong28 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r714438112 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/PipelineModel.java ## @@ -0,0 +1,86 @@ +/* + * Licensed to the Apache Software Foundat

[jira] [Closed] (FLINK-23739) PrintTableSink do not implement SupportsPartitioning interface

[ https://issues.apache.org/jira/browse/FLINK-23739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-23739. Fix Version/s: 1.15.0 Resolution: Fixed master: 038f78ffa19c7e8b3dbd3da60c0e5054d575a870 >

[GitHub] [flink] JingsongLi merged pull request #16792: [FLINK-23739][table]BlackHoleSink & PrintSink implement SupportsParti…

JingsongLi merged pull request #16792: URL: https://github.com/apache/flink/pull/16792 -- 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

[jira] [Commented] (FLINK-24338) Provide an interface to validate flinksql

[ https://issues.apache.org/jira/browse/FLINK-24338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418908#comment-17418908 ] Jark Wu commented on FLINK-24338: - If you want to just validate SQL sytnax, maybe you ca

[jira] [Comment Edited] (FLINK-24353) Bash scripts do not respect dynamic configurations when calculating memory sizes

[ https://issues.apache.org/jira/browse/FLINK-24353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418471#comment-17418471 ] Xintong Song edited comment on FLINK-24353 at 9/23/21, 2:26 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 347481706d1752ab6cdef0ae207d0b286bf6daf2 UNKNOWN * 765eb79602d0d359ad2267f97cc578566301

[GitHub] [flink] libenchao commented on pull request #13081: [FLINK-18590][json] Support json array explode to multi messages

libenchao commented on pull request #13081: URL: https://github.com/apache/flink/pull/13081#issuecomment-925459467 @slinkydeveloper Thanks for your interest, I'll rebase this pr and let's move forward. -- This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] flinkbot commented on pull request #17336: [BP-1.13][FLINK-24315][k8s] Throw exception in failing watching pods

flinkbot commented on pull request #17336: URL: https://github.com/apache/flink/pull/17336#issuecomment-925459351 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] KarmaGYZ opened a new pull request #17336: [BP-1.13][FLINK-24315][k8s] Throw exception in failing watching pods

KarmaGYZ opened a new pull request #17336: URL: https://github.com/apache/flink/pull/17336 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

zhipeng93 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r714414798 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/PipelineModel.java ## @@ -0,0 +1,86 @@ +/* + * Licensed to the Apache Software Foundat

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

zhipeng93 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r714414999 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java ## @@ -19,241 +19,102 @@ package org.apache.flink.ml.api.core; import

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 347481706d1752ab6cdef0ae207d0b286bf6daf2 UNKNOWN * 765eb79602d0d359ad2267f97cc578566301

[GitHub] [flink] flinkbot edited a comment on pull request #17305: [hotfix][flink-avro] Use local actual schema variable

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

[GitHub] [flink] xuyangzhong commented on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

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

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

RocMarshal commented on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-925446816 Hi, @MartijnVisser @Airblader , I made some changes based on your suggestions. Would you like to review it for me? Thank you so much for your attention. -- This is an auto

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

zhipeng93 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r714413715 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java ## @@ -19,241 +19,102 @@ package org.apache.flink.ml.api.core; import

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

zhipeng93 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r714414312 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java ## @@ -19,241 +19,102 @@ package org.apache.flink.ml.api.core; import

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #4: [FLINK-22915][FLIP-173] Update Flink ML API to support AlgoOperator with multiple input tables and multiple output tables

zhipeng93 commented on a change in pull request #4: URL: https://github.com/apache/flink-ml/pull/4#discussion_r714413715 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/api/core/Pipeline.java ## @@ -19,241 +19,102 @@ package org.apache.flink.ml.api.core; import

[GitHub] [flink] flinkbot edited a comment on pull request #17305: [hotfix][flink-avro] Removed unused variable

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

[jira] [Updated] (FLINK-18996) Avoid disorder for time interval join

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

[jira] [Updated] (FLINK-19822) Remove redundant shuffle for streaming

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

[jira] [Updated] (FLINK-7151) Support function DDL

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

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17278: [FLINK-24280] Support manual checkpoints triggering from a MiniCluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[jira] [Commented] (FLINK-23976) Add additional availability timing metrics to Job lifecycle events

[ https://issues.apache.org/jira/browse/FLINK-23976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418765#comment-17418765 ] Seth Wiesman commented on FLINK-23976: -- [~thw] interesting. Similar to the linked t

[GitHub] [flink] pnowojski commented on a change in pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

pnowojski commented on a change in pull request #17331: URL: https://github.com/apache/flink/pull/17331#discussion_r714192215 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java ## @@ -62,36 +115,45 @@ public CheckpointFa

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17278: [FLINK-24280] Support manual checkpoints triggering from a MiniCluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17253: [FLINK-24182][task] Do not interrupt tasks/operators that are already closing

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

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17278: [FLINK-24280] Support manual checkpoints triggering from a MiniCluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418400#comment-17418400 ] Steven Zhen Wu edited comment on FLINK-23886 at 9/22/21, 3:58 PM:

[jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418400#comment-17418400 ] Steven Zhen Wu edited comment on FLINK-23886 at 9/22/21, 3:58 PM:

[GitHub] [flink] dawidwys commented on a change in pull request #17253: [FLINK-24182][task] Do not interrupt tasks/operators that are already closing

dawidwys commented on a change in pull request #17253: URL: https://github.com/apache/flink/pull/17253#discussion_r713933683 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskCancellationTest.java ## @@ -56,6 +60,41 @@ /** Tes

[GitHub] [flink-statefun] tzulitai commented on pull request #271: [FLINK-24356] Support delayed message cancellation in the remote SDKs

tzulitai commented on pull request #271: URL: https://github.com/apache/flink-statefun/pull/271#issuecomment-925038097 +1, LGTM. Not as part of this PR, and could probably be hard due to its indeterministic / best-effort nature of cancellations, but I think we thought of adding dela

[jira] [Updated] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

[ https://issues.apache.org/jira/browse/FLINK-24031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julio Pérez updated FLINK-24031: Priority: Major (was: Minor) > I am trying to deploy Flink in kubernetes but when I launch the ta

[jira] [Commented] (FLINK-24357) ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled fails with an Unhandled error

[ https://issues.apache.org/jira/browse/FLINK-24357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418658#comment-17418658 ] Piotr Nowojski commented on FLINK-24357: Very unlikely, but potentially related

[jira] [Created] (FLINK-24357) ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled fails with an Unhandled error

Piotr Nowojski created FLINK-24357: -- Summary: ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled fails with an Unhandled error Key: FLINK-24357

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 347481706d1752ab6cdef0ae207d0b286bf6daf2 UNKNOWN * 765eb79602d0d359ad2267f97cc578566301

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

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

[GitHub] [flink] matriv commented on a change in pull request #17313: [FLINK-16204][table] Support JSON_ARRAY()

matriv commented on a change in pull request #17313: URL: https://github.com/apache/flink/pull/17313#discussion_r714024229 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java ## @@ -76,6

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

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

[GitHub] [flink] pnowojski commented on a change in pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

pnowojski commented on a change in pull request #17331: URL: https://github.com/apache/flink/pull/17331#discussion_r713977586 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java ## @@ -53,6 +56,49 @@ public CheckpointFail

[GitHub] [flink] flinkbot edited a comment on pull request #17335: [FLINK-24353][scripts] Respect dynamic configurations when calculating memory sizes.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[jira] [Comment Edited] (FLINK-23189) Count and fail the task when the disk is error on JobManager

[ https://issues.apache.org/jira/browse/FLINK-23189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418602#comment-17418602 ] zlzhang0122 edited comment on FLINK-23189 at 9/22/21, 1:52 PM: ---

[jira] [Commented] (FLINK-24338) Provide an interface to validate flinksql

[ https://issues.apache.org/jira/browse/FLINK-24338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418611#comment-17418611 ] Martijn Visser commented on FLINK-24338: I don't think that will work since Flin

[jira] [Commented] (FLINK-24338) Provide an interface to validate flinksql

[ https://issues.apache.org/jira/browse/FLINK-24338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418607#comment-17418607 ] Ingo Bürk commented on FLINK-24338: --- For a basic yes/no answer, the EXPLAIN solution w

[jira] [Commented] (FLINK-24338) Provide an interface to validate flinksql

[ https://issues.apache.org/jira/browse/FLINK-24338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418603#comment-17418603 ] Spongebob commented on FLINK-24338: --- Hi Patrick, I'd like to ask that how can I valida

[GitHub] [flink] Airblader commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

Airblader commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r713954142 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[GitHub] [flink] Airblader commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

Airblader commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r713951668 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[GitHub] [flink] Airblader commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

Airblader commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r713951668 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[GitHub] [flink] Airblader commented on a change in pull request #17332: [FLINK-24349]Support customized Calalogs via JDBC

Airblader commented on a change in pull request #17332: URL: https://github.com/apache/flink/pull/17332#discussion_r713951668 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java ## @@ -142,4 +143,16 @@

[jira] [Commented] (FLINK-23189) Count and fail the task when the disk is error on JobManager

[ https://issues.apache.org/jira/browse/FLINK-23189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418602#comment-17418602 ] zlzhang0122 commented on FLINK-23189: - [~pnowojski] ok, I've seen the fix and found

[jira] [Commented] (FLINK-24356) Not able to cancel delayed message using remote stateful function mode

[ https://issues.apache.org/jira/browse/FLINK-24356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418601#comment-17418601 ] Julia Pedrycz commented on FLINK-24356: --- I see PR, I will try to build and test it

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17253: [FLINK-24182][task] Do not interrupt tasks/operators that are already closing

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

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 347481706d1752ab6cdef0ae207d0b286bf6daf2 UNKNOWN * 765eb79602d0d359ad2267f97cc578566301

[GitHub] [flink] flinkbot edited a comment on pull request #17253: [FLINK-24182][task] Do not interrupt tasks/operators that are already closing

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

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418568#comment-17418568 ] Leonard Xu commented on FLINK-24168: [~qingru zhang] [~godfreyhe]  Should we also ad

[jira] [Updated] (FLINK-24356) Not able to cancel delayed message using remote stateful function mode

[ https://issues.apache.org/jira/browse/FLINK-24356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24356: --- Labels: pull-request-available (was: ) > Not able to cancel delayed message using remote st

[GitHub] [flink-statefun] igalshilman opened a new pull request #271: [FLINK-24356] Support delayed message cancellation in the remote SDKs

igalshilman opened a new pull request #271: URL: https://github.com/apache/flink-statefun/pull/271 This PR fixes a bug in a delayed message cancellation flow for remote SDKS. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[GitHub] [flink] flinkbot edited a comment on pull request #17331: [FLINK-24344][runtime] Calling the CheckpointFailureManager even if the exception happens during the checkpoint initialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #17308: [FLINK-24291][table-planner]Decimal precision is lost when deserializing in test cases

flinkbot edited a comment on pull request #17308: URL: https://github.com/apache/flink/pull/17308#issuecomment-921483643 ## CI report: * 8bab59ec4ddf8c0775e3199944be09f37aaa7a5d UNKNOWN * 1d20e8536f5cb590b904763fbcec1a5a2d074164 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] pnowojski commented on pull request #17328: Group of hotfix commits fixing a couple of things in the tests

pnowojski commented on pull request #17328: URL: https://github.com/apache/flink/pull/17328#issuecomment-924871370 [private azure build is green](https://dev.azure.com/pnowojski/Flink/_build/results?buildId=516&view=results), merging. -- This is an automated message from the Apache Git

  1   2   >