[jira] [Updated] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-19589: - Priority: Major (was: Not a Priority) > Expose S3 options for tagging and object lifecycle poli

[jira] [Closed] (FLINK-18221) SQL client YAML validation incomplete

[ https://issues.apache.org/jira/browse/FLINK-18221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-18221. Resolution: Won't Fix The SQL Client YAML file is deprecated and has been replaced with SQL files.

[jira] [Closed] (FLINK-11982) BatchTableSourceFactory support Json Format File

[ https://issues.apache.org/jira/browse/FLINK-11982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11982. Resolution: Won't Fix BatchTableSourceFactory is not supported anymore. > BatchTableSourceFactory

[jira] [Updated] (FLINK-25229) Introduce flink-table-api-bridge-base

[ https://issues.apache.org/jira/browse/FLINK-25229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25229: - Summary: Introduce flink-table-api-bridge-base (was: Introduce flink-table-api-bridge-common)

[jira] [Closed] (FLINK-25229) Introduce flink-table-api-bridge-common

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

[jira] [Closed] (FLINK-24186) Disable single rowtime column check for collect/print

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

[jira] [Assigned] (FLINK-25230) Harden type serialization in JSON plan

[ https://issues.apache.org/jira/browse/FLINK-25230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25230: Assignee: Timo Walther > Harden type serialization in JSON plan > ---

[jira] [Updated] (FLINK-25234) Flink should parse ISO timestamp in UTC format

[ https://issues.apache.org/jira/browse/FLINK-25234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25234: - Component/s: Table SQL / API > Flink should parse ISO timestamp in UTC format >

[jira] [Commented] (FLINK-25234) Flink should parse ISO timestamp in UTC format

[ https://issues.apache.org/jira/browse/FLINK-25234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456460#comment-17456460 ] Timo Walther commented on FLINK-25234: -- Which format are you using? JSON, Avro, ...

[jira] [Comment Edited] (FLINK-25234) Flink should parse ISO timestamp in UTC format

[ https://issues.apache.org/jira/browse/FLINK-25234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456460#comment-17456460 ] Timo Walther edited comment on FLINK-25234 at 12/9/21, 2:05 PM: --

[jira] [Closed] (FLINK-25157) Introduce NULL type to string cast rule

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

[jira] [Created] (FLINK-25230) Harden type serialization in JSON plan

Timo Walther created FLINK-25230: Summary: Harden type serialization in JSON plan Key: FLINK-25230 URL: https://issues.apache.org/jira/browse/FLINK-25230 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-25230) Harden type serialization in JSON plan

[ https://issues.apache.org/jira/browse/FLINK-25230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25230: - Component/s: Table SQL / Planner > Harden type serialization in JSON plan >

[jira] [Closed] (FLINK-25156) DISTINCT is not handled correctly by CastRules

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

[jira] [Closed] (FLINK-25052) Port row to row cast logic to CastRule

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

[jira] [Created] (FLINK-25221) Allow global table options for all table connectors

Timo Walther created FLINK-25221: Summary: Allow global table options for all table connectors Key: FLINK-25221 URL: https://issues.apache.org/jira/browse/FLINK-25221 Project: Flink Issue Typ

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

[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454726#comment-17454726 ] Timo Walther commented on FLINK-25217: -- The FLIP has not been accepted yet but I wi

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

Timo Walther created FLINK-25217: Summary: FLIP-190: Support Version Upgrades for Table API & SQL Programs Key: FLINK-25217 URL: https://issues.apache.org/jira/browse/FLINK-25217 Project: Flink

[jira] [Commented] (FLINK-25205) Optimize SinkUpsertMaterializer

[ https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454718#comment-17454718 ] Timo Walther commented on FLINK-25205: -- But this also means that UPDATE_BEFORE beco

[jira] [Comment Edited] (FLINK-24077) HBaseConnectorITCase.testTableSink

[ https://issues.apache.org/jira/browse/FLINK-24077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454510#comment-17454510 ] Timo Walther edited comment on FLINK-24077 at 12/7/21, 9:51 AM: --

[jira] [Commented] (FLINK-24077) HBaseConnectorITCase.testTableSink

[ https://issues.apache.org/jira/browse/FLINK-24077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454510#comment-17454510 ] Timo Walther commented on FLINK-24077: -- [~jingge] I agree. We should definitely add

[jira] [Closed] (FLINK-25014) Table to DataStream conversion, wrong field order

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

[jira] [Updated] (FLINK-25014) Table to DataStream conversion, wrong field order

[ https://issues.apache.org/jira/browse/FLINK-25014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25014: - Issue Type: Improvement (was: Bug) > Table to DataStream conversion, wrong field order > --

[jira] [Closed] (FLINK-25114) Remove flink-scala dependency from flink-table-runtime

[ https://issues.apache.org/jira/browse/FLINK-25114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25114. Release Note: The flink-table-runtime has no Scala suffix anymore. Make sure to include flink-scal

[jira] [Closed] (FLINK-25114) Remove flink-scala dependency from flink-table-runtime

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

[jira] [Reopened] (FLINK-25114) Remove flink-scala dependency from flink-table-runtime

[ https://issues.apache.org/jira/browse/FLINK-25114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-25114: -- > Remove flink-scala dependency from flink-table-runtime > ---

[jira] [Created] (FLINK-25199) fromValues does not emit final MAX watermark

Timo Walther created FLINK-25199: Summary: fromValues does not emit final MAX watermark Key: FLINK-25199 URL: https://issues.apache.org/jira/browse/FLINK-25199 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-25186) KafkaDynamicTableFactoryTest and UpsertKafkaDynamicTableFactoryTest fails on AZP

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

[jira] [Assigned] (FLINK-25014) Table to DataStream conversion, wrong field order

[ https://issues.apache.org/jira/browse/FLINK-25014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25014: Assignee: Timo Walther > Table to DataStream conversion, wrong field order >

[jira] [Commented] (FLINK-25014) Table to DataStream conversion, wrong field order

[ https://issues.apache.org/jira/browse/FLINK-25014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17454025#comment-17454025 ] Timo Walther commented on FLINK-25014: -- The issue here is that we perform a case-se

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453964#comment-17453964 ] Timo Walther commented on FLINK-20370: -- Given that many people still wait for 1.14.

[jira] [Closed] (FLINK-9477) FLIP-90: Support SQL 2016 JSON functions in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-9477. --- Resolution: Fixed FLIP-90 can be considered as done. The remaining open issues are rather "minor" is

[jira] [Updated] (FLINK-24351) translate "JSON Function" pages into Chinese

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

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453957#comment-17453957 ] Timo Walther commented on FLINK-24351: -- I will decouple this issue from the parent.

[jira] [Closed] (FLINK-24290) Support STRUCTURED_TYPE for JSON_OBJECT / JSON_ARRAY

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

[jira] [Commented] (FLINK-25186) KafkaDynamicTableFactoryTest and UpsertKafkaDynamicTableFactoryTest fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453901#comment-17453901 ] Timo Walther commented on FLINK-25186: -- CC [~slinkydeveloper] > KafkaDynamicTable

[jira] [Closed] (FLINK-25111) Introduce config option to keep previous CAST behaviour

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

[jira] [Closed] (FLINK-24687) flink-table uber jar should not include flink-connector-files dependency

[ https://issues.apache.org/jira/browse/FLINK-24687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24687. Fix Version/s: 1.15.0 Release Note: The table file system connector is not part of the table-

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17453124#comment-17453124 ] Timo Walther commented on FLINK-20370: -- [~lzljs3620320] are we planning to back por

[jira] [Assigned] (FLINK-24290) Support STRUCTURED_TYPE for JSON_OBJECT / JSON_ARRAY

[ https://issues.apache.org/jira/browse/FLINK-24290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-24290: Assignee: Timo Walther > Support STRUCTURED_TYPE for JSON_OBJECT / JSON_ARRAY > -

[jira] [Commented] (FLINK-15775) SourceFunctions are instantiated twice when pulled on from 2 Sinks

[ https://issues.apache.org/jira/browse/FLINK-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452988#comment-17452988 ] Timo Walther commented on FLINK-15775: -- [~BenoitParis] yes, please have a look at h

[jira] [Commented] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452985#comment-17452985 ] Timo Walther commented on FLINK-24103: -- [~monster#12] no there is still no result.

[jira] [Commented] (FLINK-24396) Add @Public annotations to Table & SQL API classes

[ https://issues.apache.org/jira/browse/FLINK-24396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452978#comment-17452978 ] Timo Walther commented on FLINK-24396: -- If you mean Maven module, yes I think {{fli

[jira] [Closed] (FLINK-24753) Enforce CHAR/VARCHAR precision when outputing to a Sink

[ https://issues.apache.org/jira/browse/FLINK-24753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24753. Fix Version/s: 1.15.0 Release Note: CHAR/VARCHAR lengths are enforced (trimmed/padded) by def

[jira] [Closed] (FLINK-24902) Port boolean <-> numeric casting logic to CastRule

[ https://issues.apache.org/jira/browse/FLINK-24902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24902. Resolution: Fixed Fixed in master: commit b17748b841bf43f2691a634889967d1eca4a1de9 [table-planner

[jira] [Updated] (FLINK-24902) Port boolean <-> numeric casting logic to CastRule

[ https://issues.apache.org/jira/browse/FLINK-24902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24902: - Release Note: (was: Casting from DECIMAL/DOUBLE/FLOAT to BOOLEAN is not supported anymore.) >

[jira] [Reopened] (FLINK-24902) Port boolean <-> numeric casting logic to CastRule

[ https://issues.apache.org/jira/browse/FLINK-24902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-24902: -- > Port boolean <-> numeric casting logic to CastRule > ---

[jira] [Commented] (FLINK-25083) Flaky Test in RowTest

[ https://issues.apache.org/jira/browse/FLINK-25083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451877#comment-17451877 ] Timo Walther commented on FLINK-25083: -- Could you elaborate why you need this patch

[jira] [Commented] (FLINK-25083) Flaky Test in RowTest

[ https://issues.apache.org/jira/browse/FLINK-25083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451875#comment-17451875 ] Timo Walther commented on FLINK-25083: -- [~HildoYe] named rows are don't have a dete

[jira] [Updated] (FLINK-25079) Globally introduce assertj assertions for tests

[ https://issues.apache.org/jira/browse/FLINK-25079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25079: - Description: As discussed on the dev@ mailing list, we advertise assertj instead of Hamcrest in

[jira] [Closed] (FLINK-25079) Globally introduce assertj assertions for tests

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

[jira] [Updated] (FLINK-25079) Globally introduce assertj assertions for tests

[ https://issues.apache.org/jira/browse/FLINK-25079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25079: - Component/s: Test Infrastructure (was: Table SQL / API) > Globally introduc

[jira] [Updated] (FLINK-25079) Globally introduce assertj assertions for tests

[ https://issues.apache.org/jira/browse/FLINK-25079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25079: - Summary: Globally introduce assertj assertions for tests (was: Add assertj assertions for table

[jira] [Closed] (FLINK-24902) Port boolean <-> numeric casting logic to CastRule

[ https://issues.apache.org/jira/browse/FLINK-24902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24902. Fix Version/s: 1.15.0 Release Note: Casting from DECIMAL/DOUBLE/FLOAT to BOOLEAN is not suppo

[jira] [Closed] (FLINK-23702) SQL casting to decimal which cannot hold its original value throws 'Column 'EXPR$0' is NOT NULL, however, a null value is being written into it'

[ https://issues.apache.org/jira/browse/FLINK-23702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-23702. > SQL casting to decimal which cannot hold its original value throws 'Column > 'EXPR$0' is NOT NULL,

[jira] [Commented] (FLINK-25111) Introduce config option to keep previous CAST behaviour

[ https://issues.apache.org/jira/browse/FLINK-25111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451697#comment-17451697 ] Timo Walther commented on FLINK-25111: -- +1 for only CastRulesTest. We should advert

[jira] [Closed] (FLINK-25075) Remove reflection to instantiate PlannerExpressionParser

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

[jira] [Closed] (FLINK-25060) Replace DataType.projectFields with Projection type

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

[jira] [Closed] (FLINK-21456) TableResult#print() should correctly stringify values

[ https://issues.apache.org/jira/browse/FLINK-21456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-21456. Fix Version/s: 1.15.0 Resolution: Fixed All subtasks of this issue have been closed. We sco

[jira] [Updated] (FLINK-21456) TableResult#print() should correctly stringify values

[ https://issues.apache.org/jira/browse/FLINK-21456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21456: - Summary: TableResult#print() should correctly stringify values (was: TableResult#print() should

[jira] [Closed] (FLINK-24507) Cleanup all the various date/time/timestamp utils

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

[jira] [Closed] (FLINK-25110) Flink SQL consumes Kafka up to a certain point in time

[ https://issues.apache.org/jira/browse/FLINK-25110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25110. Resolution: Duplicate Duplicate of FLINK-24456 > Flink SQL consumes Kafka up to a certain point i

[jira] [Updated] (FLINK-25110) Flink SQL consumes Kafka up to a certain point in time

[ https://issues.apache.org/jira/browse/FLINK-25110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25110: - Component/s: Table SQL / Ecosystem > Flink SQL consumes Kafka up to a certain point in time > --

[jira] [Commented] (FLINK-25110) Flink SQL consumes Kafka up to a certain point in time

[ https://issues.apache.org/jira/browse/FLINK-25110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451097#comment-17451097 ] Timo Walther commented on FLINK-25110: -- Flink's DataStream API connector can alread

[jira] [Commented] (FLINK-23918) FileNotFoundException when open auto-compact in filesystem

[ https://issues.apache.org/jira/browse/FLINK-23918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17451091#comment-17451091 ] Timo Walther commented on FLINK-23918: -- I downgraded it to Critical until we know m

[jira] [Updated] (FLINK-23918) FileNotFoundException when open auto-compact in filesystem

[ https://issues.apache.org/jira/browse/FLINK-23918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-23918: - Priority: Critical (was: Blocker) > FileNotFoundException when open auto-compact in filesystem

[jira] [Commented] (FLINK-24396) Add @Public annotations to Table & SQL API classes

[ https://issues.apache.org/jira/browse/FLINK-24396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450977#comment-17450977 ] Timo Walther commented on FLINK-24396: -- [~monster#12] let's split this into multipl

[jira] [Comment Edited] (FLINK-24396) Add @Public annotations to Table & SQL API classes

[ https://issues.apache.org/jira/browse/FLINK-24396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450977#comment-17450977 ] Timo Walther edited comment on FLINK-24396 at 11/30/21, 9:24 AM: -

[jira] [Closed] (FLINK-25047) Resolve most (trivial) architectural violations in flink-table

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

[jira] [Commented] (FLINK-24413) Casting to a CHAR() and VARCHAR() doesn't trim the string to the specified precision

[ https://issues.apache.org/jira/browse/FLINK-24413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450481#comment-17450481 ] Timo Walther commented on FLINK-24413: -- I'm pretty sure we had option 2 in the old

[jira] [Commented] (FLINK-21539) 'SQL Client end-to-end test (Blink planner) Elasticsearch (v6.3.1)' fails during download

[ https://issues.apache.org/jira/browse/FLINK-21539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17450456#comment-17450456 ] Timo Walther commented on FLINK-21539: -- Sorry, I forgot about this one. I will give

[jira] [Closed] (FLINK-24781) Port from string casting logic to CastRule

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

[jira] [Closed] (FLINK-24608) Sinks built with the unified sink framework do not receive timestamps when used in Table API

[ https://issues.apache.org/jira/browse/FLINK-24608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24608. Fix Version/s: 1.15.0 1.14.1 Release Note: This adds an additional operator

[jira] [Closed] (FLINK-19903) Allow to read metadata in filesystem connector

[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-19903. Fix Version/s: 1.15.0 Resolution: Fixed All subtasks are implemented. > Allow to read meta

[jira] [Closed] (FLINK-24616) Expose all metadata in FileStatus

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

[jira] [Closed] (FLINK-24889) Flink SQL Client should print corrently multisets

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

[jira] [Closed] (FLINK-24776) Clarify semantics of DecodingFormat and its data type

[ https://issues.apache.org/jira/browse/FLINK-24776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24776. Fix Version/s: 1.15.0 Release Note: The DecodingFormat interfaces was used for both projectabl

[jira] [Updated] (FLINK-24776) Clarify semantics of DecodingFormat and its data type

[ https://issues.apache.org/jira/browse/FLINK-24776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24776: - Description: Today the {{org.apache.flink.table.connector.format.DecodingFormat}} interface has

[jira] [Commented] (FLINK-24924) TO_TIMESTAMP and TO_DATE should fail

[ https://issues.apache.org/jira/browse/FLINK-24924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445014#comment-17445014 ] Timo Walther commented on FLINK-24924: -- I agree that exceptions are not optimal for

[jira] [Commented] (FLINK-24924) TO_TIMESTAMP and TO_DATE should fail

[ https://issues.apache.org/jira/browse/FLINK-24924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444548#comment-17444548 ] Timo Walther commented on FLINK-24924: -- Interestingly, we just have a conversion in

[jira] [Commented] (FLINK-24895) SqlTimestampSerializer#deserialize forgets to fully read from source when the record is null.

[ https://issues.apache.org/jira/browse/FLINK-24895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444312#comment-17444312 ] Timo Walther commented on FLINK-24895: -- Thanks, we will find someone who can fix th

[jira] [Updated] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000)

[ https://issues.apache.org/jira/browse/FLINK-24586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24586: - Release Note: Functions that returned VARCHAR(2000) in 1.14, return VARCHAR with maximum length

[jira] [Closed] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000)

[ https://issues.apache.org/jira/browse/FLINK-24586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24586. Fix Version/s: 1.15.0 Release Note: Functions that returned VARCHAR(2000) in 1.14, return VAR

[jira] [Updated] (FLINK-24685) Use the new casting rules in TableResult#print

[ https://issues.apache.org/jira/browse/FLINK-24685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24685: - Release Note: The string representation of BOOLEAN columns from DDL results (true/false -> TRUE/

[jira] [Closed] (FLINK-24685) Use the new casting rules in TableResult#print

[ https://issues.apache.org/jira/browse/FLINK-24685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24685. Fix Version/s: 1.15.0 Release Note: The string representation of BOOLEAN columns from DDL res

[jira] [Closed] (FLINK-24779) Port Numeric casting logic to CastRule

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

[jira] [Commented] (FLINK-24877) Implicitly add time attributes for VALUES clause

[ https://issues.apache.org/jira/browse/FLINK-24877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442336#comment-17442336 ] Timo Walther commented on FLINK-24877: -- Alternatively or additionally, we could als

[jira] [Comment Edited] (FLINK-24877) Implicitly add time attributes for VALUES clause

[ https://issues.apache.org/jira/browse/FLINK-24877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442336#comment-17442336 ] Timo Walther edited comment on FLINK-24877 at 11/11/21, 4:14 PM: -

[jira] [Updated] (FLINK-24877) Implicitly add time attributes for VALUES clause

[ https://issues.apache.org/jira/browse/FLINK-24877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24877: - Description: This might be a big change that we cannot do due to backwards compatibility. But I

[jira] [Created] (FLINK-24877) Implicitly add time attributes for VALUES clause

Timo Walther created FLINK-24877: Summary: Implicitly add time attributes for VALUES clause Key: FLINK-24877 URL: https://issues.apache.org/jira/browse/FLINK-24877 Project: Flink Issue Type:

[jira] [Closed] (FLINK-24615) Add infrastructure to support metadata in filesystem connector

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

[jira] [Commented] (FLINK-24608) Sinks built with the unified sink framework do not receive timestamps when used in Table API

[ https://issues.apache.org/jira/browse/FLINK-24608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441009#comment-17441009 ] Timo Walther commented on FLINK-24608: -- I would vote for option 1. In theory, when

[jira] [Updated] (FLINK-24843) DynamicTableFactory.Context.getCatalogTable().getPartitionKeys() should return indexes

[ https://issues.apache.org/jira/browse/FLINK-24843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24843: - Parent: FLINK-16987 Issue Type: Sub-task (was: Bug) > DynamicTableFactory.Context.getCa

[jira] [Updated] (FLINK-24691) FLINK SQL SUM() causes a precision error

[ https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24691: - Release Note: This changes the result of a decimal SUM() between 1.14.0 and 1.14.1. It restores

[jira] [Closed] (FLINK-24691) FLINK SQL SUM() causes a precision error

[ https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24691. Release Note: This changes the result of a decimal SUM() between 1.14.0 and 1.14.1. It restores th

[jira] [Closed] (FLINK-24684) Port to string casting rules to the new CastRule interface

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

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440534#comment-17440534 ] Timo Walther commented on FLINK-20370: -- [~wenlong.lwl] I guess for Kafka you are ri

[jira] [Closed] (FLINK-24717) Push down partitions before filters

[ https://issues.apache.org/jira/browse/FLINK-24717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24717. Release Note: This might have an impact on existing table source implementations as push down filt

[jira] [Closed] (FLINK-24414) Casting a decimal to a String doesn't do left zero padding

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

[jira] [Commented] (FLINK-24254) Support configuration hints for table sources and sinks

[ https://issues.apache.org/jira/browse/FLINK-24254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440327#comment-17440327 ] Timo Walther commented on FLINK-24254: -- Another symptom of this issue is {{FileSys

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