[jira] [Assigned] (FLINK-38063) Update dependencies in the Flink Connector Kafka Project

2025-07-16 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-38063: --- Assignee: Thomas Cooper > Update dependencies in the Flink Connector Kafka Project > --

[jira] [Commented] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters

2025-07-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007728#comment-18007728 ] ouyangwulin commented on FLINK-38110: - !image-2025-07-17-14-53-02-657.png! It seems

[jira] [Updated] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters

2025-07-16 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-38110: Attachment: image-2025-07-17-14-53-02-657.png > PostgreSQL connector reads Chinese columns with ga

Re: [PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink]

2025-07-16 Thread via GitHub
fapaul commented on code in PR #26802: URL: https://github.com/apache/flink/pull/26802#discussion_r2212446505 ## flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/ValueDataTypeConverterTest.java: ## @@ -60,6 +60,9 @@ private static Stream testData() {

Re: [PR] [FLINK-36465] Bump okhttp3 to 4.12.0 [flink]

2025-07-16 Thread via GitHub
github-actions[bot] commented on PR #26472: URL: https://github.com/apache/flink/pull/26472#issuecomment-3082741557 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

[jira] [Resolved] (FLINK-37990) [Umbrella] Test Flink Release 2.1

2025-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-37990. --- Fix Version/s: 2.1.0 Resolution: Fixed > [Umbrella] Test Flink Release 2.1 >

[jira] [Resolved] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin

2025-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-38029. --- Assignee: Shuai Xu Resolution: Fixed > Release Testing: Verify FLIP-486: Introduce a new Delta

[jira] [Commented] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin

2025-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007722#comment-18007722 ] dalongliu commented on FLINK-38029: --- Thanks for [~xu_shuai_], closed it. > Release Te

[jira] [Updated] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters

2025-07-16 Thread haiqingchen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] haiqingchen updated FLINK-38110: Description: When there's column name in Chinese in PG tables, Postgresql connector with pgoutput

[jira] [Updated] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters

2025-07-16 Thread haiqingchen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] haiqingchen updated FLINK-38110: Description: When there's column name in Chinese in PG tables, Postgresql connector with pgoutput

[jira] [Created] (FLINK-38110) PostgreSQL connector reads Chinese columns with garbled characters

2025-07-16 Thread haiqingchen (Jira)
haiqingchen created FLINK-38110: --- Summary: PostgreSQL connector reads Chinese columns with garbled characters Key: FLINK-38110 URL: https://issues.apache.org/jira/browse/FLINK-38110 Project: Flink

[jira] [Comment Edited] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin

2025-07-16 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007720#comment-18007720 ] Shuai Xu edited comment on FLINK-38029 at 7/17/25 6:14 AM: --- I

[jira] [Commented] (FLINK-38029) Release Testing: Verify FLIP-486: Introduce a new DeltaJoin

2025-07-16 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007720#comment-18007720 ] Shuai Xu commented on FLINK-38029: -- I have conducted cross testing on FLIP-486, and the

[jira] [Closed] (FLINK-38098) When submitting a task with the flink run command, adding the -sae parameter will cause the task to be killed

2025-07-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-38098. Fix Version/s: 2.1.0 2.0.1 1.20.3 Resolution: Fixed -

Re: [PR] [FLINK-38098][Runtime] Fix JobClientHeartbeatRequestBody deserialization error [flink]

2025-07-16 Thread via GitHub
xintongsong merged PR #26800: URL: https://github.com/apache/flink/pull/26800 -- 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] [Updated] (FLINK-37867) ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying

2025-07-16 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-37867: Fix Version/s: 2.0.1 > ForSt StateBackend fail to clean up files of the half-uploaded checkpoint

[jira] [Commented] (FLINK-37867) ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying

2025-07-16 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007703#comment-18007703 ] Zakelly Lan commented on FLINK-37867: - Merge da38a9810b816c59b14cbedf514d13bb47d094a

Re: [PR] [BP-2.0][FLINK-37867][state/forst] Ensure files of half-uploaded checkpoints are cleaned when using path copying [flink]

2025-07-16 Thread via GitHub
Zakelly merged PR #26759: URL: https://github.com/apache/flink/pull/26759 -- 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.apach

Re: [PR] [Python] Support for Event containing Row field can be json serializable [flink-agents]

2025-07-16 Thread via GitHub
wenjin272 commented on PR #63: URL: https://github.com/apache/flink-agents/pull/63#issuecomment-3082284343 Thanks for your contribution, @Kavishankarks. LGTM. @xintongsong Please take a look at your convenience -- This is an automated message from the Apache Git Service. To respond to

[jira] [Resolved] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator

2025-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-38052. --- Resolution: Fixed > Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator > --

[jira] [Commented] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator

2025-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007700#comment-18007700 ] dalongliu commented on FLINK-38052: --- Closed it. > Release Testing: Verify FLIP-516: N

[jira] [Commented] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator

2025-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007699#comment-18007699 ] dalongliu commented on FLINK-38052: --- Thanks, [~kartikeypant], great job. >> Additiona

[jira] [Comment Edited] (FLINK-38073) Add documentation for the MultiJoin Operator

2025-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007692#comment-18007692 ] dalongliu edited comment on FLINK-38073 at 7/17/25 2:02 AM:

[jira] [Resolved] (FLINK-38073) Add documentation for the MultiJoin Operator

2025-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-38073. --- Resolution: Fixed > Add documentation for the MultiJoin Operator > -

[jira] [Commented] (FLINK-38073) Add documentation for the MultiJoin Operator

2025-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007692#comment-18007692 ] dalongliu commented on FLINK-38073: --- Merged in master: a7aabb8c8a386580f0be3e4681971e8

[jira] [Updated] (FLINK-38073) Add documentation for the MultiJoin Operator

2025-07-16 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-38073: -- Fix Version/s: 2.1.0 2.2.0 > Add documentation for the MultiJoin Operator > ---

Re: [PR] [FLINK-38073][docs] Add documentation for the MultiJoin operator [flink]

2025-07-16 Thread via GitHub
lsyldliu merged PR #26775: URL: https://github.com/apache/flink/pull/26775 -- 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] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host

2025-07-16 Thread Rosa Seohwa Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rosa Seohwa Kang updated FLINK-38109: - Description: In a flink cluster, if the JobManager bind-host is configured with an addre

[jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host

2025-07-16 Thread Rosa Seohwa Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rosa Seohwa Kang updated FLINK-38109: - Description: In a flink cluster, if the JobManager bind-host is configured with an addre

[jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host

2025-07-16 Thread Rosa Seohwa Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rosa Seohwa Kang updated FLINK-38109: - Description: In a flink cluster, if the JobManager bind-host is configured with an addre

[jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host

2025-07-16 Thread Rosa Seohwa Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rosa Seohwa Kang updated FLINK-38109: - Description: package com.shopify.flink.examples.functions.asynchttpfunction;   import or

[jira] [Updated] (FLINK-38109) BlobServer isn't associated with the correct bind-host

2025-07-16 Thread Rosa Seohwa Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rosa Seohwa Kang updated FLINK-38109: - Environment: (was: !image-2025-07-16-18-23-30-302.png|width=654,height=135!) > Blob

[jira] [Created] (FLINK-38109) BlobServer isn't associated with the correct bind-host

2025-07-16 Thread Rosa Seohwa Kang (Jira)
Rosa Seohwa Kang created FLINK-38109: Summary: BlobServer isn't associated with the correct bind-host Key: FLINK-38109 URL: https://issues.apache.org/jira/browse/FLINK-38109 Project: Flink

[jira] [Comment Edited] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator

2025-07-16 Thread Kartikey Pant (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007649#comment-18007649 ] Kartikey Pant edited comment on FLINK-38052 at 7/16/25 7:32 PM: --

[jira] [Comment Edited] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator

2025-07-16 Thread Kartikey Pant (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007649#comment-18007649 ] Kartikey Pant edited comment on FLINK-38052 at 7/16/25 7:31 PM: --

[jira] [Comment Edited] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator

2025-07-16 Thread Kartikey Pant (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007649#comment-18007649 ] Kartikey Pant edited comment on FLINK-38052 at 7/16/25 7:26 PM: --

[jira] [Comment Edited] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator

2025-07-16 Thread Kartikey Pant (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007649#comment-18007649 ] Kartikey Pant edited comment on FLINK-38052 at 7/16/25 7:26 PM: --

[jira] [Commented] (FLINK-38052) Release Testing: Verify FLIP-516: New Streaming Multi-Way Join Operator

2025-07-16 Thread Kartikey Pant (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007649#comment-18007649 ] Kartikey Pant commented on FLINK-38052: --- Hi team, I have completed the release te

Re: [PR] [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging [flink]

2025-07-16 Thread via GitHub
rmetzger commented on PR #26803: URL: https://github.com/apache/flink/pull/26803#issuecomment-3079911814 Please run mvn spotless:apply to make sure the code is properly formatted: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=68903&view=logs&j=52b61abe-a3cc-5bde-cc35

Re: [PR] [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging [flink]

2025-07-16 Thread via GitHub
rmetzger commented on code in PR #26803: URL: https://github.com/apache/flink/pull/26803#discussion_r2211303565 ## flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java: ## @@ -544,4 +541,23 @@ public void run() { } } } + +/

Re: [PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink]

2025-07-16 Thread via GitHub
dylanhz commented on code in PR #26802: URL: https://github.com/apache/flink/pull/26802#discussion_r2211187990 ## flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/ValueDataTypeConverterTest.java: ## @@ -60,6 +60,9 @@ private static Stream testData() {

Re: [PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink]

2025-07-16 Thread via GitHub
dylanhz commented on code in PR #26802: URL: https://github.com/apache/flink/pull/26802#discussion_r2211187990 ## flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/ValueDataTypeConverterTest.java: ## @@ -60,6 +60,9 @@ private static Stream testData() {

Re: [PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink]

2025-07-16 Thread via GitHub
dylanhz commented on code in PR #26802: URL: https://github.com/apache/flink/pull/26802#discussion_r229972 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/ValueDataTypeConverter.java: ## @@ -122,16 +122,17 @@ private static DataType convert

Re: [PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink]

2025-07-16 Thread via GitHub
dylanhz commented on PR #26802: URL: https://github.com/apache/flink/pull/26802#issuecomment-3079640437 > Changes look good to me. Can you also update > > https://github.com/apache/flink/blob/352c9d2498f15c8c21a83db6bfad7077e5807800/docs/content/docs/dev/table/types.md?plain=1#L395

Re: [PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink]

2025-07-16 Thread via GitHub
davidradl commented on code in PR #26802: URL: https://github.com/apache/flink/pull/26802#discussion_r2210873321 ## flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/ValueDataTypeConverterTest.java: ## @@ -60,6 +60,9 @@ private static Stream testData() {

Re: [PR] [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging [flink]

2025-07-16 Thread via GitHub
flinkbot commented on PR #26803: URL: https://github.com/apache/flink/pull/26803#issuecomment-3079030181 ## CI report: * 27427baee05c22ff837822fadfc2ba11d5290349 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-38035][Python][PythonEnvUtils] Redact sensitive env vars in PythonEnvUtils logging [flink]

2025-07-16 Thread via GitHub
vssakuru opened a new pull request, #26803: URL: https://github.com/apache/flink/pull/26803 ## What is the purpose of the change This pull request addresses a security concern in PyFlink’s environment logging. Previously, all environment variables were logged in plaintext when

Re: [PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink]

2025-07-16 Thread via GitHub
davidradl commented on code in PR #26802: URL: https://github.com/apache/flink/pull/26802#discussion_r2210624071 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/ValueDataTypeConverter.java: ## @@ -122,16 +122,17 @@ private static DataType conve

Re: [I] [Feature][api] Support ReAct Agent [flink-agents]

2025-07-16 Thread via GitHub
kitalkuyo-gita commented on issue #57: URL: https://github.com/apache/flink-agents/issues/57#issuecomment-3078769220 # Technical Design for Supporting ReAct Agent Feature ## 1. Current Architecture Analysis Apache Flink Agents currently uses an event-driven architecture , with

[PR] [plan][runtime][python] Introduce Resource and Resource Provider in java [flink-agents]

2025-07-16 Thread via GitHub
kitalkuyo-gita opened a new pull request, #71: URL: https://github.com/apache/flink-agents/pull/71 ### Purpose of change Related to ISSUE#69 - Create Resource and ResourceProvider interfaces - Implement the basic AbstractResource class - Create ResourceManager class ### Tes

Re: [I] [Feature][plan][runtime][python] Introduce Resource and Resource Provider in java [flink-agents]

2025-07-16 Thread via GitHub
kitalkuyo-gita commented on issue #69: URL: https://github.com/apache/flink-agents/issues/69#issuecomment-3078617951 # Resource and Resource Provider Feature Design Proposal Based on my analysis of the Apache Flink Agents codebase, I've designed a comprehensive proposal for introducin

Re: [PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink]

2025-07-16 Thread via GitHub
dylanhz commented on PR #26802: URL: https://github.com/apache/flink/pull/26802#issuecomment-3078254071 > Changes look good to me. Can you also update > > https://github.com/apache/flink/blob/352c9d2498f15c8c21a83db6bfad7077e5807800/docs/content/docs/dev/table/types.md?plain=1#L395

[PR] [plan][runtime][python] Introduce Resource and Resource Provider in p… [flink-agents]

2025-07-16 Thread via GitHub
wenjin272 opened a new pull request, #70: URL: https://github.com/apache/flink-agents/pull/70 Linked issue: #68 ### Purpose of change Introduce Resource and Resource Provider in python ### Tests Unit test ### API Yes, add Resource and ResourceProvide

[I] [Feature][plan][runtime][python] Introduce Resource and Resource Provider in java [flink-agents]

2025-07-16 Thread via GitHub
wenjin272 opened a new issue, #69: URL: https://github.com/apache/flink-agents/issues/69 ### Search before asking - [x] I searched in the [issues](https://github.com/apache/flink-agents/issues) and found nothing similar. ### Description Introduce Resource and Resource P

[I] [Feature][plan][runtime][python] Introduce Resource and Resource Provider in python [flink-agents]

2025-07-16 Thread via GitHub
wenjin272 opened a new issue, #68: URL: https://github.com/apache/flink-agents/issues/68 ### Search before asking - [x] I searched in the [issues](https://github.com/apache/flink-agents/issues) and found nothing similar. ### Description Introduce Resource and Resource P

Re: [PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink]

2025-07-16 Thread via GitHub
flinkbot commented on PR #26802: URL: https://github.com/apache/flink/pull/26802#issuecomment-3077920901 ## CI report: * 29a2241b85a22b107306a4669a7e04c027e850c4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL

2025-07-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-38108: --- Labels: pull-request-available (was: ) > Incorrect conversion from Java BigDecimal to SQL D

[PR] [FLINK-38108][table] Fix incorrect conversion from Java BigDecimal to SQL DECIMAL [flink]

2025-07-16 Thread via GitHub
dylanhz opened a new pull request, #26802: URL: https://github.com/apache/flink/pull/26802 ## What is the purpose of the change Fix incorrect precision conversion from Java BigDecimal to SQL DECIMAL in Table API. ## Brief change log This change aligns the precision conve

[jira] [Commented] (FLINK-38083) OBJECT_OF function's type don't get inferred correctly during comparison

2025-07-16 Thread Ramin Gharib (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007526#comment-18007526 ] Ramin Gharib commented on FLINK-38083: -- [~maheshsambaram] Hello, You still need to

[jira] [Updated] (FLINK-38083) OBJECT_OF function's type don't get inferred correctly during comparison

2025-07-16 Thread Ramin Gharib (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ramin Gharib updated FLINK-38083: - Description: Whenever we compare a structure type in the example below with one that was create

[jira] [Updated] (FLINK-38083) OBJECT_OF function's type don't get inferred correctly during comparison

2025-07-16 Thread Ramin Gharib (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ramin Gharib updated FLINK-38083: - Description: Whenever we compare a structure type in the example below with one that was create

[jira] [Assigned] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL

2025-07-16 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-38108: --- Assignee: dylanhz > Incorrect conversion from Java BigDecimal to SQL DECIMAL >

[jira] [Commented] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL

2025-07-16 Thread dylanhz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007520#comment-18007520 ] dylanhz commented on FLINK-38108: - [~fpaul] I'm working on a fix for this. Could you ple

Re: [PR] [Feature][api][runtime] Support Short-Term Memory [flink-agents]

2025-07-16 Thread via GitHub
codenohup commented on code in PR #67: URL: https://github.com/apache/flink-agents/pull/67#discussion_r2209627514 ## python/flink_agents/api/memoryobject.py: ## @@ -0,0 +1,116 @@ + +# Licensed to th

[jira] [Commented] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL

2025-07-16 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18007518#comment-18007518 ] Fabian Paul commented on FLINK-38108: - [~dylanhz] thanks for opening the ticket. Are

[jira] [Created] (FLINK-38108) Incorrect conversion from Java BigDecimal to SQL DECIMAL

2025-07-16 Thread dylanhz (Jira)
dylanhz created FLINK-38108: --- Summary: Incorrect conversion from Java BigDecimal to SQL DECIMAL Key: FLINK-38108 URL: https://issues.apache.org/jira/browse/FLINK-38108 Project: Flink Issue Type: Bu

Re: [PR] [FLINK-38044][runtime-web] update angular to v19 [flink]

2025-07-16 Thread via GitHub
Laffery commented on PR #26801: URL: https://github.com/apache/flink/pull/26801#issuecomment-3077503840 > The initial contribution of a change should be made to master and then backported appropriately. > > Can I check why we have not gone for Angular 20 which now has a stable releas

[PR] [Feature][api][runtime] Support Short-Term Memory [flink-agents]

2025-07-16 Thread via GitHub
KeGu-069 opened a new pull request, #67: URL: https://github.com/apache/flink-agents/pull/67 Linked issue: #55 ### Purpose of change This pr introduces the short-term memory api and wires it into the operator/runtime layer. ### Tests ### API