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

2024-04-30 Thread Timo Walther (Jira)
[ 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

2024-04-24 Thread Timo Walther (Jira)
[ 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

2024-04-24 Thread Timo Walther (Jira)
[ 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

2024-04-24 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840650#comment-17840650 ] Timo Walther commented on FLINK-34902: -- [~jeyhunkarimov] could you take another look at your

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

2024-04-18 Thread Timo Walther (Jira)
[ 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

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

2024-04-04 Thread Timo Walther (Jira)
[ 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 /

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

2024-04-03 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17833551#comment-17833551 ] Timo Walther commented on FLINK-35001: -- Since functions in CompiledPlan are versioned. We could

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

2024-04-03 Thread Timo Walther (Jira)
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:

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

2024-03-25 Thread Timo Walther (Jira)
[ 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

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

2024-03-25 Thread Timo Walther (Jira)
[ 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:

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

2024-03-21 Thread Timo Walther (Jira)
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

2024-02-22 Thread Timo Walther (Jira)
[ 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

2024-02-22 Thread Timo Walther (Jira)
[ 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

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

2024-02-20 Thread Timo Walther (Jira)
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

2024-02-20 Thread Timo Walther (Jira)
[ 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

2024-02-20 Thread Timo Walther (Jira)
[ 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

2024-02-20 Thread Timo Walther (Jira)
[ 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

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

2024-02-19 Thread Timo Walther (Jira)
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

2024-02-19 Thread Timo Walther (Jira)
[ 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

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

2024-02-19 Thread Timo Walther (Jira)
[ 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 -

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

2024-02-19 Thread Timo Walther (Jira)
[ 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

2024-02-19 Thread Timo Walther (Jira)
[ 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

2024-02-19 Thread Timo Walther (Jira)
[ 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

2024-02-19 Thread Timo Walther (Jira)
[ 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:

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

2024-02-19 Thread Timo Walther (Jira)
[ 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

2024-02-19 Thread Timo Walther (Jira)
[ 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:

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

2024-02-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815962#comment-17815962 ] Timo Walther edited comment on FLINK-34394 at 2/9/24 8:36 AM: -- Hi

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

2024-02-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815962#comment-17815962 ] Timo Walther commented on FLINK-34394: -- Hi [~lincoln.86xy], this feature is rather small and should

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

2024-02-09 Thread Timo Walther (Jira)
[ 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

2024-02-07 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815242#comment-17815242 ] Timo Walther commented on FLINK-34404: -- If this is a new error, it might be related to FLINK-34095

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

2024-02-06 Thread Timo Walther (Jira)
[ 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:

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

2024-01-31 Thread Timo Walther (Jira)
[ 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:

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

2024-01-30 Thread Timo Walther (Jira)
[ 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

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

2024-01-30 Thread Timo Walther (Jira)
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

2024-01-19 Thread Timo Walther (Jira)
[ 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

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

2024-01-19 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17808558#comment-17808558 ] Timo Walther commented on FLINK-33950: -- Hi [~jackylau], sorry for not replying earlier. I get too

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

2024-01-15 Thread Timo Walther (Jira)
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:

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

2024-01-15 Thread Timo Walther (Jira)
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

2024-01-15 Thread Timo Walther (Jira)
[ 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

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

2024-01-15 Thread Timo Walther (Jira)
[ 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

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

2024-01-15 Thread Timo Walther (Jira)
[ 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

2024-01-15 Thread Timo Walther (Jira)
[ 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:

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

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

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

2023-12-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17797131#comment-17797131 ] Timo Walther commented on FLINK-33644: -- [~fsk119] QueryOperations are intended to be put into a

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

2023-12-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796862#comment-17796862 ] Timo Walther commented on FLINK-33666: -- [~jhughes] was this issue resolved? Was it just a problem

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

2023-12-11 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17795266#comment-17795266 ] Timo Walther commented on FLINK-33784: -- Hi [~hackergin], DelegatingReadableConfig could be one

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

2023-12-11 Thread Timo Walther (Jira)
[ 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

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

2023-12-08 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17794746#comment-17794746 ] Timo Walther commented on FLINK-33784: -- What is required is this: {code} final

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

2023-12-08 Thread Timo Walther (Jira)
[ 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

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

2023-12-08 Thread Timo Walther (Jira)
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:

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

2023-12-07 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17794179#comment-17794179 ] Timo Walther commented on FLINK-31835: -- {quote} My only concern is the compatibility problem. What

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

2023-12-07 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17794170#comment-17794170 ] Timo Walther commented on FLINK-33523: -- Thanks for reporting this issue [~prabhujoseph]. I replied

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

2023-12-07 Thread Timo Walther (Jira)
[ 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:

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

2023-12-07 Thread Timo Walther (Jira)
[ 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

2023-12-07 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2023-11-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791152#comment-17791152 ] Timo Walther commented on FLINK-33597: -- Thanks for linking the issue [~lincoln.86xy]. Yes, this was

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

2023-11-27 Thread Timo Walther (Jira)
[ 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

2023-11-27 Thread Timo Walther (Jira)
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

2023-11-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17784363#comment-17784363 ] Timo Walther commented on FLINK-33497: -- [~tzulitai] would you like to take this? Or who in the

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

2023-11-09 Thread Timo Walther (Jira)
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

2023-11-09 Thread Timo Walther (Jira)
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

2023-11-09 Thread Timo Walther (Jira)
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

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

2023-11-09 Thread Timo Walther (Jira)
[ 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.

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

2023-11-09 Thread Timo Walther (Jira)
[ 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

2023-11-09 Thread Timo Walther (Jira)
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

2023-11-08 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783921#comment-17783921 ] Timo Walther commented on FLINK-32444: -- The easiest solution could be to check for the configured

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

2023-11-08 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783919#comment-17783919 ] Timo Walther commented on FLINK-32444: -- I was about to simply open a PR for this change, but then I

[jira] [Closed] (FLINK-33447) Avoid CompiledPlan recompilation during loading

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

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

2023-11-03 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782654#comment-17782654 ] Timo Walther commented on FLINK-32444: -- [~jark] is there a reason why you didn't implement this

[jira] [Created] (FLINK-33447) Avoid CompiledPlan recompilation during loading

2023-11-03 Thread Timo Walther (Jira)
Timo Walther created FLINK-33447: Summary: Avoid CompiledPlan recompilation during loading Key: FLINK-33447 URL: https://issues.apache.org/jira/browse/FLINK-33447 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27774) Window Agg doesn't work when used in Batch Table API

2023-11-02 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782077#comment-17782077 ] Timo Walther commented on FLINK-27774: -- Table API uses the deprecated windows right now. We should

[jira] [Closed] (FLINK-25809) Introduce test infra for building FLIP-190 tests

2023-10-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25809. Resolution: Fixed Based on recent feedback, we slightly improved the API. Fixed in master:

[jira] [Reopened] (FLINK-25809) Introduce test infra for building FLIP-190 tests

2023-10-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-25809: -- > Introduce test infra for building FLIP-190 tests >

[jira] [Closed] (FLINK-25809) Introduce test infra for building FLIP-190 tests

2023-10-26 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25809. Fix Version/s: 1.19.0 Resolution: Fixed Fixed in master:

[jira] [Assigned] (FLINK-25809) Introduce test infra for building FLIP-190 tests

2023-10-23 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25809: Assignee: Timo Walther > Introduce test infra for building FLIP-190 tests >

[jira] [Commented] (FLINK-25217) FLIP-190: Support Version Upgrades for Table API & SQL Programs

2023-10-23 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778588#comment-17778588 ] Timo Walther commented on FLINK-25217: -- Update: A more sophisticated testing infra around

[jira] [Commented] (FLINK-32397) Add doc for add/drop/show partition

2023-10-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1601#comment-1601 ] Timo Walther commented on FLINK-32397: -- [~luoyuxia] sorry for the ping but I see this ALTER TABLE

[jira] (FLINK-32397) Add doc for add/drop/show partition

2023-10-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32397 ] Timo Walther deleted comment on FLINK-32397: -- was (Author: twalthr): [~ruanhang1993][~luoyuxia] Is there a bug in the ALTER TABLE documentation or what does this mean:

[jira] [Commented] (FLINK-32397) Add doc for add/drop/show partition

2023-10-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1593#comment-1593 ] Timo Walther commented on FLINK-32397: -- [~ruanhang1993][~luoyuxia] Is there a bug in the ALTER

[jira] [Commented] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17774387#comment-17774387 ] Timo Walther commented on FLINK-33200: -- We should not use `PlannerTypeInferenceUtilImpl` anymore.

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

2023-10-11 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773973#comment-17773973 ] Timo Walther commented on FLINK-33182: -- Thanks [~lincoln.86xy]. Let me know if I can help with a

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

2023-10-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773370#comment-17773370 ] Timo Walther commented on FLINK-33182: -- Great that we are on the same page. Yes I meant the

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

2023-10-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773229#comment-17773229 ] Timo Walther edited comment on FLINK-33182 at 10/9/23 10:22 AM:

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

2023-10-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773229#comment-17773229 ] Timo Walther commented on FLINK-33182: -- [~lincoln.86xy] not sure if I understand your comment

[jira] [Commented] (FLINK-33183) Enable metadata columns in NduAnalyzer with retract if non-virtual

2023-10-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17771876#comment-17771876 ] Timo Walther commented on FLINK-33183: -- [~lincoln.86xy] what is you opinion here? This might be

[jira] [Created] (FLINK-33183) Enable metadata columns in NduAnalyzer with retract if non-virtual

2023-10-04 Thread Timo Walther (Jira)
Timo Walther created FLINK-33183: Summary: Enable metadata columns in NduAnalyzer with retract if non-virtual Key: FLINK-33183 URL: https://issues.apache.org/jira/browse/FLINK-33183 Project: Flink

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

2023-10-04 Thread Timo Walther (Jira)
Timo Walther created FLINK-33182: Summary: Allow metadata columns in NduAnalyzer with ChangelogNormalize Key: FLINK-33182 URL: https://issues.apache.org/jira/browse/FLINK-33182 Project: Flink

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

2023-10-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17771868#comment-17771868 ] Timo Walther commented on FLINK-33182: -- [~lincoln.86xy] do you agree with this assumption? > Allow

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

2023-09-29 Thread Timo Walther (Jira)
[ 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-33169) Window TVFs don't consider column expansion

2023-09-29 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-33169. Fix Version/s: 1.19.0 Resolution: Fixed Fixed in master:

[jira] [Created] (FLINK-33169) Window TVFs don't consider column expansion

2023-09-29 Thread Timo Walther (Jira)
Timo Walther created FLINK-33169: Summary: Window TVFs don't consider column expansion Key: FLINK-33169 URL: https://issues.apache.org/jira/browse/FLINK-33169 Project: Flink Issue Type:

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

2023-09-29 Thread Timo Walther (Jira)
[ 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-33028) FLIP-348: Make expanding behavior of virtual metadata columns configurable

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

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

2023-09-04 Thread Timo Walther (Jira)
Timo Walther created FLINK-33028: Summary: FLIP-348: Make expanding behavior of virtual metadata columns configurable Key: FLINK-33028 URL: https://issues.apache.org/jira/browse/FLINK-33028 Project:

[jira] [Commented] (FLINK-24803) Fix cast BINARY/VARBINARY to STRING

2023-08-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754687#comment-17754687 ] Timo Walther commented on FLINK-24803: -- If you like the old casting behavior, we provide a config

[jira] [Commented] (FLINK-24803) Fix cast BINARY/VARBINARY to STRING

2023-08-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754686#comment-17754686 ] Timo Walther commented on FLINK-24803: -- I answered in

[jira] [Commented] (FLINK-32815) Add HASHCODE support in SQL & Table API

2023-08-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752313#comment-17752313 ] Timo Walther commented on FLINK-32815: -- >From all links in the description, only the Oracle one

[jira] [Commented] (FLINK-24024) Support session Window TVF

2023-08-08 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752063#comment-17752063 ] Timo Walther commented on FLINK-24024: -- Thanks for the background information [~Sergey Nuyanzin]. I

[jira] [Commented] (FLINK-24024) Support session Window TVF

2023-08-07 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751733#comment-17751733 ] Timo Walther commented on FLINK-24024: -- [~Sergey Nuyanzin] so I guess CALCITE-4337 is the missing

[jira] [Closed] (FLINK-32689) Insufficient validation for table.local-time-zone

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

  1   2   3   4   5   6   7   8   9   10   >