使用flinksql 输出到文件，能设置把数据输出 一天一个文件吗？

是的，可以使用 Flink SQL 将数据输出到每天一个文件。您可以使用以下步骤：

1. 创建滚动策略：

CREATE TABLE output_table (
id INT NOT NULL,
timestamp TIMESTAMP NOT NULL,
...
) WITH (
'connector' = 'filesystem',
'path' = '/path/to/output',
'format' = 'parquet',
'partition.time-extractor.strategy' = 'custom',
'partition.time-extractor.timestamp-pattern' = 'yyyy-MM-dd',
'partition.time-extractor.class' = 'org.apache.flink.formats.parquet.utils.DayTimeExtractor'
);

1. 将数据插入输出表：

INSERT INTO output_table
SELECT *
FROM cdc_table;

1. 启动作业：

以上步骤将创建一个滚动策略，该策略会将数据分区到每天一个文件中。当您启动 Flink 作业时，数据将被写入相应的每天一个文件中。

示例：

以下示例展示了如何使用 Flink SQL 将数据从 CDC 表输出到每天一个 Parquet 文件：

CREATE TABLE cdc_table (
id INT NOT NULL,
timestamp TIMESTAMP NOT NULL,
...
) WITH (
'connector' = '...', // CDC 连接器配置
...
);

CREATE TABLE output_table (
id INT NOT NULL,
timestamp TIMESTAMP NOT NULL,
...
) WITH (
'connector' = 'filesystem',
'path' = '/path/to/output',
'format' = 'parquet',
'partition.time-extractor.strategy' = 'custom',
'partition.time-extractor.timestamp-pattern' = 'yyyy-MM-dd',
'partition.time-extractor.class' = 'org.apache.flink.formats.parquet.utils.DayTimeExtractor'
);

INSERT INTO output_table
SELECT *
FROM cdc_table;
通过这种方式，您可以在每天一个文件中捕获和存储 Oracle 数据库中的变更数据。