[GitHub] [flink] xintongsong commented on pull request #22960: [FLINK-32549][network] Tiered storage memory manager supports ownership transfer for buffers

2023-07-08 Thread via GitHub
xintongsong commented on PR #22960: URL: https://github.com/apache/flink/pull/22960#issuecomment-1627617148 @TanYuxin-tyx, I have 2 questions regarding the current approach. 1. The transfer of the buffer ownership seems to be divided into two steps: a) updating the buffer recycler, and b)

[GitHub] [flink] xintongsong commented on a diff in pull request #22855: [FLINK-31647][network] Introduce the RemoteTierConsumerAgent

2023-07-08 Thread via GitHub
xintongsong commented on code in PR #22855: URL: https://github.com/apache/flink/pull/22855#discussion_r1257405998 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/disk/DiskTierConsumerAgent.java: ## @@ -42,6 +44,8 @@ public class D

[GitHub] [flink] hanyuzheng7 commented on pull request #22834: [FLINK-32260][table] Add built-in ARRAY_SLICE function.

2023-07-08 Thread via GitHub
hanyuzheng7 commented on PR #22834: URL: https://github.com/apache/flink/pull/22834#issuecomment-1627426328 Thank you @snuyanzin, I learned a lots from your comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-32565) Support cast from BYTES to DOUBLE

2023-07-08 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32565: Description: We are undertaking a task that requires casting from the BYTES type to DOUBLE. In pa

[jira] [Updated] (FLINK-32564) Support cast from BYTES to BIGINT

2023-07-08 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hanyu Zheng updated FLINK-32564: Description: We are dealing with a task that requires casting from the BYTES type to BIGINT. Spec

[jira] (FLINK-32565) Support cast from BYTES to DOUBLE

2023-07-08 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32565 ] Hanyu Zheng deleted comment on FLINK-32565: - was (Author: JIRAUSER300701): [~martijnvisser] can you please assign this ticket to [~hanyuzheng] ? > Support cast from BYTES to DOUBLE > ---

[jira] (FLINK-32564) Support cast from BYTES to BIGINT

2023-07-08 Thread Hanyu Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32564 ] Hanyu Zheng deleted comment on FLINK-32564: - was (Author: JIRAUSER300701): [~martijnvisser] can you please assign this ticket to [~hanyuzheng] ? > Support cast from BYTES to BIGINT > ---

[GitHub] [flink] liuyongvs commented on pull request #22745: [FLINK-31691][table] Add built-in MAP_FROM_ENTRIES function.

2023-07-08 Thread via GitHub
liuyongvs commented on PR #22745: URL: https://github.com/apache/flink/pull/22745#issuecomment-1627241981 Hi @snuyanzin will it be merged 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

[jira] [Commented] (FLINK-24588) Optimisation of chained cast calls can lead to unexpected behaviour

2023-07-08 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741270#comment-17741270 ] Sergey Nuyanzin commented on FLINK-24588: - Calcite dependency bumped to 1.31.0 a

[jira] [Assigned] (FLINK-24588) Optimisation of chained cast calls can lead to unexpected behaviour

2023-07-08 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-24588: --- Assignee: Sergey Nuyanzin > Optimisation of chained cast calls can lead to unexpect

[jira] [Resolved] (FLINK-32260) Add ARRAY_SLICE support in SQL & Table API

2023-07-08 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-32260. - Resolution: Fixed Merged to master as [e6e0f47bf3e7f7541da9e7be009cc6dcf4d86129|https:/

[GitHub] [flink] snuyanzin commented on pull request #22834: [FLINK-32260][table] Add built-in ARRAY_SLICE function.

2023-07-08 Thread via GitHub
snuyanzin commented on PR #22834: URL: https://github.com/apache/flink/pull/22834#issuecomment-1627059380 Thanks for the PR @hanyuzheng7 -- 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 speci

[GitHub] [flink] snuyanzin merged pull request #22834: [FLINK-32260][table] Add built-in ARRAY_SLICE function.

2023-07-08 Thread via GitHub
snuyanzin merged PR #22834: URL: https://github.com/apache/flink/pull/22834 -- 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.apa

[jira] [Created] (FLINK-32566) HeapBytesVector meets java.lang.NegativeArraySizeException

2023-07-08 Thread Yuan Kui (Jira)
Yuan Kui created FLINK-32566: Summary: HeapBytesVector meets java.lang.NegativeArraySizeException Key: FLINK-32566 URL: https://issues.apache.org/jira/browse/FLINK-32566 Project: Flink Issue Type

[jira] [Comment Edited] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-07-08 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741256#comment-17741256 ] Sergey Nuyanzin edited comment on FLINK-32296 at 7/8/23 8:50 AM: -

[jira] [Commented] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-07-08 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741256#comment-17741256 ] Sergey Nuyanzin commented on FLINK-32296: - [~qingwei91] this error means that yo

[jira] [Comment Edited] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-07-08 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741252#comment-17741252 ] Lim Qing Wei edited comment on FLINK-32296 at 7/8/23 8:38 AM:

[jira] [Commented] (FLINK-32296) Flink SQL handle array of row incorrectly

2023-07-08 Thread Lim Qing Wei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741252#comment-17741252 ] Lim Qing Wei commented on FLINK-32296: -- Hi [~Sergey Nuyanzin] , I am not able to bu