[jira] [Created] (FLINK-31952) Support 'EXPLAIN' statement for CompiledPlan

2023-04-27 Thread Jane Chan (Jira)
Jane Chan created FLINK-31952: - Summary: Support 'EXPLAIN' statement for CompiledPlan Key: FLINK-31952 URL: https://issues.apache.org/jira/browse/FLINK-31952 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-31860) FlinkDeployments never finalize when namespace is deleted

2023-04-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717055#comment-17717055 ] Gyula Fora commented on FLINK-31860: I have to put this work on hold for now because any effort on

[jira] [Created] (FLINK-31954) Prevent Mockito for the new code with Checkstyle

2023-04-27 Thread Jira
David Morávek created FLINK-31954: - Summary: Prevent Mockito for the new code with Checkstyle Key: FLINK-31954 URL: https://issues.apache.org/jira/browse/FLINK-31954 Project: Flink Issue

[GitHub] [flink] LadyForest opened a new pull request, #22492: [FLINK-31950][table-planner] Introduce StateMetadata and support operator-level state TTL configuration via Compiled Plan

2023-04-27 Thread via GitHub
LadyForest opened a new pull request, #22492: URL: https://github.com/apache/flink/pull/22492 ## What is the purpose of the change This is the first subtask of FLINK-31791 for FLIP-288. ## Brief change log This PR contains 3 commits - The 1st commit introduces

[jira] [Updated] (FLINK-31950) Introduce StateMetadata and support operator-level state TTL configuration via Compiled Plan

2023-04-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31950: --- Labels: pull-request-available (was: ) > Introduce StateMetadata and support

[jira] [Created] (FLINK-31953) FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

2023-04-27 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-31953: - Summary: FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source Key: FLINK-31953 URL: https://issues.apache.org/jira/browse/FLINK-31953 Project:

[GitHub] [flink] TanYuxin-tyx commented on pull request #22352: [FLINK-31639][network] Introduce tiered store memory manager

2023-04-27 Thread via GitHub
TanYuxin-tyx commented on PR #22352: URL: https://github.com/apache/flink/pull/22352#issuecomment-1525027465 @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] [Updated] (FLINK-31954) Prevent Mockito usage for the new code with Checkstyle

2023-04-27 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-31954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-31954: -- Summary: Prevent Mockito usage for the new code with Checkstyle (was: Prevent Mockito for

[GitHub] [flink] zoltar9264 commented on pull request #21822: [FLINK-30863][state] Register local recovery files of changelog before notifyCheckpointComplete()

2023-04-27 Thread via GitHub
zoltar9264 commented on PR #21822: URL: https://github.com/apache/flink/pull/21822#issuecomment-1524782057 LGTM, @Myasuka Do you have any other comments? -- 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

[jira] [Commented] (FLINK-31139) not upload empty state changelog file

2023-04-27 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717003#comment-17717003 ] Feifan Wang commented on FLINK-31139: - Thanks [~roman] , remember to re-run failed stages for 1.17.

[GitHub] [flink] flinkbot commented on pull request #22492: [FLINK-31950][table-planner] Introduce StateMetadata and support operator-level state TTL configuration via Compiled Plan

2023-04-27 Thread via GitHub
flinkbot commented on PR #22492: URL: https://github.com/apache/flink/pull/22492#issuecomment-1524870395 ## CI report: * 4da69ac609ceda1b471fc3c15d797217d2f4dd2e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Closed] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

2023-04-27 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21711. -- Fix Version/s: (was: 1.11.7) (was: 1.12.8)

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #577: [FLINK-31860] Ignore Event creation errors during cleanup

2023-04-27 Thread via GitHub
gyfora commented on PR #577: URL: https://github.com/apache/flink-kubernetes-operator/pull/577#issuecomment-1524896806 Unfortunately this still doesn't address the original issue. Even if we ignore all errors (event creation and others we still get the following JOSDK error) ```

[jira] [Comment Edited] (FLINK-31952) Support 'EXPLAIN' statement for CompiledPlan

2023-04-27 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717031#comment-17717031 ] Shuai Xu edited comment on FLINK-31952 at 4/27/23 7:31 AM: --- Hi Jane, I have

[jira] [Commented] (FLINK-31952) Support 'EXPLAIN' statement for CompiledPlan

2023-04-27 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717033#comment-17717033 ] Jane Chan commented on FLINK-31952: --- Hi [~xu_shuai_], thanks for your interest in this ticket! The

[jira] [Updated] (FLINK-31953) FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

2023-04-27 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-31953: -- Description: This improvement implements

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #577: [FLINK-31860] Ignore Event creation errors during cleanup

2023-04-27 Thread via GitHub
gyfora commented on PR #577: URL: https://github.com/apache/flink-kubernetes-operator/pull/577#issuecomment-1525091614 Closing this for now, there seem to be a bigger underlying problem outside the flink operator . More details here:

[GitHub] [flink-kubernetes-operator] gyfora closed pull request #577: [FLINK-31860] Ignore Event creation errors during cleanup

2023-04-27 Thread via GitHub
gyfora closed pull request #577: [FLINK-31860] Ignore Event creation errors during cleanup URL: https://github.com/apache/flink-kubernetes-operator/pull/577 -- 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

[GitHub] [flink] reswqa commented on a diff in pull request #22489: [hotfix][docs] Fix link to Ververica Platform

2023-04-27 Thread via GitHub
reswqa commented on code in PR #22489: URL: https://github.com/apache/flink/pull/22489#discussion_r1178841917 ## docs/content/docs/deployment/overview.md: ## @@ -321,7 +321,7 @@ Supported Environment: Ververica Platform

[jira] [Commented] (FLINK-31135) ConfigMap DataSize went > 1 MB and cluster stopped working

2023-04-27 Thread Zhihao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717014#comment-17717014 ] Zhihao Chen commented on FLINK-31135: - [~Swathi Chandrashekar], please see the attached log from JM

[jira] [Updated] (FLINK-31135) ConfigMap DataSize went > 1 MB and cluster stopped working

2023-04-27 Thread Zhihao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhihao Chen updated FLINK-31135: Attachment: jobmanager_log.txt > ConfigMap DataSize went > 1 MB and cluster stopped working >

[jira] [Commented] (FLINK-24657) Add metric of the total real size of input/output buffers queue

2023-04-27 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717051#comment-17717051 ] Weijie Guo commented on FLINK-24657: Hi [~akalashnikov]. For {{inputQueueLength}}, we considered the

[jira] [Comment Edited] (FLINK-24657) Add metric of the total real size of input/output buffers queue

2023-04-27 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717051#comment-17717051 ] Weijie Guo edited comment on FLINK-24657 at 4/27/23 8:14 AM: - Hi

[jira] [Commented] (FLINK-31850) Fix args in JobSpec not being passed through to Flink in Standalone mode - 1.4.0

2023-04-27 Thread Gil Shmaya (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717030#comment-17717030 ] Gil Shmaya commented on FLINK-31850: Hi, Could you kindly provide an update on the status, please?

[jira] [Commented] (FLINK-31952) Support 'EXPLAIN' statement for CompiledPlan

2023-04-27 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717031#comment-17717031 ] Shuai Xu commented on FLINK-31952: -- Hi Jane, I have some ideas for the task and this is how I consider

[jira] [Updated] (FLINK-31952) Support 'EXPLAIN' statement for CompiledPlan

2023-04-27 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-31952: -- Description:  Support the explain SQL syntax towards serialized CompiledPlan {code:sql} EXPLAIN [ |

[jira] [Assigned] (FLINK-31952) Support 'EXPLAIN' statement for CompiledPlan

2023-04-27 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-31952: Assignee: Shuai Xu > Support 'EXPLAIN' statement for CompiledPlan >

[GitHub] [flink] luoyuxia commented on pull request #22488: [FLINK-31882][sql-client] Fix sql client can't show result for DELETE statement when delete is pushed down

2023-04-27 Thread via GitHub
luoyuxia commented on PR #22488: URL: https://github.com/apache/flink/pull/22488#issuecomment-1525001148 @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 comment.

[jira] [Created] (FLINK-31955) Prevent JUnit 4 usage for the new code with Checkstyle

2023-04-27 Thread Jira
David Morávek created FLINK-31955: - Summary: Prevent JUnit 4 usage for the new code with Checkstyle Key: FLINK-31955 URL: https://issues.apache.org/jira/browse/FLINK-31955 Project: Flink

[GitHub] [flink] novakov-alexey commented on a diff in pull request #22489: [hotfix][docs] Fix link to Ververica Platform

2023-04-27 Thread via GitHub
novakov-alexey commented on code in PR #22489: URL: https://github.com/apache/flink/pull/22489#discussion_r1178978700 ## docs/content/docs/deployment/overview.md: ## @@ -321,7 +321,7 @@ Supported Environment: Ververica Platform

[GitHub] [flink] flinkbot commented on pull request #22494: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.

2023-04-27 Thread via GitHub
flinkbot commented on PR #22494: URL: https://github.com/apache/flink/pull/22494#issuecomment-1525707627 ## CI report: * 0443bcca5bc44abebcfd1659d9f73301525005f1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dmvk closed pull request #18650: [FLINK-26188] Refactor TestingHighAvailabilityServices to properly use the builder pattern.

2023-04-27 Thread via GitHub
dmvk closed pull request #18650: [FLINK-26188] Refactor TestingHighAvailabilityServices to properly use the builder pattern. URL: https://github.com/apache/flink/pull/18650 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

2023-04-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28786. --- Fix Version/s: 1.17.1 (was: 1.17.0) Resolution: Fixed > Cannot run PyFlink

[jira] [Comment Edited] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

2023-04-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716967#comment-17716967 ] Dian Fu edited comment on FLINK-28786 at 4/27/23 10:04 AM: --- Fixed in: -

[GitHub] [flink] flinkbot commented on pull request #22493: Flink 31952

2023-04-27 Thread via GitHub
flinkbot commented on PR #22493: URL: https://github.com/apache/flink/pull/22493#issuecomment-1525331839 ## CI report: * 44323c4a8cf912ea566013eac8205d57919566a6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] godfreyhe commented on a diff in pull request #22427: [FLINK-30815][tests] Migrate BatchAbstractTestBase and BatchTestBase to junit5

2023-04-27 Thread via GitHub
godfreyhe commented on code in PR #22427: URL: https://github.com/apache/flink/pull/22427#discussion_r1178891930 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/LegacyTableSourceITCase.scala: ## @@ -347,7 +349,7 @@ class

[jira] [Created] (FLINK-31958) Table to DataStream allow partial fields

2023-04-27 Thread padavan (Jira)
padavan created FLINK-31958: --- Summary: Table to DataStream allow partial fields Key: FLINK-31958 URL: https://issues.apache.org/jira/browse/FLINK-31958 Project: Flink Issue Type: Improvement

[GitHub] [flink] zentol commented on pull request #22473: [FLINK-31911][sql][tests] Fix address construction

2023-04-27 Thread via GitHub
zentol commented on PR #22473: URL: https://github.com/apache/flink/pull/22473#issuecomment-1525589562 This should be FLINK-31911. -- 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] [Updated] (FLINK-31911) Bad address construction in SqlClientTest

2023-04-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31911: --- Labels: pull-request-available (was: ) > Bad address construction in SqlClientTest >

[GitHub] [flink] zentol merged pull request #22473: [FLINK-31911][sql][tests] Fix address construction

2023-04-27 Thread via GitHub
zentol merged PR #22473: URL: https://github.com/apache/flink/pull/22473 -- 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] wangyang0918 commented on a diff in pull request #22491: [FLINK-31947] enable stdout for flink-console.sh

2023-04-27 Thread via GitHub
wangyang0918 commented on code in PR #22491: URL: https://github.com/apache/flink/pull/22491#discussion_r1178864770 ## flink-dist/src/main/flink-bin/bin/flink-console.sh: ## @@ -116,4 +117,5 @@ echo $$ >> "$pid" 2>/dev/null # Evaluate user options for local variable expansion

[GitHub] [flink] dmvk closed pull request #18321: [FLINK-25224] Reuse globally defined version of hadoop (`hadoop.versi…

2023-04-27 Thread via GitHub
dmvk closed pull request #18321: [FLINK-25224] Reuse globally defined version of hadoop (`hadoop.versi… URL: https://github.com/apache/flink/pull/18321 -- 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

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #235: [FLINK-31899] Upgrade Flink version of Flink ML to 1.17.0

2023-04-27 Thread via GitHub
jiangxin369 commented on code in PR #235: URL: https://github.com/apache/flink-ml/pull/235#discussion_r1178910190 ## flink-ml-iteration/src/main/java/org/apache/flink/iteration/utils/ReflectionUtils.java: ## @@ -80,4 +83,55 @@ public static T callMethod(

[GitHub] [flink] xishuaidelin closed pull request #22493: Flink 31952

2023-04-27 Thread via GitHub
xishuaidelin closed pull request #22493: Flink 31952 URL: https://github.com/apache/flink/pull/22493 -- 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-31953) FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

2023-04-27 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717084#comment-17717084 ] Hongshun Wang commented on FLINK-31953: --- I'd like to keep working on FLIP-288. Could someone

[GitHub] [flink] luoyuxia commented on pull request #22488: [FLINK-31882][sql-client] Fix sql client can't show result for DELETE statement when delete is pushed down

2023-04-27 Thread via GitHub
luoyuxia commented on PR #22488: URL: https://github.com/apache/flink/pull/22488#issuecomment-1525581073 @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 comment.

[jira] [Closed] (FLINK-31911) Bad address construction in SqlClientTest

2023-04-27 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-31911. Resolution: Fixed master: 146847e53f10967dc2133cfdee6adbc57bccdd38 > Bad address

[GitHub] [flink] xishuaidelin closed pull request #22494: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.

2023-04-27 Thread via GitHub
xishuaidelin closed pull request #22494: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan. URL: https://github.com/apache/flink/pull/22494 -- 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

[GitHub] [flink] xishuaidelin opened a new pull request, #22494: [FLINK-31952][table] Support 'EXPLAIN' statement for CompiledPlan.

2023-04-27 Thread via GitHub
xishuaidelin opened a new pull request, #22494: URL: https://github.com/apache/flink/pull/22494 ## What is the purpose of the change * This pull request support 'EXPLAIN' statement for CompiledPlan which contributes to the FLINK-31791.* ## Brief change log

[jira] [Updated] (FLINK-31952) Support 'EXPLAIN' statement for CompiledPlan

2023-04-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31952: --- Labels: pull-request-available (was: ) > Support 'EXPLAIN' statement for CompiledPlan >

[GitHub] [flink] ericxiao251 commented on a diff in pull request #22438: [FLINK-31873] Add method setMaxParallelism to DataStreamSink.

2023-04-27 Thread via GitHub
ericxiao251 commented on code in PR #22438: URL: https://github.com/apache/flink/pull/22438#discussion_r1179231832 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java: ## @@ -180,6 +180,18 @@ public DataStreamSink

[GitHub] [flink] dmvk commented on pull request #22473: [FLINK-31933][sql][tests] Fix address construction

2023-04-27 Thread via GitHub
dmvk commented on PR #22473: URL: https://github.com/apache/flink/pull/22473#issuecomment-1525291666 Is this linked to the correct issue? The linked one refers to `Remove Whitebox usage in ExpressionKeysTest` -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-31958) Table to DataStream allow partial fields

2023-04-27 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31958: Description: Hello i have a Model with many many fields, example:     {{}} {code:java} public class

[jira] [Updated] (FLINK-31958) Table to DataStream allow partial fields

2023-04-27 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31958: Description: Hello i have a Model with many many fields, example: {code:java} public class UserModel {

[jira] [Updated] (FLINK-31958) Table to DataStream allow partial fields

2023-04-27 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31958: Description: Hello i have a Model with many many fields, example:       {code:java} public class

[jira] [Assigned] (FLINK-31947) Enable stdout redirect in flink-console.sh

2023-04-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-31947: -- Assignee: Zhenqiu Huang > Enable stdout redirect in flink-console.sh >

[jira] [Created] (FLINK-31959) Correct the unaligned checkpoint type at checkpoint level

2023-04-27 Thread Rui Fan (Jira)
Rui Fan created FLINK-31959: --- Summary: Correct the unaligned checkpoint type at checkpoint level Key: FLINK-31959 URL: https://issues.apache.org/jira/browse/FLINK-31959 Project: Flink Issue Type:

[GitHub] [flink] LadyForest commented on pull request #22478: [FLINK-31917][table-planner] Fix the idempotence lost in JsonSerDe round trip for AggregateCall and RexNode

2023-04-27 Thread via GitHub
LadyForest commented on PR #22478: URL: https://github.com/apache/flink/pull/22478#issuecomment-1525541392 @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] [Created] (FLINK-31956) Extend the CompiledPlan to read from/write to Flink's FileSystem

2023-04-27 Thread Jane Chan (Jira)
Jane Chan created FLINK-31956: - Summary: Extend the CompiledPlan to read from/write to Flink's FileSystem Key: FLINK-31956 URL: https://issues.apache.org/jira/browse/FLINK-31956 Project: Flink

[jira] [Updated] (FLINK-31956) Extend the CompiledPlan to read from/write to Flink's FileSystem

2023-04-27 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-31956: -- Description: At present, COMPILE/EXECUTE PLAN FOR '${plan.json}' only supports writing to/reading

[jira] [Commented] (FLINK-31956) Extend the CompiledPlan to read from/write to Flink's FileSystem

2023-04-27 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717082#comment-17717082 ] Shuai Xu commented on FLINK-31956: -- Hi Jane, I have taken the FLINK-31952 which is similar to the task.

[jira] [Created] (FLINK-31957) Add documentation for the user story

2023-04-27 Thread Jane Chan (Jira)
Jane Chan created FLINK-31957: - Summary: Add documentation for the user story Key: FLINK-31957 URL: https://issues.apache.org/jira/browse/FLINK-31957 Project: Flink Issue Type: Sub-task

[GitHub] [flink] xishuaidelin opened a new pull request, #22493: Flink 31952

2023-04-27 Thread via GitHub
xishuaidelin opened a new pull request, #22493: URL: https://github.com/apache/flink/pull/22493 ## What is the purpose of the change * This pull request aims to support 'EXPLAIN' statement for CompiledPlan which supports the FLINK-31791.* ## Brief change log

[GitHub] [flink] xintongsong commented on a diff in pull request #22330: [FLINK-31635][network] Support writing records to the new tiered store architecture

2023-04-27 Thread via GitHub
xintongsong commented on code in PR #22330: URL: https://github.com/apache/flink/pull/22330#discussion_r1170781624 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/common/TieredStorageUtils.java: ## @@ -0,0 +1,56 @@ +/* + * Licensed to

[GitHub] [flink] LadyForest commented on pull request #22492: [FLINK-31950][table-planner] Introduce StateMetadata and support operator-level state TTL configuration via Compiled Plan

2023-04-27 Thread via GitHub
LadyForest commented on PR #22492: URL: https://github.com/apache/flink/pull/22492#issuecomment-1525542072 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] TanYuxin-tyx commented on pull request #22427: [FLINK-30815][tests] Migrate BatchAbstractTestBase and BatchTestBase to junit5

2023-04-27 Thread via GitHub
TanYuxin-tyx commented on PR #22427: URL: https://github.com/apache/flink/pull/22427#issuecomment-1525612113 @godfreyhe Thanks for helping review the change. I have updated the code according to the comments. I add 3 methods in `BatchAbstractTestBase`, `createTempFolder`,

[GitHub] [flink] sigalite commented on pull request #22393: FLINK-28171 [flink-kubernates] enable add appProtocol via the configuration and verify it is not overridden by Default port defintion

2023-04-27 Thread via GitHub
sigalite commented on PR #22393: URL: https://github.com/apache/flink/pull/22393#issuecomment-1525791232 added unit tests. thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] dmvk commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-27 Thread via GitHub
dmvk commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179264603 ## flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java: ## @@ -0,0 +1,227 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-kubernetes-operator] rodmeneses commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

2023-04-27 Thread via GitHub
rodmeneses commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179342548 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java: ## @@ -113,7 +115,13

[jira] [Created] (FLINK-31960) SQL OverBy. Error on a code that does not exist

2023-04-27 Thread padavan (Jira)
padavan created FLINK-31960: --- Summary: SQL OverBy. Error on a code that does not exist Key: FLINK-31960 URL: https://issues.apache.org/jira/browse/FLINK-31960 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31961) Implement ExpandedQuery and OriginalQuery methods for glue in catalog

2023-04-27 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-31961: -- Summary: Implement ExpandedQuery and OriginalQuery methods for glue in catalog Key: FLINK-31961 URL: https://issues.apache.org/jira/browse/FLINK-31961 Project: Flink

[jira] [Commented] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

2023-04-27 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717308#comment-17717308 ] Samrat Deb commented on FLINK-31080: [~Weijie Guo] we have worked internally to fix this bug.  If

[jira] [Commented] (FLINK-26425) Yarn aggregate log files in a rolling fashion for flink

2023-04-27 Thread Prabhu Joseph (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717324#comment-17717324 ] Prabhu Joseph commented on FLINK-26425: --- This is very useful to Flink on YARN, as without this,

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

2023-04-27 Thread via GitHub
mxm commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179255242 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/metrics/ScalingMetrics.java: ## @@ -83,6 +83,8 @@

[jira] [Resolved] (FLINK-31866) Autoscaler metric trimming reduces the number of metric observations on recovery

2023-04-27 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-31866. Resolution: Fixed > Autoscaler metric trimming reduces the number of metric

[GitHub] [flink-kubernetes-operator] rodmeneses commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

2023-04-27 Thread via GitHub
rodmeneses commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179330753 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java: ## @@ -81,17 +83,17

[GitHub] [flink] nateab commented on pull request #22359: [FLINK-31660][table] add jayway json path dependency to table-planner

2023-04-27 Thread via GitHub
nateab commented on PR #22359: URL: https://github.com/apache/flink/pull/22359#issuecomment-1526076794 CI failed with this, will look at fixing the notice file ```01:53:59,901 INFO org.apache.flink.tools.ci.licensecheck.NoticeFileChecker [] - Problems were detected for a NOTICE

[GitHub] [flink] ericxiao251 commented on a diff in pull request #22438: [FLINK-31873] Add method setMaxParallelism to DataStreamSink.

2023-04-27 Thread via GitHub
ericxiao251 commented on code in PR #22438: URL: https://github.com/apache/flink/pull/22438#discussion_r1179247666 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java: ## @@ -283,6 +283,27 @@ public void

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

2023-04-27 Thread via GitHub
gyfora commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179349838 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/metrics/ScalingMetrics.java: ## @@ -83,6 +83,8 @@

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

2023-04-27 Thread via GitHub
gyfora commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179350480 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java: ## @@ -113,7 +115,13 @@

[jira] [Updated] (FLINK-31960) SQL OverBy. Error on a code that does not exist

2023-04-27 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31960: Description: Hello. I use latest Flink. And want make query with LEAD, LAG function , but i got error 

[jira] [Updated] (FLINK-31960) SQL OverBy. Error on a code that does not exist

2023-04-27 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31960: Description: Hello. I use latest Flink. And want make query with LEAD, LAG function , but i got error   

[GitHub] [flink] ericxiao251 commented on pull request #22438: [FLINK-31873] Add method setMaxParallelism to DataStreamSink.

2023-04-27 Thread via GitHub
ericxiao251 commented on PR #22438: URL: https://github.com/apache/flink/pull/22438#issuecomment-1525799723 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink-kubernetes-operator] rodmeneses commented on a diff in pull request #575: [FLINK-31885] Trigger event on autoscaler error

2023-04-27 Thread via GitHub
rodmeneses commented on code in PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575#discussion_r1179340070 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/JobAutoScalerImpl.java: ## @@ -113,7 +115,13

[GitHub] [flink-kubernetes-operator] yangjf2019 opened a new pull request, #578: [FLINK-31815] Fixing the container vulnerability by upgrade the SnakeYaml Maven dependency

2023-04-27 Thread via GitHub
yangjf2019 opened a new pull request, #578: URL: https://github.com/apache/flink-kubernetes-operator/pull/578 ## What is the purpose of the change *Upgrade the SnakeYaml Maven dependency from 1.33 to 2.0 to fix the container vulnerability

[GitHub] [flink-training] alpinegizmo commented on pull request #59: Changes done after Pavel review

2023-04-27 Thread via GitHub
alpinegizmo commented on PR #59: URL: https://github.com/apache/flink-training/pull/59#issuecomment-1526862659 @ness-vaibhavtyagi Thank you for your interest in contributing to Flink. Please note, however, that we don't intend for the exercise classes in this repository to provide

[GitHub] [flink-training] alpinegizmo closed pull request #59: Changes done after Pavel review

2023-04-27 Thread via GitHub
alpinegizmo closed pull request #59: Changes done after Pavel review URL: https://github.com/apache/flink-training/pull/59 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

[GitHub] [flink-kubernetes-operator] yangjf2019 commented on pull request #567: [FLINK-31815] Fixing the container vulnerability by upgrade the SnakeYaml Maven dependency

2023-04-27 Thread via GitHub
yangjf2019 commented on PR #567: URL: https://github.com/apache/flink-kubernetes-operator/pull/567#issuecomment-1526847015 Okay, I'll fix it, thanks! -- 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

[GitHub] [flink-kubernetes-operator] yangjf2019 closed pull request #567: [FLINK-31815] Fixing the container vulnerability by upgrade the SnakeYaml Maven dependency

2023-04-27 Thread via GitHub
yangjf2019 closed pull request #567: [FLINK-31815] Fixing the container vulnerability by upgrade the SnakeYaml Maven dependency URL: https://github.com/apache/flink-kubernetes-operator/pull/567 -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-27 Thread via GitHub
pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179534966 ## flink-core/src/main/java/org/apache/flink/core/failure/FailureEnricher.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[jira] [Updated] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

2023-04-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31080: --- Labels: pull-request-available (was: ) > Idle slots are not released due to a mismatch in

[GitHub] [flink] Samrat002 opened a new pull request, #22495: [FLINK-31080][Flink-runtime]Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAl

2023-04-27 Thread via GitHub
Samrat002 opened a new pull request, #22495: URL: https://github.com/apache/flink/pull/22495 ## What is the purpose of the change Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator ## Does this pull request

[jira] [Created] (FLINK-31962) libssl not found when running CI

2023-04-27 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-31962: -- Summary: libssl not found when running CI Key: FLINK-31962 URL: https://issues.apache.org/jira/browse/FLINK-31962 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25000) Scala 2.12.7 doesn't compile on Java 17

2023-04-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717380#comment-17717380 ] Martijn Visser commented on FLINK-25000: Per

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-27 Thread via GitHub
pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179537961 ## flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java: ## @@ -0,0 +1,227 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-27 Thread via GitHub
pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179537961 ## flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java: ## @@ -0,0 +1,227 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Comment Edited] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

2023-04-27 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717308#comment-17717308 ] Samrat Deb edited comment on FLINK-31080 at 4/27/23 6:33 PM: - [~Weijie Guo]

[GitHub] [flink] ericxiao251 commented on pull request #22438: [FLINK-31873][API / DataStream] Add method setMaxParallelism to DataStreamSink.

2023-04-27 Thread via GitHub
ericxiao251 commented on PR #22438: URL: https://github.com/apache/flink/pull/22438#issuecomment-1526147308 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-27 Thread via GitHub
pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179539366 ## flink-runtime/src/test/java/org/apache/flink/runtime/failure/FailureEnricherUtilsTest.java: ## @@ -0,0 +1,284 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-27 Thread via GitHub
pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1179535697 ## flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java: ## @@ -0,0 +1,227 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

  1   2   >