[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:

[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:

[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

[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

[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

[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=17418915#comment-17418915 ] huntercc commented on FLINK-24293: -- hi [~jark], I have added some meaningful content and reopened this

[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:

[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=17418923#comment-17418923 ] Xintong Song commented on FLINK-24358: -- It's wired this does not fail other stages. cc [~chesnay],

[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:

[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 *

[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

[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

[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 *

[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;

[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;

[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

[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:

[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=17418908#comment-17418908 ] Jark Wu commented on FLINK-24338: - If you want to just validate SQL sytnax, maybe you can try to use

[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=17418471#comment-17418471 ] Xintong Song edited comment on FLINK-24353 at 9/23/21, 2:26 AM: I think

[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 *

[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

[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

[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

[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

[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;

[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 *

[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:

[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

[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

[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;

[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;

[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;

[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:

[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:

[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:

[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:

[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:

[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:

[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=17418765#comment-17418765 ] Seth Wiesman commented on FLINK-23976: -- [~thw] interesting. Similar to the linked ticket we'll need

[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

[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:

[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:

[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:

[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:

[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:

[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:

[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:

[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=17418400#comment-17418400 ] Steven Zhen Wu edited comment on FLINK-23886 at 9/22/21, 3:58 PM: -- Just

[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=17418400#comment-17418400 ] Steven Zhen Wu edited comment on FLINK-23886 at 9/22/21, 3:58 PM: -- Just

[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 @@ /**

[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

[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

[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=17418658#comment-17418658 ] Piotr Nowojski commented on FLINK-24357: Very unlikely, but potentially related to FLINK-24182,

[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:

[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 *

[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:

[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:

[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

[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:

[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:

[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=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=17418611#comment-17418611 ] Martijn Visser commented on FLINK-24338: I don't think that will work since Flink SQL implements

[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=17418607#comment-17418607 ] Ingo Bürk commented on FLINK-24338: --- For a basic yes/no answer, the EXPLAIN solution would probably

[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=17418603#comment-17418603 ] Spongebob commented on FLINK-24338: --- Hi Patrick, I'd like to ask that how can I validate FlinkSQL with

[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=17418602#comment-17418602 ] zlzhang0122 commented on FLINK-23189: - [~pnowojski] ok, I've seen the fix and found that it added

[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=17418601#comment-17418601 ] Julia Pedrycz commented on FLINK-24356: --- I see PR, I will try to build and test it.  > Not able

[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:

[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:

[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:

[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 *

[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:

[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=17418568#comment-17418568 ] Leonard Xu commented on FLINK-24168: [~qingru zhang] [~godfreyhe]  Should we also add documentation

[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

[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

[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:

[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:

[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=results), merging. -- This is an automated message from the Apache Git

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

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

[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-924865986 Hi @libenchao are you still interested in working on this issue? Can you rebase? -- This is an automated message from the Apache Git Service. To respond to the

[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=17418559#comment-17418559 ] Igal Shilman commented on FLINK-24356: -- [~Pedrycz] I have forgot to ask, which remote SDK are you

[jira] [Issue Comment Deleted] (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 ] Igal Shilman updated FLINK-24356: - Comment: was deleted (was: [~Pedrycz] I have forgot to ask, which remote SDK are you using?) >

[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=17418558#comment-17418558 ] Igal Shilman commented on FLINK-24356: -- We will try to kick off the release process by the end of

[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=17418556#comment-17418556 ] Julia Pedrycz commented on FLINK-24356: --- Thank you for quick response. What is the ETA for the

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

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

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

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

[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:

[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:

[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:

[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_r713855871 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1955,6 +1959,25 @@ private void

[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_r713852975 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1955,6 +1959,25 @@ private void

[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-924844336 @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

  1   2   >