[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833414#comment-17833414 ] Matthias Pohl commented on FLINK-34643: --- I guess, reopening the issue would be fin

Re: [PR] [FLINK-24939][table] Support `SHOW CREATE CATALOG` syntax [flink]

2024-04-02 Thread via GitHub
LadyForest commented on code in PR #24555: URL: https://github.com/apache/flink/pull/24555#discussion_r1548860085 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowCreateCatalog.java: ## @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-34988][build] Fix the reflection issue of ExecutionEnvironmentImpl for JDK17 [flink]

2024-04-02 Thread via GitHub
reswqa commented on PR #24610: URL: https://github.com/apache/flink/pull/24610#issuecomment-2033624958 @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. T

Re: [PR] [FLINK-34690] Cast decimal to VARCHAR as primary key in starrocks sink [flink-cdc]

2024-04-02 Thread via GitHub
yuxiqian commented on code in PR #3150: URL: https://github.com/apache/flink-cdc/pull/3150#discussion_r1548950314 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/CdcDataTypeTransformer

[jira] [Created] (FLINK-34993) Support Model CRUD in parser

2024-04-02 Thread Hao Li (Jira)
Hao Li created FLINK-34993: -- Summary: Support Model CRUD in parser Key: FLINK-34993 URL: https://issues.apache.org/jira/browse/FLINK-34993 Project: Flink Issue Type: Sub-task Reporter: H

[jira] [Created] (FLINK-34992) FLIP-437: Support ML Models in Flink SQL

2024-04-02 Thread Hao Li (Jira)
Hao Li created FLINK-34992: -- Summary: FLIP-437: Support ML Models in Flink SQL Key: FLINK-34992 URL: https://issues.apache.org/jira/browse/FLINK-34992 Project: Flink Issue Type: New Feature

Re: [PR] [FLINK-34690] Cast decimal to VARCHAR as primary key in starrocks sink [flink-cdc]

2024-04-02 Thread via GitHub
loserwang1024 commented on code in PR #3150: URL: https://github.com/apache/flink-cdc/pull/3150#discussion_r1548867762 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.ja

[jira] [Updated] (FLINK-34973) FLIP-425: Asynchronous Execution Model

2024-04-02 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-34973: Component/s: Runtime / Checkpointing Runtime / State Backends Run

Re: [PR] [FLINK-34690] Cast decimal to VARCHAR/INT/BIGINT/LARGEINT as primary … [flink-cdc]

2024-04-02 Thread via GitHub
loserwang1024 commented on PR #3150: URL: https://github.com/apache/flink-cdc/pull/3150#issuecomment-2033455598 @yuxiqian , thanks for your advise. I think cast decimal to VARCHAR rather than VARCHAR/INT/BIGINT/LARGEINT is more easy for user to understand, so I just modified it. Could y

[jira] [Comment Edited] (FLINK-34988) Class loading issues in JDK17 and JDK21

2024-04-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833188#comment-17833188 ] Weijie Guo edited comment on FLINK-34988 at 4/3/24 3:17 AM:

[jira] [Updated] (FLINK-34988) Class loading issues in JDK17 and JDK21

2024-04-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34988: --- Labels: pull-request-available test-stability (was: test-stability) > Class loading issues

[PR] [FLINK-34988][build] Fix the reflection issue of ExecutionEnvironmentImpl for JDK17 [flink]

2024-04-02 Thread via GitHub
reswqa opened a new pull request, #24610: URL: https://github.com/apache/flink/pull/24610 ## What is the purpose of the change *In JDK17, we cannot access a final field via reflection by default. Following #22794, I have added `--add-opens=java.base/java.util=ALL-UNNAMED` to the modu

[jira] [Updated] (FLINK-34690) If data from upstream is decimal and primary key , starrocks sink will not support.

2024-04-02 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongshun Wang updated FLINK-34690: -- Description: h3. What's the problem Flink only have bigint type, if mysql data is unsigned bi

Re: [PR] [docs]Change host to host name in configuration for readme [flink-cdc]

2024-04-02 Thread via GitHub
cjj2010 closed pull request #3076: [docs]Change host to host name in configuration for readme URL: https://github.com/apache/flink-cdc/pull/3076 -- 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 s

Re: [PR] [docs]Change host to host name in configuration for readme [flink-cdc]

2024-04-02 Thread via GitHub
cjj2010 commented on PR #3076: URL: https://github.com/apache/flink-cdc/pull/3076#issuecomment-2033405869 The document has been repaired -- 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 specif

Re: [PR] [hotfix] Fix YARN ContainerId.getId Deprecated Used. [flink]

2024-04-02 Thread via GitHub
slfan1989 commented on PR #24601: URL: https://github.com/apache/flink/pull/24601#issuecomment-2033272213 @1996fanrui Can you help review this pr? Thank you very much! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

Re: [PR] [BP-1.19][FLINK-34955] Upgrade commons-compress to 1.26.0. [flink]

2024-04-02 Thread via GitHub
slfan1989 commented on PR #24609: URL: https://github.com/apache/flink/pull/24609#issuecomment-2033234777 @mbalassi Thank you for following up on this issue! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]

2024-04-02 Thread via GitHub
anupamaggarwal commented on code in PR #24482: URL: https://github.com/apache/flink/pull/24482#discussion_r1548361941 ## flink-formats/flink-protobuf-confluent-registry/src/main/java/org/apache/flink/formats/protobuf/registry/confluent/ProtoRegistrySerializationSchema.java: ## @

Re: [PR] [DRAFT][FLINK-34440][formats][protobuf-confluent] add support for protobuf-confluent [flink]

2024-04-02 Thread via GitHub
anupamaggarwal commented on code in PR #24482: URL: https://github.com/apache/flink/pull/24482#discussion_r1548361941 ## flink-formats/flink-protobuf-confluent-registry/src/main/java/org/apache/flink/formats/protobuf/registry/confluent/ProtoRegistrySerializationSchema.java: ## @

Re: [PR] [FLINK-34324][ci] Replaces AWS-based S3 e2e tests with Minio-backed version [flink]

2024-04-02 Thread via GitHub
XComp commented on PR #24465: URL: https://github.com/apache/flink/pull/24465#issuecomment-2032569042 I verified that the tests ran in CI as well: see [logs #2614ff](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58690&view=logs&j=af184cdd-c6d8-5084-0b69-7e9c67b35f7a&

[jira] [Updated] (FLINK-34991) Flink Operator ClassPath Race Condition Bug

2024-04-02 Thread Ryan van Huuksloot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan van Huuksloot updated FLINK-34991: --- Description: Hello, I believe we've found a bug with the Job Managers of the Kubern

[jira] [Updated] (FLINK-34991) Flink Operator ClassPath Race Condition Bug

2024-04-02 Thread Ryan van Huuksloot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan van Huuksloot updated FLINK-34991: --- Description: Hello, I believe we've found a bug with the Job Managers of the Kubern

[jira] [Created] (FLINK-34991) Flink Operator ClassPath Race Condition Bug

2024-04-02 Thread Ryan van Huuksloot (Jira)
Ryan van Huuksloot created FLINK-34991: -- Summary: Flink Operator ClassPath Race Condition Bug Key: FLINK-34991 URL: https://issues.apache.org/jira/browse/FLINK-34991 Project: Flink Issue

[jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out

2024-04-02 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833252#comment-17833252 ] Ryan Skraba commented on FLINK-34224: - 1.19, JDK8: [https://github.com/apache/flink

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-04-02 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833247#comment-17833247 ] Ryan Skraba commented on FLINK-34227: - 1.18, adaptive scheduler: [https://github.co

[jira] [Commented] (FLINK-34645) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails

2024-04-02 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833246#comment-17833246 ] Ryan Skraba commented on FLINK-34645: - 1.18, hadoop 3.1.3: [https://github.com/apac

[jira] [Commented] (FLINK-34495) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failure due to FileNotFoundException

2024-04-02 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833249#comment-17833249 ] Ryan Skraba commented on FLINK-34495: - 1.19, JDK21: [https://github.com/apache/flin

[jira] [Commented] (FLINK-34464) actions/cache@v4 times out

2024-04-02 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833248#comment-17833248 ] Ryan Skraba commented on FLINK-34464: - 1.18, jdk17: [https://github.com/apache/flin

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-04-02 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833244#comment-17833244 ] Ryan Skraba commented on FLINK-34643: - 1.20, on JDK 11, not adaptive schedule: [htt

[jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out

2024-04-02 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833243#comment-17833243 ] Ryan Skraba commented on FLINK-34224: - 1.20, hadoop-3.1.3: https://github.com/apach

Re: [PR] [Feature-2932][Pipeline] Flink CDC pipeline supports transform [flink-cdc]

2024-04-02 Thread via GitHub
leonardBang merged PR #2937: URL: https://github.com/apache/flink-cdc/pull/2937 -- 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

Re: [PR] [FLINK-34990][cdc-connector][oracle] Oracle cdc support newly add table [flink-cdc]

2024-04-02 Thread via GitHub
gong commented on PR #3203: URL: https://github.com/apache/flink-cdc/pull/3203#issuecomment-2032318710 @leonardBang PTAL -- 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

[jira] [Updated] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

2024-04-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34990: --- Labels: pull-request-available (was: ) > [feature][cdc-connector][oracle] Oracle cdc suppor

[PR] test access [flink-training]

2024-04-02 Thread via GitHub
LaviniaMaria opened a new pull request, #75: URL: https://github.com/apache/flink-training/pull/75 test acces -- 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

[jira] [Updated] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

2024-04-02 Thread Xin Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-34990: - External issue URL: (was: https://github.com/apache/flink-cdc/pull/3203) > [feature][cdc-connector][or

[jira] [Updated] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

2024-04-02 Thread Xin Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-34990: - External issue URL: https://github.com/apache/flink-cdc/pull/3203 > [feature][cdc-connector][oracle] Ora

[PR] test repo [flink-training]

2024-04-02 Thread via GitHub
ness-LaviniaGherasim opened a new pull request, #74: URL: https://github.com/apache/flink-training/pull/74 test if i can add reviewers -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Commented] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

2024-04-02 Thread Xin Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833221#comment-17833221 ] Xin Gong commented on FLINK-34990: -- I will submit the PR. cc [~Leonard]  > [feature][c

[jira] [Created] (FLINK-34990) [feature][cdc-connector][oracle] Oracle cdc support newly add table

2024-04-02 Thread Xin Gong (Jira)
Xin Gong created FLINK-34990: Summary: [feature][cdc-connector][oracle] Oracle cdc support newly add table Key: FLINK-34990 URL: https://issues.apache.org/jira/browse/FLINK-34990 Project: Flink

Re: [PR] [Feature-2932][Pipeline] Flink CDC pipeline supports transform [flink-cdc]

2024-04-02 Thread via GitHub
aiwenmo commented on PR #2937: URL: https://github.com/apache/flink-cdc/pull/2937#issuecomment-2032174460 > Thanks @aiwenmo for the great work, LGTM although I think we can improve the test coverage as well as the document, but I think we can improve them later. Thanks @leonardBang ,

Re: [PR] [FLINK-34162][table] Migrate LogicalUnnestRule to java [flink]

2024-04-02 Thread via GitHub
RyanSkraba commented on code in PR #24144: URL: https://github.com/apache/flink/pull/24144#discussion_r1547947032 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/LogicalUnnestRule.java: ## @@ -0,0 +1,180 @@ +/* + * Licensed to t

Re: [PR] [BP-1.19][FLINK-34955] Upgrade commons-compress to 1.26.0. [flink]

2024-04-02 Thread via GitHub
flinkbot commented on PR #24609: URL: https://github.com/apache/flink/pull/24609#issuecomment-2032111428 ## CI report: * 6af6f478ec3c894edd12eb01f038737e7d0cbd09 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [BP-1.18][FLINK-34955] Upgrade commons-compress to 1.26.0. [flink]

2024-04-02 Thread via GitHub
flinkbot commented on PR #24608: URL: https://github.com/apache/flink/pull/24608#issuecomment-2032097767 ## CI report: * 55ec4699d2e6e09a01afcdfbec446abe2cf67eed UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-34955) Upgrade commons-compress to 1.26.0

2024-04-02 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833201#comment-17833201 ] Márton Balassi commented on FLINK-34955: [163b9cc|https://github.com/apache/flin

[jira] [Updated] (FLINK-34955) Upgrade commons-compress to 1.26.0

2024-04-02 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-34955: --- Fix Version/s: 1.18.2 1.20.0 1.19.1 > Upgrade commons-

[jira] [Assigned] (FLINK-34955) Upgrade commons-compress to 1.26.0

2024-04-02 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-34955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-34955: -- Assignee: Shilun Fan > Upgrade commons-compress to 1.26.0 > -

Re: [PR] [FLINK-34955] Upgrade commons-compress to 1.26.0. [flink]

2024-04-02 Thread via GitHub
mbalassi merged PR #24580: URL: https://github.com/apache/flink/pull/24580 -- 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

Re: [PR] [docs]Change host to host name in configuration for readme [flink-cdc]

2024-04-02 Thread via GitHub
gtk96 commented on PR #3076: URL: https://github.com/apache/flink-cdc/pull/3076#issuecomment-2032038036 @cjj2010 Can you only keep your own changes to submit? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[jira] [Commented] (FLINK-34988) Class loading issues in JDK17 and JDK21

2024-04-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833188#comment-17833188 ] Weijie Guo commented on FLINK-34988: Yes, this not founded class is introduced by my

[jira] [Commented] (FLINK-32957) Add current timer trigger lag to metrics

2024-04-02 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833184#comment-17833184 ] Piotr Nowojski commented on FLINK-32957: {{mailboxLatencyMs}} shows basically th

Re: [PR] [FLINK-34937][ci] Updates GitHub actions to use the proper pinned and most-recent version [flink]

2024-04-02 Thread via GitHub
flinkbot commented on PR #24607: URL: https://github.com/apache/flink/pull/24607#issuecomment-2031953860 ## CI report: * 30de0e3a6217d6cafc4065e5b79f2a327420f6d5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-34937][ci] Updates GitHub actions to use the proper pinned and most-recent version [flink]

2024-04-02 Thread via GitHub
XComp opened a new pull request, #24607: URL: https://github.com/apache/flink/pull/24607 ## What is the purpose of the change According to Apache Infra's [GitHub Action Policy|(https://infra.apache.org/github-actions-policy.html) we are allowed to use any action that is under `apache

[jira] [Updated] (FLINK-34937) Apache Infra GHA policy update

2024-04-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34937: --- Labels: pull-request-available (was: ) > Apache Infra GHA policy update > -

[jira] [Comment Edited] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833154#comment-17833154 ] Matthias Pohl edited comment on FLINK-34989 at 4/2/24 12:18 PM: --

[jira] [Updated] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34989: -- Description: The GitHub Actions CI utilizes runners that are hosted by Apache Infra right now

[jira] [Updated] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34989: --- Labels: pull-request-available (was: ) > Apache Infra requests to reduce the runner usage f

Re: [PR] [FLINK-34989][ci] Reduces number of concurrent jobs for nightly runs [flink]

2024-04-02 Thread via GitHub
flinkbot commented on PR #24606: URL: https://github.com/apache/flink/pull/24606#issuecomment-2031881597 ## CI report: * a3a393aa586cae3637c1f17e0714b304d5df286f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] Flink 34989 [flink]

2024-04-02 Thread via GitHub
XComp opened a new pull request, #24606: URL: https://github.com/apache/flink/pull/24606 ## What is the purpose of the change See FLINK-34989 for further details ## Brief change log tbd ## Verifying this change Manual CI runs ## Does this pull request

[jira] [Commented] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833155#comment-17833155 ] Matthias Pohl commented on FLINK-34989: --- For this issue, we should keep in mind th

[jira] [Updated] (FLINK-34331) Enable Apache INFRA ephemeral runners for nightly builds

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34331: -- Summary: Enable Apache INFRA ephemeral runners for nightly builds (was: Enable Apache INFRA r

[jira] [Commented] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833154#comment-17833154 ] Matthias Pohl commented on FLINK-34989: --- This Jira issue is about adding job concu

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: api [flink]

2024-04-02 Thread via GitHub
Jiabao-Sun commented on code in PR #24603: URL: https://github.com/apache/flink/pull/24603#discussion_r1547534597 ## flink-core/src/test/java/org/apache/flink/api/java/typeutils/PojoTypeExtractionTest.java: ## @@ -260,99 +262,98 @@ private void checkWCPojoAsserts(TypeInformation

[jira] [Commented] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833153#comment-17833153 ] Matthias Pohl commented on FLINK-34989: --- Here's a summary of the requirements and

[jira] [Updated] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34989: -- Description: The GitHub Actions CI utilizes runners that are hosted by Apache Infra right now

[jira] [Updated] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34989: -- Description: The GitHub Actions CI utilizes runners that are hosted by Apache Infra right now

[jira] [Commented] (FLINK-34937) Apache Infra GHA policy update

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833149#comment-17833149 ] Matthias Pohl commented on FLINK-34937: --- I moved the runner usage discussion into

[jira] [Created] (FLINK-34989) Apache Infra requests to reduce the runner usage for a project

2024-04-02 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34989: - Summary: Apache Infra requests to reduce the runner usage for a project Key: FLINK-34989 URL: https://issues.apache.org/jira/browse/FLINK-34989 Project: Flink

Re: [PR] [FLINK-34903][MySQL][Feature] Add mysql-pipeline-connector with table.exclude.list option to exclude unnecessary tables [flink-cdc]

2024-04-02 Thread via GitHub
Jiabao-Sun commented on PR #3186: URL: https://github.com/apache/flink-cdc/pull/3186#issuecomment-2031767868 Thanks @shiyiky for this contribution. @ruanhang1993, could you help review this when you have time? -- This is an automated message from the Apache Git Service. To respond to th

Re: [PR] Update README.md [flink-cdc]

2024-04-02 Thread via GitHub
Jiabao-Sun merged PR #3196: URL: https://github.com/apache/flink-cdc/pull/3196 -- 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.

Re: [PR] [FLINK-34180] Migrate doc website from ververica to apache flink [flink-cdc]

2024-04-02 Thread via GitHub
Jiabao-Sun commented on PR #3144: URL: https://github.com/apache/flink-cdc/pull/3144#issuecomment-2031746484 Hi @hirolee88, I checked the code in the master branch, and it seems that this issue does not need to be fixed. I will close this PR. Thanks for your contribution. -- Th

Re: [PR] [FLINK-34180] Migrate doc website from ververica to apache flink [flink-cdc]

2024-04-02 Thread via GitHub
Jiabao-Sun closed pull request #3144: [FLINK-34180] Migrate doc website from ververica to apache flink URL: https://github.com/apache/flink-cdc/pull/3144 -- 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 g

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-02 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2031643286 @Zakelly @masteryhx The code has been adjusted, please help me take a look again. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-24939][table] Support `SHOW CREATE CATALOG` syntax [flink]

2024-04-02 Thread via GitHub
LadyForest commented on PR #24555: URL: https://github.com/apache/flink/pull/24555#issuecomment-2031634753 > @LadyForest @xuyangzhong @hackergin Hi, CI passed, Could you please take a review? thanks very much :) Thanks for reaching out and I will take a look ASAP -- This is an auto

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: api [flink]

2024-04-02 Thread via GitHub
Jiabao-Sun commented on code in PR #24603: URL: https://github.com/apache/flink/pull/24603#discussion_r1547495311 ## flink-core/src/test/java/org/apache/flink/api/common/operators/ResourceSpecTest.java: ## @@ -141,12 +141,12 @@ void testMerge() { ResourceSpec rs3 = rs1.

[jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239)

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833098#comment-17833098 ] Matthias Pohl commented on FLINK-34427: --- Copied over from FLINK-33416: * https://g

[jira] [Closed] (FLINK-33416) FineGrainedSlotManagerTest failed with fatal error

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-33416. - Resolution: Duplicate This issue is addressed in FLINK-34427. I'm closing FLINK-33416 in favor o

[jira] [Comment Edited] (FLINK-34988) Class loading issues in JDK17 and JDK21

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833095#comment-17833095 ] Matthias Pohl edited comment on FLINK-34988 at 4/2/24 10:07 AM: --

[jira] [Commented] (FLINK-34988) Class loading issues in JDK17 and JDK21

2024-04-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833095#comment-17833095 ] Matthias Pohl commented on FLINK-34988: --- It's most likely caused by FLINK-34548 ba

[jira] [Created] (FLINK-34988) Class loading issues in JDK17 and JDK21

2024-04-02 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34988: - Summary: Class loading issues in JDK17 and JDK21 Key: FLINK-34988 URL: https://issues.apache.org/jira/browse/FLINK-34988 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-34987) Introduce Internal State Interface for Async State API

2024-04-02 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34987: - Component/s: Runtime / State Backends > Introduce Internal State Interface for Async State API >

[jira] [Created] (FLINK-34987) Introduce Internal State Interface for Async API

2024-04-02 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-34987: Summary: Introduce Internal State Interface for Async API Key: FLINK-34987 URL: https://issues.apache.org/jira/browse/FLINK-34987 Project: Flink Issue Type:

[jira] [Updated] (FLINK-34987) Introduce Internal State Interface for Async State API

2024-04-02 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34987: - Summary: Introduce Internal State Interface for Async State API (was: Introduce Internal State

Re: [PR] [BP-1.19][FLINK-34324][ci] Replaces AWS-based S3 e2e tests with Minio-backed version [flink]

2024-04-02 Thread via GitHub
flinkbot commented on PR #24605: URL: https://github.com/apache/flink/pull/24605#issuecomment-2031568599 ## CI report: * 34d6ed1e68162b5711e389258927c0817e03340e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [BP-1.18][FLINK-34324][ci] Replaces AWS-based S3 e2e tests with Minio-backed version [flink]

2024-04-02 Thread via GitHub
flinkbot commented on PR #24604: URL: https://github.com/apache/flink/pull/24604#issuecomment-2031568387 ## CI report: * 0b2b36518cb327e06e65d0805e956edaed454d4b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-34960) NullPointerException while applying parallelism overrides for session jobs

2024-04-02 Thread Kunal Rohitas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833087#comment-17833087 ] Kunal Rohitas commented on FLINK-34960: --- Okay, thanks for the help. > NullPointer

Re: [PR] [FLINK-34324][ci] Replaces AWS-based S3 e2e tests with Minio-backed version [flink]

2024-04-02 Thread via GitHub
XComp commented on PR #24465: URL: https://github.com/apache/flink/pull/24465#issuecomment-2031543538 master rebase -- 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 unsub

Re: [PR] [FLINK-34324][ci] Replaces AWS-based S3 e2e tests with Minio-backed version [flink]

2024-04-02 Thread via GitHub
XComp commented on PR #24465: URL: https://github.com/apache/flink/pull/24465#issuecomment-2031542673 Reorganized the commits in the most-recent force-push. -- 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-34960) NullPointerException while applying parallelism overrides for session jobs

2024-04-02 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833086#comment-17833086 ] Robert Metzger commented on FLINK-34960: Sorry, that's something you need to fig

[jira] [Commented] (FLINK-34960) NullPointerException while applying parallelism overrides for session jobs

2024-04-02 Thread Kunal Rohitas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833083#comment-17833083 ] Kunal Rohitas commented on FLINK-34960: --- Thanks, not getting NPE anymore but to ac

Re: [PR] [FLINK-34690] Cast decimal to VARCHAR/INT/BIGINT/LARGEINT as primary … [flink-cdc]

2024-04-02 Thread via GitHub
yuxiqian commented on PR #3150: URL: https://github.com/apache/flink-cdc/pull/3150#issuecomment-2031514128 Thanks for @loserwang1024's contribution, left some comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

Re: [PR] [FLINK-34633][table] Support unnesting array constants [flink]

2024-04-02 Thread via GitHub
LadyForest commented on PR #24510: URL: https://github.com/apache/flink/pull/24510#issuecomment-2031513708 Hi @jeyhunkarimov, thanks for reaching out and sorry for the late response. I'll take a look ASAP. -- This is an automated message from the Apache Git Service. To respond to the mess

[jira] [Updated] (FLINK-34960) NullPointerException while applying parallelism overrides for session jobs

2024-04-02 Thread Kunal Rohitas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kunal Rohitas updated FLINK-34960: -- Description: While using the autoscaler for session jobs, the operator throws a NullPointerEx

Re: [PR] [FLINK-34690] Cast decimal to VARCHAR/INT/BIGINT/LARGEINT as primary … [flink-cdc]

2024-04-02 Thread via GitHub
yuxiqian commented on code in PR #3150: URL: https://github.com/apache/flink-cdc/pull/3150#discussion_r1547462148 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/CdcDataTypeTransformer

Re: [PR] [FLINK-34690] Cast decimal to VARCHAR/INT/BIGINT/LARGEINT as primary … [flink-cdc]

2024-04-02 Thread via GitHub
yuxiqian commented on code in PR #3150: URL: https://github.com/apache/flink-cdc/pull/3150#discussion_r1547451624 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java: #

Re: [PR] [FLINK-34690] Cast decimal to VARCHAR/INT/BIGINT/LARGEINT as primary … [flink-cdc]

2024-04-02 Thread via GitHub
yuxiqian commented on code in PR #3150: URL: https://github.com/apache/flink-cdc/pull/3150#discussion_r1547445765 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java: #

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: api [flink]

2024-04-02 Thread via GitHub
GOODBOY008 commented on PR #24603: URL: https://github.com/apache/flink/pull/24603#issuecomment-2031475327 I have compared https://github.com/apache/flink/actions/runs/8395180921/job/22994258945 (flink master) and https://github.com/GOODBOY008/flink/actions/runs/8517183618/job/23327527159

[jira] [Updated] (FLINK-34969) Error due to Flink CDC using deprecated flink-conf.yaml in light of Flink's full YAML 1.2 support since version 1.19

2024-04-02 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-34969: -- Fix Version/s: cdc-3.1.0 > Error due to Flink CDC using deprecated flink-conf.yaml in light of

[jira] [Assigned] (FLINK-34969) Error due to Flink CDC using deprecated flink-conf.yaml in light of Flink's full YAML 1.2 support since version 1.19

2024-04-02 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-34969: - Assignee: skymilong > Error due to Flink CDC using deprecated flink-conf.yaml in light

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

2024-04-02 Thread Hunter Medney (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833077#comment-17833077 ] Hunter Medney commented on FLINK-25649: --- I was seeing this issue consistently, and

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-02 Thread via GitHub
spoon-lz commented on PR #24461: URL: https://github.com/apache/flink/pull/24461#issuecomment-2031422386 @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.

  1   2   >