真是谢谢你。翻了下源码发现不太对劲,下次我先搜搜Issue再提问。感谢。
原始邮件
发件人: Kurt Young
收件人: user-zh
发送时间: 2020年4月2日(周四) 17:18
主题: Re: flink 1.10 createTemporaryTable丢失proctime问题
看起来你是踩到了这个bug:https://issues.apache.org/jira/browse/FLINK-16160
在这个bug修复前,先继续用老的API吧 Best, Kurt On Thu, Apr 2, 2020 at 10:34 AM deadwind4
user-zh
> 发送时间: 2020年4月2日(周四) 10:30
> 主题: Re: flink 1.10 createTemporaryTable丢失proctime问题
>
>
> 修改前
> tEnv.connect().withFormat().withSchema(
> xxx.proctime()
> ).registerTableSource(“foo”);
>
>
> 修改后
> tEnv.connect().withFormat().withSchema(
> xxx.proctime()
registerTableSource 被标记了@Deprecated 在flink
1.10,我这种情况是继续沿用过期的API(registerTableSource)吗?
原始邮件
发件人: deadwind4
收件人: user-zh
发送时间: 2020年4月2日(周四) 10:30
主题: Re: flink 1.10 createTemporaryTable丢失proctime问题
修改前
tEnv.connect().withFormat().withSchema(
xxx.proctime()
).registerTableSource(“foo
: flink 1.10 createTemporaryTable丢失proctime问题
tEnv.connect().withFormat().withSchema().registerTableSource(“foo”);
tEnv.connect().withFormat().withSchema().createTemporaryTable(“foo”);
原始邮件
发件人: Jark Wu
收件人: user-zh
发送时间: 2020年4月2日(周四) 10:18
主题: Re: flink 1.10 createTemporaryTable丢失proctime问题
tEnv.connect().withFormat().withSchema().registerTableSource(“foo”);
tEnv.connect().withFormat().withSchema().createTemporaryTable(“foo”);
原始邮件
发件人: Jark Wu
收件人: user-zh
发送时间: 2020年4月2日(周四) 10:18
主题: Re: flink 1.10 createTemporaryTable丢失proctime问题
Hi, 你能描述下你的改动前后的代码吗?据我所知 TableEnvironment 上没
le,proctime就不起作用了。这种情况我应该如何使用呢?谢谢您,叨扰了。
>
>
> 原始邮件
> 发件人: Jark Wu
> 收件人: user-zh
> 发送时间: 2020年4月1日(周三) 21:37
> 主题: Re: flink 1.10 createTemporaryTable丢失proctime问题
>
>
> Hi, proctime 的含义是机器时间,不等价于 now()或者 current_timestamp() 函数,该字段只有在真正使用的才会物化(即去取
> System.curr
Hi,
proctime 的含义是机器时间,不等价于 now()或者 current_timestamp() 函数,该字段只有在真正使用的才会物化(即去取
System.currentTimeMillis)。
能请描述下你想用 createTemporaryTable 做什么呢?当前哪里不能满足你的需求呢?
Best,
Jark
On Wed, 1 Apr 2020 at 18:56, deadwind4 wrote:
>
>
我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。
如果我想使用createTemporaryTable该怎么办。
并且我debug了createTemporaryTable的源码没有发现对proctime的处理。