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

[ 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

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)

[ 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

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

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

[ 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

[ 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

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

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

[ 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

[ 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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-36707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911564#comment-17911564 ] Timo Walther commented on FLINK-36707: -- Fixed in master: 5e5d0d5d2cd322ae53ad909dd0

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

Timo Walther created FLINK-37076: Summary: Support PTF skeleton in planner Key: FLINK-37076 URL: https://issues.apache.org/jira/browse/FLINK-37076 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-36824) Backport from Calcite 1.37.0 support table function calls in FROM clause without TABLE() wrapper

[ https://issues.apache.org/jira/browse/FLINK-36824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-36824. > Backport from Calcite 1.37.0 support table function calls in FROM clause > without TABLE() wrapper

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

Timo Walther created FLINK-36937: Summary: Integrate PTF TypeInference into Table API Key: FLINK-36937 URL: https://issues.apache.org/jira/browse/FLINK-36937 Project: Flink Issue Type: Sub-ta

[jira] [Closed] (FLINK-36706) Update TypeInferenceExtractor for PTFs

[ https://issues.apache.org/jira/browse/FLINK-36706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-36706. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: ab8286e8b5c7895cc0d009521eb9c660eeb

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

[ https://issues.apache.org/jira/browse/FLINK-19059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-19059: - Labels: (was: auto-deprioritized-major auto-deprioritized-minor) > Support to consume retracti

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

[ https://issues.apache.org/jira/browse/FLINK-19059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-19059: - Priority: Major (was: Not a Priority) > Support to consume retractions for OVER WINDOW operator

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

[ https://issues.apache.org/jira/browse/FLINK-19059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-19059: Assignee: Bonnie Varghese > Support to consume retractions for OVER WINDOW operator > ---

[jira] [Closed] (FLINK-36809) Add ifNotExists param to createTable

[ https://issues.apache.org/jira/browse/FLINK-36809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-36809. Fix Version/s: 2.0.0 Assignee: Gustavo de Morais Resolution: Fixed Fixed in master

[jira] [Commented] (FLINK-36284) StreamTableEnvironment#toDataStream(Table table, Class targetClass) is not suitable for setting targetClass as a class generated by Avro.

[ https://issues.apache.org/jira/browse/FLINK-36284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901943#comment-17901943 ] Timo Walther commented on FLINK-36284: -- [~xuyangzhong] [~lincoln.86xy] I don't thin

[jira] [Closed] (FLINK-36705) Add ProcessTableFunction class and annotations

[ https://issues.apache.org/jira/browse/FLINK-36705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-36705. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 2897ab7db1081c9bf1f477dc221b84e7c66

[jira] [Closed] (FLINK-36720) Add CompiledPlan annotations to BatchExecWindowTableFunction

[ https://issues.apache.org/jira/browse/FLINK-36720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-36720. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: f58d5fc024c9b40de505f03982d058a252f

[jira] [Updated] (FLINK-36789) Update FunctionHint and ArgumentHint with StaticArguments

[ https://issues.apache.org/jira/browse/FLINK-36789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-36789: - Release Note: @FunctionHint(argument = {}) and @FunctionHint(argumentNames = {}) are deprecated.

[jira] [Closed] (FLINK-36789) Update FunctionHint and ArgumentHint with StaticArguments

[ https://issues.apache.org/jira/browse/FLINK-36789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-36789. Fix Version/s: 2.0.0 Release Note: `@FunctionHint(argument = {})` and `@FunctionHint(argument

[jira] [Created] (FLINK-36789) Update FunctionHint and ArgumentHint with StaticArguments

Timo Walther created FLINK-36789: Summary: Update FunctionHint and ArgumentHint with StaticArguments Key: FLINK-36789 URL: https://issues.apache.org/jira/browse/FLINK-36789 Project: Flink Iss

[jira] [Closed] (FLINK-36704) Update TypeInference with StaticArgument and StateTypeStrategy

[ https://issues.apache.org/jira/browse/FLINK-36704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-36704. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 3ac109b0b4faea35bd58bd16e7c0657b80b

[jira] [Created] (FLINK-36706) Update TypeInferenceExtractor for PTFs

Timo Walther created FLINK-36706: Summary: Update TypeInferenceExtractor for PTFs Key: FLINK-36706 URL: https://issues.apache.org/jira/browse/FLINK-36706 Project: Flink Issue Type: Sub-task

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

[ 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-36707) Integrate PTF TypeInference into Calcite validator

Timo Walther created FLINK-36707: Summary: Integrate PTF TypeInference into Calcite validator Key: FLINK-36707 URL: https://issues.apache.org/jira/browse/FLINK-36707 Project: Flink Issue Type

[jira] [Created] (FLINK-36705) Add ProcessTableFunction class and annotations

Timo Walther created FLINK-36705: Summary: Add ProcessTableFunction class and annotations Key: FLINK-36705 URL: https://issues.apache.org/jira/browse/FLINK-36705 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-36704) Update TypeInference with StaticArgument and StateTypeStrategy

Timo Walther created FLINK-36704: Summary: Update TypeInference with StaticArgument and StateTypeStrategy Key: FLINK-36704 URL: https://issues.apache.org/jira/browse/FLINK-36704 Project: Flink

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

Timo Walther created FLINK-36703: Summary: FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF) Key: FLINK-36703 URL: https://issues.apache.org/jira/browse/FLINK-36703 Project: Flink

[jira] [Closed] (FLINK-35016) Catalog changes for model CRUD

[ https://issues.apache.org/jira/browse/FLINK-35016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35016. Fix Version/s: 2.0.0 Assignee: Hao Li Resolution: Fixed Fixed in master: 2d17f6148

[jira] [Closed] (FLINK-28770) CREATE TABLE AS SELECT supports explain

[ https://issues.apache.org/jira/browse/FLINK-28770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-28770. Fix Version/s: 2.0-preview Resolution: Fixed Fixed in master: 8127f4f9fb59cb1717393aafa480d

[jira] [Assigned] (FLINK-28770) CREATE TABLE AS SELECT supports explain

[ https://issues.apache.org/jira/browse/FLINK-28770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-28770: Assignee: Sergio Peña > CREATE TABLE AS SELECT supports explain > ---

[jira] [Closed] (FLINK-35790) Update docs for new schema definition in CTAS and RTAS

[ https://issues.apache.org/jira/browse/FLINK-35790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35790. Fix Version/s: 2.0.0 Assignee: Sergio Peña Resolution: Fixed Fixed in master: 8c11

[jira] [Closed] (FLINK-35708) Allow defining a schema in REPLACE TABLE AS (RTAS)

[ https://issues.apache.org/jira/browse/FLINK-35708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35708. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: c1fa29ac91aeef64701d8d97b13644a4267

[jira] [Closed] (FLINK-35716) Fix use of AsyncScalarFunction in join conditions

[ https://issues.apache.org/jira/browse/FLINK-35716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35716. Fix Version/s: 2.0.0 Assignee: Alan Sheinberg Resolution: Fixed Fixed in master: 9

[jira] [Closed] (FLINK-36003) Add CompiledPlan annotations to BatchExecExpand and BatchExecSortAggregate

[ https://issues.apache.org/jira/browse/FLINK-36003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-36003. Resolution: Fixed Fixed in master: 268144c30fab7704e713ccfcda0c3e6be3857660 > Add CompiledPlan an

[jira] [Closed] (FLINK-31534) CREATE TABLE AS SELECT should support to define primary key

[ https://issues.apache.org/jira/browse/FLINK-31534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-31534. Fix Version/s: 2.0.0 Assignee: Sergio Peña Resolution: Fixed Fixed as part of FLIN

[jira] [Updated] (FLINK-31534) CREATE TABLE AS SELECT should support to define primary key

[ https://issues.apache.org/jira/browse/FLINK-31534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-31534: - Component/s: Table SQL / Planner > CREATE TABLE AS SELECT should support to define primary key >

[jira] [Closed] (FLINK-31533) CREATE TABLE AS SELECT should support to define partition

[ https://issues.apache.org/jira/browse/FLINK-31533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-31533. Fix Version/s: 2.0.0 Assignee: Sergio Peña Resolution: Fixed Fixed as part of FLIN

[jira] [Updated] (FLINK-35941) Add CompiledPlan annotations to BatchExecLimit

[ https://issues.apache.org/jira/browse/FLINK-35941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-35941: - Component/s: Table SQL / Planner > Add CompiledPlan annotations to BatchExecLimit >

[jira] [Closed] (FLINK-35941) Add CompiledPlan annotations to BatchExecLimit

[ https://issues.apache.org/jira/browse/FLINK-35941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35941. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 8a45cd6cffb7ff55e0af6c1167b255d7da6

[jira] [Updated] (FLINK-35943) Add CompiledPlan annotations to BatchExecHashJoin and BatchExecNestedLoopJoin

[ https://issues.apache.org/jira/browse/FLINK-35943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-35943: - Component/s: Table SQL / Planner > Add CompiledPlan annotations to BatchExecHashJoin and BatchEx

[jira] [Closed] (FLINK-35943) Add CompiledPlan annotations to BatchExecHashJoin and BatchExecNestedLoopJoin

[ https://issues.apache.org/jira/browse/FLINK-35943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35943. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: a885f4ffd08a7b138bb7d643723038c8558

[jira] [Updated] (FLINK-35942) Add CompiledPlan annotations to BatchExecCorrelate

[ https://issues.apache.org/jira/browse/FLINK-35942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-35942: - Component/s: Table SQL / Planner > Add CompiledPlan annotations to BatchExecCorrelate >

[jira] [Closed] (FLINK-35942) Add CompiledPlan annotations to BatchExecCorrelate

[ https://issues.apache.org/jira/browse/FLINK-35942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35942. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 783150aa9abc9b26f06db04b6807d0a57ae

[jira] [Updated] (FLINK-35798) Implement a BatchRestoreTestBase

[ https://issues.apache.org/jira/browse/FLINK-35798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-35798: - Component/s: Table SQL / Planner > Implement a BatchRestoreTestBase > --

[jira] [Updated] (FLINK-35799) Add CompiledPlan annotations to BatchExecCalc

[ https://issues.apache.org/jira/browse/FLINK-35799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-35799: - Component/s: Table SQL / Planner > Add CompiledPlan annotations to BatchExecCalc > -

[jira] [Updated] (FLINK-35797) FLIP-456: CompiledPlan support for Batch Execution Mode

[ https://issues.apache.org/jira/browse/FLINK-35797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-35797: - Component/s: Table SQL / Planner > FLIP-456: CompiledPlan support for Batch Execution Mode > ---

[jira] [Updated] (FLINK-35934) Add CompiledPlan annotations to BatchExecValues

[ https://issues.apache.org/jira/browse/FLINK-35934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-35934: - Component/s: Table SQL / Planner > Add CompiledPlan annotations to BatchExecValues > ---

[jira] [Updated] (FLINK-35923) Add CompiledPlan annotations to BatchExecSort/BatchExecExchange

[ https://issues.apache.org/jira/browse/FLINK-35923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-35923: - Component/s: Table SQL / Planner > Add CompiledPlan annotations to BatchExecSort/BatchExecExchan

[jira] [Closed] (FLINK-35934) Add CompiledPlan annotations to BatchExecValues

[ https://issues.apache.org/jira/browse/FLINK-35934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35934. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 8ab011243a8028aeee5bbc73ac56a7426a5

[jira] [Closed] (FLINK-35923) Add CompiledPlan annotations to BatchExecSort/BatchExecExchange

[ https://issues.apache.org/jira/browse/FLINK-35923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35923. Resolution: Fixed Fixed in master: be11c63a21f2fabf1006d7867e9c74bf2b65ca41 > Add CompiledPlan an

[jira] [Updated] (FLINK-35923) Add CompiledPlan annotations to BatchExecSort/BatchExecExchange

[ https://issues.apache.org/jira/browse/FLINK-35923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-35923: - Summary: Add CompiledPlan annotations to BatchExecSort/BatchExecExchange (was: Add CompiledPlan

[jira] [Closed] (FLINK-35799) Add CompiledPlan annotations to BatchExecCalc

[ https://issues.apache.org/jira/browse/FLINK-35799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35799. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 0050e426bc0640858c539d43032a4226eea

[jira] [Closed] (FLINK-35717) Allow DISTRIBUTED BY in CREATE TABLE AS (CTAS)

[ https://issues.apache.org/jira/browse/FLINK-35717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35717. Fix Version/s: 2.0.0 Assignee: Sergio Peña Resolution: Fixed Fixed in master: 4041

[jira] [Closed] (FLINK-35789) Allow defining watermarks & PRIMARY KEY in CREATE TABLE AS (CTAS)

[ https://issues.apache.org/jira/browse/FLINK-35789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35789. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 5c9c58c2827566f6780243cb14bd418f218

[jira] [Closed] (FLINK-35707) Allow column definition in CREATE TABLE AS (CTAS)

[ https://issues.apache.org/jira/browse/FLINK-35707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35707. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 93d7f45595435da10ac1d685feae8f7e8a9

[jira] [Closed] (FLINK-35585) Add documentation for distribution

[ https://issues.apache.org/jira/browse/FLINK-35585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35585. Fix Version/s: 1.20.0 Resolution: Fixed Fixed in master: f6f88135b3a5fa5616fe905346e5ab6dce

[jira] [Closed] (FLINK-34172) Add support for altering a distribution via ALTER TABLE

[ https://issues.apache.org/jira/browse/FLINK-34172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34172. Resolution: Fixed Fixed in master: d0f9bb40a614c3c52c7abc9e608391e4bca9a3ca > Add support for alt

[jira] [Closed] (FLINK-35403) FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding

[ https://issues.apache.org/jira/browse/FLINK-35403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35403. Fix Version/s: 1.20.0 Resolution: Fixed Fixed in master: efcd146e0119cc7e67fea74cc46fbde083

[jira] [Updated] (FLINK-34993) Support MODEL syntax in parser

[ https://issues.apache.org/jira/browse/FLINK-34993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34993: - Description: Adds all parser changes required for FLIP-437. > Support MODEL syntax in parser > -

[jira] [Closed] (FLINK-34993) Support MODEL syntax in parser

[ https://issues.apache.org/jira/browse/FLINK-34993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34993. Fix Version/s: 1.20.0 Resolution: Fixed Fixed in master: 4d39738587e0f07a4776eebb83e2bcaf28

[jira] [Updated] (FLINK-34993) Support MODEL syntax in parser

[ https://issues.apache.org/jira/browse/FLINK-34993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34993: - Summary: Support MODEL syntax in parser (was: Support Model CRUD in parser) > Support MODEL syn

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

[ https://issues.apache.org/jira/browse/FLINK-34993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-34993: Assignee: Hao Li > Support Model CRUD in parser > > >

[jira] [Closed] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-34902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34902. Resolution: Fixed Fixed in master: 8a75f8f22b8e08e45f1a6453b87718eab6db115a > INSERT INTO column

[jira] [Closed] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line

[ https://issues.apache.org/jira/browse/FLINK-35097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35097. Fix Version/s: 1.18.2 1.20.0 1.19.1 Resolution: Fixed

[jira] [Reopened] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-34902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-34902: -- > INSERT INTO column mismatch leads to IndexOutOfBoundsException > ---

[jira] [Commented] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-34902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840650#comment-17840650 ] Timo Walther commented on FLINK-34902: -- [~jeyhunkarimov] could you take another loo

[jira] [Assigned] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line

[ https://issues.apache.org/jira/browse/FLINK-35097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-35097: Assignee: Kumar Mallikarjuna > Table API Filesystem connector with 'raw' format repeats l

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

[ https://issues.apache.org/jira/browse/FLINK-34992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34992: - Component/s: Table SQL / API Table SQL / Planner Table SQL / Ru

[jira] [Commented] (FLINK-35001) Avoid scientific notation for DOUBLE to STRING

[ https://issues.apache.org/jira/browse/FLINK-35001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17833551#comment-17833551 ] Timo Walther commented on FLINK-35001: -- Since functions in CompiledPlan are version

[jira] [Created] (FLINK-35001) Avoid scientific notation for DOUBLE to STRING

Timo Walther created FLINK-35001: Summary: Avoid scientific notation for DOUBLE to STRING Key: FLINK-35001 URL: https://issues.apache.org/jira/browse/FLINK-35001 Project: Flink Issue Type: Su

[jira] [Assigned] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-34902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-34902: Assignee: Jeyhun Karimov > INSERT INTO column mismatch leads to IndexOutOfBoundsException

[jira] [Closed] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-34902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34902. Fix Version/s: 1.20.0 Resolution: Fixed Fixed in master: 3a55a3ff750d67cfa48d15f818c1307b89

[jira] [Created] (FLINK-34902) INSERT INTO column mismatch leads to IndexOutOfBoundsException

Timo Walther created FLINK-34902: Summary: INSERT INTO column mismatch leads to IndexOutOfBoundsException Key: FLINK-34902 URL: https://issues.apache.org/jira/browse/FLINK-34902 Project: Flink

[jira] [Closed] (FLINK-33028) FLIP-348: Make expanding behavior of virtual metadata columns configurable

[ https://issues.apache.org/jira/browse/FLINK-33028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-33028. Resolution: Fixed > FLIP-348: Make expanding behavior of virtual metadata columns configurable > -

[jira] [Closed] (FLINK-34476) Window TVFs with named parameters don't support column expansion

[ https://issues.apache.org/jira/browse/FLINK-34476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34476. Resolution: Fixed Fixed in master: e622205d0b74c6cbaf6fef6d8c11a397cdc30284 Fixed in release-1.19:

[jira] [Created] (FLINK-34476) Window TVFs with named parameters don't support column expansion

Timo Walther created FLINK-34476: Summary: Window TVFs with named parameters don't support column expansion Key: FLINK-34476 URL: https://issues.apache.org/jira/browse/FLINK-34476 Project: Flink

[jira] [Updated] (FLINK-34476) Window TVFs with named parameters don't support column expansion

[ https://issues.apache.org/jira/browse/FLINK-34476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34476: - Fix Version/s: 1.19.0 > Window TVFs with named parameters don't support column expansion > -

[jira] [Reopened] (FLINK-33028) FLIP-348: Make expanding behavior of virtual metadata columns configurable

[ https://issues.apache.org/jira/browse/FLINK-33028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-33028: -- > FLIP-348: Make expanding behavior of virtual metadata columns configurable > ---

[jira] [Closed] (FLINK-33182) Allow metadata columns in NduAnalyzer with ChangelogNormalize

[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-33182. Fix Version/s: 1.20.0 (was: 1.19.0) Resolution: Fixed Fixed in maste

[jira] [Created] (FLINK-34469) Implement TableDistribution toString

Timo Walther created FLINK-34469: Summary: Implement TableDistribution toString Key: FLINK-34469 URL: https://issues.apache.org/jira/browse/FLINK-34469 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-33495) Add DISTRIBUTED BY clause for CREATE TABLE

[ https://issues.apache.org/jira/browse/FLINK-33495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-33495: - Summary: Add DISTRIBUTED BY clause for CREATE TABLE (was: Add catalog and connector ability API

[jira] [Updated] (FLINK-33495) Add DISTRIBUTED BY clause for CREATE TABLE

[ https://issues.apache.org/jira/browse/FLINK-33495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-33495: - Description: Updates: - CatalogTable - CatalogTable.Builder - TableDistribution - SupportsBu

[jira] [Closed] (FLINK-33496) Expose DISTRIBUTED BY clause via parser

[ https://issues.apache.org/jira/browse/FLINK-33496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-33496. Resolution: Won't Fix Fixed as part of FLINK-33495. > Expose DISTRIBUTED BY clause via parser > -

[jira] [Closed] (FLINK-34173) Implement CatalogTable.Builder

[ https://issues.apache.org/jira/browse/FLINK-34173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34173. Resolution: Duplicate Fixed as part of FLINK-33495. > Implement CatalogTable.Builder > --

[jira] [Reopened] (FLINK-33496) Expose DISTRIBUTED BY clause via parser

[ https://issues.apache.org/jira/browse/FLINK-33496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-33496: -- Assignee: (was: Timo Walther) > Expose DISTRIBUTED BY clause via parser > --

[jira] [Closed] (FLINK-33496) Expose DISTRIBUTED BY clause via parser

[ https://issues.apache.org/jira/browse/FLINK-33496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-33496. Fix Version/s: 1.20.0 Resolution: Fixed Fixed in master: 6c9ac5c6ae06bf5b42d33b57a7dc1006ac

[jira] (FLINK-33496) Expose DISTRIBUTED BY clause via parser

[ https://issues.apache.org/jira/browse/FLINK-33496 ] Timo Walther deleted comment on FLINK-33496: -- was (Author: twalthr): Fixed in master: 6c9ac5c6ae06bf5b42d33b57a7dc1006ac2b2744 > Expose DISTRIBUTED BY clause via parser > --

[jira] [Closed] (FLINK-33495) Add catalog and connector ability API and validation

[ https://issues.apache.org/jira/browse/FLINK-33495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-33495. Fix Version/s: 1.20.0 Resolution: Fixed Fixed in master: 6c9ac5c6ae06bf5b42d33b57a7dc1006ac

[jira] [Comment Edited] (FLINK-34394) Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of virtual metadata columns configurable

[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815962#comment-17815962 ] Timo Walther edited comment on FLINK-34394 at 2/9/24 8:36 AM:

[jira] [Commented] (FLINK-34394) Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of virtual metadata columns configurable

[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815962#comment-17815962 ] Timo Walther commented on FLINK-34394: -- Hi [~lincoln.86xy], this feature is rather

[jira] [Closed] (FLINK-34394) Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of virtual metadata columns configurable

[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34394. Resolution: Fixed > Release Testing Instructions: Verify FLINK-33028 Make expanding behavior of >

[jira] [Commented] (FLINK-34404) RestoreTestBase#testRestore times out

[ https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815242#comment-17815242 ] Timo Walther commented on FLINK-34404: -- If this is a new error, it might be related

[jira] [Closed] (FLINK-34095) Add a restore test for StreamExecAsyncCalc

[ https://issues.apache.org/jira/browse/FLINK-34095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34095. Fix Version/s: 1.19.0 Resolution: Fixed Fixed in master: 4264c30d367c1847d702ea5438da648765

  1   2   3   4   5   6   7   8   9   10   >