JennyChen
JennyChen
Thanks! @Leomrlin My rough idea is to add some options for kafka source. 1."geaflow.dsl.kafka.format". It can be configured as text or json. If it's configured as "json", kafka message will...
Thanks @Leomrlin! As you said, there may be numerous parameters to further define the deserialization configuration. So my idea is the configuration for json format itself could be a more...
试一下用最新的master分支跑一遍？ 如果还是不行，发一下`SELECT engine_full FROM system.tables WHERE database = ? AND name = ?`的输出结果
@liming30 could you help review this pr?
> The error message may be more clear, e.g. "The not_exist aggregation function is not existing" Or "We can't find function 'not_exist' in current class path. @leaves12138 The full stack...
> [@qingfei1994](https://github.com/qingfei1994) hi, I think that there is no need to validate the existence of `aggregate-functions` during the DDL stage because paimon already support `user-defined aggregate-functions`. > > In our...
> I agree that `user-defined aggregate-functions` should be validated in advance, rather than during the actual write stage. Perhaps we could add this validation when creating the `Source / Sink`,...
@melin I'm willing to work on this, could you provide more detail?