[jira] [Closed] (FLINK-34094) Document new AsyncScalarFunction

2025-07-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34094. Fix Version/s: 2.1.1 Resolution: Fixed Fixed in master: 7910e519fdcd78de29be4154ca23da87e31

[jira] [Closed] (FLINK-38140) Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations

2025-07-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-38140. Fix Version/s: 2.2.0 Assignee: Alan Sheinberg Resolution: Fixed Fixed in master: 1

[jira] [Closed] (FLINK-38136) Add restore tests for PTFs

2025-07-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-38136. Fix Version/s: 2.2.0 Resolution: Fixed Fixed in master: 0c64dcf203ba017604d8bdf37482667d2e0

[jira] [Assigned] (FLINK-38136) Add restore tests for PTFs

2025-07-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-38136: Assignee: Ramin Gharib > Add restore tests for PTFs > -- > >

[jira] [Closed] (FLINK-38149) Convert COLUMN_LIST to DescriptorType

2025-07-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-38149. Fix Version/s: 2.1.1 Assignee: Ramin Gharib Resolution: Fixed Fixed in release-2.1

[jira] [Updated] (FLINK-38149) Convert COLUMN_LIST to DescriptorType

2025-07-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-38149: - Parent: FLINK-36703 Issue Type: Sub-task (was: Bug) > Convert COLUMN_LIST to Descriptor

[jira] [Updated] (FLINK-37914) Implement OBJECT_UPDATE Function for In-Place Modification of Structured Types

2025-07-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37914: - Component/s: Table SQL / Runtime (was: Table SQL / Planner) > Implement OBJ

[jira] [Updated] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction

2025-07-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37913: - Component/s: Table SQL / API Table SQL / Planner > Implement OBJECT_OF Functio

[jira] [Updated] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction

2025-07-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37913: - Component/s: Table SQL / Runtime (was: Table SQL / Planner) > Implement OB

[jira] [Closed] (FLINK-37914) Implement OBJECT_UPDATE Function for In-Place Modification of Structured Types

2025-07-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37914. Fix Version/s: 2.2.0 Assignee: Ramin Gharib Resolution: Fixed Fixed in master: 568

[jira] [Updated] (FLINK-37914) Implement OBJECT_UPDATE Function for In-Place Modification of Structured Types

2025-07-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37914: - Component/s: Table SQL / API Table SQL / Planner > Implement OBJECT_UPDATE Func

[jira] [Closed] (FLINK-37913) Implement OBJECT_OF Function for Structured Type Value Construction

2025-07-17 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37913. Fix Version/s: 2.2.0 Assignee: Ramin Gharib Resolution: Fixed Fixed in master: 71f

[jira] [Closed] (FLINK-38103) DataTypeFactory cannot restore inline structured types

2025-07-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-38103. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 75355decc3fe2684ae4f366cf782a5fcb4b

[jira] [Created] (FLINK-38103) DataTypeFactory cannot restore inline structured types

2025-07-14 Thread Timo Walther (Jira)
Timo Walther created FLINK-38103: Summary: DataTypeFactory cannot restore inline structured types Key: FLINK-38103 URL: https://issues.apache.org/jira/browse/FLINK-38103 Project: Flink Issue

[jira] [Closed] (FLINK-38090) TableResult.collect() returns incorrect SQL inline structured types

2025-07-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-38090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-38090. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 03530b6085deb016a6dbca9b92825cc

[jira] [Created] (FLINK-38090) TableResult.collect() returns incorrect SQL inline structured types

2025-07-11 Thread Timo Walther (Jira)
Timo Walther created FLINK-38090: Summary: TableResult.collect() returns incorrect SQL inline structured types Key: FLINK-38090 URL: https://issues.apache.org/jira/browse/FLINK-38090 Project: Flink

[jira] [Commented] (FLINK-37861) FLIP-520: Simplify StructuredType handling

2025-07-11 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18004651#comment-18004651 ] Timo Walther commented on FLINK-37861: -- [~lsy] I updated the release notes of FLINK

[jira] [Updated] (FLINK-37862) Implement data type improvements for StructuredType

2025-07-11 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37862: - Release Note: Inline structured types can be created in SQL now using type strings like `STRUCTU

[jira] [Commented] (FLINK-37974) Avoid confusion when declaring table arguments

2025-06-25 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17986250#comment-17986250 ] Timo Walther commented on FLINK-37974: -- See discussion here: https://lists.apache.

[jira] [Closed] (FLINK-37962) Implement visitMultiJoin for RelTimeIndicatorConverter

2025-06-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37962. Fix Version/s: 2.1.0 Assignee: Gustavo de Morais Resolution: Fixed Fixed in master

[jira] [Created] (FLINK-37974) Avoid confusion when declaring table arguments

2025-06-19 Thread Timo Walther (Jira)
Timo Walther created FLINK-37974: Summary: Avoid confusion when declaring table arguments Key: FLINK-37974 URL: https://issues.apache.org/jira/browse/FLINK-37974 Project: Flink Issue Type: Su

[jira] [Assigned] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests

2025-06-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-37966: Assignee: Gustavo de Morais > Add Semantic, Restore, Rel and ExecPlan Tests > ---

[jira] [Closed] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests

2025-06-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37966. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: f7f96af5355f0bc20e3c0e251bd75657b13

[jira] [Closed] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin

2025-06-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37965. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: f7f96af5355f0bc20e3c0e251bd75657b13

[jira] [Assigned] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule

2025-06-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-37889: Assignee: Gustavo de Morais > Add new FlinkJoinToFlinkMultiJoinRule rule > --

[jira] [Closed] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule

2025-06-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37889. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: f7f96af5355f0bc20e3c0e251bd75657b13

[jira] [Assigned] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin

2025-06-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-37965: Assignee: Gustavo de Morais > Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin >

[jira] [Commented] (FLINK-37956) Update SQL gateway for inline structured types

2025-06-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17979241#comment-17979241 ] Timo Walther commented on FLINK-37956: -- [~shengkai] could you find an owner for thi

[jira] [Assigned] (FLINK-37956) Update SQL gateway for inline structured types

2025-06-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-37956: Assignee: (was: Timo Walther) > Update SQL gateway for inline structured types >

[jira] [Created] (FLINK-37956) Update SQL gateway for inline structured types

2025-06-15 Thread Timo Walther (Jira)
Timo Walther created FLINK-37956: Summary: Update SQL gateway for inline structured types Key: FLINK-37956 URL: https://issues.apache.org/jira/browse/FLINK-37956 Project: Flink Issue Type: Su

[jira] [Closed] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram

2025-06-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37945. Fix Version/s: 2.1.0 Assignee: Gustavo de Morais Resolution: Fixed Fixed in master

[jira] [Assigned] (FLINK-37916) Add StreamPhysicalMultiJoin physical node

2025-06-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-37916: Assignee: Gustavo de Morais > Add StreamPhysicalMultiJoin physical node > --

[jira] [Closed] (FLINK-37916) Add StreamPhysicalMultiJoin physical node

2025-06-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37916. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 4280dbd01d25e30290fc13ee8f309cb9861

[jira] [Updated] (FLINK-37814) Add RIGHT JOIN to LEFT JOIN rule

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37814: - Summary: Add RIGHT JOIN to LEFT JOIN rule (was: FLIP-516: Add RIGHT JOIN to LEFT JOIN rule) >

[jira] [Updated] (FLINK-37859) FLIP-516: Streaming Multi-Way Join Optimization

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37859: - Summary: FLIP-516: Streaming Multi-Way Join Optimization (was: [umbrella] FLIP-516: Streaming M

[jira] [Updated] (FLINK-37890) Extend FlinkLogicalMultiJoin to check for common join key

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37890: - Summary: Extend FlinkLogicalMultiJoin to check for common join key (was: FLIP-516: Extend Flink

[jira] [Updated] (FLINK-37481) Multi way join operator

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37481: - Summary: Multi way join operator (was: FLIP-516: Multi way join operator) > Multi way join oper

[jira] [Updated] (FLINK-37889) Add new FlinkJoinToFlinkMultiJoinRule rule + FlinkLogicalMultiJoin

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37889: - Summary: Add new FlinkJoinToFlinkMultiJoinRule rule + FlinkLogicalMultiJoin (was: FLIP-516: Add

[jira] [Updated] (FLINK-37844) Push down projections for StreamingMultiJoinOperator

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37844: - Summary: Push down projections for StreamingMultiJoinOperator (was: FLIP-516 Optimization: Push

[jira] [Updated] (FLINK-37916) Add StreamPhysicalMultiJoin physical node

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37916: - Summary: Add StreamPhysicalMultiJoin physical node (was: FLIP-516: Add StreamPhysicalMultiJoin

[jira] [Updated] (FLINK-37910) Add StreamExecMultiJoin exec node

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37910: - Summary: Add StreamExecMultiJoin exec node (was: FLIP-516: Add StreamExecMultiJoin exec node)

[jira] [Closed] (FLINK-37910) FLIP-516: Add StreamExecMultiJoin exec node

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37910. Fix Version/s: 2.1.0 Assignee: Gustavo de Morais Resolution: Fixed Fixed in master

[jira] [Commented] (FLINK-37861) FLIP-520: Simplify StructuredType handling

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17958780#comment-17958780 ] Timo Walther commented on FLINK-37861: -- The main PR containing the type system chan

[jira] [Closed] (FLINK-37862) Implement data type improvements for StructuredType

2025-06-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37862. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 1586a55d8d3124e784bcc280c93defc026b

[jira] [Closed] (FLINK-37776) Drop support for Python 3.8

2025-06-05 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37776. Fix Version/s: 2.1.0 Release Note: Support for Python 3.8 has reached end of life. Reso

[jira] [Commented] (FLINK-37861) FLIP-520: Simplify StructuredType handling

2025-05-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17955162#comment-17955162 ] Timo Walther commented on FLINK-37861: -- [~lsy] yes, I'm actively working on it. I s

[jira] [Closed] (FLINK-37763) Support multiple tables with set semantics

2025-05-28 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37763. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 86ee4b58e3878335d15aeb425025dd8b059

[jira] [Created] (FLINK-37862) Implement data type improvements for StructuredType

2025-05-28 Thread Timo Walther (Jira)
Timo Walther created FLINK-37862: Summary: Implement data type improvements for StructuredType Key: FLINK-37862 URL: https://issues.apache.org/jira/browse/FLINK-37862 Project: Flink Issue Typ

[jira] [Created] (FLINK-37861) FLIP-520: Simplify StructuredType handling

2025-05-28 Thread Timo Walther (Jira)
Timo Walther created FLINK-37861: Summary: FLIP-520: Simplify StructuredType handling Key: FLINK-37861 URL: https://issues.apache.org/jira/browse/FLINK-37861 Project: Flink Issue Type: New Fe

[jira] [Closed] (FLINK-37632) Add ChangelogFunction interface

2025-05-07 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37632. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: ddd65bd03749b740ea978570509f2286cda

[jira] [Created] (FLINK-37763) Support multiple tables with set semantics

2025-05-06 Thread Timo Walther (Jira)
Timo Walther created FLINK-37763: Summary: Support multiple tables with set semantics Key: FLINK-37763 URL: https://issues.apache.org/jira/browse/FLINK-37763 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-37745) ChangelogModeJsonSerializer doesn't handle partial deletes

2025-04-28 Thread Timo Walther (Jira)
Timo Walther created FLINK-37745: Summary: ChangelogModeJsonSerializer doesn't handle partial deletes Key: FLINK-37745 URL: https://issues.apache.org/jira/browse/FLINK-37745 Project: Flink Is

[jira] [Commented] (FLINK-37618) Support PTFs INTERVAL argument

2025-04-22 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17946427#comment-17946427 ] Timo Walther commented on FLINK-37618: -- Hi [~juntaozhang], thanks for working on th

[jira] [Created] (FLINK-37671) ChangelogMode.toString returns invalid string for partial deletes

2025-04-14 Thread Timo Walther (Jira)
Timo Walther created FLINK-37671: Summary: ChangelogMode.toString returns invalid string for partial deletes Key: FLINK-37671 URL: https://issues.apache.org/jira/browse/FLINK-37671 Project: Flink

[jira] [Created] (FLINK-37632) Add ChangelogFunction interface

2025-04-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-37632: Summary: Add ChangelogFunction interface Key: FLINK-37632 URL: https://issues.apache.org/jira/browse/FLINK-37632 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37651) Simplify StaticArgument builders for easier type inference

2025-04-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-37651: Summary: Simplify StaticArgument builders for easier type inference Key: FLINK-37651 URL: https://issues.apache.org/jira/browse/FLINK-37651 Project: Flink Is

[jira] [Commented] (FLINK-35466) Cannot pass all columns to SQL UDFs using `*`

2025-04-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942194#comment-17942194 ] Timo Walther commented on FLINK-35466: -- The Table API is more flexible than SQL. Th

[jira] [Closed] (FLINK-37598) Support ListView and MapView in PTFs

2025-04-08 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37598. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 92c5c98a0e76e052a8fe27478557e772d7a

[jira] [Created] (FLINK-37547) Add initial document for PTFs

2025-04-05 Thread Timo Walther (Jira)
Timo Walther created FLINK-37547: Summary: Add initial document for PTFs Key: FLINK-37547 URL: https://issues.apache.org/jira/browse/FLINK-37547 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-37481) Multi way join operator

2025-04-05 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937081#comment-17937081 ] Timo Walther edited comment on FLINK-37481 at 3/20/25 10:28 AM: --

[jira] [Closed] (FLINK-37547) Add initial document for PTFs

2025-04-01 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37547. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 60041948a63706be596f12b309c79dbe9a0

[jira] [Closed] (FLINK-19059) Support to consume retractions for OVER WINDOW operator

2025-04-01 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-19059. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: e06fddc95541cb10df1b605087acc4b4925

[jira] [Created] (FLINK-37599) Consider on_time argument for column expansion

2025-04-01 Thread Timo Walther (Jira)
Timo Walther created FLINK-37599: Summary: Consider on_time argument for column expansion Key: FLINK-37599 URL: https://issues.apache.org/jira/browse/FLINK-37599 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-37598) Support ListView and MapView in PTFs

2025-04-01 Thread Timo Walther (Jira)
Timo Walther created FLINK-37598: Summary: Support ListView and MapView in PTFs Key: FLINK-37598 URL: https://issues.apache.org/jira/browse/FLINK-37598 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-36703) FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)

2025-04-01 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-36703: - Description: Introduce a new kind of user-defined function (UDF) that enables implementing user

[jira] [Assigned] (FLINK-37481) Multi way join operator

2025-03-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-37481: Assignee: Gustavo de Morais > Multi way join operator > --- > >

[jira] [Closed] (FLINK-37423) Add support for PTFs in Table API

2025-03-24 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37423. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: ddba701ec67f16c5f2e43b34428add686fd

[jira] [Updated] (FLINK-37547) Add initial document for PTFs

2025-03-24 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37547: - Description: Add documentation for phase 1-3. (was: Add documentation for phase 1.) > Add init

[jira] [Updated] (FLINK-37481) FLIP-516: Multi way join operator

2025-03-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-37481: - Summary: FLIP-516: Multi way join operator (was: Multi way join operator) > FLIP-516: Multi way

[jira] [Commented] (FLINK-37481) Multi way join operator

2025-03-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937081#comment-17937081 ] Timo Walther commented on FLINK-37481: -- [~gustavodemorais] I reservedĀ FLIP-516 for

[jira] [Comment Edited] (FLINK-37481) Multi way join operator

2025-03-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17937081#comment-17937081 ] Timo Walther edited comment on FLINK-37481 at 3/20/25 10:28 AM: --

[jira] [Closed] (FLINK-25986) Add FLIP-190 new API methods to python

2025-03-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25986. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 3c31e646a8efc13943b33d012a70d748cf1

[jira] [Closed] (FLINK-37466) A helper function for DEFAULT in Table API

2025-03-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37466. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 3dde2552e841130a59fdc2aef6ed241fe0e

[jira] [Closed] (FLINK-37446) Support asArgument in Table API

2025-03-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37446. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 66913489fb380fa735e3511f58533147494

[jira] [Created] (FLINK-37466) A helper function for DEFAULT in Table API

2025-03-12 Thread Timo Walther (Jira)
Timo Walther created FLINK-37466: Summary: A helper function for DEFAULT in Table API Key: FLINK-37466 URL: https://issues.apache.org/jira/browse/FLINK-37466 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-37457) Support asArgument in Python Table API

2025-03-11 Thread Timo Walther (Jira)
Timo Walther created FLINK-37457: Summary: Support asArgument in Python Table API Key: FLINK-37457 URL: https://issues.apache.org/jira/browse/FLINK-37457 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37446) Support asArgument in Table API

2025-03-10 Thread Timo Walther (Jira)
Timo Walther created FLINK-37446: Summary: Support asArgument in Table API Key: FLINK-37446 URL: https://issues.apache.org/jira/browse/FLINK-37446 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-37302) Support timers in PTFs

2025-03-10 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37302. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 7b35edeb3e343d9d35e432bb2c08f43055b

[jira] [Closed] (FLINK-36937) Integrate PTF TypeInference into Table API

2025-03-05 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-36937. Resolution: Duplicate Subsumed by FLINK-37423 > Integrate PTF TypeInference into Table API >

[jira] [Created] (FLINK-37423) Add support for PTFs in Table API

2025-03-05 Thread Timo Walther (Jira)
Timo Walther created FLINK-37423: Summary: Add support for PTFs in Table API Key: FLINK-37423 URL: https://issues.apache.org/jira/browse/FLINK-37423 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-21912) Introduce Schema and ResolvedSchema in Python API

2025-03-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-21912. Fix Version/s: 2.1.0 Assignee: Mika Naylor Resolution: Fixed Fixed in master: ea9c

[jira] [Closed] (FLINK-37402) SQL testing sources produce incorrect watermarks

2025-03-03 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37402. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: d5ffb88df4d033b357a72a3def6d45ebc80

[jira] [Created] (FLINK-37402) SQL testing sources produce incorrect watermarks

2025-02-27 Thread Timo Walther (Jira)
Timo Walther created FLINK-37402: Summary: SQL testing sources produce incorrect watermarks Key: FLINK-37402 URL: https://issues.apache.org/jira/browse/FLINK-37402 Project: Flink Issue Type:

[jira] [Closed] (FLINK-37269) Add new DESCRIPTOR data type

2025-02-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37269. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 356f5bb8e2e199e3e1c80ed3332d3381699

[jira] [Closed] (FLINK-37336) Introduce TablePipeline to Python API

2025-02-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37336. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: cd62c6cf6783741f2d040518e9b987c43a4

[jira] [Closed] (FLINK-37267) Support WITH ORDINALITY for UNNEST

2025-02-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37267. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 4091e85b62845680c450b7db6301903de10

[jira] [Closed] (FLINK-37219) Support value state in PTFs

2025-02-11 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37219. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 24f18975c7205ec3b58e2fb8dca048fa2b6

[jira] [Created] (FLINK-37302) Support timers in PTFs

2025-02-11 Thread Timo Walther (Jira)
Timo Walther created FLINK-37302: Summary: Support timers in PTFs Key: FLINK-37302 URL: https://issues.apache.org/jira/browse/FLINK-37302 Project: Flink Issue Type: Sub-task Compone

[jira] [Closed] (FLINK-37180) Implement StreamOperator for PTF

2025-02-06 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37180. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 0a7a0a30904cf0a58ead8306bbf0b5b18d3

[jira] [Created] (FLINK-37269) Add new DESCRIPTOR data type

2025-02-06 Thread Timo Walther (Jira)
Timo Walther created FLINK-37269: Summary: Add new DESCRIPTOR data type Key: FLINK-37269 URL: https://issues.apache.org/jira/browse/FLINK-37269 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-36703) FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)

2025-02-06 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-36703: - Description: Introduce a new kind of user-defined function (UDF) that enables implementing user

[jira] [Created] (FLINK-37219) Support value state in PTFs

2025-01-24 Thread Timo Walther (Jira)
Timo Walther created FLINK-37219: Summary: Support value state in PTFs Key: FLINK-37219 URL: https://issues.apache.org/jira/browse/FLINK-37219 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-37211) Fix field resolution for PARTITION BY/ORDER BY

2025-01-23 Thread Timo Walther (Jira)
Timo Walther created FLINK-37211: Summary: Fix field resolution for PARTITION BY/ORDER BY Key: FLINK-37211 URL: https://issues.apache.org/jira/browse/FLINK-37211 Project: Flink Issue Type: Su

[jira] [Commented] (FLINK-37076) Support PTF skeleton in planner

2025-01-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915717#comment-17915717 ] Timo Walther commented on FLINK-37076: -- Fixed in master: [table-planner] Support PT

[jira] [Closed] (FLINK-37076) Support PTF skeleton in planner

2025-01-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37076. Fix Version/s: 2.1.0 Resolution: Fixed > Support PTF skeleton in planner >

[jira] [Created] (FLINK-37180) Implement StreamOperator for PTF

2025-01-20 Thread Timo Walther (Jira)
Timo Walther created FLINK-37180: Summary: Implement StreamOperator for PTF Key: FLINK-37180 URL: https://issues.apache.org/jira/browse/FLINK-37180 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37167) Fix operand reordering in SqlValidatorImpl for tableCharacteristics

2025-01-17 Thread Timo Walther (Jira)
Timo Walther created FLINK-37167: Summary: Fix operand reordering in SqlValidatorImpl for tableCharacteristics Key: FLINK-37167 URL: https://issues.apache.org/jira/browse/FLINK-37167 Project: Flink

[jira] [Commented] (FLINK-37076) Support PTF skeleton in planner

2025-01-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913797#comment-17913797 ] Timo Walther commented on FLINK-37076: -- Fixed in master: [table-planner] Make table

[jira] [Closed] (FLINK-36707) Integrate PTF TypeInference into Calcite validator

2025-01-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-36707. Fix Version/s: 2.0.0 Resolution: Fixed > Integrate PTF TypeInference into Calcite validator

[jira] [Commented] (FLINK-36707) Integrate PTF TypeInference into Calcite validator

2025-01-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912852#comment-17912852 ] Timo Walther commented on FLINK-36707: -- Output strategy fixed in master: b71dd7695c

  1   2   3   4   5   6   7   8   9   10   >