search

childe / gohangout

使用 golang 模仿的 Logstash。用于消费 Kafka 数据，处理后写入 ES、Clickhouse 等。
MIT License
1.01k stars 234 forks source link

CK 里面设置的 default 失效 #159

Closed childe closed 2 years ago

childe commented 2 years ago

dea7f179043c625c53fc953c1e39971ce7e70247 版本问题

一些字段，比如说 Datetime 类型的字段，在 CK 里面配置了 default 是 now。 但是 Gohangout 里面总是使用 UnixTimestamp(0) 覆盖了这个值。

原因： CK 初始化的时候会从 describe table 拿到所有 fields，然后给他们设置了一个 default 值。insert 的时候使用这个 Gohangout 里面设置的 default 值写入，就导致了覆盖正确的 default 值。

childe commented 2 years ago

先允许用户自己配置 fields。 一些字段不要 insert from gohangout.