[jira] [Updated] (FLINK-32700) Support job drain for Savepoint upgrade mode jobs in Flink Operator

2023-07-26 Thread Manan Mangal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manan Mangal updated FLINK-32700: - Description: During cancel job with savepoint upgrade mode, jobs should be allowed to drain bef

[jira] [Updated] (FLINK-32700) Support job drain for Savepoint upgrade mode jobs in Flink Operator

2023-07-26 Thread Manan Mangal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manan Mangal updated FLINK-32700: - Description: During cancel job with savepoint upgrade mode, jobs should be allowed to drain bef

[jira] [Created] (FLINK-32700) Support job drain for Savepoint upgrade mode jobs in Flink Operator

2023-07-26 Thread Manan Mangal (Jira)
Manan Mangal created FLINK-32700: Summary: Support job drain for Savepoint upgrade mode jobs in Flink Operator Key: FLINK-32700 URL: https://issues.apache.org/jira/browse/FLINK-32700 Project: Flink

[jira] [Commented] (FLINK-32698) Add getCheckpointOptions interface in ManagedSnapshotContext

2023-07-26 Thread Ming Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747789#comment-17747789 ] Ming Li commented on FLINK-32698: - [~zjureel] [~zhuzh] [~fanrui]  Thanks for your sugges

[GitHub] [flink] WencongLiu commented on pull request #22341: [FLINK-27204][flink-runtime] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

2023-07-26 Thread via GitHub
WencongLiu commented on PR #22341: URL: https://github.com/apache/flink/pull/22341#issuecomment-1652958163 The CI has passed and pull request is ready for review now.😊 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[jira] [Commented] (FLINK-32698) Add getCheckpointOptions interface in ManagedSnapshotContext

2023-07-26 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747772#comment-17747772 ] Rui Fan commented on FLINK-32698: - bq. I found the sink operator in `Paimon` is a `OneIn

[jira] [Resolved] (FLINK-32674) Add documentation for the new Context.getTargetColumns

2023-07-26 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee resolved FLINK-32674. - Resolution: Fixed fixed in master:65f200b819e47800ff31cad55d4fe5c4a31706c7 > Add documentation

[jira] [Closed] (FLINK-32674) Add documentation for the new Context.getTargetColumns

2023-07-26 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-32674. --- > Add documentation for the new Context.getTargetColumns > -

[jira] [Updated] (FLINK-25015) job name should not always be `collect` submitted by sql client

2023-07-26 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-25015: -- Parent: FLINK-25318 Issue Type: Sub-task (was: Improvement) > job name should not always be `

[jira] [Commented] (FLINK-25015) job name should not always be `collect` submitted by sql client

2023-07-26 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747763#comment-17747763 ] Fang Yong commented on FLINK-25015: --- [~zouyunhe] What's the progress of this issue, th

[GitHub] [flink] lincoln-lil merged pull request #23075: [FLINK-32674][doc] Add documentation for the new getTargetColumns in DynamicTableSink

2023-07-26 Thread via GitHub
lincoln-lil merged PR #23075: URL: https://github.com/apache/flink/pull/23075 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.a

[jira] [Commented] (FLINK-32679) Filter conditions cannot be pushed to JOIN in some case

2023-07-26 Thread grandfisher (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747762#comment-17747762 ] grandfisher commented on FLINK-32679: - It's not the same question. I think FLINK-287

[jira] [Created] (FLINK-32699) select typeof(proctime()); throw exception in sql-client

2023-07-26 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-32699: - Summary: select typeof(proctime()); throw exception in sql-client Key: FLINK-32699 URL: https://issues.apache.org/jira/browse/FLINK-32699 Project: Flink Issue Type

[jira] [Commented] (FLINK-32679) Filter conditions cannot be pushed to JOIN in some case

2023-07-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747739#comment-17747739 ] Benchao Li commented on FLINK-32679: In FLINK-28753 (merged in 1.16.0), we have supp

[jira] [Commented] (FLINK-32698) Add getCheckpointOptions interface in ManagedSnapshotContext

2023-07-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747738#comment-17747738 ] Zhu Zhu commented on FLINK-32698: - Thanks for the proposal. [~Ming Li] Flink tends to av

[jira] [Commented] (FLINK-32698) Add getCheckpointOptions interface in ManagedSnapshotContext

2023-07-26 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747737#comment-17747737 ] Fang Yong commented on FLINK-32698: --- [~Ming Li] `ManagedSnapshotContext` is a `public`

[jira] [Updated] (FLINK-32698) Add getCheckpointOptions interface in ManagedSnapshotContext

2023-07-26 Thread Ming Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ming Li updated FLINK-32698: Description: Currently only {{checkpointID}} and {{checkpointTimestamp}} information are provided in {{{}

[GitHub] [flink] flinkbot commented on pull request #23086: [FLINK-32686][network] Avoid creating tiered internal shuffle master before enabling the tiered storage

2023-07-26 Thread via GitHub
flinkbot commented on PR #23086: URL: https://github.com/apache/flink/pull/23086#issuecomment-1652865213 ## CI report: * bac4b2c25121c38f2d0ba2dbe1e1de801e32691c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-32686) Performance regression on startScheduling.BATCH and startScheduling.STREAMING since 2023-07-24

2023-07-26 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747733#comment-17747733 ] Wencong Liu edited comment on FLINK-32686 at 7/27/23 3:42 AM:

[jira] [Updated] (FLINK-32686) Performance regression on startScheduling.BATCH and startScheduling.STREAMING since 2023-07-24

2023-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32686: --- Labels: pull-request-available (was: ) > Performance regression on startScheduling.BATCH an

[GitHub] [flink] WencongLiu opened a new pull request, #23086: [FLINK-32686][network] Avoid creating tiered internal shuffle master before enabling the tiered storage

2023-07-26 Thread via GitHub
WencongLiu opened a new pull request, #23086: URL: https://github.com/apache/flink/pull/23086 ## What is the purpose of the change *Avoid creating tiered internal shuffle master before enabling the tiered storage.* ## Brief change log - *Avoid creating tiered inter

[jira] [Created] (FLINK-32698) Add getCheckpointOptions interface in ManagedSnapshotContext

2023-07-26 Thread Ming Li (Jira)
Ming Li created FLINK-32698: --- Summary: Add getCheckpointOptions interface in ManagedSnapshotContext Key: FLINK-32698 URL: https://issues.apache.org/jira/browse/FLINK-32698 Project: Flink Issue Typ

[jira] [Updated] (FLINK-32650) Added the ability to split flink-protobuf codegen code

2023-07-26 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 李精卫 updated FLINK-32650: Fix Version/s: 1.18.0 (was: 1.17.0) > Added the ability to split flink-protobuf codegen cod

[jira] [Commented] (FLINK-32686) Performance regression on startScheduling.BATCH and startScheduling.STREAMING since 2023-07-24

2023-07-26 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747733#comment-17747733 ] Wencong Liu commented on FLINK-32686: - Thanks for reporting this. The second regress

[jira] [Updated] (FLINK-32650) Added the ability to split flink-protobuf codegen code

2023-07-26 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 李精卫 updated FLINK-32650: Affects Version/s: 1.18.0 (was: 1.17.0) > Added the ability to split flink-protobuf cod

[jira] [Commented] (FLINK-32650) Added the ability to split flink-protobuf codegen code

2023-07-26 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747732#comment-17747732 ] 李精卫 commented on FLINK-32650: - [~libenchao]  I don't know much about the specific implementa

[GitHub] [flink] flinkbot commented on pull request #23085: [FLINK-32680][streaming] Fix the messed up JobVertex name when the source nodes chained with a MultipleInput node.

2023-07-26 Thread via GitHub
flinkbot commented on PR #23085: URL: https://github.com/apache/flink/pull/23085#issuecomment-1652832579 ## CI report: * d09ca1560ad0cd2b452de8205af4a9ea5f3e3569 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32680) Job vertex names get messed up once there is a source vertex chained with a MultipleInput vertex in job graph

2023-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32680: --- Labels: pull-request-available (was: ) > Job vertex names get messed up once there is a sou

[GitHub] [flink] JunRuiLee opened a new pull request, #23085: [FLINK-32680][streaming] Fix the messed up JobVertex name when the source nodes chained with a MultipleInput node.

2023-07-26 Thread via GitHub
JunRuiLee opened a new pull request, #23085: URL: https://github.com/apache/flink/pull/23085 ## What is the purpose of the change There is a bug in generating the JobVertex name when the source nodes are chained with a MultipleInput node, resulting in a messed up JobVertex

[jira] [Updated] (FLINK-32697) When using JDBC to insert data into the oracle database, an error will be reported if the target field is lowercase,

2023-07-26 Thread sunyanyong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunyanyong updated FLINK-32697: --- Description: When using JDBC to insert data into the oracle database, if the target field is lowerc

[jira] [Created] (FLINK-32697) When using JDBC to insert data into the oracle database, an error will be reported if the target field is lowercase,

2023-07-26 Thread sunyanyong (Jira)
sunyanyong created FLINK-32697: -- Summary: When using JDBC to insert data into the oracle database, an error will be reported if the target field is lowercase, Key: FLINK-32697 URL: https://issues.apache.org/jira/brow

[jira] [Commented] (FLINK-32402) FLIP-294: Support Customized Catalog Modification Listener

2023-07-26 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747719#comment-17747719 ] Fang Yong commented on FLINK-32402: --- [~knaufk] Currently I think it's better to add th

[GitHub] [flink] luoyuxia merged pull request #23076: [FLINK-32460][doc] Add doc for show procedures statement

2023-07-26 Thread via GitHub
luoyuxia merged PR #23076: URL: https://github.com/apache/flink/pull/23076 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

[jira] [Resolved] (FLINK-32460) Add doc for list procedures

2023-07-26 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-32460. -- Fix Version/s: 1.18.0 Resolution: Fixed master: 3c452de8922784d58e0ebd68f5303e9459cc1d58 > Ad

[GitHub] [flink] lindong28 commented on a diff in pull request #23021: [FLINK-32603] Avoid consuming twice when two pipelines have the same table source

2023-07-26 Thread via GitHub
lindong28 commented on code in PR #23021: URL: https://github.com/apache/flink/pull/23021#discussion_r1275633566 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java: ## @@ -103,56 +106,63 @@ protec

[GitHub] [flink] lindong28 commented on a diff in pull request #23021: [FLINK-32603] Avoid consuming twice when two pipelines have the same table source

2023-07-26 Thread via GitHub
lindong28 commented on code in PR #23021: URL: https://github.com/apache/flink/pull/23021#discussion_r1275633566 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java: ## @@ -103,56 +106,63 @@ protec

[GitHub] [flink] luoyuxia commented on a diff in pull request #23075: [FLINK-32674][doc] Add documentation for the new getTargetColumns in DynamicTableSink

2023-07-26 Thread via GitHub
luoyuxia commented on code in PR #23075: URL: https://github.com/apache/flink/pull/23075#discussion_r1275626333 ## docs/content/docs/dev/table/sql/insert.md: ## @@ -208,7 +208,9 @@ column_list: **COLUMN LIST** Given a table T(a INT, b INT, c INT), Flink supports INSERT INTO

[GitHub] [flink] lincoln-lil commented on a diff in pull request #23075: [FLINK-32674][doc] Add documentation for the new getTargetColumns in DynamicTableSink

2023-07-26 Thread via GitHub
lincoln-lil commented on code in PR #23075: URL: https://github.com/apache/flink/pull/23075#discussion_r1274924840 ## docs/content/docs/dev/table/sql/insert.md: ## @@ -208,7 +208,9 @@ column_list: **COLUMN LIST** Given a table T(a INT, b INT, c INT), Flink supports INSERT IN

[GitHub] [flink] lincoln-lil commented on a diff in pull request #23075: [FLINK-32674][doc] Add documentation for the new getTargetColumns in DynamicTableSink

2023-07-26 Thread via GitHub
lincoln-lil commented on code in PR #23075: URL: https://github.com/apache/flink/pull/23075#discussion_r1274924840 ## docs/content/docs/dev/table/sql/insert.md: ## @@ -208,7 +208,9 @@ column_list: **COLUMN LIST** Given a table T(a INT, b INT, c INT), Flink supports INSERT IN

[jira] [Closed] (FLINK-32628) build_wheels_on_macos fails on AZP

2023-07-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-32628. --- > build_wheels_on_macos fails on AZP > -- > > Ke

[jira] [Updated] (FLINK-32628) build_wheels_on_macos fails on AZP

2023-07-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32628: Fix Version/s: 1.18.0 1.16.3 1.17.2 > build_wheels_o

[jira] [Resolved] (FLINK-32628) build_wheels_on_macos fails on AZP

2023-07-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-32628. - Resolution: Fixed > build_wheels_on_macos fails on AZP > ---

[jira] [Commented] (FLINK-32628) build_wheels_on_macos fails on AZP

2023-07-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747689#comment-17747689 ] Sergey Nuyanzin commented on FLINK-32628: - Merged to 1.16: [5aed79cc3165e1df1cd

[jira] [Assigned] (FLINK-32628) build_wheels_on_macos fails on AZP

2023-07-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-32628: --- Assignee: Sergey Nuyanzin > build_wheels_on_macos fails on AZP > --

[GitHub] [flink] hanyuzheng7 commented on pull request #22842: [FLINK-32261][table] Add built-in MAP_UNION function.

2023-07-26 Thread via GitHub
hanyuzheng7 commented on PR #22842: URL: https://github.com/apache/flink/pull/22842#issuecomment-1652682664 @snuyanzin ci test pass now -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specifi

[jira] [Commented] (FLINK-28045) [umbrella] Blockers for SourceFunction API removal (in Flink 2.0)

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747665#comment-17747665 ] Alexander Fedulov commented on FLINK-28045: --- [~danny.cranmer] I see that Kines

[jira] [Updated] (FLINK-28045) [umbrella] Blockers for SourceFunction API (in Flink 2.0)

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28045: -- Summary: [umbrella] Blockers for SourceFunction API (in Flink 2.0) (was: [umbrella] B

[jira] [Updated] (FLINK-28045) [umbrella] Blockers for SourceFunction API removal (in Flink 2.0)

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28045: -- Summary: [umbrella] Blockers for SourceFunction API removal (in Flink 2.0) (was: [umb

[jira] [Updated] (FLINK-28045) [umbrella] Blockers for SourceFunction API removal

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28045: -- Description: This ticket should only contain items where SourceFunction is already use

[jira] [Created] (FLINK-32696) Promote Kinesis connector support to PublicEvolving

2023-07-26 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32696: - Summary: Promote Kinesis connector support to PublicEvolving Key: FLINK-32696 URL: https://issues.apache.org/jira/browse/FLINK-32696 Project: Flink

[jira] [Updated] (FLINK-28045) [umbrella] Blockers for SourceFunction API removal

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28045: -- Description: This ticket should only contain items where SourceFunction is already use

[jira] [Updated] (FLINK-32695) Migrate SourceFunction in Tests to Source V2 API

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32695: -- Summary: Migrate SourceFunction in Tests to Source V2 API (was: Migrate SourceFunctio

[jira] [Updated] (FLINK-32692) [umbrella] Nice-to-haves for SourceFunction API removal

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32692: -- Description: See also FLINK-28045 (was: See also https://issues.apache.org/jira/brows

[jira] [Updated] (FLINK-28045) [umbrella] Blockers for SourceFunction API removal

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28045: -- Description: This ticket should only contain items where SourceFunction is already use

[jira] [Updated] (FLINK-32692) [umbrella] Nice-to-haves for SourceFunction API removal

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32692: -- Description: See also https://issues.apache.org/jira/browse/FLINK-28045 > [umbrella] N

[jira] [Updated] (FLINK-28051) Introduce Source API alternative to ExternallyInducedSource

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28051: -- Summary: Introduce Source API alternative to ExternallyInducedSource (was: Introduce

[jira] [Updated] (FLINK-28045) [umbrella] Blockers for SourceFunction API removal

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28045: -- Description: This ticket should only contain items where SourceFunction is already use

[jira] [Updated] (FLINK-28045) [umbrella] Blockers for SourceFunction API removal

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28045: -- Description: Should only contain items where SourceFunction is used in the existing co

[jira] [Updated] (FLINK-28045) [umbrella] Blockers for SourceFunction API removal

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28045: -- Description: This ticket should only contain items where SourceFunction is used in the

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #639: [FLINK-32690] report Double.NAN instead of null for missing autoscaler metrics

2023-07-26 Thread via GitHub
gyfora commented on PR #639: URL: https://github.com/apache/flink-kubernetes-operator/pull/639#issuecomment-1652453972 cc @mxm -- 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 comme

[jira] [Created] (FLINK-32695) Migrate SourceFunction in Tests to Source API

2023-07-26 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32695: - Summary: Migrate SourceFunction in Tests to Source API Key: FLINK-32695 URL: https://issues.apache.org/jira/browse/FLINK-32695 Project: Flink Issue

[jira] [Updated] (FLINK-28048) Introduce Source API alternative to FiniteTestSource

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28048: -- Description: This also has to verify that Iceberg connector tests mentioned in FLINK-2

[jira] [Created] (FLINK-32694) Cascade deprecation to classes that implement ParallelSourceFunction

2023-07-26 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32694: - Summary: Cascade deprecation to classes that implement ParallelSourceFunction Key: FLINK-32694 URL: https://issues.apache.org/jira/browse/FLINK-32694 Projec

[jira] [Updated] (FLINK-32693) Cascade deprecation to classes that directly implement SourceFunction

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32693: -- Description: * SocketTextStreamFunction (org.apache.flink.streaming.api.functions.sour

[jira] [Assigned] (FLINK-32693) Cascade deprecation to classes that directly implement SourceFunction

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov reassigned FLINK-32693: - Assignee: Alexander Fedulov > Cascade deprecation to classes that directly impl

[jira] [Updated] (FLINK-32693) Cascade deprecation to classes that directly implement SourceFunction

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32693: -- Description: * SocketTextStreamFunction (org.apache.flink.streaming.api.functions.sour

[jira] [Created] (FLINK-32693) Cascade deprecation to classes that directly implement SourceFunction

2023-07-26 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32693: - Summary: Cascade deprecation to classes that directly implement SourceFunction Key: FLINK-32693 URL: https://issues.apache.org/jira/browse/FLINK-32693 Proje

[jira] [Updated] (FLINK-28050) Introduce Source API alternative to SourceExecutionContext#fromElements(*) methods

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28050: -- Summary: Introduce Source API alternative to SourceExecutionContext#fromElements(*) me

[jira] [Updated] (FLINK-28054) Introduce Source API utilities to control records emitted per checkpoint

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28054: -- Parent: (was: FLINK-28045) Issue Type: Improvement (was: Sub-task) > Intr

[jira] [Updated] (FLINK-28056) Introduce high level API for cases that do not require specific SourceEnumerator logic.

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28056: -- Parent: FLINK-32692 Issue Type: Sub-task (was: Improvement) > Introduce high

[jira] [Updated] (FLINK-28056) Introduce high level API for cases that do not require specific SourceEnumerator logic.

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28056: -- Parent: (was: FLINK-28045) Issue Type: Improvement (was: Sub-task) > Intr

[jira] [Updated] (FLINK-28049) Introduce FLIP-208 functionality to stop Source based on consumed records

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28049: -- Parent: FLINK-32692 Issue Type: Sub-task (was: Improvement) > Introduce FLIP-

[jira] [Updated] (FLINK-28049) Introduce FLIP-208 functionality to stop Source based on consumed records

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28049: -- Parent: (was: FLINK-28045) Issue Type: Improvement (was: Sub-task) > Intr

[jira] [Created] (FLINK-32692) [umbrella] Nice-to-haves for SourceFunction API removal

2023-07-26 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32692: - Summary: [umbrella] Nice-to-haves for SourceFunction API removal Key: FLINK-32692 URL: https://issues.apache.org/jira/browse/FLINK-32692 Project: Flink

[jira] [Updated] (FLINK-28045) [umbrella] Blockers for SourceFunction API removal

2023-07-26 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28045: -- Summary: [umbrella] Blockers for SourceFunction API removal (was: [umbrella] Deprecat

[GitHub] [flink] flinkbot commented on pull request #23084: [FLINK-32691] SELECT fcn does not work with an unset catalog or database

2023-07-26 Thread via GitHub
flinkbot commented on PR #23084: URL: https://github.com/apache/flink/pull/23084#issuecomment-1652312270 ## CI report: * 4d3ccc527fcb655ddb5df44797819c1ee1684fe9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32691) SELECT fcn does not work with an unset catalog or database

2023-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32691: --- Labels: pull-request-available (was: ) > SELECT fcn does not work with an unset catalog or

[GitHub] [flink] jnh5y opened a new pull request, #23084: [FLINK-32691] SELECT fcn does not work with an unset catalog or database

2023-07-26 Thread via GitHub
jnh5y opened a new pull request, #23084: URL: https://github.com/apache/flink/pull/23084 ## What is the purpose of the change This commit addresses FLINK-32691 by having function lookup skip looking for functions in catalog / database specific locations when the catalog and/or databa

[jira] [Created] (FLINK-32691) SELECT fcn does not work with an unset catalog or database

2023-07-26 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-32691: -- Summary: SELECT fcn does not work with an unset catalog or database Key: FLINK-32691 URL: https://issues.apache.org/jira/browse/FLINK-32691 Project: Flink Issue

[jira] [Updated] (FLINK-32690) Report Double.NAN instead of null for missing autoscaler metrics

2023-07-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32690: --- Labels: pull-request-available (was: ) > Report Double.NAN instead of null for missing auto

[GitHub] [flink-kubernetes-operator] morhidi opened a new pull request, #639: [FLINK-32690] report Double.NAN instead of null for missing autoscaler metrics

2023-07-26 Thread via GitHub
morhidi opened a new pull request, #639: URL: https://github.com/apache/flink-kubernetes-operator/pull/639 ## What is the purpose of the change Change null values to Double.NAN for autoscaler metrics during blackout periods when no data is gathered. This appears to be a more common pr

[GitHub] [flink] patricklucas commented on pull request #22987: [FLINK-32583][rest] Fix deadlock in RestClient

2023-07-26 Thread via GitHub
patricklucas commented on PR #22987: URL: https://github.com/apache/flink/pull/22987#issuecomment-1652189416 Great, I'll get to this tomorrow, thanks for the reviews @XComp. Regarding the commit organization, I'm happy to break out another hotfix commit—wasn't sure if the branch would

[GitHub] [flink] patricklucas commented on a diff in pull request #22987: [FLINK-32583][rest] Fix deadlock in RestClient

2023-07-26 Thread via GitHub
patricklucas commented on code in PR #22987: URL: https://github.com/apache/flink/pull/22987#discussion_r1275249702 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java: ## @@ -207,6 +218,120 @@ public void testRestClientClosedHandling() throws Excep

[jira] [Created] (FLINK-32690) Report Double.NAN instead of null for missing autoscaler metrics

2023-07-26 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-32690: - Summary: Report Double.NAN instead of null for missing autoscaler metrics Key: FLINK-32690 URL: https://issues.apache.org/jira/browse/FLINK-32690 Project: Flink

[jira] [Assigned] (FLINK-31611) Add delayed restart to failed jobs

2023-07-26 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi reassigned FLINK-31611: - Assignee: (was: Matyas Orhidi) > Add delayed restart to failed jobs > -

[jira] [Updated] (FLINK-32684) Renaming AkkaOptions into PekkoOptions

2023-07-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32684: -- Description: FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved re

[jira] [Updated] (FLINK-32684) Renaming AkkaOptions into PekkoOptions

2023-07-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32684: -- Description: FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved re

[jira] [Updated] (FLINK-32684) Renaming AkkaOptions into PekkoOptions

2023-07-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32684: -- Description: FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved re

[jira] [Updated] (FLINK-32684) Renaming AkkaOptions into PekkoOptions

2023-07-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32684: -- Description: FLINK-32468 introduced Apache Pekko as an replacement for Akka. This involved re

[GitHub] [flink] hanyuzheng7 commented on pull request #22842: [FLINK-32261][table] Add built-in MAP_UNION function.

2023-07-26 Thread via GitHub
hanyuzheng7 commented on PR #22842: URL: https://github.com/apache/flink/pull/22842#issuecomment-1652083503 @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 commen

[jira] [Commented] (FLINK-32684) Renaming AkkaOptions into PekkoOptions

2023-07-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747575#comment-17747575 ] Chesnay Schepler commented on FLINK-32684: -- Related to FLINK-14052. > Renaming

[jira] [Commented] (FLINK-32689) Insufficient validation for table.local-time-zone

2023-07-26 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747559#comment-17747559 ] Timo Walther commented on FLINK-32689: -- Update: I could confirm it with this progra

[jira] [Commented] (FLINK-32689) Insufficient validation for table.local-time-zone

2023-07-26 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747557#comment-17747557 ] Timo Walther commented on FLINK-32689: -- [~leonard] Could you give more context why

[jira] [Created] (FLINK-32689) Insufficient validation for table.local-time-zone

2023-07-26 Thread Timo Walther (Jira)
Timo Walther created FLINK-32689: Summary: Insufficient validation for table.local-time-zone Key: FLINK-32689 URL: https://issues.apache.org/jira/browse/FLINK-32689 Project: Flink Issue Type:

[jira] [Updated] (FLINK-32119) Revise source partition skew logic

2023-07-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-32119: --- Fix Version/s: (was: kubernetes-operator-1.6.0) > Revise source partition skew logic >

[jira] [Updated] (FLINK-31867) Enforce a minimum number of observations within a metric window

2023-07-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-31867: --- Fix Version/s: (was: kubernetes-operator-1.6.0) > Enforce a minimum number of observations withi

[jira] [Updated] (FLINK-32120) Add autoscaler config option to disable parallelism key group alignment

2023-07-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-32120: --- Fix Version/s: (was: kubernetes-operator-1.6.0) > Add autoscaler config option to disable parall

[jira] [Updated] (FLINK-31998) Flink Operator Deadlock on run job Failure

2023-07-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-31998: --- Fix Version/s: (was: kubernetes-operator-1.6.0) > Flink Operator Deadlock on run job Failure > -

[jira] [Updated] (FLINK-31400) Add autoscaler integration for Iceberg source

2023-07-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-31400: --- Fix Version/s: (was: kubernetes-operator-1.6.0) > Add autoscaler integration for Iceberg source

[jira] [Commented] (FLINK-29281) Replace Akka by gRPC-based RPC implementation

2023-07-26 Thread Claude Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747553#comment-17747553 ] Claude Warren commented on FLINK-29281: --- Pekko v1.0.1 was just released. [d...@pe

  1   2   >