DataStream API 中使用 .serverTimeZone("Asia/Shanghai")不生效，扔然早了八小时 about flink-cdc HOT 10 CLOSED

配置serverTimeZone的作用有两个：

1. 对debezium而言，它会先从mysql端获取默认的时区，如果没有则使用 配置的database.serverTimezone.
2. 对flink-cdc而言，会用指定的serverTimeZone来转换timestamp的时间(但只对 sql 有效)

所以目前暂时DataStreaApi只满足了第一个，还需要自己参照 RowDataDebeziumDeserializeSchema的实现，把UTC时间转换成指定的serverTimeZone的时间

from flink-cdc.

你的 mysql的time_zone是什么？在mysql客户端上看下： show variable like '%zone%', 我的是 system_time_zone是CST， time_zone是SYSTEM。 然后mysql的字段是timestamp类型，启动cdc时，开始的snapshot没问题，更新后就会有时差，但是加上serverTimeZone为 “Asia/Shanghai”就没有问题。

from flink-cdc.

dbz默认都会把timestamp类型字段转换成UTC，如果需要转到指定时区，需要参考实现CustomConverter接口，对timestamp类型字段做处理，参考 #28

from flink-cdc.

你的 mysql的time_zone是什么？在mysql客户端上看下： show variable like '%zone%', 我的是 system_time_zone是CST， time_zone是SYSTEM。 然后mysql的字段是timestamp类型，启动cdc时，开始的snapshot没问题，更新后就会有时差，但是加上serverTimeZone为 “Asia/Shanghai”就没有问题。

我的mysql中的 system_time_zone也是CST， time_zone也是SYSTEM。加上.serverTimeZone("Asia/Shanghai")后，cdc启动后凡是字段是timestamp类型的都有时差

from flink-cdc.

dbz默认都会把timestamp类型字段转换成UTC，如果需要转到指定时区，需要参考实现CustomConverter接口，对timestamp类型字段做处理，参考 #28

需要自己写debezium的Converter是么？我直接使用debezium的时候是通过写converter实现时间转换的。

from flink-cdc.

dbz默认都会把timestamp类型字段转换成UTC，如果需要转到指定时区，需要参考实现CustomConverter接口，对timestamp类型字段做处理，参考 #28

的确是这样没错，但是我看了代码，servertimezone的配置就是启到了这个作用，把UTC的时间转换成指定的timezone的时间，所以，实现converter的方法和加server-time-zone的方法其实是一样的。

from flink-cdc.

你的 mysql的time_zone是什么？在mysql客户端上看下： show variable like '%zone%', 我的是 system_time_zone是CST， time_zone是SYSTEM。 然后mysql的字段是timestamp类型，启动cdc时，开始的snapshot没问题，更新后就会有时差，但是加上serverTimeZone为 “Asia/Shanghai”就没有问题。

我的mysql中的 system_time_zone也是CST， time_zone也是SYSTEM。加上.serverTimeZone("Asia/Shanghai")后，cdc启动后凡是字段是timestamp类型的都有时差

你用的是stream api， 你看下你是不是用了 RowDataDebeziumDeserializeSchema这个deserialize，这个sql是默认的，如果是stream api的话，要自己实现。类似下面：
SourceFunction<String> sourceFunction = MySQLSource.<String>builder() .hostname("localhost") .port(3306) .databaseList("inventory") // monitor all tables under inventory database .username("flinkuser") .password("flinkpw") .deserializer(new CoustomDebeziumDeserializationSchema()) // converts SourceRecord to String .build();

from flink-cdc.

配置serverTimeZone的作用有两个：

1. 对debezium而言，它会先从mysql端获取默认的时区，如果没有则使用 配置的database.serverTimezone.
2. 对flink-cdc而言，会用指定的serverTimeZone来转换timestamp的时间(但只对 sql 有效)

所以目前暂时DataStreaApi只满足了第一个，还需要自己参照 RowDataDebeziumDeserializeSchema的实现，把UTC时间转换成指定的serverTimeZone的时间

原来需要自己去自定义序列化后的结果去解决时区问题是么？

from flink-cdc.

你的 mysql的time_zone是什么？在mysql客户端上看下： show variable like '%zone%', 我的是 system_time_zone是CST， time_zone是SYSTEM。 然后mysql的字段是timestamp类型，启动cdc时，开始的snapshot没问题，更新后就会有时差，但是加上serverTimeZone为 “Asia/Shanghai”就没有问题。

我的mysql中的 system_time_zone也是CST， time_zone也是SYSTEM。加上.serverTimeZone("Asia/Shanghai")后，cdc启动后凡是字段是timestamp类型的都有时差

你用的是stream api， 你看下你是不是用了 RowDataDebeziumDeserializeSchema这个deserialize，这个sql是默认的，如果是stream api的话，要自己实现。类似下面：
SourceFunction<String> sourceFunction = MySQLSource.<String>builder() .hostname("localhost") .port(3306) .databaseList("inventory") // monitor all tables under inventory database .username("flinkuser") .password("flinkpw") .deserializer(new CoustomDebeziumDeserializationSchema()) // converts SourceRecord to String .build();

我用的是StringDebeziumDeserializationSchema，没找到使用RowDataDebeziumDeserializeSchema的demo

from flink-cdc.

配置serverTimeZone的作用有两个：

1. 对debezium而言，它会先从mysql端获取默认的时区，如果没有则使用 配置的database.serverTimezone.
2. 对flink-cdc而言，会用指定的serverTimeZone来转换timestamp的时间(但只对 sql 有效)

所以目前暂时DataStreaApi只满足了第一个，还需要自己参照 RowDataDebeziumDeserializeSchema的实现，把UTC时间转换成指定的serverTimeZone的时间

原来需要自己去自定义序列化后的结果去解决时区问题是么？

如果用DataStream API，的确是要自己去实现deserialize

from flink-cdc.