flink zeppelin的type参数(append/update/single)和flink的动态表有关系嘛

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

flink zeppelin的type参数(append/update/single)和flink的动态表有关系嘛

nobleyd
如题,这个参数是仅仅zeppelin自身的参数,用于决定如何展示数据之类的逻辑呢?
还是和flink任务也有关系。按照https://www.yuque.com/jeffzhangjianfeng/gldg8w/te2l1c#AzSOu
说法,append模式第一个结果列必须是时间,所以看起来更像是zeppelin自身的要求。

我看了下append方式执行,jdbc仍然使用的upsertSink。

所以谁确认下这个参数是不是和具体任务没啥关系。
Reply | Threaded
Open this post in threaded view
|

Re: flink zeppelin的type参数(append/update/single)和flink的动态表有关系嘛

Jeff Zhang
和 flink 没关系,是zeppelin自己定义的参数,只影响select 语句,对于zeppelin的数据可视化有影响,不影响flink job

赵一旦 <[hidden email]> 于2020年11月23日周一 下午1:11写道:

> 如题,这个参数是仅仅zeppelin自身的参数,用于决定如何展示数据之类的逻辑呢?
> 还是和flink任务也有关系。按照
> https://www.yuque.com/jeffzhangjianfeng/gldg8w/te2l1c#AzSOu
> 说法,append模式第一个结果列必须是时间,所以看起来更像是zeppelin自身的要求。
>
> 我看了下append方式执行,jdbc仍然使用的upsertSink。
>
> 所以谁确认下这个参数是不是和具体任务没啥关系。
>


--
Best Regards

Jeff Zhang