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

["Jing Zhang (Jira)" <ji...@apache.org>]

Jing Zhang created FLINK-25641:
----------------------------------

             Summary: Unexpected aggregate plan after load hive module
                 Key: FLINK-25641
                 URL: https://issues.apache.org/jira/browse/FLINK-25641
             Project: Flink
          Issue Type: Sub-task
          Components: Table SQL / Planner
            Reporter: Jing Zhang
         Attachments: image-2022-01-13-15-52-27-783.png, image-2022-01-13-15-55-40-958.png

When using flink batch sql to run hive sql queries, we load hive module to use Hive built-in functions.
However some query plan plan are unexpected after loading hive module.
For the following sql,

{code:sql}
load module hive;
use modules hive,core;
set table.sql-dialect=hive;

select
  account_id,
  sum(impression)
from test_db.test_table where dt = '2022-01-10' and hi = '0100' group by account_id
{code}
The planner is:

 !image-2022-01-13-15-55-40-958.png! 

After remove 'load mudiles hive; use modules hive, core;', the planner is:

 !image-2022-01-13-15-52-27-783.png! 

After loading hive modules, hash aggregate is not final plan because the aggregate buffer is not fixed length which type is as following.
{code:java}
LEGACY('RAW', 'ANY<org.apache.hadoop.hive.ql.udf.generic.GenericUDAFEvaluator$AggregationBuffer>')
{code}






--
This message was sent by Atlassian Jira
(v8.20.1#820001)