[jira] [Assigned] (FLINK-25931) Add projection pushdown support for CsvFormatFactory

[ https://issues.apache.org/jira/browse/FLINK-25931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25931: -- Assignee: Alexander Fedulov > Add projection pushdown support for CsvFormatFactory >

[jira] [Assigned] (FLINK-27878) Add Retry Support For Async I/O In DataStream API

[ https://issues.apache.org/jira/browse/FLINK-27878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27878: -- Assignee: lincoln lee > Add Retry Support For Async I/O In DataStream API >

[jira] [Commented] (FLINK-27667) YARNHighAvailabilityITCase fails with "Failed to delete temp directory /tmp/junit1681"

[ https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544349#comment-17544349 ] godfrey he commented on FLINK-27667: cc [~wangyang0918] > YARNHighAvailabilityITCase fails with

[jira] [Commented] (FLINK-27667) YARNHighAvailabilityITCase fails with "Failed to delete temp directory /tmp/junit1681"

[ https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544348#comment-17544348 ] godfrey he commented on FLINK-27667:

[jira] [Assigned] (FLINK-27832) SplitAggregateITCase tests failed with Could not acquire the minimum required resources

[ https://issues.apache.org/jira/browse/FLINK-27832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27832: -- Assignee: godfrey he > SplitAggregateITCase tests failed with Could not acquire the minimum

[jira] [Assigned] (FLINK-27691) RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result mismatch

[ https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27691: -- Assignee: lincoln lee > RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast

[jira] [Commented] (FLINK-27691) RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result mismatch

[ https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544257#comment-17544257 ] godfrey he commented on FLINK-27691: Thanks [~lincoln.86xy] > RankHarnessTest.

[jira] [Commented] (FLINK-27745) ClientUtilsTest.uploadAndSetUserArtifacts failed with NoClassDefFoundError

[ https://issues.apache.org/jira/browse/FLINK-27745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544255#comment-17544255 ] godfrey he commented on FLINK-27745: cc [~wangyang0918] > ClientUtilsTest.uploadAndSetUserArtifacts

[jira] [Assigned] (FLINK-27745) ClientUtilsTest.uploadAndSetUserArtifacts failed with NoClassDefFoundError

[ https://issues.apache.org/jira/browse/FLINK-27745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27745: -- Assignee: Yang Wang > ClientUtilsTest.uploadAndSetUserArtifacts failed with

[jira] [Assigned] (FLINK-27791) SlotCountExceedingParallelismTest tests failed with NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27791: -- Assignee: Zhu Zhu > SlotCountExceedingParallelismTest tests failed with >

[jira] [Commented] (FLINK-27832) SplitAggregateITCase tests failed with Could not acquire the minimum required resources

[ https://issues.apache.org/jira/browse/FLINK-27832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544244#comment-17544244 ] godfrey he commented on FLINK-27832: I will have a look > SplitAggregateITCase tests failed with

[jira] [Comment Edited] (FLINK-27791) SlotCountExceedingParallelismTest tests failed with NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544235#comment-17544235 ] godfrey he edited comment on FLINK-27791 at 5/31/22 8:58 AM: - [~zhuzh] could

[jira] [Commented] (FLINK-27791) SlotCountExceedingParallelismTest tests failed with NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-27791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544235#comment-17544235 ] godfrey he commented on FLINK-27791: [~gaoyunhaii] could you have a look ? >

[jira] [Commented] (FLINK-27691) RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result mismatch

[ https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17544178#comment-17544178 ] godfrey he commented on FLINK-27691: cc [~lzljs3620320] could you help fixing this? >

[jira] [Assigned] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline

[ https://issues.apache.org/jira/browse/FLINK-27849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27849: -- Assignee: lincoln lee > Harden correctness for non-deterministic updates present in the

[jira] [Created] (FLINK-27817) TaskManager metaspace OOM for session cluster

godfrey he created FLINK-27817: -- Summary: TaskManager metaspace OOM for session cluster Key: FLINK-27817 URL: https://issues.apache.org/jira/browse/FLINK-27817 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-27815) Improve the join reorder strategy for batch sql job

[ https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-27815: --- Description: Join is heavy operation in the execution, the join order in a query can have a

[jira] [Assigned] (FLINK-27815) Improve the join reorder strategy for batch sql job

[ https://issues.apache.org/jira/browse/FLINK-27815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27815: -- Assignee: godfrey he > Improve the join reorder strategy for batch sql job >

[jira] [Created] (FLINK-27815) Improve the join reorder strategy for batch sql job

godfrey he created FLINK-27815: -- Summary: Improve the join reorder strategy for batch sql job Key: FLINK-27815 URL: https://issues.apache.org/jira/browse/FLINK-27815 Project: Flink Issue Type:

[jira] [Commented] (FLINK-15123) remove uniqueKeys from FlinkStatistic in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536420#comment-17536420 ] godfrey he commented on FLINK-15123: Thanks [~LingJin] > remove uniqueKeys from FlinkStatistic in

[jira] [Updated] (FLINK-14500) Support Flink Python User-Defined Stateless Function for Table - Phase 2

[ https://issues.apache.org/jira/browse/FLINK-14500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-14500: --- Fix Version/s: 1.17.0 (was: 1.16.0) > Support Flink Python User-Defined

[jira] [Updated] (FLINK-27591) Improve the plan for batch queries when statistics is unavailable

[ https://issues.apache.org/jira/browse/FLINK-27591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-27591: --- Fix Version/s: 1.16.0 > Improve the plan for batch queries when statistics is unavailable >

[jira] [Created] (FLINK-27591) Improve the plan for batch queries when statistics is unavailable

godfrey he created FLINK-27591: -- Summary: Improve the plan for batch queries when statistics is unavailable Key: FLINK-27591 URL: https://issues.apache.org/jira/browse/FLINK-27591 Project: Flink

[jira] [Created] (FLINK-27583) Improve the plan for TPC-DS queries

godfrey he created FLINK-27583: -- Summary: Improve the plan for TPC-DS queries Key: FLINK-27583 URL: https://issues.apache.org/jira/browse/FLINK-27583 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks

[ https://issues.apache.org/jira/browse/FLINK-25447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25447: -- Assignee: Zheng yunhong > batch query cannot generate plan when a sorted view into multi

[jira] [Assigned] (FLINK-25097) Bug in inner join when the filter condition is boolean type

[ https://issues.apache.org/jira/browse/FLINK-25097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25097: -- Assignee: Yunhong Zheng > Bug in inner join when the filter condition is boolean type >

[jira] [Commented] (FLINK-25097) Bug in inner join when the filter condition is boolean type

[ https://issues.apache.org/jira/browse/FLINK-25097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527873#comment-17527873 ] godfrey he commented on FLINK-25097: [~337361...@qq.com] assign to you > Bug in inner join when the

[jira] [Closed] (FLINK-27369) COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch

[ https://issues.apache.org/jira/browse/FLINK-27369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-27369. -- Resolution: Fixed Fixed in master: 2e632af6a75ae8db8b1dd8b2b8af9fa5a514af36 1.15.0:

[jira] [Commented] (FLINK-27369) COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch

[ https://issues.apache.org/jira/browse/FLINK-27369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527344#comment-17527344 ] godfrey he commented on FLINK-27369: The reason UnreachableCoalesceArgumentsRemoveRexShuttle will

[jira] [Assigned] (FLINK-27369) COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch

[ https://issues.apache.org/jira/browse/FLINK-27369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27369: -- Assignee: godfrey he > COALESCE('1', CAST(NULL as varchar)) throws expression type mismatch

[jira] [Closed] (FLINK-27272) The plan for query with local sort is incorrect if adaptive batch scheduler is enabled

[ https://issues.apache.org/jira/browse/FLINK-27272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-27272. -- Resolution: Fixed Fixed in master: 456ceb299d0601dee283f718f5d3d0a9d108196e 1.15.0:

[jira] [Updated] (FLINK-27272) The plan for query with local sort is incorrect if adaptive batch scheduler is enabled

[ https://issues.apache.org/jira/browse/FLINK-27272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-27272: --- Fix Version/s: 1.15.0 1.16.0 > The plan for query with local sort is incorrect

[jira] [Assigned] (FLINK-27272) The plan for query with local sort is incorrect if adaptive batch scheduler is enabled

[ https://issues.apache.org/jira/browse/FLINK-27272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-27272: -- Assignee: godfrey he > The plan for query with local sort is incorrect if adaptive batch

[jira] [Created] (FLINK-27272) The plan for query with local sort is incorrect if adaptive batch scheduler is enabled

godfrey he created FLINK-27272: -- Summary: The plan for query with local sort is incorrect if adaptive batch scheduler is enabled Key: FLINK-27272 URL: https://issues.apache.org/jira/browse/FLINK-27272

[jira] [Updated] (FLINK-27272) The plan for query with local sort is incorrect if adaptive batch scheduler is enabled

[ https://issues.apache.org/jira/browse/FLINK-27272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-27272: --- Description: Add the following test case in ForwardHashExchangeTest {code:java} @Test

[jira] [Closed] (FLINK-26756) Failed to deserialize for match recognize

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

[jira] [Assigned] (FLINK-26756) Failed to deserialize for match recognize

[ https://issues.apache.org/jira/browse/FLINK-26756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-26756: -- Assignee: godfrey he > Failed to deserialize for match recognize >

[jira] [Updated] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-26761: --- Fix Version/s: 1.16.0 > Fix the cast exception thrown by PreValidateReWriter when insert >

[jira] [Commented] (FLINK-26761) Fix the cast exception thrown by PreValidateReWriter when insert into/overwrite a partitioned table.

[ https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520902#comment-17520902 ] godfrey he commented on FLINK-26761: [~zoucao] you are right, it's a bug. would you like to fix it ?

[jira] [Assigned] (FLINK-26829) ClassCastException will be thrown when the second operand of divide is a function call

[ https://issues.apache.org/jira/browse/FLINK-26829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-26829: -- Assignee: luoyuxia > ClassCastException will be thrown when the second operand of divide is

[jira] [Commented] (FLINK-25242) UDF with primitive int argument does not accept int values even after a not null filter

[ https://issues.apache.org/jira/browse/FLINK-25242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520898#comment-17520898 ] godfrey he commented on FLINK-25242: good catch~ > UDF with primitive int argument does not accept

[jira] [Closed] (FLINK-26460) Fix Unsupported type when convertTypeToSpec: MAP

[ https://issues.apache.org/jira/browse/FLINK-26460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-26460. -- Resolution: Fixed Fixed in 1.16.0: 33e7c84fb0f6aadf9d228c41c0ba6808634a7e36 1.15.0:

[jira] [Updated] (FLINK-26460) Fix Unsupported type when convertTypeToSpec: MAP

[ https://issues.apache.org/jira/browse/FLINK-26460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-26460: --- Fix Version/s: 1.16.0 > Fix Unsupported type when convertTypeToSpec: MAP >

[jira] [Commented] (FLINK-26756) Failed to deserialize for match recognize

[ https://issues.apache.org/jira/browse/FLINK-26756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509583#comment-17509583 ] godfrey he commented on FLINK-26756: cc [~twalthr] > Failed to deserialize for match recognize >

[jira] [Updated] (FLINK-26756) Failed to deserialize for match recognize

[ https://issues.apache.org/jira/browse/FLINK-26756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-26756: --- Fix Version/s: 1.15.0 > Failed to deserialize for match recognize >

[jira] [Created] (FLINK-26756) Failed to deserialize for match recognize

godfrey he created FLINK-26756: -- Summary: Failed to deserialize for match recognize Key: FLINK-26756 URL: https://issues.apache.org/jira/browse/FLINK-26756 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-26495) Dynamic table options does not work for view

[ https://issues.apache.org/jira/browse/FLINK-26495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-26495: -- Assignee: Jane Chan > Dynamic table options does not work for view >

[jira] [Updated] (FLINK-25600) Support new statement set syntax in sql client and update docs

[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-25600: --- Fix Version/s: 1.15.0 > Support new statement set syntax in sql client and update docs >

[jira] [Closed] (FLINK-25600) Support new statement set syntax in sql client and update docs

[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-25600. -- Resolution: Fixed Fixed in 1.15.0: 80786b2524c1c060be68f3a45c72f5b286be7963

[jira] [Closed] (FLINK-26167) Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

[ https://issues.apache.org/jira/browse/FLINK-26167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-26167. -- Resolution: Fixed Fixed in 1.15.0: 910149c49a6b5f662dfc5503326339f5e62cf4f8 > Explicitly set the

[jira] [Updated] (FLINK-26167) Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

[ https://issues.apache.org/jira/browse/FLINK-26167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-26167: --- Parent: (was: FLINK-24892) Issue Type: Bug (was: Sub-task) > Explicitly set the

[jira] [Commented] (FLINK-20200) SQL Hints are not supported in "Create View" syntax

[ https://issues.apache.org/jira/browse/FLINK-20200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493097#comment-17493097 ] godfrey he commented on FLINK-20200:

[jira] [Reopened] (FLINK-20200) SQL Hints are not supported in "Create View" syntax

[ https://issues.apache.org/jira/browse/FLINK-20200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reopened FLINK-20200: Assignee: godfrey he (was: Danny Chen) > SQL Hints are not supported in "Create View" syntax

[jira] [Updated] (FLINK-26167) Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

[ https://issues.apache.org/jira/browse/FLINK-26167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-26167: --- Description: After FLINK-25995 is finished, we have add an exchange (which will be converted to

[jira] [Updated] (FLINK-26167) Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

[ https://issues.apache.org/jira/browse/FLINK-26167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-26167: --- Description: After FLINK-25995 is finished, we have add an exchange (which will be converted to

[jira] [Updated] (FLINK-26167) Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

[ https://issues.apache.org/jira/browse/FLINK-26167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-26167: --- Description: After FLINK-25995 is finished, we have add an exchange (which will be converted to

[jira] [Created] (FLINK-26167) Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

godfrey he created FLINK-26167: -- Summary: Explicitly set the partitioner for the sql operators whose shuffle and sort are removed Key: FLINK-26167 URL: https://issues.apache.org/jira/browse/FLINK-26167

[jira] [Assigned] (FLINK-26167) Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

[ https://issues.apache.org/jira/browse/FLINK-26167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-26167: -- Assignee: godfrey he > Explicitly set the partitioner for the sql operators whose shuffle

[jira] [Closed] (FLINK-25995) Make implicit assumption of SQL local hash explicit

[ https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-25995. -- Resolution: Fixed Fixed in 1.15.0: 546af8424b32ea13cfeec0a12561b6b73e5f8e7d > Make implicit

[jira] [Assigned] (FLINK-25995) Make implicit assumption of SQL local keyBy/groupBy explicit

[ https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25995: -- Assignee: godfrey he > Make implicit assumption of SQL local keyBy/groupBy explicit >

[jira] [Assigned] (FLINK-25995) Make implicit assumption of SQL local keyBy/groupBy explicit

[ https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25995: -- Assignee: (was: godfrey he) > Make implicit assumption of SQL local keyBy/groupBy

[jira] [Assigned] (FLINK-25995) Make implicit assumption of SQL local keyBy/groupBy explicit

[ https://issues.apache.org/jira/browse/FLINK-25995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25995: -- Assignee: godfrey he > Make implicit assumption of SQL local keyBy/groupBy explicit >

[jira] [Commented] (FLINK-25595) Specify hash/sort aggregate strategy in SQL hint

[ https://issues.apache.org/jira/browse/FLINK-25595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488661#comment-17488661 ] godfrey he commented on FLINK-25595: This is an invalid issue. HashAgg is the best choose if all the

[jira] [Assigned] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25171: -- Assignee: shouzuo meng > When the DDL statement was executed, the column names of the

[jira] [Closed] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-25171. -- Fix Version/s: 1.15.0 1.14.4 (was: 1.14.0)

[jira] [Commented] (FLINK-25641) Unexpected aggregate plan after load hive module

[ https://issues.apache.org/jira/browse/FLINK-25641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475164#comment-17475164 ] godfrey he commented on FLINK-25641: good catch > Unexpected aggregate plan after load hive module

[jira] [Assigned] (FLINK-25600) Support new statement set syntax in sql client and update docs

[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25600: -- Assignee: Wenlong Lyu > Support new statement set syntax in sql client and update docs >

[jira] [Assigned] (FLINK-25604) Remove useless aggregate function

[ https://issues.apache.org/jira/browse/FLINK-25604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25604: -- Assignee: godfrey he > Remove useless aggregate function >

[jira] [Closed] (FLINK-24352) Lookup join + WITH clause throws NPE

[ https://issues.apache.org/jira/browse/FLINK-24352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24352. -- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in 1.15.0:

[jira] [Commented] (FLINK-25474) Idea Scala plugin can not compile RexExplainUtil

[ https://issues.apache.org/jira/browse/FLINK-25474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466463#comment-17466463 ] godfrey he commented on FLINK-25474: Fixed in 1.15.0: bd11bbc8073ac3a8decc6f4cb171b27855d821e5 >

[jira] [Commented] (FLINK-25474) Idea Scala plugin can not compile RexExplainUtil

[ https://issues.apache.org/jira/browse/FLINK-25474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466462#comment-17466462 ] godfrey he commented on FLINK-25474: [~MartijnVisser], 1.13 & 1.14 also has similar problem > Idea

[jira] [Updated] (FLINK-25474) Idea Scala plugin can not compile RexExplainUtil

[ https://issues.apache.org/jira/browse/FLINK-25474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-25474: --- Description: Idea version: 2021.2.3 Scala version: 2.11.12 There are some errors in

[jira] [Updated] (FLINK-25474) Idea Scala plugin can not compile RexExplainUtil

[ https://issues.apache.org/jira/browse/FLINK-25474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-25474: --- Description: Idea version: 2021.2.3 Scala version: 2.12 There are some errors in

[jira] [Assigned] (FLINK-25474) Idea Scala plugin can not compile RexExplainUtil

[ https://issues.apache.org/jira/browse/FLINK-25474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25474: -- Assignee: godfrey he > Idea Scala plugin can not compile RexExplainUtil >

[jira] [Created] (FLINK-25474) Idea Scala plugin can not compile RexExplainUtil

godfrey he created FLINK-25474: -- Summary: Idea Scala plugin can not compile RexExplainUtil Key: FLINK-25474 URL: https://issues.apache.org/jira/browse/FLINK-25474 Project: Flink Issue Type:

[jira] [Closed] (FLINK-25123) Improve expression description in SQL operator

[ https://issues.apache.org/jira/browse/FLINK-25123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-25123. -- Resolution: Fixed Fixed in 1.15.0: d3b6a690b41c4f2a69dfe889ce852f11b798612d > Improve expression

[jira] [Closed] (FLINK-25076) Simplify name of SQL operators

[ https://issues.apache.org/jira/browse/FLINK-25076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-25076. -- Resolution: Fixed Fixed in 1.15.0: 1255c190b750da5a560204dfe9ff283082d0d424 > Simplify name of SQL

[jira] [Comment Edited] (FLINK-24813) Improve ImplicitTypeConversionITCase

[ https://issues.apache.org/jira/browse/FLINK-24813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452863#comment-17452863 ] godfrey he edited comment on FLINK-24813 at 12/13/21, 2:00 AM: --- Fixed in

[jira] [Closed] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL

[ https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22113. -- Resolution: Fixed Fixed in 1.15.0: ac957ae07a49ab88ad46a14c6ea0d4891d5437d7 1.14.1:

[jira] [Commented] (FLINK-25149) getScanRuntimeProvider method called before the pushDown method,

[ https://issues.apache.org/jira/browse/FLINK-25149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453798#comment-17453798 ] godfrey he commented on FLINK-25149: could you close this issue since you have solved the problem?

[jira] [Commented] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453793#comment-17453793 ] godfrey he commented on FLINK-25171: can you given an example ? > When the DDL statement was

[jira] [Closed] (FLINK-24813) Improve ImplicitTypeConversionITCase

[ https://issues.apache.org/jira/browse/FLINK-24813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24813. -- Resolution: Fixed Fixed in 1.15.0: d489558f46e8348e7f7aaa066925f5c0adaa09a8 1.14.1:

[jira] [Assigned] (FLINK-25076) Simplify name of SQL operators

[ https://issues.apache.org/jira/browse/FLINK-25076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25076: -- Assignee: Wenlong Lyu > Simplify name of SQL operators > -- > >

[jira] [Assigned] (FLINK-25074) Simplify name of window operators in DS by moving details to description

[ https://issues.apache.org/jira/browse/FLINK-25074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25074: -- Assignee: Wenlong Lyu > Simplify name of window operators in DS by moving details to

[jira] [Assigned] (FLINK-25123) Improve expression description in SQL operator

[ https://issues.apache.org/jira/browse/FLINK-25123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25123: -- Assignee: Wenlong Lyu > Improve expression description in SQL operator >

[jira] [Assigned] (FLINK-25118) Add vertex index as prefix in vertex name

[ https://issues.apache.org/jira/browse/FLINK-25118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25118: -- Assignee: Wenlong Lyu > Add vertex index as prefix in vertex name >

[jira] [Assigned] (FLINK-25073) Introduce Tree Mode description for job vertex

[ https://issues.apache.org/jira/browse/FLINK-25073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25073: -- Assignee: Wenlong Lyu > Introduce Tree Mode description for job vertex >

[jira] [Assigned] (FLINK-25072) Introduce description for operator

[ https://issues.apache.org/jira/browse/FLINK-25072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25072: -- Assignee: Wenlong Lyu > Introduce description for operator >

[jira] [Assigned] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

[ https://issues.apache.org/jira/browse/FLINK-25070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25070: -- Assignee: Wenlong Lyu > FLIP-195: Improve the name and structure of vertex and operator name

[jira] [Assigned] (FLINK-24352) Lookup join + WITH clause throws NPE

[ https://issues.apache.org/jira/browse/FLINK-24352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-24352: -- Assignee: Yuval Itzchakov > Lookup join + WITH clause throws NPE >

[jira] [Closed] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

[ https://issues.apache.org/jira/browse/FLINK-24708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24708. -- Resolution: Fixed Fixed in: 1.15.0: 90e850301e672fc0da293abc55eb446f7ec68ffa 1.14.1:

[jira] [Updated] (FLINK-24835) "group by" in the interval join will throw a exception

[ https://issues.apache.org/jira/browse/FLINK-24835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24835: --- Fix Version/s: (was: 1.13.4) > "group by" in the interval join will throw a exception >

[jira] [Closed] (FLINK-24835) "group by" in the interval join will throw a exception

[ https://issues.apache.org/jira/browse/FLINK-24835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24835. -- Resolution: Fixed Fixed in 1.15.0: 8aa74d5ad7026734bdd98eabbc9cbbb243bbe8b0 1.14.1:

[jira] [Closed] (FLINK-24656) Add user document for Window Deduplication

[ https://issues.apache.org/jira/browse/FLINK-24656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24656. -- Resolution: Fixed Fixed in 1.15.0: 69d0918a0420c1a3da2488b1548243e3fb65d17c > Add user document for

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

[ https://issues.apache.org/jira/browse/FLINK-24924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444957#comment-17444957 ] godfrey he commented on FLINK-24924: CAST is used at high frequencies, +1 keep the behavior before

[jira] [Closed] (FLINK-23014) Support streaming window Deduplicate in planner

[ https://issues.apache.org/jira/browse/FLINK-23014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-23014. -- Resolution: Fixed Fixed in 1.15.0: 9699484b006b7772df077052887acfe19dcc5680 > Support streaming

[jira] [Updated] (FLINK-24835) "group by" in the interval join will throw a exception

[ https://issues.apache.org/jira/browse/FLINK-24835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24835: --- Fix Version/s: 1.14.1 1.13.4 > "group by" in the interval join will throw a

[jira] [Updated] (FLINK-24835) "group by" in the interval join will throw a exception

[ https://issues.apache.org/jira/browse/FLINK-24835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24835: --- Fix Version/s: 1.15.0 > "group by" in the interval join will throw a exception >

[jira] [Updated] (FLINK-24835) "group by" in the interval join will throw a exception

[ https://issues.apache.org/jira/browse/FLINK-24835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-24835: --- Component/s: Table SQL / Planner > "group by" in the interval join will throw a exception >

[jira] [Assigned] (FLINK-24835) "group by" in the interval join will throw a exception

[ https://issues.apache.org/jira/browse/FLINK-24835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-24835: -- Assignee: JING ZHANG > "group by" in the interval join will throw a exception >

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