czy006 commented on PR #3028:
URL: https://github.com/apache/amoro/pull/3028#issuecomment-2228358015
```
CREATE TABLE print_paimon_table (
debezium_json STRING,
database_name STRING,
table_name STRING,
partition_key STRING,
partition_value STRING,
kafka_offset int,
kafka_partition bigint,
dt STRING
) WITH ('connector' = 'blackhole');
CREATE CATALOG tb_catalog WITH (
'type' = 'paimon',
'warehouse' = 'hdfs:///flink/warehouse'
);
use CATALOG tb_catalog;
INSERT INTO
default_catalog.default_database.print_paimon_table
select
debezium_json,
database_name,
table_name,
partition_key,
partition_value,
kafka_offset,
kafka_partition,
dt
from
tb_cdc_db_torrent_table
/*+ OPTIONS('scan.snapshot-id' = '111','consumer-id' = 'test2') */;
```
--
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]
