You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by deadwind4 <de...@outlook.com> on 2020/04/01 10:56:25 UTC

flink 1.10 createTemporaryTable丢失proctime问题

我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。
如果我想使用createTemporaryTable该怎么办。
并且我debug了createTemporaryTable的源码没有发现对proctime的处理。

Re: flink 1.10 createTemporaryTable丢失proctime问题

Posted by Jark Wu <im...@gmail.com>.

Hi,

proctime 的含义是机器时间，不等价于 now()或者 current_timestamp() 函数，该字段只有在真正使用的才会物化（即去取
System.currentTimeMillis）。

能请描述下你想用 createTemporaryTable 做什么呢？当前哪里不能满足你的需求呢？

Best,
Jark

On Wed, 1 Apr 2020 at 18:56, deadwind4 <de...@outlook.com> wrote:

>
> 我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。
> 如果我想使用createTemporaryTable该怎么办。
> 并且我debug了createTemporaryTable的源码没有发现对proctime的处理。