Dkbei commented on issue #2976:
URL:
https://github.com/apache/incubator-streampark/issues/2976#issuecomment-1692720447
sql脚本如下：
SET 'execution.runtime-mode' = 'batch';
SET 'parallelism.default' = '30';
SET 'pipeline.max-parallelism' = '30';
CREATE CATALOG paimon WITH (
'type' = 'paimon',
'metastore' = 'hive',
'uri' = 'thrift://xxx:9083',
'warehouse' = 'hdfs://xx/user/hive/warehouse/',
'hive-conf-dir' = '/etc/hive/conf'
);
insert into paimon.ods.ods_record_dynamic_realtime
select
*
from (
select a.*,row_number() over(partition by synid order by upload_update desc)
as rn from paimon.ods.ods_record_realtime /*+ OPTIONS('scan.infer-parallelism'
= 'false') */ a
) zz
;
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
