Re: 关于无法被看作POJO的类型,怎么转变可以让其不当作GenericType呢?

2021-03-31 Thread Lin Hou
你好,请问一下,这个问题是怎么解决的啊? 赵一旦 于2021年2月3日周三 下午1:59写道: > 我看Flink的要求是public,每个属性要么public,要么有getter/setter。估计内嵌的属性也会递归检查的。 > > ℡小新的蜡笔不见嘞、 <1515827...@qq.com> 于2021年2月3日周三 下午1:52写道: > > > 你好,我们是否可以通过对该类LinkedHashMap进行包装来实现当前功能呢?如果你需要PojoSerializer来序列化数据的话。 > > > > > > > > > >

flink sql多层view嵌套,字段not found

2020-09-03 Thread Lin Hou
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)

Re: Flink SQL 问题;

2020-08-27 Thread Lin Hou
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' >