[jira] [Assigned] (FLINK-25390) Support mutable options in DynamicTableFactory

2022-01-03 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25390: Assignee: Francesco Guardiani > Support mutable options in DynamicTableFactory >

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

2022-01-03 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467836#comment-17467836 ] Timo Walther commented on FLINK-18356: -- I will run one more CI to verify. If this turns out to be

[jira] [Closed] (FLINK-25502) eval method of Flink ScalerFunction only run one time

2022-01-02 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25502. Resolution: Invalid Please take a look at:

[jira] [Closed] (FLINK-25187) Apply padding for BINARY()

2021-12-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25187. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[jira] [Commented] (FLINK-25491) Code generation: init method exceeds 64 KB when there is a large IN filter with Table API

2021-12-31 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467142#comment-17467142 ] Timo Walther commented on FLINK-25491: -- [~TsReaper] is this a known issue? > Code generation: init

[jira] [Commented] (FLINK-25128) Reorganize table modules and introduce flink-table-planner-loader

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466889#comment-17466889 ] Timo Walther commented on FLINK-25128: -- Also announced on the dev@ ML:

[jira] [Updated] (FLINK-25128) Reorganize table modules and introduce flink-table-planner-loader

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25128: - Release Note: The new module flink-table-planner-loader replaces flink-table-planner_2.12 and

[jira] [Updated] (FLINK-25128) Reorganize table modules and introduce flink-table-planner-loader

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25128: - Release Note: The new module flink-table-planner-loader replaces flink-table-planner_2.12 and

[jira] [Commented] (FLINK-25487) Improve exception when flink-table-runtime is not in classpath

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466864#comment-17466864 ] Timo Walther commented on FLINK-25487: -- CC [~slinkydeveloper] > Improve exception when

[jira] [Created] (FLINK-25487) Improve exception when flink-table-runtime is not in classpath

2021-12-30 Thread Timo Walther (Jira)
Timo Walther created FLINK-25487: Summary: Improve exception when flink-table-runtime is not in classpath Key: FLINK-25487 URL: https://issues.apache.org/jira/browse/FLINK-25487 Project: Flink

[jira] [Closed] (FLINK-25131) Update sql client to ship flink-table-planner-loader instead of flink-table-planner

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25131. Fix Version/s: 1.15.0 Resolution: Implemented Fixed as part of FLINK-25128. > Update sql

[jira] [Closed] (FLINK-25130) Update flink-table-uber to ship flink-table-planner-loader instead of flink-table-planner

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25130. Fix Version/s: 1.15.0 Resolution: Implemented Fixed as part of FLINK-25128. > Update

[jira] [Closed] (FLINK-25128) Reorganize table modules and introduce flink-table-planner-loader

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25128. Fix Version/s: 1.15.0 Release Note: The new module flink-table-planner-loader replaces

[jira] [Updated] (FLINK-25128) Reorganize table modules and introduce flink-table-planner-loader

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25128: - Summary: Reorganize table modules and introduce flink-table-planner-loader (was: Introduce

[jira] [Closed] (FLINK-9239) Reintroduce example program in quickstarts

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-9239. --- Resolution: Won't Fix Seems to be not so important. > Reintroduce example program in quickstarts >

[jira] [Commented] (FLINK-25476) CharType lost in the creation of MaxAggFunction & MinAggFunction

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466741#comment-17466741 ] Timo Walther commented on FLINK-25476: -- [~zoucao] could you elaborate when this is necessary? Only

[jira] [Closed] (FLINK-24809) Check & possible fix decimal precision and scale for all Aggregate functions

2021-12-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24809. Fix Version/s: 1.15.0 Release Note: This changes the result of a decimal SUM with retraction

[jira] [Assigned] (FLINK-25392) Add new STATEMENT SET syntax

2021-12-22 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25392: Assignee: Wenlong Lyu > Add new STATEMENT SET syntax > > >

[jira] [Closed] (FLINK-25365) Remove remaining references to planner from Python

2021-12-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25365. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[jira] [Closed] (FLINK-25363) Replace LogicalWindow and related planner expressions

2021-12-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25363. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

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

2021-12-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463148#comment-17463148 ] Timo Walther edited comment on FLINK-25217 at 12/21/21, 11:12 AM: --

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

2021-12-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463161#comment-17463161 ] Timo Walther commented on FLINK-25217: -- [~wenlong.lwl] please note that the subtasks have an order

[jira] [Assigned] (FLINK-25385) Harden function serialization in JSON plan

2021-12-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25385: Assignee: Timo Walther > Harden function serialization in JSON plan >

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

2021-12-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463148#comment-17463148 ] Timo Walther commented on FLINK-25217: -- Thanks, I assigned it to you. I might introduce the config

[jira] [Assigned] (FLINK-25386) Harden table serialization in JSON plan

2021-12-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25386: Assignee: Wenlong Lyu (was: Wenlong Li) > Harden table serialization in JSON plan >

[jira] [Assigned] (FLINK-25386) Harden table serialization in JSON plan

2021-12-21 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-25386: Assignee: Wenlong Li > Harden table serialization in JSON plan >

[jira] [Closed] (FLINK-25215) ISODOW for timestamps with timezones fails with Invalid start unit

2021-12-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25215. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[jira] [Closed] (FLINK-25366) Enforce BINARY/VARBINARY precision when outputing to a Sink

2021-12-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25366. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[jira] [Closed] (FLINK-25364) Don't generate code in open() methods of Python operators

2021-12-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25364. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[jira] [Created] (FLINK-25392) Add new STATEMENT SET syntax

2021-12-20 Thread Timo Walther (Jira)
Timo Walther created FLINK-25392: Summary: Add new STATEMENT SET syntax Key: FLINK-25392 URL: https://issues.apache.org/jira/browse/FLINK-25392 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25391) Updating existing table factories for mutable table options

2021-12-20 Thread Timo Walther (Jira)
Timo Walther created FLINK-25391: Summary: Updating existing table factories for mutable table options Key: FLINK-25391 URL: https://issues.apache.org/jira/browse/FLINK-25391 Project: Flink

[jira] [Created] (FLINK-25390) Support mutable options in DynamicTableFactory

2021-12-20 Thread Timo Walther (Jira)
Timo Walther created FLINK-25390: Summary: Support mutable options in DynamicTableFactory Key: FLINK-25390 URL: https://issues.apache.org/jira/browse/FLINK-25390 Project: Flink Issue Type:

[jira] [Created] (FLINK-25389) Update JSON plan with new ExecNodeMetadata

2021-12-20 Thread Timo Walther (Jira)
Timo Walther created FLINK-25389: Summary: Update JSON plan with new ExecNodeMetadata Key: FLINK-25389 URL: https://issues.apache.org/jira/browse/FLINK-25389 Project: Flink Issue Type:

[jira] [Created] (FLINK-25388) Add annotation to all StreamExec nodes

2021-12-20 Thread Timo Walther (Jira)
Timo Walther created FLINK-25388: Summary: Add annotation to all StreamExec nodes Key: FLINK-25388 URL: https://issues.apache.org/jira/browse/FLINK-25388 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25387) Introduce ExecNodeMetadata annotation and tooling

2021-12-20 Thread Timo Walther (Jira)
Timo Walther created FLINK-25387: Summary: Introduce ExecNodeMetadata annotation and tooling Key: FLINK-25387 URL: https://issues.apache.org/jira/browse/FLINK-25387 Project: Flink Issue

[jira] [Created] (FLINK-25386) Harden table serialization in JSON plan

2021-12-20 Thread Timo Walther (Jira)
Timo Walther created FLINK-25386: Summary: Harden table serialization in JSON plan Key: FLINK-25386 URL: https://issues.apache.org/jira/browse/FLINK-25386 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25385) Harden function serialization in JSON plan

2021-12-20 Thread Timo Walther (Jira)
Timo Walther created FLINK-25385: Summary: Harden function serialization in JSON plan Key: FLINK-25385 URL: https://issues.apache.org/jira/browse/FLINK-25385 Project: Flink Issue Type:

[jira] [Closed] (FLINK-25384) Job can not migrate from flink-1.12 to flink-1.13

2021-12-20 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25384. Resolution: Not A Problem [~tanjialiang] please use the user@ mailing for asking questions.

[jira] [Created] (FLINK-25365) Remove remaining references to planner from Python

2021-12-17 Thread Timo Walther (Jira)
Timo Walther created FLINK-25365: Summary: Remove remaining references to planner from Python Key: FLINK-25365 URL: https://issues.apache.org/jira/browse/FLINK-25365 Project: Flink Issue

[jira] [Created] (FLINK-25364) Don't generate code in open() methods of Python operators

2021-12-17 Thread Timo Walther (Jira)
Timo Walther created FLINK-25364: Summary: Don't generate code in open() methods of Python operators Key: FLINK-25364 URL: https://issues.apache.org/jira/browse/FLINK-25364 Project: Flink

[jira] [Created] (FLINK-25363) Replace LogicalWindow and related planner expressions

2021-12-17 Thread Timo Walther (Jira)
Timo Walther created FLINK-25363: Summary: Replace LogicalWindow and related planner expressions Key: FLINK-25363 URL: https://issues.apache.org/jira/browse/FLINK-25363 Project: Flink Issue

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

2021-12-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460697#comment-17460697 ] Timo Walther commented on FLINK-18356: -- Esp. the batch tests can be quite resource hungry. I'm sure

[jira] [Closed] (FLINK-25282) Move runtime dependencies from table-planner to table-runtime

2021-12-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25282. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[jira] [Commented] (FLINK-25341) Improve casting structured type to STRING

2021-12-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460546#comment-17460546 ] Timo Walther commented on FLINK-25341: -- maybe converting to external class is not easy to do at

[jira] [Updated] (FLINK-25341) Improve casting structured type to STRING

2021-12-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-25341: - Description: Structured types currently use ROW to STRING logic. However, this is not very

[jira] [Created] (FLINK-25341) Improve casting structured type to STRING

2021-12-16 Thread Timo Walther (Jira)
Timo Walther created FLINK-25341: Summary: Improve casting structured type to STRING Key: FLINK-25341 URL: https://issues.apache.org/jira/browse/FLINK-25341 Project: Flink Issue Type:

[jira] [Closed] (FLINK-25158) Fix formatting for true, false and null to uppercase

2021-12-16 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25158. Resolution: Fixed Fixed in master: f14ff3d5da471bf263ed7165c09bc8c57cdc4eaf > Fix formatting for

[jira] [Commented] (FLINK-24847) Decide the overflows behaviour

2021-12-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460093#comment-17460093 ] Timo Walther commented on FLINK-24847: -- btw couldn't we solve this chain by a planner rewrite rule

[jira] [Closed] (FLINK-17151) Align Calcite's and Flink's SYMBOL types

2021-12-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-17151. Fix Version/s: 1.15.0 Assignee: Timo Walther Resolution: Fixed Fixed in master:

[jira] [Commented] (FLINK-24420) Casting to a "narrower" type doesn't throw exception but follows Java overflow

2021-12-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460043#comment-17460043 ] Timo Walther commented on FLINK-24420: -- I would vote for OVERFLOW for the legacy mode and FAIL for

[jira] [Commented] (FLINK-24420) Casting to a "narrower" type doesn't throw exception but follows Java overflow

2021-12-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459877#comment-17459877 ] Timo Walther commented on FLINK-24420: -- Maybe the options could be `OVERFLOW`, `FAIL`, `BOUNDARY`

[jira] [Commented] (FLINK-25187) Apply padding for BINARY()

2021-12-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459873#comment-17459873 ] Timo Walther commented on FLINK-25187: -- Let's do exactly the same as for CHAR/VARCHAR for

[jira] [Closed] (FLINK-25051) Port raw <-> binary logic to CastRule

2021-12-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25051. Fix Version/s: 1.15.0 Assignee: Shen Zhu Resolution: Fixed Fixed in master:

[jira] [Closed] (FLINK-24419) Casting to a bounded BINARY/VARBINARY doesn't trim to the specified precision

2021-12-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24419. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[jira] [Assigned] (FLINK-24419) Casting to a bounded BINARY/VARBINARY doesn't trim to the specified precision

2021-12-15 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-24419: Assignee: Shen Zhu > Casting to a bounded BINARY/VARBINARY doesn't trim to the specified

[jira] [Closed] (FLINK-25304) TIMESTAMP/TIMESTAMP_LTZ Pad with trailing zeros for fractional seconds depending on the precision specified

2021-12-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-25304. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[jira] [Commented] (FLINK-25304) TIMESTAMP/TIMESTAMP_LTZ Pad with trailing zeros for fractional seconds depending on the precision specified

2021-12-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459156#comment-17459156 ] Timo Walther commented on FLINK-25304: -- +1 for the current behavior. We also pad DECIMAL digits,

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

2021-12-14 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24413. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[jira] [Updated] (FLINK-19589) Support per-connector FileSystem configuration

2021-12-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-19589: - Labels: (was: auto-deprioritized-minor auto-unassigned) > Support per-connector FileSystem

[jira] (FLINK-19589) Support per-connector FileSystem configuration

2021-12-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589 ] Timo Walther deleted comment on FLINK-19589: -- was (Author: flink-jira-bot): This issue was marked "stale-assigned" and has not received an update in 7 days. It is now automatically

[jira] (FLINK-19589) Support per-connector FileSystem configuration

2021-12-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589 ] Timo Walther deleted comment on FLINK-19589: -- was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its

[jira] (FLINK-19589) Support per-connector FileSystem configuration

2021-12-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589 ] Timo Walther deleted comment on FLINK-19589: -- was (Author: flink-jira-bot): This issue is assigned but has not received an update in 7 days so it has been labeled "stale-assigned". If you

[jira] (FLINK-19589) Support per-connector FileSystem configuration

2021-12-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589 ] Timo Walther deleted comment on FLINK-19589: -- was (Author: flink-jira-bot): This issue was labeled "stale-minor" 7 days ago and has not received any updates so it is being deprioritized.

[jira] [Commented] (FLINK-19589) Support per-connector FileSystem configuration

2021-12-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458457#comment-17458457 ] Timo Walther commented on FLINK-19589: -- Another request on this topic:

[jira] [Updated] (FLINK-19589) Support per-connector FileSystem configuration

2021-12-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-19589: - Description: Currently, options for file systems can only be configured globally. However, in

[jira] [Updated] (FLINK-19589) Support per-connector FileSystem configuration

2021-12-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-19589: - Summary: Support per-connector FileSystem configuration (was: Expose S3 options for

[jira] [Updated] (FLINK-19589) Expose S3 options for per-connector FileSystem configuration

2021-12-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-19589: - Summary: Expose S3 options for per-connector FileSystem configuration (was: Expose S3 options

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

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

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

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

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

2021-12-13 Thread Timo Walther (Jira)
[ 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. >

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

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

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

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

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

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

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

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

2021-12-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456460#comment-17456460 ] Timo Walther commented on FLINK-25234: -- Which format are you using? JSON, Avro, ...? > Flink

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

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

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

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

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

2021-12-09 Thread Timo Walther (Jira)
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

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

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

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

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

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

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

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

2021-12-07 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454726#comment-17454726 ] Timo Walther commented on FLINK-25217: -- The FLIP has not been accepted yet but I will add the first

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

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

2021-12-07 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454718#comment-17454718 ] Timo Walther commented on FLINK-25205: -- But this also means that UPDATE_BEFORE becomes an INSERT

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

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

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

2021-12-07 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454510#comment-17454510 ] Timo Walther commented on FLINK-24077: -- [~jingge] I agree. We should definitely add the cluster

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

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

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

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

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

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

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

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

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

2021-12-06 Thread Timo Walther (Jira)
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

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

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

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

2021-12-06 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454025#comment-17454025 ] Timo Walther commented on FLINK-25014: -- The issue here is that we perform a case-sensitive

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

2021-12-06 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453964#comment-17453964 ] Timo Walther commented on FLINK-20370: -- Given that many people still wait for 1.14.1 and don't

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

2021-12-06 Thread Timo Walther (Jira)
[ 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"

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

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

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