[jira] [Assigned] (FLINK-29215) Use config based constructors for flink calcite Converter rules

[ https://issues.apache.org/jira/browse/FLINK-29215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-29215: Assignee: Sergey Nuyanzin > Use config based constructors for flink calcite Converter rul

[jira] [Comment Edited] (FLINK-30292) Better support for conversion between DataType and TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-30292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17648563#comment-17648563 ] Timo Walther edited comment on FLINK-30292 at 12/16/22 10:57 AM: -

[jira] [Commented] (FLINK-30292) Better support for conversion between DataType and TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-30292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17648563#comment-17648563 ] Timo Walther commented on FLINK-30292: -- Thanks for starting this discussion [~yunfe

[jira] [Commented] (FLINK-15635) Allow passing a ClassLoader to EnvironmentSettings

[ https://issues.apache.org/jira/browse/FLINK-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17645970#comment-17645970 ] Timo Walther commented on FLINK-15635: -- [~prabhujoseph] the DataStream API still re

[jira] [Closed] (FLINK-21239) Upgrade Calcite version to 1.28

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

[jira] [Commented] (FLINK-29540) SubQueryAntiJoinTest started to fail after Calcite 1.27

[ https://issues.apache.org/jira/browse/FLINK-29540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17645322#comment-17645322 ] Timo Walther commented on FLINK-29540: -- [~Sergey Nuyanzin] I moved this to 1.29 upd

[jira] [Updated] (FLINK-29540) SubQueryAntiJoinTest started to fail after Calcite 1.27

[ https://issues.apache.org/jira/browse/FLINK-29540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29540: - Parent Issue: FLINK-29932 (was: FLINK-21239) > SubQueryAntiJoinTest started to fail after Calci

[jira] [Updated] (FLINK-29237) RexSimplify can not be removed after update to calcite 1.27

[ https://issues.apache.org/jira/browse/FLINK-29237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29237: - Parent Issue: FLINK-29932 (was: FLINK-21239) > RexSimplify can not be removed after update to c

[jira] [Commented] (FLINK-30121) Support Stored procedures

[ https://issues.apache.org/jira/browse/FLINK-30121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17640016#comment-17640016 ] Timo Walther commented on FLINK-30121: -- I agree with [~martijnvisser], we all have

[jira] [Created] (FLINK-30226) Offer a Identity(De)SerializationSchema

Timo Walther created FLINK-30226: Summary: Offer a Identity(De)SerializationSchema Key: FLINK-30226 URL: https://issues.apache.org/jira/browse/FLINK-30226 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625534#comment-17625534 ] Timo Walther commented on FLINK-29739: -- Sorry, to jump into this topic so late. But

[jira] [Updated] (FLINK-29540) SubQueryAntiJoinTest started to fail after Calcite 1.27

[ https://issues.apache.org/jira/browse/FLINK-29540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29540: - Parent Issue: FLINK-21239 (was: FLINK-20873) > SubQueryAntiJoinTest started to fail after Calci

[jira] [Updated] (FLINK-29237) RexSimplify can not be removed after update to calcite 1.27

[ https://issues.apache.org/jira/browse/FLINK-29237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29237: - Parent Issue: FLINK-21239 (was: FLINK-20873) > RexSimplify can not be removed after update to c

[jira] [Updated] (FLINK-29203) Support optimization of Union(all, Values, Values) to Values

[ https://issues.apache.org/jira/browse/FLINK-29203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29203: - Parent: (was: FLINK-20873) Issue Type: Improvement (was: Sub-task) > Support optimi

[jira] [Closed] (FLINK-20873) Upgrade Calcite version to 1.27

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

[jira] [Commented] (FLINK-21239) Upgrade Calcite version to 1.28

[ https://issues.apache.org/jira/browse/FLINK-21239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622084#comment-17622084 ] Timo Walther commented on FLINK-21239: -- [~Sergey Nuyanzin] I assume you will take t

[jira] [Reopened] (FLINK-21239) Upgrade Calcite version to 1.28

[ https://issues.apache.org/jira/browse/FLINK-21239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-21239: -- We decided to incrementally upgrade Calcite version by version to keep PR readable and spot break

[jira] [Assigned] (FLINK-21239) Upgrade Calcite version to 1.28

[ https://issues.apache.org/jira/browse/FLINK-21239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-21239: Assignee: Sergey Nuyanzin > Upgrade Calcite version to 1.28 > ---

[jira] [Closed] (FLINK-29446) Remove Calcite classes which were fixed in 1.24

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

[jira] [Closed] (FLINK-29309) Relax allow-client-job-configurations for Table API and parameters

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

[jira] [Commented] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607636#comment-17607636 ] Timo Walther commented on FLINK-29379: -- The question is when does the merging happe

[jira] [Updated] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29379: - Description: Not sure if this is a duplicate, but as this issue pops up over and over again, it

[jira] [Updated] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

[ https://issues.apache.org/jira/browse/FLINK-29379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29379: - Description: Not sure if this is a duplicate, but as this issue pops up over and over again, it

[jira] [Created] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

Timo Walther created FLINK-29379: Summary: Back ExecutionConfig and CheckpointConfig by Configuration Key: FLINK-29379 URL: https://issues.apache.org/jira/browse/FLINK-29379 Project: Flink Is

[jira] [Commented] (FLINK-29370) Protobuf in flink-sql-protobuf is not shaded

[ https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607615#comment-17607615 ] Timo Walther commented on FLINK-29370: -- In Avro this is the difference between gene

[jira] [Created] (FLINK-29309) Relax allow-client-job-configurations for Table API and parameters

Timo Walther created FLINK-29309: Summary: Relax allow-client-job-configurations for Table API and parameters Key: FLINK-29309 URL: https://issues.apache.org/jira/browse/FLINK-29309 Project: Flink

[jira] [Comment Edited] (FLINK-29267) Support external type systems in DDL

[ https://issues.apache.org/jira/browse/FLINK-29267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603592#comment-17603592 ] Timo Walther edited comment on FLINK-29267 at 9/13/22 2:20 PM: ---

[jira] [Commented] (FLINK-29267) Support external type systems in DDL

[ https://issues.apache.org/jira/browse/FLINK-29267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603592#comment-17603592 ] Timo Walther commented on FLINK-29267: -- > "you could also consider what pg extensio

[jira] [Commented] (FLINK-29267) Support external type systems in DDL

[ https://issues.apache.org/jira/browse/FLINK-29267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603589#comment-17603589 ] Timo Walther commented on FLINK-29267: -- >From Henrik Feldt >(https://apache-flink.

[jira] [Updated] (FLINK-29267) Support external type systems in DDL

[ https://issues.apache.org/jira/browse/FLINK-29267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29267: - Description: Many connectors and formats require supporting external data types. Postgres users

[jira] [Created] (FLINK-29267) Support external type systems in DDL

Timo Walther created FLINK-29267: Summary: Support external type systems in DDL Key: FLINK-29267 URL: https://issues.apache.org/jira/browse/FLINK-29267 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-25932) Introduce ExecNodeContext.generateUid()

[ https://issues.apache.org/jira/browse/FLINK-25932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602182#comment-17602182 ] Timo Walther commented on FLINK-25932: -- Hi [~tonywei], no it will not be determinis

[jira] [Commented] (FLINK-27998) Upgrade Calcite version to 1.30

[ https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597797#comment-17597797 ] Timo Walther commented on FLINK-27998: -- Btw maybe it makes sense to apply Calcite v

[jira] [Commented] (FLINK-27998) Upgrade Calcite version to 1.30

[ https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597793#comment-17597793 ] Timo Walther commented on FLINK-27998: -- [~Sergey Nuyanzin] [~jingzhang] please ping

[jira] [Commented] (FLINK-29088) Project push down cause the source reuse can not work

[ https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585224#comment-17585224 ] Timo Walther commented on FLINK-29088: -- Thanks for identifying the problem [~aitozi

[jira] [Assigned] (FLINK-29088) Project push down cause the source reuse can not work

[ https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-29088: Assignee: Aitozi > Project push down cause the source reuse can not work > --

[jira] [Closed] (FLINK-29014) Use setting instead of merging for pipeline.jars in StreamExecutionEnvironment.configure

[ https://issues.apache.org/jira/browse/FLINK-29014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-29014. Resolution: Fixed Fixed in master: eb69b11532e6ac3fafd74849ed5f8a2c1273b71c > Use setting instead

[jira] [Commented] (FLINK-29035) ExpressionReducer does not work with jar resources

[ https://issues.apache.org/jira/browse/FLINK-29035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17581348#comment-17581348 ] Timo Walther commented on FLINK-29035: -- CC [~lsy]  > ExpressionReducer does not wo

[jira] [Created] (FLINK-29035) ExpressionReducer does not work with jar resources

Timo Walther created FLINK-29035: Summary: ExpressionReducer does not work with jar resources Key: FLINK-29035 URL: https://issues.apache.org/jira/browse/FLINK-29035 Project: Flink Issue Type

[jira] [Updated] (FLINK-29035) ExpressionReducer does not work with jar resources

[ https://issues.apache.org/jira/browse/FLINK-29035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29035: - Fix Version/s: 1.16.0 > ExpressionReducer does not work with jar resources > ---

[jira] [Closed] (FLINK-28951) Header in janino generated java files can merge with line numbers

[ https://issues.apache.org/jira/browse/FLINK-28951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-28951. Fix Version/s: 1.16.0 1.15.2 Assignee: Sergey Nuyanzin Resolutio

[jira] [Updated] (FLINK-29014) Use setting instead of merging for pipeline.jars in StreamExecutionEnvironment.configure

[ https://issues.apache.org/jira/browse/FLINK-29014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29014: - Priority: Critical (was: Major) > Use setting instead of merging for pipeline.jars in > Stream

[jira] [Updated] (FLINK-29014) Use setting instead of merging for pipeline.jars in StreamExecutionEnvironment.configure

[ https://issues.apache.org/jira/browse/FLINK-29014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29014: - Fix Version/s: 1.16.0 > Use setting instead of merging for pipeline.jars in > StreamExecutionEn

[jira] [Commented] (FLINK-28213) StreamExecutionEnvironment configure method support override pipeline.jars option

[ https://issues.apache.org/jira/browse/FLINK-28213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580740#comment-17580740 ] Timo Walther commented on FLINK-28213: -- I created FLINK-29014 and will come up with

[jira] [Updated] (FLINK-29014) Use setting instead of merging for pipeline.jars in StreamExecutionEnvironment.configure

[ https://issues.apache.org/jira/browse/FLINK-29014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29014: - Description: See discussion in FLINK-28213. We should restore a "setting" behavior instead of a

[jira] [Created] (FLINK-29014) Use setting instead of merging for pipeline.jars in StreamExecutionEnvironment.configure

Timo Walther created FLINK-29014: Summary: Use setting instead of merging for pipeline.jars in StreamExecutionEnvironment.configure Key: FLINK-29014 URL: https://issues.apache.org/jira/browse/FLINK-29014

[jira] [Closed] (FLINK-28994) Enable withCredentials for Flink UI

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

[jira] [Updated] (FLINK-28994) Enable withCredentials for Flink UI

[ https://issues.apache.org/jira/browse/FLINK-28994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-28994: - Issue Type: Bug (was: Improvement) > Enable withCredentials for Flink UI >

[jira] [Updated] (FLINK-28994) Enable withCredentials for Flink UI

[ https://issues.apache.org/jira/browse/FLINK-28994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-28994: - Description: Some environments require cookies to authenticate the Flink UI. By enabling the wit

[jira] [Closed] (FLINK-28861) Non-deterministic UID generation might cause issues during restore

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-28861. Release Note: 1.15.0 and 1.15.1 generated non-deterministic UIDs for operators that make it diffic

[jira] [Updated] (FLINK-28861) Non-deterministic UID generation might cause issues during restore

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-28861: - Summary: Non-deterministic UID generation might cause issues during restore (was: Cannot resume

[jira] [Commented] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580104#comment-17580104 ] Timo Walther commented on FLINK-28861: -- Fixed in 1.15.2: commit 105d7c911bd0c5d863

[jira] [Commented] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

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

[jira] [Comment Edited] (FLINK-28213) StreamExecutionEnvironment configure method support override pipeline.jars option

[ https://issues.apache.org/jira/browse/FLINK-28213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579668#comment-17579668 ] Timo Walther edited comment on FLINK-28213 at 8/15/22 12:02 PM: --

[jira] [Commented] (FLINK-28213) StreamExecutionEnvironment configure method support override pipeline.jars option

[ https://issues.apache.org/jira/browse/FLINK-28213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579668#comment-17579668 ] Timo Walther commented on FLINK-28213: -- [~lsy] I'm not super happy about the change

[jira] [Updated] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-28861: - Priority: Blocker (was: Critical) > Cannot resume from savepoint when using fromChangelogStream

[jira] [Updated] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-28861: - Fix Version/s: 1.16.0 1.15.2 > Cannot resume from savepoint when using fromCh

[jira] [Commented] (FLINK-27376) Hive dialect supports "select current_database()"

[ https://issues.apache.org/jira/browse/FLINK-27376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577382#comment-17577382 ] Timo Walther commented on FLINK-27376: -- [~luoyuxia] if you find some time, it would

[jira] [Comment Edited] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577337#comment-17577337 ] Timo Walther edited comment on FLINK-28861 at 8/9/22 10:19 AM: ---

[jira] [Commented] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17577337#comment-17577337 ] Timo Walther commented on FLINK-28861: -- Let me summarize the issue: The UID generat

[jira] [Assigned] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-28861: Assignee: Timo Walther > Cannot resume from savepoint when using fromChangelogStream in u

[jira] [Commented] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576821#comment-17576821 ] Timo Walther commented on FLINK-28861: -- Thanks for the response! The generated UID

[jira] [Updated] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-28861: - Priority: Critical (was: Major) > Cannot resume from savepoint when using fromChangelogStream i

[jira] [Commented] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576770#comment-17576770 ] Timo Walther commented on FLINK-28861: -- After looking into this topic, I have a fir

[jira] [Commented] (FLINK-28861) Cannot resume from savepoint when using fromChangelogStream in upsert mode

[ https://issues.apache.org/jira/browse/FLINK-28861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576645#comment-17576645 ] Timo Walther commented on FLINK-28861: -- This is clearly a bug that needs investigat

[jira] [Commented] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17565320#comment-17565320 ] Timo Walther commented on FLINK-27142: -- In the past, time attributes were causing i

[jira] [Commented] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563211#comment-17563211 ] Timo Walther commented on FLINK-27142: -- Yes and no, the bash script tests the SQL C

[jira] [Comment Edited] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563066#comment-17563066 ] Timo Walther edited comment on FLINK-27142 at 7/6/22 9:09 AM:

[jira] [Commented] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563066#comment-17563066 ] Timo Walther commented on FLINK-27142: -- The intention of the test_sql_client.sh was

[jira] [Comment Edited] (FLINK-27142) Remove bash tests dependencies on the Elasticsearch connector.

[ https://issues.apache.org/jira/browse/FLINK-27142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563066#comment-17563066 ] Timo Walther edited comment on FLINK-27142 at 7/6/22 9:07 AM:

[jira] [Commented] (FLINK-28160) org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled.

[ https://issues.apache.org/jira/browse/FLINK-28160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17557255#comment-17557255 ] Timo Walther commented on FLINK-28160: -- [~cjh] please add a reproducible example. O

[jira] [Commented] (FLINK-28071) Support missing built-in functions in Table API

[ https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17554484#comment-17554484 ] Timo Walther commented on FLINK-28071: -- Until this issue is fixed: A current work a

[jira] [Commented] (FLINK-28071) Support missing built-in functions in Table API

[ https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17554483#comment-17554483 ] Timo Walther commented on FLINK-28071: -- [~ana4] please also take a look at FLINK-22

[jira] [Commented] (FLINK-27725) Create tests for TypeInformation and TypeSerializer classes in table

[ https://issues.apache.org/jira/browse/FLINK-27725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540877#comment-17540877 ] Timo Walther commented on FLINK-27725: -- What do you mean with "connector is not tab

[jira] [Commented] (FLINK-27725) Create tests for TypeInformation and TypeSerializer classes in table

[ https://issues.apache.org/jira/browse/FLINK-27725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540859#comment-17540859 ] Timo Walther commented on FLINK-27725: -- Btw wouldn't it make sense to put the "file

[jira] [Commented] (FLINK-27725) Create tests for TypeInformation and TypeSerializer classes in table

[ https://issues.apache.org/jira/browse/FLINK-27725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540855#comment-17540855 ] Timo Walther commented on FLINK-27725: -- Adding `flink-table-runtime` did not solve

[jira] [Commented] (FLINK-27725) Create tests for TypeInformation and TypeSerializer classes in table

[ https://issues.apache.org/jira/browse/FLINK-27725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540838#comment-17540838 ] Timo Walther commented on FLINK-27725: -- [~alexanderpreuss] You can depend on the `f

[jira] [Commented] (FLINK-27725) Create tests for TypeInformation and TypeSerializer classes in table

[ https://issues.apache.org/jira/browse/FLINK-27725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17540823#comment-17540823 ] Timo Walther commented on FLINK-27725: -- [~alexanderpreuss] why do you need a depend

[jira] [Commented] (FLINK-27492) Flink table scala example does not including the scala-api jars

[ https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537377#comment-17537377 ] Timo Walther commented on FLINK-27492: -- [~gaoyunhaii] yes we can put the Scala API

[jira] [Assigned] (FLINK-27492) Flink table scala example does not including the scala-api jars

[ https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-27492: Assignee: Timo Walther > Flink table scala example does not including the scala-api jars

[jira] [Updated] (FLINK-27534) Apply scalafmt to 1.15 branch

[ https://issues.apache.org/jira/browse/FLINK-27534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-27534: - Description: As discussed on the mailing list: https://lists.apache.org/thread/9jznwjh73jhcncnx

[jira] [Created] (FLINK-27534) Apply scalafmt to 1.15 branch

Timo Walther created FLINK-27534: Summary: Apply scalafmt to 1.15 branch Key: FLINK-27534 URL: https://issues.apache.org/jira/browse/FLINK-27534 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-27492) Flink table scala example does not including the scala-api jars

[ https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17532155#comment-17532155 ] Timo Walther commented on FLINK-27492: -- Yes, this seems to be a shortcoming. It wou

[jira] [Closed] (FLINK-27368) CAST(' 1 ' as BIGINT) reutrns wrong result

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

[jira] [Commented] (FLINK-26947) Add ARRAY_CONTAINS supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-26947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531170#comment-17531170 ] Timo Walther commented on FLINK-26947: -- So are you fine with the current implementa

[jira] [Commented] (FLINK-6810) Add a set of built-in functions to Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530628#comment-17530628 ] Timo Walther commented on FLINK-6810: - FLINK-22857 added the last missing piece that

[jira] [Commented] (FLINK-26947) Add ARRAY_CONTAINS supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-26947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530627#comment-17530627 ] Timo Walther commented on FLINK-26947: -- [~lsy] I just noticed that your JIRA issue

[jira] [Closed] (FLINK-26947) Add ARRAY_CONTAINS supported in SQL & Table API

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

[jira] [Closed] (FLINK-22857) Add possibility to call built-in functions in SpecializedFunction

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

[jira] [Commented] (FLINK-27365) [umbrella] Schema evolution on table store

[ https://issues.apache.org/jira/browse/FLINK-27365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527521#comment-17527521 ] Timo Walther commented on FLINK-27365: -- [~lzljs3620320] Is there any design documen

[jira] [Comment Edited] (FLINK-27346) [umbrella] Introduce Hive reader for table store

[ https://issues.apache.org/jira/browse/FLINK-27346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527515#comment-17527515 ] Timo Walther edited comment on FLINK-27346 at 4/25/22 2:01 PM: ---

[jira] [Commented] (FLINK-27346) [umbrella] Introduce Hive reader for table store

[ https://issues.apache.org/jira/browse/FLINK-27346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527515#comment-17527515 ] Timo Walther commented on FLINK-27346: -- Please add some explanation to JIRA issue.

[jira] [Commented] (FLINK-27367) CAST between INT and DATE is broken

[ https://issues.apache.org/jira/browse/FLINK-27367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527466#comment-17527466 ] Timo Walther commented on FLINK-27367: -- Sure, this we can do. > CAST between INT a

[jira] [Assigned] (FLINK-27368) CAST(' 1 ' as BIGINT) reutrns wrong result

[ https://issues.apache.org/jira/browse/FLINK-27368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-27368: Assignee: Timo Walther > CAST(' 1 ' as BIGINT) reutrns wrong result > ---

[jira] [Commented] (FLINK-27368) CAST(' 1 ' as BIGINT) reutrns wrong result

[ https://issues.apache.org/jira/browse/FLINK-27368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527346#comment-17527346 ] Timo Walther commented on FLINK-27368: -- +1 for performing trimming again. > CAST('

[jira] [Commented] (FLINK-27367) CAST between INT and DATE is broken

[ https://issues.apache.org/jira/browse/FLINK-27367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17527345#comment-17527345 ] Timo Walther commented on FLINK-27367: -- I would say this is on purpose. It is simil

[jira] [Updated] (FLINK-27247) ScalarOperatorGens.numericCasting is not compatible with legacy behavior

[ https://issues.apache.org/jira/browse/FLINK-27247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-27247: - Fix Version/s: 1.16.0 > ScalarOperatorGens.numericCasting is not compatible with legacy behavior

[jira] [Closed] (FLINK-27247) ScalarOperatorGens.numericCasting is not compatible with legacy behavior

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

[jira] [Assigned] (FLINK-26947) Add ARRAY_CONTAINS supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-26947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-26947: Assignee: Timo Walther > Add ARRAY_CONTAINS supported in SQL & Table API > --

[jira] [Closed] (FLINK-27263) Rename the metadata column to the user specified name in DDL

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

<    1   2   3   4   5   6   7   8   9   10   >