[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

[jira] [Closed] (FLINK-34316) Reduce instantiation of ScanRuntimeProvider in streaming mode

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

[jira] [Updated] (FLINK-34316) Reduce instantiation of ScanRuntimeProvider in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-34316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34316: - Summary: Reduce instantiation of ScanRuntimeProvider in streaming mode (was: Reduce instantiati

[jira] [Created] (FLINK-34316) Reduce instantiation of ScanRuntimeProvider for in streaming mode

Timo Walther created FLINK-34316: Summary: Reduce instantiation of ScanRuntimeProvider for in streaming mode Key: FLINK-34316 URL: https://issues.apache.org/jira/browse/FLINK-34316 Project: Flink

[jira] [Updated] (FLINK-27992) cep StreamExecMatch need check the parallelism and maxParallelism of the two transformation in it

[ https://issues.apache.org/jira/browse/FLINK-27992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-27992: - Fix Version/s: 1.19.0 > cep StreamExecMatch need check the parallelism and maxParallelism of the

[jira] [Commented] (FLINK-33950) Update max aggregate functions to new type system

[ https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808558#comment-17808558 ] Timo Walther commented on FLINK-33950: -- Hi [~jackylau], sorry for not replying earl

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

Timo Walther created FLINK-34095: Summary: Add a restore test for StreamExecAsyncCalc Key: FLINK-34095 URL: https://issues.apache.org/jira/browse/FLINK-34095 Project: Flink Issue Type: Sub-ta

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

Timo Walther created FLINK-34094: Summary: Document new AsyncScalarFunction Key: FLINK-34094 URL: https://issues.apache.org/jira/browse/FLINK-34094 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-34027) Introduce AsyncScalarFunction as a new UDF type

[ https://issues.apache.org/jira/browse/FLINK-34027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34027. Resolution: Fixed Fixed in master: b666de974b5dbc6e0d6710baececb1d6ede9b769 > Introduce AsyncScal

[jira] [Updated] (FLINK-34027) Introduce AsyncScalarFunction as a new UDF type

[ https://issues.apache.org/jira/browse/FLINK-34027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34027: - Description: Initial PR for FLIP-400. Excluding documentation and restore tests. > Introduce As

[jira] [Updated] (FLINK-34027) Introduce AsyncScalarFunction as a new UDF type

[ https://issues.apache.org/jira/browse/FLINK-34027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34027: - Summary: Introduce AsyncScalarFunction as a new UDF type (was: Create initial PR for FLIP-400)

[jira] [Closed] (FLINK-34067) Fix javacc warnings in flink-sql-parser

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

[jira] [Commented] (FLINK-31829) Conversion to relational algebra failed to preserve datatypes' nullabilities

[ https://issues.apache.org/jira/browse/FLINK-31829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801734#comment-17801734 ] Timo Walther commented on FLINK-31829: -- {quote}There's no exception thrown anymore.

[jira] [Commented] (FLINK-33644) FLIP-393: Make QueryOperations SQL serializable

[ https://issues.apache.org/jira/browse/FLINK-33644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17797131#comment-17797131 ] Timo Walther commented on FLINK-33644: -- [~fsk119] QueryOperations are intended to b

[jira] [Commented] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

[ https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17796862#comment-17796862 ] Timo Walther commented on FLINK-33666: -- [~jhughes] was this issue resolved? Was it

[jira] [Commented] (FLINK-33784) CatalogStoreFactory can not be configured via StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-33784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17795266#comment-17795266 ] Timo Walther commented on FLINK-33784: -- Hi [~hackergin], DelegatingReadableConfig c

[jira] [Assigned] (FLINK-33784) CatalogStoreFactory can not be configured via StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-33784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-33784: Assignee: Feng Jin > CatalogStoreFactory can not be configured via StreamExecutionEnviron

[jira] [Commented] (FLINK-33784) CatalogStoreFactory can not be configured via StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-33784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794746#comment-17794746 ] Timo Walther commented on FLINK-33784: -- What is required is this: {code} fi

[jira] [Assigned] (FLINK-33784) CatalogStoreFactory can not be configured via StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-33784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-33784: Assignee: (was: Timo Walther) > CatalogStoreFactory can not be configured via StreamE

[jira] [Created] (FLINK-33784) CatalogStoreFactory can not be configured via StreamExecutionEnvironment

Timo Walther created FLINK-33784: Summary: CatalogStoreFactory can not be configured via StreamExecutionEnvironment Key: FLINK-33784 URL: https://issues.apache.org/jira/browse/FLINK-33784 Project: Fli

[jira] [Commented] (FLINK-31835) DataTypeHint don't support Row>

[ https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794179#comment-17794179 ] Timo Walther commented on FLINK-31835: -- {quote} My only concern is the compatibilit

[jira] [Commented] (FLINK-33523) DataType ARRAY fails to cast into Object[]

[ https://issues.apache.org/jira/browse/FLINK-33523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794170#comment-17794170 ] Timo Walther commented on FLINK-33523: -- Thanks for reporting this issue [~prabhujos

[jira] [Closed] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

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

[jira] [Assigned] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

[ https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-33666: Assignee: Jeyhun Karimov > MergeTableLikeUtil uses different constraint name than Schema

[jira] [Commented] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

[ https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794086#comment-17794086 ] Timo Walther commented on FLINK-33666: -- Thanks [~jeyhunkarimov] for working on this

[jira] [Commented] (FLINK-33597) Can not use a nested column for a join condition

[ https://issues.apache.org/jira/browse/FLINK-33597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17791152#comment-17791152 ] Timo Walther commented on FLINK-33597: -- Thanks for linking the issue [~lincoln.86xy

[jira] [Updated] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

[ https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-33666: - Affects Version/s: 1.18.0 > MergeTableLikeUtil uses different constraint name than Schema >

[jira] [Created] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

Timo Walther created FLINK-33666: Summary: MergeTableLikeUtil uses different constraint name than Schema Key: FLINK-33666 URL: https://issues.apache.org/jira/browse/FLINK-33666 Project: Flink

[jira] [Commented] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-33497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784363#comment-17784363 ] Timo Walther commented on FLINK-33497: -- [~tzulitai] would you like to take this? Or

[jira] [Created] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause

Timo Walther created FLINK-33497: Summary: Update the Kafka connector to support DISTRIBUTED BY clause Key: FLINK-33497 URL: https://issues.apache.org/jira/browse/FLINK-33497 Project: Flink

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

Timo Walther created FLINK-33496: Summary: Expose DISTRIBUTED BY clause via parser Key: FLINK-33496 URL: https://issues.apache.org/jira/browse/FLINK-33496 Project: Flink Issue Type: Sub-task

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

Timo Walther created FLINK-33495: Summary: Add catalog and connector ability API and validation Key: FLINK-33495 URL: https://issues.apache.org/jira/browse/FLINK-33495 Project: Flink Issue Ty

[jira] [Updated] (FLINK-33494) FLIP-376: Add DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-33494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-33494: - Description: Many SQL vendors expose the concepts of Partitioning, Bucketing, and Clustering. p

[jira] [Assigned] (FLINK-33494) FLIP-376: Add DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-33494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-33494: Assignee: Timo Walther > FLIP-376: Add DISTRIBUTED BY clause > --

[jira] [Created] (FLINK-33494) FLIP-376: Add DISTRIBUTED BY clause

Timo Walther created FLINK-33494: Summary: FLIP-376: Add DISTRIBUTED BY clause Key: FLINK-33494 URL: https://issues.apache.org/jira/browse/FLINK-33494 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-32444) Enable object reuse for Flink SQL jobs by default

[ https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783921#comment-17783921 ] Timo Walther commented on FLINK-32444: -- The easiest solution could be to check for

  1   2   3   4   5   6   7   8   9   10   >