[PR] FLINK-37881: Drop gosu in favour of Dockerfile USER [flink-docker]

2025-05-31 Thread via GitHub
avi-sanwal opened a new pull request, #225: URL: https://github.com/apache/flink-docker/pull/225 This is a minor improvement from security standpoint on flink's docker image. In the dockerfile of flink's docker image, we are adding gosu: https://github.com/apache/flink-docker/blob/

Re: [PR] [hotfix] fix data race in method `drain()` in `TaskMailboxImpl.java` [flink]

2025-05-31 Thread via GitHub
github-actions[bot] commented on PR #26219: URL: https://github.com/apache/flink/pull/26219#issuecomment-2926651059 This PR is being marked as stale since it has not had any activity in the last 90 days. If you would like to keep this PR alive, please leave a comment asking for a review

Re: [PR] [FLINK-25521][docs] Fix the composition description of 'INTERVAL DAY TO SECOND' in the data type [flink]

2025-05-31 Thread via GitHub
github-actions[bot] closed pull request #18267: [FLINK-25521][docs] Fix the composition description of 'INTERVAL DAY TO SECOND' in the data type URL: https://github.com/apache/flink/pull/18267 -- This is an automated message from the Apache Git Service. To respond to the message, please log o

Re: [PR] [FLINK-25521][docs] Fix the composition description of 'INTERVAL DAY TO SECOND' in the data type [flink]

2025-05-31 Thread via GitHub
github-actions[bot] commented on PR #18267: URL: https://github.com/apache/flink/pull/18267#issuecomment-2926650624 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel fre

[jira] [Updated] (FLINK-37881) Drop gosu in favour of Dockerfile's USER

2025-05-31 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37881: --- Labels: pull-request-available (was: ) > Drop gosu in favour of Dockerfile's USER > ---

Re: [PR] [FLINK-37791][6/N] model sql to rel converter [flink]

2025-05-31 Thread via GitHub
lihaosky commented on code in PR #26603: URL: https://github.com/apache/flink/pull/26603#discussion_r2118375538 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalMLPredictTableFunctionRule.java: ## @@ -0,0 +1

Re: [PR] [FLINK-36442][postgres-cdc] Add insert-only change stream option [flink-cdc]

2025-05-31 Thread via GitHub
github-actions[bot] commented on PR #3629: URL: https://github.com/apache/flink-cdc/pull/3629#issuecomment-2926049747 This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encou

Re: [PR] [FLINK-36442][postgres-cdc] Add insert-only change stream option [flink-cdc]

2025-05-31 Thread via GitHub
github-actions[bot] closed pull request #3629: [FLINK-36442][postgres-cdc] Add insert-only change stream option URL: https://github.com/apache/flink-cdc/pull/3629 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc]

2025-05-31 Thread via GitHub
phamvinh1712 commented on PR #4004: URL: https://github.com/apache/flink-cdc/pull/4004#issuecomment-2925691301 hi @loserwang1024 , i've updated the option name based on your suggestion -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [FLINK-37851][state] Migrate state processor API from source API v1 to source API v2 [flink]

2025-05-31 Thread via GitHub
gaborgsomogyi commented on PR #26620: URL: https://github.com/apache/flink/pull/26620#issuecomment-2925250460 cc @gyfora -- 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

Re: [PR] [WIP][FLINK-37851][state] Migrate state processor API from source API v1 to source API v2 [flink]

2025-05-31 Thread via GitHub
gaborgsomogyi commented on PR #26620: URL: https://github.com/apache/flink/pull/26620#issuecomment-2925249527 Rebased to master and added the enrichment so it's final from my point of view. -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] Upgrade to JOSDK 5.1 [flink-kubernetes-operator]

2025-05-31 Thread via GitHub
gyfora commented on code in PR #982: URL: https://github.com/apache/flink-kubernetes-operator/pull/982#discussion_r2117900754 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EventSourceUtils.java: ## @@ -114,8 +115,8 @@ public static Inform

[jira] [Created] (FLINK-37881) Drop gosu in favour of Dockerfile's USER

2025-05-31 Thread Avi Sanwal (Jira)
Avi Sanwal created FLINK-37881: -- Summary: Drop gosu in favour of Dockerfile's USER Key: FLINK-37881 URL: https://issues.apache.org/jira/browse/FLINK-37881 Project: Flink Issue Type: Improvement

Re: [PR] [WIP][FLINK-37851][state] Migrate state processor API from source API v1 to source API v2 [flink]

2025-05-31 Thread via GitHub
gaborgsomogyi commented on PR #26620: URL: https://github.com/apache/flink/pull/26620#issuecomment-2925129561 I've just tested it on load and both streaming and batch execution mode works fine with the same performance. Now enrichment is the missing piece. -- This is an automated message

Re: [PR] [FLINK-37791][6/N] model sql to rel converter [flink]

2025-05-31 Thread via GitHub
fsk119 commented on code in PR #26603: URL: https://github.com/apache/flink/pull/26603#discussion_r2117617720 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalMLPredictTableFunction.java: ## @@ -0,0 +1,76 @@

Re: [PR] [FLINK-37791][6/N] model sql to rel converter [flink]

2025-05-31 Thread via GitHub
fsk119 commented on code in PR #26603: URL: https://github.com/apache/flink/pull/26603#discussion_r2117608943 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/catalog/CatalogSchemaModel.java: ## @@ -85,4 +109,34 @@ private static RelDataType schema

[jira] [Assigned] (FLINK-37872) Autoscaler computes negative true processing rate

2025-05-31 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-37872: -- Assignee: Sai Sharath Dandi > Autoscaler computes negative true processing rate > ---

[jira] [Commented] (FLINK-37872) Autoscaler computes negative true processing rate

2025-05-31 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955376#comment-17955376 ] Gyula Fora commented on FLINK-37872: Thank you for reporting the issue, assigned it

[PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [2.0] [flink]

2025-05-31 Thread via GitHub
AHeise opened a new pull request, #26621: URL: https://github.com/apache/flink/pull/26621 Unchanged backport of #26601 -- 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 u

Re: [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [2.0] [flink]

2025-05-31 Thread via GitHub
flinkbot commented on PR #26621: URL: https://github.com/apache/flink/pull/26621#issuecomment-2924608780 ## CI report: * 85abb7184003a410da0c744f14c6d5e00228473f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [WIP][FLINK-37851][state] Migrate state processor API from source API v1 to source API v2 [flink]

2025-05-31 Thread via GitHub
gaborgsomogyi commented on PR #26620: URL: https://github.com/apache/flink/pull/26620#issuecomment-2924606840 cc @Zakelly high scale tests are ongoing + the actual version not yet contains the `rich` trick what we've spoken about. First I would like to reach a rock stable state and then mak

[jira] [Commented] (FLINK-37856) Sink option hints are not present in compiled plan

2025-05-31 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955369#comment-17955369 ] Arvid Heise commented on FLINK-37856: - Merged into main as 986ab86. > Sink option h

[jira] [Updated] (FLINK-37856) Sink option hints are not present in compiled plan

2025-05-31 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-37856: Fix Version/s: 2.1.0 > Sink option hints are not present in compiled plan > --

Re: [PR] [FLINK-37856] Ensure sink option hints are present in compiled plan [flink]

2025-05-31 Thread via GitHub
AHeise merged PR #26601: URL: https://github.com/apache/flink/pull/26601 -- 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.apache