[jira] [Resolved] (FLINK-38081) FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-38081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-38081. -- Fix Version/s: 2.1.0 Assignee: Ramin Gharib Resolution: Implemented Im

[jira] [Updated] (FLINK-38081) FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-38081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-38081: - Fix Version/s: 2.2.0 (was: 2.1.0) > FLIP-528: Support EXPLAIN EXE

[jira] [Comment Edited] (FLINK-38037) Configure hashDistribution with commonJoinKey

[ https://issues.apache.org/jira/browse/FLINK-38037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17987908#comment-17987908 ] Dawid Wysakowicz edited comment on FLINK-38037 at 7/3/25 2:37 PM:

[jira] [Closed] (FLINK-38037) Configure hashDistribution with commonJoinKey

[ https://issues.apache.org/jira/browse/FLINK-38037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-38037. Resolution: Fixed Fixed in 4aa434fbf46e1648a56265748d93883844aae700 > Configure hashDistr

[jira] [Closed] (FLINK-37814) FLIP-516: Add RIGHT JOIN to LEFT JOIN rule

[ https://issues.apache.org/jira/browse/FLINK-37814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37814. Resolution: Implemented Implemented in 58d3cb4dee7317202afdffe158b4d109f4328b09 > FLIP-51

[jira] [Assigned] (FLINK-37814) FLIP-516: Add RIGHT JOIN to LEFT JOIN rule

[ https://issues.apache.org/jira/browse/FLINK-37814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-37814: Assignee: Stepan Stepanishchev > FLIP-516: Add RIGHT JOIN to LEFT JOIN rule > ---

[jira] [Closed] (FLINK-37481) FLIP-516: Multi way join operator

[ https://issues.apache.org/jira/browse/FLINK-37481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37481. Fix Version/s: 2.1.0 Resolution: Implemented Implemented in cf55d306f570134e2d3d332

[jira] [Closed] (FLINK-37829) ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition

[ https://issues.apache.org/jira/browse/FLINK-37829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37829. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in e36309a420c4c30ad98026c192881784edc

[jira] [Created] (FLINK-37829) ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition

Dawid Wysakowicz created FLINK-37829: Summary: ChangelogNormalize fails with CURRENT_WATERMARK in the filter condition Key: FLINK-37829 URL: https://issues.apache.org/jira/browse/FLINK-37829 Proje

[jira] [Closed] (FLINK-37768) ConstraintEnforcer not handling all constraints

[ https://issues.apache.org/jira/browse/FLINK-37768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37768. Resolution: Implemented Implemented in 9d0f9156f60329c19e5814e93505e4907adf1c92 > Constra

[jira] [Resolved] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar

[ https://issues.apache.org/jira/browse/FLINK-37725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-37725. -- Fix Version/s: 2.1.0 Assignee: Alan Sheinberg Resolution: Fixed Fixed

[jira] [Updated] (FLINK-37803) LocalTime without seconds is incorrectly serialized to SQL as a value literal

[ https://issues.apache.org/jira/browse/FLINK-37803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37803: - Fix Version/s: 2.1.0 > LocalTime without seconds is incorrectly serialized to SQL as a v

[jira] [Closed] (FLINK-37721) Fix janino bug returning incorrect results

[ https://issues.apache.org/jira/browse/FLINK-37721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37721. Resolution: Fixed Fixed in ef934ca8bfa6543ac3a84693e8fdc260c4961255 > Fix janino bug retu

[jira] [Updated] (FLINK-37721) Fix janino bug returning incorrect results

[ https://issues.apache.org/jira/browse/FLINK-37721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37721: - Fix Version/s: 2.1.0 > Fix janino bug returning incorrect results >

[jira] [Assigned] (FLINK-37721) Fix janino bug returning incorrect results

[ https://issues.apache.org/jira/browse/FLINK-37721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-37721: Assignee: Alan Sheinberg > Fix janino bug returning incorrect results > -

[jira] [Created] (FLINK-37768) ConstraintEnforcer not handling all constraints

Dawid Wysakowicz created FLINK-37768: Summary: ConstraintEnforcer not handling all constraints Key: FLINK-37768 URL: https://issues.apache.org/jira/browse/FLINK-37768 Project: Flink Issue

[jira] [Closed] (FLINK-37523) e2e: Test stream python udf sql job fails

[ https://issues.apache.org/jira/browse/FLINK-37523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37523. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in bda84091f950327a6021f43476a0cea44f8

[jira] [Closed] (FLINK-37625) PyFlink Table API skips validation for Rows created with positional arguments

[ https://issues.apache.org/jira/browse/FLINK-37625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37625. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in 5390362ccfc5231b2d3fc5c4663c8a4f39f

[jira] [Resolved] (FLINK-37745) ChangelogModeJsonSerializer doesn't handle partial deletes

[ https://issues.apache.org/jira/browse/FLINK-37745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-37745. -- Fix Version/s: 2.1.0 Resolution: Fixed Fixed in a790428a1bbed8c09004e6afe1a47bb

[jira] [Closed] (FLINK-37691) Can't consume changelog stream with upsert-kafka connector

[ https://issues.apache.org/jira/browse/FLINK-37691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37691. Resolution: Fixed Fixed in 4b6ea1eecd152e85c969eef377135de623cdf4c6 > Can't consume chang

[jira] [Assigned] (FLINK-37691) Can't consume changelog stream with upsert-kafka connector

[ https://issues.apache.org/jira/browse/FLINK-37691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-37691: Assignee: Dawid Wysakowicz > Can't consume changelog stream with upsert-kafka con

[jira] [Closed] (FLINK-37671) ChangelogMode.toString returns invalid string for partial deletes

[ https://issues.apache.org/jira/browse/FLINK-37671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37671. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in e004410f359c7f04b0b11c1272232ca4d41

[jira] [Closed] (FLINK-37643) Support partial deletes when converting to external data structures

[ https://issues.apache.org/jira/browse/FLINK-37643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37643. Resolution: Fixed Fixed in 0053b41d5d07252fef468e43c33f30b7fd1e27da > Support partial del

[jira] [Closed] (FLINK-37476) Update Kafka connector's ChangelogMode

[ https://issues.apache.org/jira/browse/FLINK-37476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37476. Resolution: Implemented > Update Kafka connector's ChangelogMode > ---

[jira] [Closed] (FLINK-37603) FLIP-502: QueryOperation SQL Serialization customization

[ https://issues.apache.org/jira/browse/FLINK-37603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37603. Resolution: Implemented Implemented in feb7ab12ddd269b46020c0fb6014a9c4461e26a6 > FLIP-50

[jira] [Created] (FLINK-37643) Support partial deletes when converting to external data structures

Dawid Wysakowicz created FLINK-37643: Summary: Support partial deletes when converting to external data structures Key: FLINK-37643 URL: https://issues.apache.org/jira/browse/FLINK-37643 Project:

[jira] [Commented] (FLINK-37476) Update Kafka connector's ChangelogMode

[ https://issues.apache.org/jira/browse/FLINK-37476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942208#comment-17942208 ] Dawid Wysakowicz commented on FLINK-37476: -- This can be considered as done, bec

[jira] [Closed] (FLINK-37475) Drop ChangelogNormalize for piping from upsert source to sink

[ https://issues.apache.org/jira/browse/FLINK-37475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37475. Resolution: Implemented Implemented in 50d46e11bd37ea3f2c19dd8f9a77c2b2dad4b7aa > Drop Ch

[jira] [Created] (FLINK-37615) Port EnvironmentSettings.Builder#withSerializationContext

Dawid Wysakowicz created FLINK-37615: Summary: Port EnvironmentSettings.Builder#withSerializationContext Key: FLINK-37615 URL: https://issues.apache.org/jira/browse/FLINK-37615 Project: Flink

[jira] [Created] (FLINK-37603) FLIP-502: QueryOperation SQL Serialization customization

Dawid Wysakowicz created FLINK-37603: Summary: FLIP-502: QueryOperation SQL Serialization customization Key: FLINK-37603 URL: https://issues.apache.org/jira/browse/FLINK-37603 Project: Flink

[jira] [Closed] (FLINK-37582) Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram

[ https://issues.apache.org/jira/browse/FLINK-37582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37582. Resolution: Implemented Implemented in 0e7b44c6009352648929a97963402f56129fdbae > Apply P

[jira] [Updated] (FLINK-37582) Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram

[ https://issues.apache.org/jira/browse/FLINK-37582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37582: - Description: Applying the rule will let eliminate ChangelogNormalize in case metadata co

[jira] [Created] (FLINK-37582) Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram

Dawid Wysakowicz created FLINK-37582: Summary: Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram Key: FLINK-37582 URL: https://issues.apache.org/jira/browse/FLINK-37582

[jira] [Closed] (FLINK-37557) ResolvedSchema#getPrimaryKeyIndexes does not filter for physical columns

[ https://issues.apache.org/jira/browse/FLINK-37557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37557. Resolution: Fixed Fixed in: * master ** 0c35363f93cbe0d48bc1b8e9e6e7624565323280 * 2.0.x *

[jira] [Created] (FLINK-37557) ResolvedSchema#getPrimaryKeyIndexes does not filter for physical columns

Dawid Wysakowicz created FLINK-37557: Summary: ResolvedSchema#getPrimaryKeyIndexes does not filter for physical columns Key: FLINK-37557 URL: https://issues.apache.org/jira/browse/FLINK-37557 Proj

[jira] [Comment Edited] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936411#comment-17936411 ] Dawid Wysakowicz edited comment on FLINK-37222 at 3/18/25 8:31 AM: ---

[jira] [Commented] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936411#comment-17936411 ] Dawid Wysakowicz commented on FLINK-37222: -- Table attributes are just the most

[jira] [Updated] (FLINK-37477) Emit full deletes from StreamJoin if it gets deletes on key on input

[ https://issues.apache.org/jira/browse/FLINK-37477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37477: - Summary: Emit full deletes from StreamJoin if it gets deletes on key on input (was: Dro

[jira] [Created] (FLINK-37475) Drop ChangelogNormalize for piping from upsert source to sink

Dawid Wysakowicz created FLINK-37475: Summary: Drop ChangelogNormalize for piping from upsert source to sink Key: FLINK-37475 URL: https://issues.apache.org/jira/browse/FLINK-37475 Project: Flink

[jira] [Created] (FLINK-37476) Update Kafka connector's ChangelogMode

Dawid Wysakowicz created FLINK-37476: Summary: Update Kafka connector's ChangelogMode Key: FLINK-37476 URL: https://issues.apache.org/jira/browse/FLINK-37476 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-37477) Drop ChangelogNormalize for a StreamJoin

Dawid Wysakowicz created FLINK-37477: Summary: Drop ChangelogNormalize for a StreamJoin Key: FLINK-37477 URL: https://issues.apache.org/jira/browse/FLINK-37477 Project: Flink Issue Type:

[jira] [Created] (FLINK-37474) FLIP-510: Drop ChangelogNormalize for operations which don't need it

Dawid Wysakowicz created FLINK-37474: Summary: FLIP-510: Drop ChangelogNormalize for operations which don't need it Key: FLINK-37474 URL: https://issues.apache.org/jira/browse/FLINK-37474 Project:

[jira] [Closed] (FLINK-37390) Push filter into ChangelogNormalize

[ https://issues.apache.org/jira/browse/FLINK-37390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37390. Resolution: Implemented Implemented in 6cf885f3aa477c80a7bc1ee5759613387062463f > Push fi

[jira] [Resolved] (FLINK-36324) MiscAggFunctionITCase expected to raise Throwable

[ https://issues.apache.org/jira/browse/FLINK-36324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-36324. -- Assignee: Dawid Wysakowicz Resolution: Fixed Hardened in 6b56f20bddc23bc63498dea

[jira] [Resolved] (FLINK-37374) Support JSON built-in function for JSON_ARRAY

[ https://issues.apache.org/jira/browse/FLINK-37374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-37374. -- Resolution: Implemented Implemented in af136b40affdd2d75b0b9db7d11ae6a47db3c6c1..2f17

[jira] [Created] (FLINK-37390) Push filter into ChangelogNormalize

Dawid Wysakowicz created FLINK-37390: Summary: Push filter into ChangelogNormalize Key: FLINK-37390 URL: https://issues.apache.org/jira/browse/FLINK-37390 Project: Flink Issue Type: Impro

[jira] [Updated] (FLINK-37390) Push filter into ChangelogNormalize

[ https://issues.apache.org/jira/browse/FLINK-37390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37390: - Description: We can optimize pipelines with ChangelogNormalize present if we push filter

[jira] [Updated] (FLINK-30252) Publish flink-shaded pom

[ https://issues.apache.org/jira/browse/FLINK-30252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-30252: - Fix Version/s: shaded-21.0 (was: shaded-20.0) > Publish flink-sha

[jira] [Closed] (FLINK-26348) Maybe ChangelogNormalize should ignore unused columns when deduplicate

[ https://issues.apache.org/jira/browse/FLINK-26348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26348. Resolution: Duplicate > Maybe ChangelogNormalize should ignore unused columns when dedupli

[jira] [Commented] (FLINK-35687) JSON_QUERY should return a well formatted nested objects/arrays for ARRAY

[ https://issues.apache.org/jira/browse/FLINK-35687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924440#comment-17924440 ] Dawid Wysakowicz commented on FLINK-35687: -- fixed in 1.20.x: 1b5fc06d9d4b37111d

[jira] [Updated] (FLINK-35687) JSON_QUERY should return a well formatted nested objects/arrays for ARRAY

[ https://issues.apache.org/jira/browse/FLINK-35687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-35687: - Fix Version/s: 1.20.2 > JSON_QUERY should return a well formatted nested objects/arrays

[jira] [Commented] (FLINK-35687) JSON_QUERY should return a well formatted nested objects/arrays for ARRAY

[ https://issues.apache.org/jira/browse/FLINK-35687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17924038#comment-17924038 ] Dawid Wysakowicz commented on FLINK-35687: -- True, it's been fixed in 2.0. I thi

[jira] [Updated] (FLINK-35687) JSON_QUERY should return a well formatted nested objects/arrays for ARRAY

[ https://issues.apache.org/jira/browse/FLINK-35687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-35687: - Fix Version/s: 2.0-preview (was: 1.20.0) > JSON_QUERY should retu

[jira] [Resolved] (FLINK-37175) Support JSON built-in function for JSON_OBJECT

[ https://issues.apache.org/jira/browse/FLINK-37175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-37175. -- Fix Version/s: 2.1.0 (was: 2.0.0) Assignee: Gustavo de

[jira] [Commented] (FLINK-37098) Can not select time attribute from a view

[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17921368#comment-17921368 ] Dawid Wysakowicz commented on FLINK-37098: -- [~afedulov] When does it fail? Runn

[jira] [Updated] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37222: - Priority: Blocker (was: Major) > Table planner exception when sql client submit job > -

[jira] [Updated] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37222: - Priority: Major (was: Blocker) > Table planner exception when sql client submit job > -

[jira] [Commented] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17921352#comment-17921352 ] Dawid Wysakowicz commented on FLINK-37222: -- It looks like the SQL gateway sessi

[jira] [Commented] (FLINK-37222) Table planner exception when sql client submit job

[ https://issues.apache.org/jira/browse/FLINK-37222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17921349#comment-17921349 ] Dawid Wysakowicz commented on FLINK-37222: -- Would you be able to provide a repr

[jira] [Commented] (FLINK-37098) Can not select time attribute from a view

[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17915950#comment-17915950 ] Dawid Wysakowicz commented on FLINK-37098: -- Additional fix in: * master ** e000

[jira] [Resolved] (FLINK-37176) setup_hugo.sh doesn't work on mac os

[ https://issues.apache.org/jira/browse/FLINK-37176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-37176. -- Resolution: Fixed Improved in 2905ec486acb29d76ed11e3795db4186436dd27e > setup_hugo.s

[jira] [Assigned] (FLINK-37176) setup_hugo.sh doesn't work on mac os

[ https://issues.apache.org/jira/browse/FLINK-37176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-37176: Assignee: Gustavo de Morais > setup_hugo.sh doesn't work on mac os >

[jira] [Closed] (FLINK-37098) Can not select time attribute from a view

[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-37098. Resolution: Fixed Fixed in: * master ** 6748cd0659a1f30579aa66d179ef3c649ac7439c * 1.20.x

[jira] [Commented] (FLINK-36482) Remove all deprecated methods in `TableEnvironment`

[ https://issues.apache.org/jira/browse/FLINK-36482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17913219#comment-17913219 ] Dawid Wysakowicz commented on FLINK-36482: -- Some feedback on one of the APIs. I

[jira] [Resolved] (FLINK-36910) Support calling time-related dynamic functions with parenthesis

[ https://issues.apache.org/jira/browse/FLINK-36910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-36910. -- Fix Version/s: 2.0.0 Assignee: Gustavo de Morais Resolution: Implemente

[jira] [Created] (FLINK-37098) Can not select time attribute from a view

Dawid Wysakowicz created FLINK-37098: Summary: Can not select time attribute from a view Key: FLINK-37098 URL: https://issues.apache.org/jira/browse/FLINK-37098 Project: Flink Issue Type:

[jira] [Updated] (FLINK-37098) Can not select time attribute from a view

[ https://issues.apache.org/jira/browse/FLINK-37098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37098: - Affects Version/s: 1.20.1 (was: 1.20.0) > Can not select time

[jira] [Resolved] (FLINK-37025) Periodic SQL watermarks can travel back in time

[ https://issues.apache.org/jira/browse/FLINK-37025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-37025. -- Resolution: Fixed Fixed in: * master ** 7059ee555c5093e3b233876ac3d84ad693023df8 * 1.2

[jira] [Commented] (FLINK-37025) Periodic SQL watermarks can travel back in time

[ https://issues.apache.org/jira/browse/FLINK-37025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910976#comment-17910976 ] Dawid Wysakowicz commented on FLINK-37025: -- [~afedulov] Sure > Periodic SQL wa

[jira] [Assigned] (FLINK-37025) Periodic SQL watermarks can travel back in time

[ https://issues.apache.org/jira/browse/FLINK-37025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-37025: Assignee: Dawid Wysakowicz > Periodic SQL watermarks can travel back in time > --

[jira] [Updated] (FLINK-37025) Periodic SQL watermarks can travel back in time

[ https://issues.apache.org/jira/browse/FLINK-37025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37025: - Description: If watermarks are generated through SQL, e.g. using `WATERMARK FOR ts AS ts

[jira] [Updated] (FLINK-37025) Periodic SQL watermarks can travel back in time

[ https://issues.apache.org/jira/browse/FLINK-37025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37025: - Description: If watermarks are generated through SQL, e.g. using `WATERMARK FOR ts AS ts

[jira] [Updated] (FLINK-37025) Periodic SQL watermarks can travel back in time

[ https://issues.apache.org/jira/browse/FLINK-37025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-37025: - Description: If watermarks are generated through SQL, e.g. using {{WATERMARK FOR ts AS t

[jira] [Created] (FLINK-37025) Periodic SQL watermarks can travel back in time

Dawid Wysakowicz created FLINK-37025: Summary: Periodic SQL watermarks can travel back in time Key: FLINK-37025 URL: https://issues.apache.org/jira/browse/FLINK-37025 Project: Flink Issue

[jira] [Closed] (FLINK-36883) Views should keep the time attributes of the query

[ https://issues.apache.org/jira/browse/FLINK-36883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-36883. Resolution: Fixed Fixed in: * master ** 529f64078a34d9840a26906bcf967a2147d305f9 * 1.20.1

[jira] [Closed] (FLINK-36861) CREATE TABLE AS with METADATA columns doesn't work

[ https://issues.apache.org/jira/browse/FLINK-36861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-36861. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in master: 5ca9eef5250c257d466d98dd13a

[jira] [Created] (FLINK-36885) Multiple tests are incorrectly migrated to JUnit 5

Dawid Wysakowicz created FLINK-36885: Summary: Multiple tests are incorrectly migrated to JUnit 5 Key: FLINK-36885 URL: https://issues.apache.org/jira/browse/FLINK-36885 Project: Flink Is

[jira] [Updated] (FLINK-36885) Multiple tests are incorrectly migrated to JUnit 5

[ https://issues.apache.org/jira/browse/FLINK-36885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-36885: - Affects Version/s: 1.20.0 2.0.0 > Multiple tests are incorrectly

[jira] [Created] (FLINK-36883) Views should keep the time attributes of the query

Dawid Wysakowicz created FLINK-36883: Summary: Views should keep the time attributes of the query Key: FLINK-36883 URL: https://issues.apache.org/jira/browse/FLINK-36883 Project: Flink Is

[jira] [Commented] (FLINK-36840) Multiple time-related built-in functions cannot be called

[ https://issues.apache.org/jira/browse/FLINK-36840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903708#comment-17903708 ] Dawid Wysakowicz commented on FLINK-36840: -- Merged to 1.20: bbe1946923ec72d0fb0

[jira] [Updated] (FLINK-36840) Multiple time-related built-in functions cannot be called

[ https://issues.apache.org/jira/browse/FLINK-36840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-36840: - Fix Version/s: 1.20.1 > Multiple time-related built-in functions cannot be called >

[jira] [Resolved] (FLINK-35519) Flink Job fails with SingleValueAggFunction received more than one element

[ https://issues.apache.org/jira/browse/FLINK-35519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-35519. -- Resolution: Not A Problem > Flink Job fails with SingleValueAggFunction received more

[jira] [Commented] (FLINK-35519) Flink Job fails with SingleValueAggFunction received more than one element

[ https://issues.apache.org/jira/browse/FLINK-35519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903623#comment-17903623 ] Dawid Wysakowicz commented on FLINK-35519: -- That's actually a correct behaviour

[jira] [Updated] (FLINK-23623) Over expression should allow to order by any fields in batch mode

[ https://issues.apache.org/jira/browse/FLINK-23623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23623: - Fix Version/s: 2.0.0 > Over expression should allow to order by any fields in batch mode

[jira] [Closed] (FLINK-36552) Fix Table API OVER window support in batch mode

[ https://issues.apache.org/jira/browse/FLINK-36552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-36552. Resolution: Duplicate > Fix Table API OVER window support in batch mode >

[jira] [Commented] (FLINK-36552) Fix Table API OVER window support in batch mode

[ https://issues.apache.org/jira/browse/FLINK-36552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898575#comment-17898575 ] Dawid Wysakowicz commented on FLINK-36552: -- Yes, it's a duplicate > Fix Table

[jira] [Created] (FLINK-36665) WINDOW_START, WINDOW_END always return TIMESTAMP(3)

Dawid Wysakowicz created FLINK-36665: Summary: WINDOW_START, WINDOW_END always return TIMESTAMP(3) Key: FLINK-36665 URL: https://issues.apache.org/jira/browse/FLINK-36665 Project: Flink I

[jira] [Updated] (FLINK-36665) WINDOW_START, WINDOW_END always return TIMESTAMP(3)

[ https://issues.apache.org/jira/browse/FLINK-36665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-36665: - Component/s: Table SQL / Runtime > WINDOW_START, WINDOW_END always return TIMESTAMP(3) >

[jira] [Closed] (FLINK-36002) Add CompiledPlan annotations to BatchExecMatch

[ https://issues.apache.org/jira/browse/FLINK-36002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-36002. Resolution: Implemented Implemented in 37642307128a83cdc83630bc286e2936decf7426 > Add Com

[jira] [Closed] (FLINK-36615) Support LEAD/LAG functions in Table API

[ https://issues.apache.org/jira/browse/FLINK-36615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-36615. Resolution: Implemented Implemented in 96b79eb23738a52ec17918c47f14fe008431f18a > Support

[jira] [Closed] (FLINK-36644) TIMESTAMPDIFF can not be string serialized

[ https://issues.apache.org/jira/browse/FLINK-36644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-36644. Resolution: Fixed Fixed in: * master ** a5b65b9bd3440d7bf74a42dd4d9681bfc61d3901 * 1.20.1

[jira] [Assigned] (FLINK-33722) MATCH_RECOGNIZE in batch mode ignores events order

[ https://issues.apache.org/jira/browse/FLINK-33722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-33722: Assignee: Grzegorz Kołakowski > MATCH_RECOGNIZE in batch mode ignores events orde

[jira] [Closed] (FLINK-33722) MATCH_RECOGNIZE in batch mode ignores events order

[ https://issues.apache.org/jira/browse/FLINK-33722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-33722. Fix Version/s: 2.0.0 Resolution: Fixed Fixed in f22c50aab1f0efe59c3c7a1d944fce79b4e

[jira] [Closed] (FLINK-36639) Use table aliases in Table API asSerializableString

[ https://issues.apache.org/jira/browse/FLINK-36639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-36639. Resolution: Implemented Implemented in 03c8185090ef7f91b525315ff828afdd97925c0d > Use tab

[jira] [Updated] (FLINK-36639) Use table aliases in Table API asSerializableString

[ https://issues.apache.org/jira/browse/FLINK-36639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-36639: - Description: Certain operations do not work without explicitly scoping a fieldreference.

[jira] [Created] (FLINK-36644) TIMESTAMPDIFF can not be string serialized

Dawid Wysakowicz created FLINK-36644: Summary: TIMESTAMPDIFF can not be string serialized Key: FLINK-36644 URL: https://issues.apache.org/jira/browse/FLINK-36644 Project: Flink Issue Type

[jira] [Updated] (FLINK-36639) Use table aliases in Table API asSerializableString

[ https://issues.apache.org/jira/browse/FLINK-36639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-36639: - Description: Certain operations do not work without explicitly scoping a fieldreference.

[jira] [Created] (FLINK-36639) Use table aliases in Table API asSerializableString

Dawid Wysakowicz created FLINK-36639: Summary: Use table aliases in Table API asSerializableString Key: FLINK-36639 URL: https://issues.apache.org/jira/browse/FLINK-36639 Project: Flink I

[jira] [Created] (FLINK-36615) Support LEAD/LAG functions in Table API

Dawid Wysakowicz created FLINK-36615: Summary: Support LEAD/LAG functions in Table API Key: FLINK-36615 URL: https://issues.apache.org/jira/browse/FLINK-36615 Project: Flink Issue Type: I

[jira] [Updated] (FLINK-36612) Flink TypeSerializer doesn't recognize valid POJO getters/setters generated by Lombok

[ https://issues.apache.org/jira/browse/FLINK-36612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-36612: - Issue Type: New Feature (was: Bug) > Flink TypeSerializer doesn't recognize valid POJO

  1   2   3   4   5   6   7   8   9   10   >