你好,请问一下,这个问题是怎么解决的啊?
赵一旦 于2021年2月3日周三 下午1:59写道:
> 我看Flink的要求是public,每个属性要么public,要么有getter/setter。估计内嵌的属性也会递归检查的。
>
> ℡小新的蜡笔不见嘞、 <1515827...@qq.com> 于2021年2月3日周三 下午1:52写道:
>
> > 你好,我们是否可以通过对该类LinkedHashMap进行包装来实现当前功能呢?如果你需要PojoSerializer来序列化数据的话。
> >
> >
> >
> >
> >
Hi,
请教一个通过sql-client提交flink sql遇到的关于嵌套view,当嵌套第二层时,查询时会报找不到字段的问题。
元数据已经建好,简述如下:
1.建嵌套的view:
create temporary view temp_app_impression_5min as
select
argService as arg_service,
timeLocal as time_local,
mid as mid,
vipruid as vipruid,
activity as activity,
LOWER(activityProperty)
jdbc connector jar没有导入线上集群,去官网上下载或者自己编译吧
air23 于2020年8月27日周四 下午3:11写道:
> 你好 我用idea本地运行的jdbc sink没有问题。但是在服务器上运行报错如下
>
>
> 麻烦帮忙看下什么问题 是1.11 版本的
>
>
> 'connector'='jdbc'
> 'password'=''
> 'sink.buffer-flush.interval'='10s'
> 'sink.buffer-flush.max-rows'='500'
> 'table-name'='flink_test3'
>