[jira] [Updated] (FLINK-22541) add json format filter params

[ https://issues.apache.org/jira/browse/FLINK-22541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sandy du updated FLINK-22541: - Description: In my case,one kafka topic store multiple table data，for example：

[jira] [Created] (FLINK-22541) add json format filter params

sandy du created FLINK-22541: Summary: add json format filter params Key: FLINK-22541 URL: https://issues.apache.org/jira/browse/FLINK-22541 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

flinkbot edited a comment on pull request #15821: URL: https://github.com/apache/flink/pull/15821#issuecomment-830427889 ## CI report: * 701b87adda8ea30306cf1d99e7aea84f1ded716a Azure:

[GitHub] [flink] fangyuefy commented on pull request #15817: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

fangyuefy commented on pull request #15817: URL: https://github.com/apache/flink/pull/15817#issuecomment-830530227 > Thanks for creating this PR @fangyuefy. I've tested it, and it works. Nicely done. I will address my comments while merging this PR. Thanks @tillrohrmann for

[GitHub] [flink] flinkbot edited a comment on pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

flinkbot edited a comment on pull request #15821: URL: https://github.com/apache/flink/pull/15821#issuecomment-830427889 ## CI report: * 701b87adda8ea30306cf1d99e7aea84f1ded716a Azure:

[GitHub] [flink] flinkbot commented on pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

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

[GitHub] [flink] flinkbot commented on pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

flinkbot commented on pull request #15821: URL: https://github.com/apache/flink/pull/15821#issuecomment-830424683 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] snuyanzin opened a new pull request #15821: [FLINK-21911][table] Add built-in greatest/least functions support

snuyanzin opened a new pull request #15821: URL: https://github.com/apache/flink/pull/15821 ## What is the purpose of the change The PR implements three functions from the list mentioned in FLINK-21911 : `GREATEST`, `LEAST` ## Brief change log Implementation,

[jira] [Updated] (FLINK-21911) Support GREATEST and LEAST functions in SQL

[ https://issues.apache.org/jira/browse/FLINK-21911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21911: --- Labels: pull-request-available (was: ) > Support GREATEST and LEAST functions in SQL >

[GitHub] [flink] fdalsotto commented on a change in pull request #15813: [FLINK-22519][flink-python] support tar.gz python archives

fdalsotto commented on a change in pull request #15813: URL: https://github.com/apache/flink/pull/15813#discussion_r624232556 ## File path: flink-python/src/main/java/org/apache/flink/python/env/beam/ProcessPythonEnvironmentManager.java ## @@ -326,9 +327,21 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * dced81c2ffc8c59f9d9311346e71309129aa73cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

flinkbot edited a comment on pull request #15820: URL: https://github.com/apache/flink/pull/15820#issuecomment-830052015 ## CI report: * c11e6cb0c0817a53ef456462f610e3d079f590f9 Azure:

[jira] [Comment Edited] (FLINK-10165) JarRunHandler/JarRunRequestBody should allow to pass program arguments as escaped json list

[ https://issues.apache.org/jira/browse/FLINK-10165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202057#comment-17202057 ] Matthias edited comment on FLINK-10165 at 4/30/21, 7:39 PM: This issue was

[GitHub] [flink] flinkbot edited a comment on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * 11787dc2e0c372007bddc148e0d4aec2ed9a275f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15789: [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * 4c5180310bf76e96f2665bf53531eccb1fa86421 UNKNOWN * 46e1be2c4832080bf1cb48c509b77cd88872d024 Azure:

[jira] [Updated] (FLINK-19164) Release scripts break other dependency versions unintentionally

[ https://issues.apache.org/jira/browse/FLINK-19164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Serhat Soydan updated FLINK-19164: -- Labels: (was: stale-assigned) > Release scripts break other dependency versions

[jira] [Comment Edited] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

[ https://issues.apache.org/jira/browse/FLINK-22506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337517#comment-17337517 ] Paul Lin edited comment on FLINK-22506 at 4/30/21, 5:09 PM: [~trohrmann]

[jira] [Comment Edited] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

[ https://issues.apache.org/jira/browse/FLINK-22506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337517#comment-17337517 ] Paul Lin edited comment on FLINK-22506 at 4/30/21, 5:08 PM: [~trohrmann]

[jira] [Commented] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

[ https://issues.apache.org/jira/browse/FLINK-22506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337517#comment-17337517 ] Paul Lin commented on FLINK-22506: -- [~trohrmann] Thanks a lot for the input. Now I'm suspecting maybe

[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=17337515#comment-17337515 ] Till Rohrmann commented on FLINK-10644: --- Sounds good to me [~wangwj]. Thanks for the update. >

[jira] [Commented] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

[ https://issues.apache.org/jira/browse/FLINK-22506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337510#comment-17337510 ] Till Rohrmann commented on FLINK-22506: --- Ok, then I have misunderstood the ticket a bit. I thought

[GitHub] [flink] flinkbot edited a comment on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * 48814bd4d49167579110479e3f3cecabff6d443a Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337504#comment-17337504 ] wangwj edited comment on FLINK-10644 at 4/30/21, 4:53 PM: -- Hi, [~trohrmann] 


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

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337504#comment-17337504 ] wangwj edited comment on FLINK-10644 at 4/30/21, 4:52 PM: -- Hi, [~trohrmann] 


[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=17337504#comment-17337504 ] wangwj commented on FLINK-10644: Hi, [~trohrmann] 
[~wind_ljy] The closest version of Flink to my Blink

[jira] [Comment Edited] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

[ https://issues.apache.org/jira/browse/FLINK-22506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337499#comment-17337499 ] Paul Lin edited comment on FLINK-22506 at 4/30/21, 4:42 PM: [~knaufk] I've

[jira] [Commented] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

[ https://issues.apache.org/jira/browse/FLINK-22506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337499#comment-17337499 ] Paul Lin commented on FLINK-22506: -- [~knaufk] I've attached the jm logs and the screen shoot yarn

[jira] [Updated] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

[ https://issues.apache.org/jira/browse/FLINK-22506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-22506: - Attachment: yarn application attempts.png > YARN job cluster stuck in retrying creating JobManager if

[jira] [Updated] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

[ https://issues.apache.org/jira/browse/FLINK-22506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paul Lin updated FLINK-22506: - Attachment: corrupted_savepoint.log > YARN job cluster stuck in retrying creating JobManager if

[GitHub] [flink] flinkbot edited a comment on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

flinkbot edited a comment on pull request #15820: URL: https://github.com/apache/flink/pull/15820#issuecomment-830052015 ## CI report: * c548fc5c79450d898eebc1c6523be98472fe1cdd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * 48814bd4d49167579110479e3f3cecabff6d443a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][security] Add an option to disable credential retrieval on a secure cluster

flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * 8cb12deac019898bb69f7a5faf7f803dd27d71d0 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334427#comment-17334427 ] wangwj edited comment on FLINK-10644 at 4/30/21, 4:15 PM: -- [~trohrmann] Hi

[jira] [Comment Edited] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337484#comment-17337484 ] Yang Wang edited comment on FLINK-22509 at 4/30/21, 4:10 PM: - [~knaufk]

[jira] [Comment Edited] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337484#comment-17337484 ] Yang Wang edited comment on FLINK-22509 at 4/30/21, 4:10 PM: - [~knaufk]

[jira] [Comment Edited] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337484#comment-17337484 ] Yang Wang edited comment on FLINK-22509 at 4/30/21, 4:09 PM: - [~knaufk]

[jira] [Commented] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337484#comment-17337484 ] Yang Wang commented on FLINK-22509: --- [~knaufk] [~rmetzger] I agree with that we should deprecate {{-m

[GitHub] [flink] yittg commented on a change in pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

yittg commented on a change in pull request #15768: URL: https://github.com/apache/flink/pull/15768#discussion_r623990859 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/table/CalcITCase.scala ## @@ -529,6

[GitHub] [flink] flinkbot edited a comment on pull request #15656: [FLINK-22233][Table SQL / API]Modified the spelling error of word "constant" in source code

flinkbot edited a comment on pull request #15656: URL: https://github.com/apache/flink/pull/15656#issuecomment-822135263 ## CI report: * fb69e9a4c5c897e75659c28915f9b9aa08e2f0c3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

flinkbot edited a comment on pull request #15820: URL: https://github.com/apache/flink/pull/15820#issuecomment-830052015 ## CI report: * c548fc5c79450d898eebc1c6523be98472fe1cdd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15760: [FLINK-19606][table-runtime-blink] Introduce WindowJoinOperator and WindowJoinOperatorBuilder.

flinkbot edited a comment on pull request #15760: URL: https://github.com/apache/flink/pull/15760#issuecomment-826500326 ## CI report: * 7fadefe78bb0f8b0d7b61ee2a105e1cb3b5d17b5 Azure:

[GitHub] [flink] yittg commented on a change in pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

yittg commented on a change in pull request #15768: URL: https://github.com/apache/flink/pull/15768#discussion_r623972440 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/table/CalcITCase.scala ## @@ -529,6

[GitHub] [flink] flinkbot edited a comment on pull request #14172: [FLINK-19545][e2e] Add e2e test for native Kubernetes HA

flinkbot edited a comment on pull request #14172: URL: https://github.com/apache/flink/pull/14172#issuecomment-73215 ## CI report: * bbe6f4a0e363170970b29269af446f0d93578e5f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

flinkbot edited a comment on pull request #15820: URL: https://github.com/apache/flink/pull/15820#issuecomment-830052015 ## CI report: * c548fc5c79450d898eebc1c6523be98472fe1cdd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15817: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

flinkbot edited a comment on pull request #15817: URL: https://github.com/apache/flink/pull/15817#issuecomment-829959024 ## CI report: * c14593a5ccd7896b041421ee4d3e433a7afc34ac Azure:

[GitHub] [flink] akalash commented on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

akalash commented on pull request #15820: URL: https://github.com/apache/flink/pull/15820#issuecomment-830157511 @gaoyunhaii , @pnowojski, Thanks guys for your comments. I fixed them and reorganized my commits. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] akalash commented on a change in pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

akalash commented on a change in pull request #15820: URL: https://github.com/apache/flink/pull/15820#discussion_r623948875 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -609,42 +615,54 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * 48814bd4d49167579110479e3f3cecabff6d443a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15728: [FLINK-22379][runtime] CheckpointCoordinator checks the state of all …

flinkbot edited a comment on pull request #15728: URL: https://github.com/apache/flink/pull/15728#issuecomment-824960796 ## CI report: * d4f85948ee5281b189ba948a8ec512f62587f979 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

wuchong commented on a change in pull request #15768: URL: https://github.com/apache/flink/pull/15768#discussion_r623933402 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/table/CalcITCase.scala ## @@ -529,6

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337429#comment-17337429 ] Jark Wu commented on FLINK-18027: - Is it possible to register a custom {{ROW}} function to override the

[jira] [Closed] (FLINK-22424) Writing to already released buffers potentially causing data corruption during job failover/cancellation

[ https://issues.apache.org/jira/browse/FLINK-22424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22424. -- Resolution: Fixed merged to release-1.13 as da26733e484 and 65319b256c8 > Writing to already

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

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334427#comment-17334427 ] wangwj edited comment on FLINK-10644 at 4/30/21, 2:40 PM: -- [~trohrmann] Hi

[jira] [Updated] (FLINK-20724) Create a http handler for aggregating metrics from whole job

[ https://issues.apache.org/jira/browse/FLINK-20724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20724: --- Affects Version/s: 1.13.0 1.12.3 > Create a http handler for

[jira] [Updated] (FLINK-20724) Create a http handler for aggregating metrics from whole job

[ https://issues.apache.org/jira/browse/FLINK-20724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-20724: --- Fix Version/s: (was: 1.14.0) > Create a http handler for aggregating metrics from whole

[jira] [Commented] (FLINK-22506) YARN job cluster stuck in retrying creating JobManager if savepoint is corrupted

[ https://issues.apache.org/jira/browse/FLINK-22506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337421#comment-17337421 ] Paul Lin commented on FLINK-22506: -- [~knaufk] Actually I'm not using the application mode, and this

[jira] [Closed] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15550. -- Resolution: Cannot Reproduce > testCancelTaskExceptionAfterTaskMarkedFailed failed on azure >

[GitHub] [flink] flinkbot edited a comment on pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

flinkbot edited a comment on pull request #15768: URL: https://github.com/apache/flink/pull/15768#issuecomment-826735938 ## CI report: * 48814bd4d49167579110479e3f3cecabff6d443a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14172: [FLINK-19545][e2e] Add e2e test for native Kubernetes HA

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

[GitHub] [flink] yittg commented on a change in pull request #15768: [FLINK-22451][table] Support (*) as parameter of UDFs in Table API

yittg commented on a change in pull request #15768: URL: https://github.com/apache/flink/pull/15768#discussion_r623903170 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/functions/CallFunctionITCase.java ## @@ -0,0 +1,98 @@ +/*

[jira] [Updated] (FLINK-22256) Persist checkpoint type information

[ https://issues.apache.org/jira/browse/FLINK-22256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22256: -- Description: As a user, it is retrospectively difficult to determine what kind of checkpoint

[jira] [Updated] (FLINK-22256) Persist checkpoint type information

[ https://issues.apache.org/jira/browse/FLINK-22256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22256: -- Priority: Major (was: Minor) > Persist checkpoint type information >

[GitHub] [flink] flinkbot edited a comment on pull request #15819: [FLINK-22512][Hive] Fix issue that can't call current_timestamp with hive dialect for hive-3.1

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

[GitHub] [flink] flinkbot edited a comment on pull request #14172: [FLINK-19545][e2e] Add e2e test for native Kubernetes HA

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

[GitHub] [flink] flinkbot edited a comment on pull request #15818: [FLINK-22539][python][docs] Restructure the Python dependency management documentation

flinkbot edited a comment on pull request #15818: URL: https://github.com/apache/flink/pull/15818#issuecomment-829970320 ## CI report: * d44f98b523a36e71a1f265768f4ea55a3aeb28ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15789: [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * 4c5180310bf76e96f2665bf53531eccb1fa86421 UNKNOWN * f87ee85814873dee4ed181eee11df9a6758a916e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15817: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

flinkbot edited a comment on pull request #15817: URL: https://github.com/apache/flink/pull/15817#issuecomment-829959024 ## CI report: * 31f01fe2108f5e18f26f50e352d3ed353bd8ffc8 Azure:

[GitHub] [flink] tillrohrmann commented on pull request #14172: [FLINK-19545][e2e] Add e2e test for native Kubernetes HA

tillrohrmann commented on pull request #14172: URL: https://github.com/apache/flink/pull/14172#issuecomment-830086650 Also, it seems that the test does not fully clean up the `minikube` cluster and Docker. Not sure whether this is due to my local setup or not. -- This is an automated

[jira] [Commented] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337377#comment-17337377 ] Robert Metzger commented on FLINK-19916: I've reset the priority to Major since multiple tickets

[jira] [Updated] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19916: --- Affects Version/s: 1.12.2 > Hadoop3 ShutdownHookManager visit closed ClassLoader >

[jira] [Closed] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21914. -- Resolution: Duplicate > Trying to access closed classloader >

[jira] [Updated] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-19916: --- Priority: Major (was: Minor) > Hadoop3 ShutdownHookManager visit closed ClassLoader >

[jira] [Commented] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337376#comment-17337376 ] Robert Metzger commented on FLINK-21914: I would like to close this ticket and track the

[jira] [Commented] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337375#comment-17337375 ] Robert Metzger commented on FLINK-21914: Just deploying on YARN doesn't cause the exceptions on

[jira] [Updated] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21914: --- Component/s: Deployment / YARN > Trying to access closed classloader >

[jira] [Updated] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21914: --- Component/s: (was: Deployment / YARN) Connectors / Hive > Trying to

[jira] [Commented] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337371#comment-17337371 ] Robert Metzger commented on FLINK-21914: This is a known issue, reported here FLINK-22509 and

[jira] [Updated] (FLINK-21914) Trying to access closed classloader

[ https://issues.apache.org/jira/browse/FLINK-21914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21914: --- Component/s: (was: API / Core) Deployment / YARN > Trying to access

[jira] [Commented] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337369#comment-17337369 ] Till Rohrmann commented on FLINK-22014: --- I couldn't really find anything suspicious in the logs.

[jira] [Commented] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337368#comment-17337368 ] Robert Metzger commented on FLINK-22509: Closing as a duplicate of FLINK-19916. > ./bin/flink

[jira] [Closed] (FLINK-22509) ./bin/flink run -m yarn-cluster -d submission leads to IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-22509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-22509. -- Resolution: Duplicate > ./bin/flink run -m yarn-cluster -d submission leads to

[jira] [Commented] (FLINK-19916) Hadoop3 ShutdownHookManager visit closed ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-19916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337367#comment-17337367 ] Robert Metzger commented on FLINK-19916: Where did you see this exception? I found the same

[jira] [Commented] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files

[ https://issues.apache.org/jira/browse/FLINK-22139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337366#comment-17337366 ] Till Rohrmann commented on FLINK-22139: --- [~bhagi__R] I've tested to deploy

[GitHub] [flink] flinkbot edited a comment on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

flinkbot edited a comment on pull request #15820: URL: https://github.com/apache/flink/pull/15820#issuecomment-830052015 ## CI report: * c548fc5c79450d898eebc1c6523be98472fe1cdd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15656: [FLINK-22233][Table SQL / API]Modified the spelling error of word "constant" in source code

flinkbot edited a comment on pull request #15656: URL: https://github.com/apache/flink/pull/15656#issuecomment-822135263 ## CI report: * 6358c33368746cf2c93463ab423f5c9ff11b641b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][security] Add an option to disable credential retrieval on a secure cluster

flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * 60812bb2804fd21d56a47a23ca4b42a04300f1c0 Azure:

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337350#comment-17337350 ] Timo Walther commented on FLINK-18027: -- I would keep the naming consistent with our existing data

[jira] [Commented] (FLINK-21949) Support collect to array aggregate function

[ https://issues.apache.org/jira/browse/FLINK-21949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337348#comment-17337348 ] Jark Wu commented on FLINK-21949: - The only concern of ARRAY_AGG from my side is it sounds similar to

[GitHub] [flink] lirui-apache commented on a change in pull request #15712: [FLINK-22400][hive connect]fix NPE problem when convert flink object for Map

lirui-apache commented on a change in pull request #15712: URL: https://github.com/apache/flink/pull/15712#discussion_r623836414 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java ## @@ -531,6

[GitHub] [flink] pnowojski commented on a change in pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

pnowojski commented on a change in pull request #15820: URL: https://github.com/apache/flink/pull/15820#discussion_r623819184 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java ## @@ -1619,6 +1616,34 @@ public void

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337346#comment-17337346 ] Jark Wu commented on FLINK-18027: - What about {{STRUCT(...)}} ? This is also a well-known word and Spark

[GitHub] [flink] flinkbot commented on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15789: [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

flinkbot edited a comment on pull request #15789: URL: https://github.com/apache/flink/pull/15789#issuecomment-827996694 ## CI report: * 4c5180310bf76e96f2665bf53531eccb1fa86421 UNKNOWN * f87ee85814873dee4ed181eee11df9a6758a916e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15656: [FLINK-22233][Table SQL / API]Modified the spelling error of word "constant" in source code

flinkbot edited a comment on pull request #15656: URL: https://github.com/apache/flink/pull/15656#issuecomment-822135263 ## CI report: * 6358c33368746cf2c93463ab423f5c9ff11b641b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15131: [FLINK-21700][security] Add an option to disable credential retrieval on a secure cluster

flinkbot edited a comment on pull request #15131: URL: https://github.com/apache/flink/pull/15131#issuecomment-794957907 ## CI report: * 60812bb2804fd21d56a47a23ca4b42a04300f1c0 Azure:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

gaoyunhaii commented on a change in pull request #15820: URL: https://github.com/apache/flink/pull/15820#discussion_r623824848 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -530,6 +532,10 @@ protected Counter

[jira] [Commented] (FLINK-18027) ROW value constructor cannot deal with complex expressions

[ https://issues.apache.org/jira/browse/FLINK-18027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337323#comment-17337323 ] Timo Walther commented on FLINK-18027: -- [~jark] what do you think about introducing a new built-in

[GitHub] [flink] flinkbot commented on pull request #15820: [FLINK-22535][runtime] CleanUp is invoked for task even when the task…

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

[jira] [Closed] (FLINK-12710) Unify built-in and user-defined functions in the API modules

[ https://issues.apache.org/jira/browse/FLINK-12710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-12710. Resolution: Implemented Implemented as part of FLINK-20522. > Unify built-in and user-defined

[GitHub] [flink] flinkbot edited a comment on pull request #15817: [FLINK-14393][webui] Add an option to enable/disable cancel job in we…

flinkbot edited a comment on pull request #15817: URL: https://github.com/apache/flink/pull/15817#issuecomment-829959024 ## CI report: * 31f01fe2108f5e18f26f50e352d3ed353bd8ffc8 Azure:

  1   2   3   4   >