[jira] [Closed] (FLINK-32052) Introduce left and right state retention time to StreamingJoinOperator

[ https://issues.apache.org/jira/browse/FLINK-32052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-32052. -- Resolution: Fixed Fixed in master: 5ba3f2bdea6fc7c9e58b50200806ea341b7dd3d3   > Introduce left and r

[jira] [Closed] (FLINK-31950) Introduce StateMetadata and StateMetadataJson SerDe

[ https://issues.apache.org/jira/browse/FLINK-31950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-31950. -- Resolution: Fixed Fixed in master: 62b11e2e117f874f073de93756c6b9889c464562 > Introduce StateMetadata

[jira] [Closed] (FLINK-30815) BatchTestBase/BatchAbstractTestBase are using JUnit4 while some child tests are using JUnit5

[ https://issues.apache.org/jira/browse/FLINK-30815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30815. -- Fix Version/s: 1.18.0 Resolution: Fixed Fixed in master: ed9ee279e50781b7bd2d85f1486721c02fc7e

[jira] [Assigned] (FLINK-30815) BatchTestBase/BatchAbstractTestBase are using JUnit4 while some child tests are using JUnit5

[ https://issues.apache.org/jira/browse/FLINK-30815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30815: -- Assignee: Yuxin Tan > BatchTestBase/BatchAbstractTestBase are using JUnit4 while some child t

[jira] [Commented] (FLINK-31884) Upgrade ExecNode to new version causes the old serialized plan failed to pass Json SerDe round trip

[ https://issues.apache.org/jira/browse/FLINK-31884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717446#comment-17717446 ] Godfrey He commented on FLINK-31884: Fixed in master: 3664609c7622ccae80e36e85099a1b

[jira] [Commented] (FLINK-31917) Loss of Idempotence in JsonSerDe Round Trip for AggregateCall and RexNode

[ https://issues.apache.org/jira/browse/FLINK-31917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715711#comment-17715711 ] Godfrey He commented on FLINK-31917: good catch [~qingyue]  > Loss of Idempotence i

[jira] [Assigned] (FLINK-31917) Loss of Idempotence in JsonSerDe Round Trip for AggregateCall and RexNode

[ https://issues.apache.org/jira/browse/FLINK-31917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-31917: -- Assignee: Jane Chan > Loss of Idempotence in JsonSerDe Round Trip for AggregateCall and RexNo

[jira] [Created] (FLINK-31833) Support code-gen fusion for multiple operators

Godfrey He created FLINK-31833: -- Summary: Support code-gen fusion for multiple operators Key: FLINK-31833 URL: https://issues.apache.org/jira/browse/FLINK-31833 Project: Flink Issue Type: Sub-ta

[jira] [Closed] (FLINK-31767) Improve the implementation for "analyze table" execution on partitioned table

[ https://issues.apache.org/jira/browse/FLINK-31767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-31767. -- Fix Version/s: 1.18.0 Resolution: Fixed Fixed in master: 0191cf7d0064003bd2d4b60ebb6e329f791c92

[jira] [Updated] (FLINK-31767) Improve the implementation for "analyze table" execution on partitioned table

[ https://issues.apache.org/jira/browse/FLINK-31767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-31767: --- Description: Currently, for partitioned table, the "analyze table" command will generate a separate

[jira] [Updated] (FLINK-31767) Improve the implementation for "analyze table" execution

[ https://issues.apache.org/jira/browse/FLINK-31767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-31767: --- Description: Currently,  > Improve the implementation for "analyze table" execution > --

[jira] [Updated] (FLINK-31767) Improve the implementation for "analyze table" execution on partitioned table

[ https://issues.apache.org/jira/browse/FLINK-31767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-31767: --- Description: Currently, for partitioned table,  (was: Currently, ) > Improve the implementation for

[jira] [Updated] (FLINK-31767) Improve the implementation for "analyze table" execution on partitioned table

[ https://issues.apache.org/jira/browse/FLINK-31767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-31767: --- Summary: Improve the implementation for "analyze table" execution on partitioned table (was: Improv

[jira] [Created] (FLINK-31767) Improve the implementation for "analyze table" execution

Godfrey He created FLINK-31767: -- Summary: Improve the implementation for "analyze table" execution Key: FLINK-31767 URL: https://issues.apache.org/jira/browse/FLINK-31767 Project: Flink Issue Ty

[jira] [Closed] (FLINK-13611) Introduce analyze statistic utility to generate table & column statistics

[ https://issues.apache.org/jira/browse/FLINK-13611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-13611. -- Resolution: Invalid see https://issues.apache.org/jira/browse/FLINK-28492 > Introduce analyze statist

[jira] [Commented] (FLINK-31165) Over Agg: The window rank function without order by error in top N query

[ https://issues.apache.org/jira/browse/FLINK-31165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706307#comment-17706307 ] Godfrey He commented on FLINK-31165: [~lincoln.86xy] [~qingyue] I prefer to just imp

[jira] [Closed] (FLINK-31273) Left join with IS_NULL filter be wrongly pushed down and get wrong join results

[ https://issues.apache.org/jira/browse/FLINK-31273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-31273. -- Fix Version/s: 1.16.2 1.18.0 1.17.1 (was:

[jira] [Closed] (FLINK-31239) Fix sum function can't get the corrected value when the argument type is string

[ https://issues.apache.org/jira/browse/FLINK-31239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-31239. -- Fix Version/s: 1.18.0 Resolution: Fixed Fixed in 1.18.0: 263555c9adcca0abe194e9a6c1d85ec591c3

[jira] [Reopened] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

[ https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reopened FLINK-30989: > Configuration table.exec.spill-compression.block-size not take effect in > batch job >

[jira] [Closed] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

[ https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30989. -- Resolution: Fixed Fixed in 1.18.0: b4d43b47c993b7b4d5e4f7a78610c54124fcbcb4 1.17.0: 333088113993f460

[jira] [Updated] (FLINK-30989) Configuration table.exec.spill-compression.block-size not take effect in batch job

[ https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-30989: --- Fix Version/s: 1.17.0 1.18.0 > Configuration table.exec.spill-compression.block-s

[jira] [Assigned] (FLINK-31239) Fix sum function can't get the corrected value when the argument type is string

[ https://issues.apache.org/jira/browse/FLINK-31239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-31239: -- Assignee: dalongliu > Fix sum function can't get the corrected value when the argument type i

[jira] [Closed] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-31082. -- Resolution: Fixed > Setting maven property 'flink.resueForks' to false in table planner module >

[jira] [Commented] (FLINK-31082) Setting maven property 'flink.resueForks' to false in table planner module

[ https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694800#comment-17694800 ] Godfrey He commented on FLINK-31082: Fixed in 1.16.2: 247a099cc358e0006aa0e387a55cf6

[jira] [Assigned] (FLINK-31059) Release Testing: Verify FLINK-29717 Supports hive udaf such as sum/count by native implementation

[ https://issues.apache.org/jira/browse/FLINK-31059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-31059: -- Assignee: miamiaoxyz (was: Yunhong Zheng) > Release Testing: Verify FLINK-29717 Supports hiv

[jira] [Assigned] (FLINK-31079) Release Testing: Verify FLINK-29663 Further improvements of adaptive batch scheduler

[ https://issues.apache.org/jira/browse/FLINK-31079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-31079: -- Assignee: miamiaoxyz (was: Yunhong Zheng) > Release Testing: Verify FLINK-29663 Further impr

[jira] [Closed] (FLINK-30824) Add document for new introduced hive agg option

[ https://issues.apache.org/jira/browse/FLINK-30824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30824. -- Resolution: Fixed Fixed in 1.17.0: afdc079465c393d98bf2b3607a75b1fc9d58d281 > Add document for new in

[jira] [Assigned] (FLINK-30824) Add document for new introduced hive agg option

[ https://issues.apache.org/jira/browse/FLINK-30824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30824: -- Assignee: dalongliu > Add document for new introduced hive agg option > -

[jira] [Closed] (FLINK-30971) Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'

[ https://issues.apache.org/jira/browse/FLINK-30971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30971. -- Resolution: Fixed Fixed in master: 55b927b0e6eb2d5d71487b9bb2c4dab80017a7e5 > Modify the default valu

[jira] [Updated] (FLINK-30971) Modify the default value of parameter 'table.exec.local-hash-agg.adaptive.sampling-threshold'

[ https://issues.apache.org/jira/browse/FLINK-30971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-30971: --- Component/s: Table SQL / Planner (was: Table SQL / Runtime) > Modify the defaul

[jira] [Commented] (FLINK-30959) UNIX_TIMESTAMP's return value does not meet expected

[ https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685777#comment-17685777 ] Godfrey He commented on FLINK-30959: Thanks for reporting this issue. [~yunfengzhou]

[jira] [Closed] (FLINK-30876) Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode

[ https://issues.apache.org/jira/browse/FLINK-30876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30876. -- Resolution: Fixed > Fix ResetTransformationProcessor don't reset the transformation of ExecNode > in

[jira] [Comment Edited] (FLINK-30876) Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode

[ https://issues.apache.org/jira/browse/FLINK-30876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684394#comment-17684394 ] Godfrey He edited comment on FLINK-30876 at 2/6/23 3:23 AM:

[jira] [Assigned] (FLINK-30876) Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode

[ https://issues.apache.org/jira/browse/FLINK-30876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30876: -- Assignee: Yunhong Zheng > Fix ResetTransformationProcessor don't reset the transformation of

[jira] [Commented] (FLINK-30876) Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode

[ https://issues.apache.org/jira/browse/FLINK-30876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684394#comment-17684394 ] Godfrey He commented on FLINK-30876: Fixed in master: 111342f37bdc0d582d3f7af458d986

[jira] [Closed] (FLINK-30542) Support adaptive local hash aggregate in runtime

[ https://issues.apache.org/jira/browse/FLINK-30542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30542. -- Resolution: Fixed Fixed in 1.17.0: 122ba8f319b0d68374abba08d676e6dfa82cc114 > Support adaptive local

[jira] [Updated] (FLINK-30542) Support adaptive local hash aggregate in runtime

[ https://issues.apache.org/jira/browse/FLINK-30542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-30542: --- Component/s: Table SQL / Planner > Support adaptive local hash aggregate in runtime > --

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682344#comment-17682344 ] Godfrey He commented on FLINK-30727: Fixed in 1.17.0: dcbb20688c0de238f65a6986f9888c

[jira] [Assigned] (FLINK-29720) Supports hive average function by native implemetatoin

[ https://issues.apache.org/jira/browse/FLINK-29720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-29720: -- Assignee: dalongliu > Supports hive average function by native implemetatoin > --

[jira] [Updated] (FLINK-29720) Supports hive average function by native implemetatoin

[ https://issues.apache.org/jira/browse/FLINK-29720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-29720: --- Component/s: Connectors / Hive > Supports hive average function by native implemetatoin > --

[jira] [Closed] (FLINK-29720) Supports hive average function by native implemetatoin

[ https://issues.apache.org/jira/browse/FLINK-29720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-29720. -- Resolution: Fixed Fixed in 1.17.0: ec3243e36eebb706c624068c8a7622cf308df95e > Supports hive average f

[jira] [Closed] (FLINK-30814) The parallelism&maxParallelism of sort after a global partitioning is not forced to be 1

[ https://issues.apache.org/jira/browse/FLINK-30814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30814. -- Resolution: Fixed Fixed in 1.17.0: 916ff76b61a0bfa8283d52be53cd33e317d0d550 > The parallelism&maxPara

[jira] [Assigned] (FLINK-30814) The parallelism&maxParallelism of sort after a global partitioning is not forced to be 1

[ https://issues.apache.org/jira/browse/FLINK-30814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30814: -- Assignee: Godfrey He > The parallelism&maxParallelism of sort after a global partitioning is

[jira] [Commented] (FLINK-30814) The parallelism&maxParallelism of sort after a global partitioning is not forced to be 1

[ https://issues.apache.org/jira/browse/FLINK-30814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681693#comment-17681693 ] Godfrey He commented on FLINK-30814: [~zhuzh] thanks for reporting this issue. Curr

[jira] [Assigned] (FLINK-29722) Supports hive max function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-29722: -- Assignee: dalongliu > Supports hive max function by native implementation > -

[jira] [Closed] (FLINK-29722) Supports hive max function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-29722. -- Resolution: Fixed Fixed in 1.17.0: 74c7188ae9898b492c94a472d9d407bf4f8e0876 > Supports hive max funct

[jira] [Updated] (FLINK-29722) Supports hive max function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-29722: --- Component/s: Connectors / Hive > Supports hive max function by native implementation > -

[jira] [Assigned] (FLINK-29719) Supports hive count function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-29719: -- Assignee: dalongliu > Supports hive count function by native implementation > ---

[jira] [Updated] (FLINK-29719) Supports hive count function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-29719: --- Component/s: Connectors / Hive > Supports hive count function by native implementation > ---

[jira] [Closed] (FLINK-29719) Supports hive count function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-29719. -- Resolution: Fixed Fixed in 1.17.0: 606f297198acd74a5c1a39700bd84ad9e26e7b82 > Supports hive count fun

[jira] [Updated] (FLINK-29721) Supports hive min function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-29721: --- Component/s: Connectors / Hive > Supports hive min function by native implementation > -

[jira] [Assigned] (FLINK-29721) Supports hive min function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-29721: -- Assignee: tartarus (was: KH) > Supports hive min function by native implementation > ---

[jira] [Closed] (FLINK-29721) Supports hive min function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-29721. -- Resolution: Fixed Fixed in 1.17.0: 8a1f66ca827163b32387e0043f4362921f6c11a9 > Supports hive min funct

[jira] [Assigned] (FLINK-29721) Supports hive min function by native implementation

[ https://issues.apache.org/jira/browse/FLINK-29721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-29721: -- Assignee: KH > Supports hive min function by native implementation >

[jira] [Assigned] (FLINK-30376) Introduce a new flink bushy join reorder rule which based on greedy algorithm

[ https://issues.apache.org/jira/browse/FLINK-30376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30376: -- Assignee: Yunhong Zheng > Introduce a new flink bushy join reorder rule which based on greedy

[jira] [Closed] (FLINK-30376) Introduce a new flink bushy join reorder rule which based on greedy algorithm

[ https://issues.apache.org/jira/browse/FLINK-30376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30376. -- Resolution: Fixed Fixed in 1.17.0: 14ea1a58e9bf516f0ed0683486252c7e54ea8039 > Introduce a new flink b

[jira] [Comment Edited] (FLINK-30586) Fix calcCodeGen failed if calc with like condition contains double quotation mark

[ https://issues.apache.org/jira/browse/FLINK-30586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656440#comment-17656440 ] Godfrey He edited comment on FLINK-30586 at 1/10/23 8:17 AM: -

[jira] [Closed] (FLINK-30586) Fix calcCodeGen failed if calc with like condition contains double quotation mark

[ https://issues.apache.org/jira/browse/FLINK-30586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30586. -- Resolution: Fixed Fixed in 1.17.0: 68b37fb867374df5a201f0b170e35c21266e5d7b > Fix calcCodeGen failed

[jira] [Assigned] (FLINK-30586) Fix calcCodeGen failed if calc with like condition contains double quotation mark

[ https://issues.apache.org/jira/browse/FLINK-30586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30586: -- Assignee: Yunhong Zheng > Fix calcCodeGen failed if calc with like condition contains double

[jira] [Closed] (FLINK-30491) Hive table partition supports to deserialize later during runtime

[ https://issues.apache.org/jira/browse/FLINK-30491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30491. -- Resolution: Fixed Fixed in 1.17.0: d4340d16708010394d7c57063b5dece8362d41d0 > Hive table partition su

[jira] [Updated] (FLINK-30542) Support adaptive local hash aggregate in runtime

[ https://issues.apache.org/jira/browse/FLINK-30542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-30542: --- Summary: Support adaptive local hash aggregate in runtime (was: Support adaptive hash aggregate in

[jira] [Assigned] (FLINK-30491) Hive table partition supports to deserialize later during runtime

[ https://issues.apache.org/jira/browse/FLINK-30491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30491: -- Assignee: dalongliu > Hive table partition supports to deserialize later during runtime > ---

[jira] [Assigned] (FLINK-30542) Support adaptive local hash aggregate in runtime

[ https://issues.apache.org/jira/browse/FLINK-30542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30542: -- Assignee: Yunhong Zheng > Support adaptive local hash aggregate in runtime >

[jira] [Closed] (FLINK-30365) New dynamic partition pruning strategy to support more dpp patterns

[ https://issues.apache.org/jira/browse/FLINK-30365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30365. -- Resolution: Fixed Fixed in 1.17.0: d9f9b55f82dfbc1676572cc36b718a99001497f8 > New dynamic partition p

[jira] [Assigned] (FLINK-30365) New dynamic partition pruning strategy to support more dpp patterns

[ https://issues.apache.org/jira/browse/FLINK-30365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30365: -- Assignee: Yunhong Zheng > New dynamic partition pruning strategy to support more dpp patterns

[jira] [Comment Edited] (FLINK-29849) Event time temporal join on an upsert source may produce incorrect execution plan

[ https://issues.apache.org/jira/browse/FLINK-29849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17650120#comment-17650120 ] Godfrey He edited comment on FLINK-29849 at 1/4/23 2:07 AM:

[jira] [Updated] (FLINK-29849) Event time temporal join on an upsert source may produce incorrect execution plan

[ https://issues.apache.org/jira/browse/FLINK-29849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-29849: --- Fix Version/s: 1.16.1 > Event time temporal join on an upsert source may produce incorrect execution

[jira] [Comment Edited] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643318#comment-17643318 ] Godfrey He edited comment on FLINK-28988 at 1/3/23 4:08 AM:

[jira] [Updated] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-28988: --- Fix Version/s: 1.16.1 > Incorrect result for filter after temporal join > --

[jira] [Closed] (FLINK-28850) Support table alias in LOOKUP hint

[ https://issues.apache.org/jira/browse/FLINK-28850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-28850. -- Resolution: Fixed Fixed in master: be6b1c94ef3f552c753746863cb0a4e7dd86d2fc f32ba645246a8180a0218265

[jira] [Updated] (FLINK-28850) Support table alias in LOOKUP hint

[ https://issues.apache.org/jira/browse/FLINK-28850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-28850: --- Fix Version/s: 1.17.0 > Support table alias in LOOKUP hint > -- > >

[jira] [Assigned] (FLINK-28850) Support table alias in LOOKUP hint

[ https://issues.apache.org/jira/browse/FLINK-28850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-28850: -- Assignee: lincoln lee > Support table alias in LOOKUP hint >

[jira] [Closed] (FLINK-30368) Fix calcite method RelMdUtil$numDistinctVals() wrongly return zero if the method input domainSize much larger than numSelected

[ https://issues.apache.org/jira/browse/FLINK-30368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30368. -- Resolution: Fixed Fixed in master: dc862dae28a172f674a9b8a2198c603275304550 > Fix calcite method RelM

[jira] [Assigned] (FLINK-30368) Fix calcite method RelMdUtil$numDistinctVals() wrongly return zero if the method input domainSize much larger than numSelected

[ https://issues.apache.org/jira/browse/FLINK-30368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30368: -- Assignee: Yunhong Zheng > Fix calcite method RelMdUtil$numDistinctVals() wrongly return zero

[jira] [Closed] (FLINK-30270) FlinkJoinToMultiJoinRule incorrectly combines Left/Right outer join to MultiJoin

[ https://issues.apache.org/jira/browse/FLINK-30270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30270. -- Resolution: Fixed Fixed in master:7590cb7d84774b0e8afd7b0af31cc0af762d4c6a 1.16.1: ca42695dba5ab72c6b

[jira] [Closed] (FLINK-29849) Event time temporal join on an upsert source may produce incorrect execution plan

[ https://issues.apache.org/jira/browse/FLINK-29849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-29849. -- Resolution: Fixed Fixed in master: eb44ac01c9969cb22ab832b6b2155b109f015b06 > Event time temporal joi

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

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646524#comment-17646524 ] Godfrey He commented on FLINK-18356: [~zhengyunhong97] will help to address this iss

[jira] [Updated] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-28988: --- Fix Version/s: 1.17.0 > Incorrect result for filter after temporal join > --

[jira] [Closed] (FLINK-28988) Incorrect result for filter after temporal join

[ https://issues.apache.org/jira/browse/FLINK-28988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-28988. -- Resolution: Fixed Fixed in 1.17.0: b2203eaef68364306dfcc27fb34ac82baefda3d3 2851fac9c4c052876c80440b

[jira] [Closed] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

[ https://issues.apache.org/jira/browse/FLINK-29781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-29781. -- Resolution: Fixed > ChangelogNormalize uses wrong keys after transformation by > WatermarkAssignerCha

[jira] [Updated] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

[ https://issues.apache.org/jira/browse/FLINK-29781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-29781: --- Fix Version/s: 1.16.1 > ChangelogNormalize uses wrong keys after transformation by > WatermarkAssig

[jira] [Comment Edited] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

[ https://issues.apache.org/jira/browse/FLINK-29781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17633625#comment-17633625 ] godfrey he edited comment on FLINK-29781 at 11/14/22 9:50 AM:

[jira] [Commented] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

[ https://issues.apache.org/jira/browse/FLINK-29781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17633625#comment-17633625 ] godfrey he commented on FLINK-29781: Fixed in master: 5463f244ec69f623d75c15374b55bb

[jira] [Assigned] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

[ https://issues.apache.org/jira/browse/FLINK-29781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-29781: -- Assignee: lincoln lee > ChangelogNormalize uses wrong keys after transformation by > Waterma

[jira] [Updated] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

[ https://issues.apache.org/jira/browse/FLINK-29781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-29781: --- Fix Version/s: 1.17.0 > ChangelogNormalize uses wrong keys after transformation by > WatermarkAssig

[jira] [Created] (FLINK-29981) Improve WatermarkAssignerChangelogNormalizeTransposeRule

godfrey he created FLINK-29981: -- Summary: Improve WatermarkAssignerChangelogNormalizeTransposeRule Key: FLINK-29981 URL: https://issues.apache.org/jira/browse/FLINK-29981 Project: Flink Issue Ty

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

[ https://issues.apache.org/jira/browse/FLINK-27998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619204#comment-17619204 ] godfrey he commented on FLINK-27998: Can this ticket be closed since "Upgrade Calcit

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

[ https://issues.apache.org/jira/browse/FLINK-21239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21239. -- Resolution: Won't Fix This ticket can be closed since "Upgrade Calcite version to 1.32" has been crea

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

[ https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20873. -- Resolution: Won't Fix > Upgrade Calcite version to 1.27 > --- > >

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

[ https://issues.apache.org/jira/browse/FLINK-20873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619201#comment-17619201 ] godfrey he commented on FLINK-20873: This ticket can be closed since "Upgrade Calci

[jira] [Commented] (FLINK-29625) Optimize changelog normalize for upsert source

[ https://issues.apache.org/jira/browse/FLINK-29625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617422#comment-17617422 ] godfrey he commented on FLINK-29625: +1 for the improvement > Optimize changelog no

[jira] [Commented] (FLINK-29126) Fix spliting file optimization doesn't work for orc format

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

[jira] [Assigned] (FLINK-29126) Fix spliting file optimization doesn't work for orc format

[ https://issues.apache.org/jira/browse/FLINK-29126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-29126: -- Assignee: luoyuxia > Fix spliting file optimization doesn't work for orc format > ---

[jira] [Updated] (FLINK-29126) Fix spliting file optimization doesn't work for orc format

[ https://issues.apache.org/jira/browse/FLINK-29126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-29126: --- Fix Version/s: 1.16.0 > Fix spliting file optimization doesn't work for orc format > ---

[jira] [Commented] (FLINK-27530) FLIP-227: Support overdraft buffer

[ https://issues.apache.org/jira/browse/FLINK-27530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606516#comment-17606516 ] godfrey he commented on FLINK-27530: [~pnowojski][~fanrui] could you update the rele

[jira] [Updated] (FLINK-29280) Join hint are not propagated in subquery

[ https://issues.apache.org/jira/browse/FLINK-29280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-29280: --- Fix Version/s: 1.16.0 1.17.0 > Join hint are not propagated in subquery > ---

[jira] [Closed] (FLINK-29280) Join hint are not propagated in subquery

[ https://issues.apache.org/jira/browse/FLINK-29280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-29280. -- Resolution: Fixed Fixed in master: 22cb554008320e6684280b5205f93d7a6f685c6c in 1.16.0: b37a8153f22b629

[jira] [Assigned] (FLINK-29280) Join hint are not propagated in subquery

[ https://issues.apache.org/jira/browse/FLINK-29280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-29280: -- Assignee: xuyang > Join hint are not propagated in subquery > ---

[jira] [Closed] (FLINK-28738) [doc] Add a user doc about the correctness for non-deterministic updates

[ https://issues.apache.org/jira/browse/FLINK-28738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-28738. -- Resolution: Fixed Fixed in master: a02b2c232ea2fb1b22bd0e5c290e4c6f0217549b in 1.16.0: be73c9695d01e3d

[jira] [Closed] (FLINK-28569) SinkUpsertMaterializer should be aware of the input upsertKey if it is not empty otherwise wrong result maybe produced

[ https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-28569. -- Resolution: Fixed Fixed in master: dbcd2d7b86fcb7fa7a26e181f1719ea4c6dad828 in 1.16.0: 390612320fa9be2

  1   2   3   4   5   6   7   8   9   10   >