[jira] [Assigned] (FLINK-23413) Port RelTimeIndicatorConverter from SCALA to JAVA

[ https://issues.apache.org/jira/browse/FLINK-23413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-23413: -- Assignee: JING ZHANG > Port RelTimeIndicatorConverter from SCALA to JAVA > --

[jira] [Updated] (FLINK-21589) Document Table/SQL API limitations regarding upgrades with savepoints

[ https://issues.apache.org/jira/browse/FLINK-21589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21589: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Document Table/SQL API limitations rega

[jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

[ https://issues.apache.org/jira/browse/FLINK-21711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21711: --- Fix Version/s: (was: 1.11.4) 1.11.5 > DataStreamSink doesn't allow setting ma

[jira] [Updated] (FLINK-18624) Document CREATE TEMPORARY TABLE

[ https://issues.apache.org/jira/browse/FLINK-18624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18624: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Document CREATE TEMPORARY TABLE > -

[jira] [Updated] (FLINK-15471) HA e2e check for empty .out files does not print specific error

[ https://issues.apache.org/jira/browse/FLINK-15471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15471: --- Fix Version/s: (was: 1.11.4) 1.11.5 > HA e2e check for empty .out files does

[jira] [Updated] (FLINK-21022) flink-connector-es add onSuccess handler after bulk process for sync success data to other third party system for data consistency checking

[ https://issues.apache.org/jira/browse/FLINK-21022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21022: --- Fix Version/s: (was: 1.11.4) 1.11.5 > flink-connector-es add onSuccess handle

[jira] [Updated] (FLINK-18734) Add documentation for DynamoStreams Consumer CDC

[ https://issues.apache.org/jira/browse/FLINK-18734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18734: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Add documentation for DynamoStreams Con

[jira] [Updated] (FLINK-15018) Add event time page to Concepts

[ https://issues.apache.org/jira/browse/FLINK-15018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15018: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Add event time page to Concepts > -

[jira] [Updated] (FLINK-17642) Exception while reading broken ORC file is hidden

[ https://issues.apache.org/jira/browse/FLINK-17642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17642: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Exception while reading broken ORC file

[jira] [Updated] (FLINK-18460) If the Python UDFs are called before calling the Python Dependency Management API, the Python Dependency Management would not will not take effect.

[ https://issues.apache.org/jira/browse/FLINK-18460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18460: --- Fix Version/s: (was: 1.11.4) 1.11.5 > If the Python UDFs are called before ca

[jira] [Updated] (FLINK-17329) Quickstarts Scala nightly e2e test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17329: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Quickstarts Scala nightly e2e test fail

[jira] [Updated] (FLINK-19887) Table program cannot be compiled when using Scala package object

[ https://issues.apache.org/jira/browse/FLINK-19887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-19887: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Table program cannot be compiled when u

[jira] [Updated] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22955: --- Fix Version/s: (was: 1.11.4) 1.11.5 > lookup join filter push down result to

[jira] [Updated] (FLINK-20067) "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job"

[ https://issues.apache.org/jira/browse/FLINK-20067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20067: --- Fix Version/s: (was: 1.11.4) 1.11.5 > "Resuming Savepoint (file, sync, scale

[jira] [Updated] (FLINK-16612) Submit job through the rest api, job name will be lost

[ https://issues.apache.org/jira/browse/FLINK-16612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-16612: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Submit job through the rest api, job na

[jira] [Updated] (FLINK-17742) Blob file not removed after task was cancelled in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-17742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17742: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Blob file not removed after task was ca

[jira] [Updated] (FLINK-16324) Checkpoint tasks progress would display 100% in web UI even not all tasks finished

[ https://issues.apache.org/jira/browse/FLINK-16324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-16324: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Checkpoint tasks progress would display

[jira] [Updated] (FLINK-15524) Some links in Chinese documents points to English documents by mistake

[ https://issues.apache.org/jira/browse/FLINK-15524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15524: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Some links in Chinese documents points

[jira] [Updated] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-14159: --- Fix Version/s: (was: 1.11.4) 1.11.5 > flink rocksdb StreamCompressionDecorato

[jira] [Updated] (FLINK-18880) Allow to configure the heap memory used by the gateway server

[ https://issues.apache.org/jira/browse/FLINK-18880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18880: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Allow to configure the heap memory used

[jira] [Updated] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18706: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Stop with savepoint cannot guarantee ex

[jira] [Updated] (FLINK-18276) NullPointerException (and potential leak) when closing KafkaConsumer after exception in reassignPartitions

[ https://issues.apache.org/jira/browse/FLINK-18276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18276: --- Fix Version/s: (was: 1.11.4) 1.11.5 > NullPointerException (and potential lea

[jira] [Updated] (FLINK-19228) Avoid accessing FileSystem in client for file system connector

[ https://issues.apache.org/jira/browse/FLINK-19228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-19228: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Avoid accessing FileSystem in client f

[jira] [Updated] (FLINK-21693) TestStreamEnvironment does not implement executeAsync

[ https://issues.apache.org/jira/browse/FLINK-21693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21693: --- Fix Version/s: (was: 1.11.4) 1.11.5 > TestStreamEnvironment does not implemen

[jira] [Updated] (FLINK-15298) Wrong dependencies in the DataStream API tutorial (the wiki-edits example)

[ https://issues.apache.org/jira/browse/FLINK-15298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15298: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Wrong dependencies in the DataStream AP

[jira] [Updated] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure

[ https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18592: --- Fix Version/s: (was: 1.11.4) 1.11.5 > StreamingFileSink fails due to truncati

[jira] [Updated] (FLINK-19144) Error when writing to partitioned table with s3 FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-19144: --- Fix Version/s: (was: 1.11.4) 1.11.5 > Error when writing to partitioned table

[jira] [Closed] (FLINK-23023) Support offset in window TVF

[ https://issues.apache.org/jira/browse/FLINK-23023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-23023. -- Resolution: Fixed Fixed in 1.14.0: 5cc769d451d97614a99015caee2f63350ad0913d > Support offset in windo

[jira] [Closed] (FLINK-23283) GroupWindowITCase.testWindowAggregateOnUpsertSource fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-23283. -- Resolution: Fixed Fixed in 1.14.0: 4e9fa339dfd921d2cbc4c169bf8b894635d1c528 > GroupWindowITCase.testW

[jira] [Closed] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22781. -- Resolution: Fixed Fixed in 1.14.0: c919edff962e218e543b1e97550d35d66b7172b2 > Incorrect result for gr

[jira] [Closed] (FLINK-22714) Simplify `StreamPhysicalWindowTableFunction` to a simple window assigner if successor node with `WindowAttachedWindowingStrategy` in planner

[ https://issues.apache.org/jira/browse/FLINK-22714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22714. -- Resolution: Fixed Fixed in 1.14.0: f61d9af916092568a0bd76a23cd2a17ec9cc6bb0 > Simplify `StreamPhysica

[jira] [Assigned] (FLINK-20435) Refactor ExecNode and ExecEdge

[ https://issues.apache.org/jira/browse/FLINK-20435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20435: -- Assignee: godfrey he > Refactor ExecNode and ExecEdge > -- > >

[jira] [Assigned] (FLINK-21091) Support ExecNode json serialization/deserialization

[ https://issues.apache.org/jira/browse/FLINK-21091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21091: -- Assignee: godfrey he > Support ExecNode json serialization/deserialization >

[jira] [Created] (FLINK-23217) Support StreamExecValues json serialization/deserialization

godfrey he created FLINK-23217: -- Summary: Support StreamExecValues json serialization/deserialization Key: FLINK-23217 URL: https://issues.apache.org/jira/browse/FLINK-23217 Project: Flink Issu

[jira] [Commented] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371029#comment-17371029 ] godfrey he commented on FLINK-22954: [~wenlong.lwl] I think we should also make sure

[jira] [Closed] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-23135. -- Resolution: Fixed > Flink SQL Error while applying rule AggregateReduceGroupingRule >

[jira] [Updated] (FLINK-22157) Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-22157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22157: --- Fix Version/s: 1.12.5 > Join & Select a part of composite primary key will cause > ArrayIndexOutOfB

[jira] [Commented] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371011#comment-17371011 ] godfrey he commented on FLINK-23135: Fixed in 1.12.5: d1b8c5fd54e1d104387ef6acb94b9a

[jira] [Comment Edited] (FLINK-22157) Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-22157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319853#comment-17319853 ] godfrey he edited comment on FLINK-22157 at 6/29/21, 3:06 AM:

[jira] [Comment Edited] (FLINK-22157) Join & Select a part of composite primary key will cause ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-22157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319853#comment-17319853 ] godfrey he edited comment on FLINK-22157 at 6/29/21, 3:06 AM:

[jira] [Comment Edited] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370232#comment-17370232 ] godfrey he edited comment on FLINK-23135 at 6/27/21, 2:46 PM:

[jira] [Comment Edited] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370232#comment-17370232 ] godfrey he edited comment on FLINK-23135 at 6/27/21, 2:46 PM:

[jira] [Comment Edited] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370232#comment-17370232 ] godfrey he edited comment on FLINK-23135 at 6/27/21, 2:44 PM:

[jira] [Commented] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370232#comment-17370232 ] godfrey he commented on FLINK-23135: [~zhengjiewen] The reason is: [FLINK-21710|htt

[jira] [Updated] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-23135: --- Fix Version/s: 1.12.5 > Flink SQL Error while applying rule AggregateReduceGroupingRule > --

[jira] [Commented] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370154#comment-17370154 ] godfrey he commented on FLINK-23135: [~zhengjiewen] could you provide the ddl statem

[jira] [Assigned] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-23135: -- Assignee: godfrey he > Flink SQL Error while applying rule AggregateReduceGroupingRule >

[jira] [Commented] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369197#comment-17369197 ] godfrey he commented on FLINK-23135: I will fix this ASAP > Flink SQL Error while a

[jira] [Commented] (FLINK-23135) Flink SQL Error while applying rule AggregateReduceGroupingRule

[ https://issues.apache.org/jira/browse/FLINK-23135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368793#comment-17368793 ] godfrey he commented on FLINK-23135: Notes: AggregateReduceGroupingRule is only used

[jira] [Updated] (FLINK-20887) Non-deterministic functions return different values even if it is referred with the same column name

[ https://issues.apache.org/jira/browse/FLINK-20887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-20887: --- Fix Version/s: 1.14.0 > Non-deterministic functions return different values even if it is referred

[jira] [Assigned] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22954: -- Assignee: Wenlong Lyu (was: Wenlong Li) > Don't support consuming update and delete changes

[jira] [Assigned] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22954: -- Assignee: Wenlong Li > Don't support consuming update and delete changes when use table funct

[jira] [Updated] (FLINK-23094) encounter thread-safe problem when using StreamExecutionEnvironment#initializeContextEnvironment in multiple-threads environment

[ https://issues.apache.org/jira/browse/FLINK-23094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-23094: --- Description: encounter thread-safe problem when using StreamExecutionEnvironment#initializeContextE

[jira] [Commented] (FLINK-23094) encounter thread-safe problem when using StreamExecutionEnvironment#initializeContextEnvironment in multiple-threads environment

[ https://issues.apache.org/jira/browse/FLINK-23094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367289#comment-17367289 ] godfrey he commented on FLINK-23094: cc [~trohrmann] > encounter thread-safe proble

[jira] [Created] (FLINK-23094) encounter thread-safe problem when using StreamExecutionEnvironment#initializeContextEnvironment in multiple-threads environment

godfrey he created FLINK-23094: -- Summary: encounter thread-safe problem when using StreamExecutionEnvironment#initializeContextEnvironment in multiple-threads environment Key: FLINK-23094 URL: https://issues.apache.

[jira] [Commented] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365276#comment-17365276 ] godfrey he commented on FLINK-22954: [~wenlong.lwl] Currently, ConstantTableFunction

[jira] [Updated] (FLINK-22967) CodeGenException: Unsupported cast for nested Decimals

[ https://issues.apache.org/jira/browse/FLINK-22967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22967: --- Component/s: (was: Table SQL / Planner) Table SQL / Runtime > CodeGenException:

[jira] [Comment Edited] (FLINK-23020) NullPointerException when running collect twice from Python API

[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365236#comment-17365236 ] godfrey he edited comment on FLINK-23020 at 6/18/21, 4:06 AM:

[jira] [Commented] (FLINK-23020) NullPointerException when running collect twice from Python API

[ https://issues.apache.org/jira/browse/FLINK-23020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17365236#comment-17365236 ] godfrey he commented on FLINK-23020: [~maver1ck] please check whether {{TableEnviron

[jira] [Commented] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360591#comment-17360591 ] godfrey he commented on FLINK-22954: [~jark] If we do not apply StreamPhysicalConsta

[jira] [Closed] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

[ https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21301. -- Resolution: Fixed Fixed in 1.14.0: 145502801c789143074536952f270bea56b30253 > Decouple window aggrega

[jira] [Assigned] (FLINK-21301) Decouple window aggregate allow lateness with state ttl configuration

[ https://issues.apache.org/jira/browse/FLINK-21301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21301: -- Assignee: JING ZHANG > Decouple window aggregate allow lateness with state ttl configuration

[jira] [Commented] (FLINK-22955) lookup join filter push down result to mismatch function signature

[ https://issues.apache.org/jira/browse/FLINK-22955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360529#comment-17360529 ] godfrey he commented on FLINK-22955: [~gsavl] Thanks for reporting this bug > looku

[jira] [Updated] (FLINK-22454) Failed to translate Lookup Join when join on a CAST expression on dimention table column

[ https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22454: --- Fix Version/s: 1.14.0 > Failed to translate Lookup Join when join on a CAST expression on dimention

[jira] [Closed] (FLINK-22454) Failed to translate Lookup Join when join on a CAST expression on dimention table column

[ https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22454. -- Resolution: Fixed Fixed in 1.14.0: f3936b20f488acf1b2592e4f0d5a5da02f444864 > Failed to translate Loo

[jira] [Assigned] (FLINK-22454) Failed to translate Lookup Join when join on a CAST expression on dimention table column

[ https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22454: -- Assignee: Wenlong Lyu (was: wenlong liu) > Failed to translate Lookup Join when join on a CA

[jira] [Assigned] (FLINK-22454) Failed to translate Lookup Join when join on a CAST expression on dimention table column

[ https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22454: -- Assignee: wenlong liu > Failed to translate Lookup Join when join on a CAST expression on dim

[jira] [Closed] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN

[ https://issues.apache.org/jira/browse/FLINK-22038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22038. -- Resolution: Fixed Fixed in 1.14.0: 92465fff779c056aa35aa4ca4207b9b652ecbe09 > Update TopN node to be

[jira] [Closed] (FLINK-22680) An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRule`

[ https://issues.apache.org/jira/browse/FLINK-22680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22680. -- Resolution: Fixed Fixed in 1.14.0: 73d97fb4c3ffd60b9657de734d0293eb5b14e4f7 > An `IndexOutOfBoundsExc

[jira] [Updated] (FLINK-22680) An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRule`

[ https://issues.apache.org/jira/browse/FLINK-22680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22680: --- Fix Version/s: (was: 1.13.2) > An `IndexOutOfBoundsException` is thrown out when apply > `Water

[jira] [Commented] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN

[ https://issues.apache.org/jira/browse/FLINK-22038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17357112#comment-17357112 ] godfrey he commented on FLINK-22038: [~chesnay] sorry about that > Update TopN node

[jira] [Updated] (FLINK-15441) Refactor StreamPhysicalWindowJoin to extends CommonPhysicalJoin

[ https://issues.apache.org/jira/browse/FLINK-15441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15441: --- Summary: Refactor StreamPhysicalWindowJoin to extends CommonPhysicalJoin (was: Refactor StreamExecW

[jira] [Closed] (FLINK-22680) An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRule`

[ https://issues.apache.org/jira/browse/FLINK-22680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22680. -- Resolution: Fixed Fixed in 1.14.0: a364daa37202dc4d7a60c613f547cdcd6893ecd2 > An `IndexOutOfBoundsExc

[jira] [Closed] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN

[ https://issues.apache.org/jira/browse/FLINK-22038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22038. -- Resolution: Fixed Fixed in 1.14.0: 362aadc335af2b6887798d22f97bf72a74229e22 > Update TopN node to be

[jira] [Updated] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN

[ https://issues.apache.org/jira/browse/FLINK-22038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22038: --- Fix Version/s: 1.14.0 > Update TopN node to be without rowNumber if rowNumber field is projected out

[jira] [Updated] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22781: --- Fix Version/s: 1.14.0 > Incorrect result for group window aggregate when mini-batch is enabled > ---

[jira] [Comment Edited] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351685#comment-17351685 ] godfrey he edited comment on FLINK-22781 at 5/26/21, 10:23 AM: ---

[jira] [Commented] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351685#comment-17351685 ] godfrey he commented on FLINK-22781: Assign to you > Incorrect result for group win

[jira] [Assigned] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22781: -- Assignee: Andy > Incorrect result for group window aggregate when mini-batch is enabled > ---

[jira] [Assigned] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

[ https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21345: -- Assignee: lynn1.zhang > NullPointerException > LogicalCorrelateToJoinFromTemporalTableFuncti

[jira] [Commented] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

[ https://issues.apache.org/jira/browse/FLINK-22781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351661#comment-17351661 ] godfrey he commented on FLINK-22781: cc [~qingru zhang] > Incorrect result for grou

[jira] [Created] (FLINK-22781) Incorrect result for group window aggregate when mini-batch is enabled

godfrey he created FLINK-22781: -- Summary: Incorrect result for group window aggregate when mini-batch is enabled Key: FLINK-22781 URL: https://issues.apache.org/jira/browse/FLINK-22781 Project: Flink

[jira] [Comment Edited] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348139#comment-17348139 ] godfrey he edited comment on FLINK-22437 at 5/20/21, 8:03 AM:

[jira] [Assigned] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22437: -- Assignee: zoucao > Miss adding parallesim for filter operator in batch mode > ---

[jira] [Commented] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348139#comment-17348139 ] godfrey he commented on FLINK-22437: [~zoucao] yes, I think that is the easiest appr

[jira] [Closed] (FLINK-11310) Convert predicates to IN or NOT_IN for Project

[ https://issues.apache.org/jira/browse/FLINK-11310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-11310. -- Resolution: Won't Fix Currently, the or expressions will be converted to Sarg, and will be put into a

[jira] [Commented] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17348120#comment-17348120 ] godfrey he commented on FLINK-22437: [~zoucao] would you like to take this ticket ?

[jira] [Closed] (FLINK-20487) Support to consume retractions for window aggregate operator

[ https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20487. -- Resolution: Fixed Fixed in 1.14.0: 1a1a72911ae2862fbfd634c2d707a68e5d296cc8 > Support to consume retr

[jira] [Assigned] (FLINK-22680) An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRule`

[ https://issues.apache.org/jira/browse/FLINK-22680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22680: -- Assignee: Andy > An `IndexOutOfBoundsException` is thrown out when apply > `WatermarkAssigne

[jira] [Commented] (FLINK-22680) An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRule`

[ https://issues.apache.org/jira/browse/FLINK-22680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346015#comment-17346015 ] godfrey he commented on FLINK-22680: Thanks for reporting this issue [~qingru zhang]

[jira] [Updated] (FLINK-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

[ https://issues.apache.org/jira/browse/FLINK-22654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22654: --- Fix Version/s: 1.13.1 > SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks >

[jira] [Comment Edited] (FLINK-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

[ https://issues.apache.org/jira/browse/FLINK-22654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17345833#comment-17345833 ] godfrey he edited comment on FLINK-22654 at 5/17/21, 2:40 AM:

[jira] [Closed] (FLINK-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

[ https://issues.apache.org/jira/browse/FLINK-22654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22654. -- Resolution: Fixed Fixed in 1.14.0: cb4b4d37870fba22af122d1c31e49ce7f3ed096c > SqlCreateTable toStrin

[jira] [Updated] (FLINK-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

[ https://issues.apache.org/jira/browse/FLINK-22654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22654: --- Fix Version/s: 1.14.0 > SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks >

[jira] [Assigned] (FLINK-20487) Support to consume retractions for window aggregate operator

[ https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20487: -- Assignee: Andy > Support to consume retractions for window aggregate operator > -

[jira] [Assigned] (FLINK-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

[ https://issues.apache.org/jira/browse/FLINK-22654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22654: -- Assignee: Terry Wang > SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

[jira] [Closed] (FLINK-15064) Remove XmlOutput util class in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-15064. -- Resolution: Fixed Fixed in 1.14.0: d241759b89ae3455afae5e434a9384ebdc3c1f5f > Remove XmlOutput util c

[jira] [Commented] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b, c)"

[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17343758#comment-17343758 ] godfrey he commented on FLINK-12999: now the exception is: Caused by: java.lang.Cla

[jira] [Updated] (FLINK-15064) Remove XmlOutput util class in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-15064: --- Fix Version/s: 1.14.0 > Remove XmlOutput util class in blink planner > -

[jira] [Assigned] (FLINK-15064) Remove XmlOutput util class in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-15064: -- Assignee: godfrey he > Remove XmlOutput util class in blink planner > ---

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