如何在Flink SQL中设置MySQL服务器的时间区?
时间: 2024-10-24 21:06:00 浏览: 20
在 Apache Flink 中,当你使用 SQL 调用 `CREATE TABLE` 或者 `INSERT INTO` 等操作从 MySQL 数据源读取或写入数据时,可以使用 `WITH` 子句来指定连接的 `tableEnvironment.connect()` 函数的 `JdbcConnectionOptions`。在这个选项中,你可以设置 `serverTimezone` 属性来明确指定 MySQL 服务器的时间区,例如:
```sql
CREATE TABLE my_table (
...
)
WITH (
'connector' = 'jdbc',
'url' = '<mysql_url>',
'username' = '<username>',
'password' = '<password>',
'driver' = 'com.mysql.jdbc.Driver', -- 如果需要的话
'serverTimezone' = 'UTC' -- 设置为与你的配置相匹配的时区
);
```
确保将 `<mysql_url>`、`<username>` 和 `<password>` 替换为实际值,并根据MySQL服务器的实际时间区调整 `'serverTimezone'`。
阅读全文