flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kurt Young <ykt...@gmail.com>
Subject Re: flink 1.10 createTemporaryTable丢失proctime问题
Date Thu, 02 Apr 2020 09:18:03 GMT
看起来你是踩到了这个bug:https://issues.apache.org/jira/browse/FLINK-16160
在这个bug修复前,先继续用老的API吧

Best,
Kurt


On Thu, Apr 2, 2020 at 10:34 AM deadwind4 <deadwind4@outlook.com> wrote:

> registerTableSource 被标记了@Deprecated 在flink
> 1.10,我这种情况是继续沿用过期的API(registerTableSource)吗?
>
>
>  原始邮件
> 发件人: deadwind4<deadwind4@outlook.com>
> 收件人: user-zh<user-zh@flink.apache.org>
> 发送时间: 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()
> ).createTemporaryTable(“foo”);
>
>
> 修改后.proctime()就失效了,所以我proctime window也用不了了。
>
>
>  原始邮件
> 发件人: deadwind4<deadwind4@outlook.com>
> 收件人: user-zh<user-zh@flink.apache.org>
> 发送时间: 2020年4月2日(周四) 10:22
> 主题: Re: flink 1.10 createTemporaryTable丢失proctime问题
>
>
> tEnv.connect().withFormat().withSchema().registerTableSource(“foo”);
> tEnv.connect().withFormat().withSchema().createTemporaryTable(“foo”);
>
>
>  原始邮件
> 发件人: Jark Wu<imjark@gmail.com>
> 收件人: user-zh<user-zh@flink.apache.org>
> 发送时间: 2020年4月2日(周四) 10:18
> 主题: Re: flink 1.10 createTemporaryTable丢失proctime问题
>
>
> Hi, 你能描述下你的改动前后的代码吗?据我所知 TableEnvironment 上没有
createTemporaryTable
> 方法,只有createTemporaryView方法,而且 registerTableSource 和 createTemporaryView
> 的参数是不一样的。 Best, Jark > 2020年4月1日 23:13,deadwind4 <deadwind4@outlook.com>
> 写道: > > 我其实是想用processing time window 但是我把过期的API
> registerTableSource换成createTemporaryTable,proctime就不起作用了。这种情况我应该如何使用呢?谢谢您,叨扰了。
> > > > 原始邮件 > 发件人: Jark Wu<imjark@gmail.com> > 收件人:
user-zh<
> user-zh@flink.apache.org> > 发送时间: 2020年4月1日(周三) 21:37 >
主题: Re: flink
> 1.10 createTemporaryTable丢失proctime问题 > > > Hi, proctime 的含义是机器时间,不等价于
> now()或者 current_timestamp() 函数,该字段只有在真正使用的才会物化(即去取
> System.currentTimeMillis)。 能请描述下你想用 createTemporaryTable
> 做什么呢?当前哪里不能满足你的需求呢? Best, Jark On Wed, 1 Apr 2020
at 18:56, deadwind4 <
> deadwind4@outlook.com> wrote: > >
> 我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。
> > 如果我想使用createTemporaryTable该怎么办。 >
> 并且我debug了createTemporaryTable的源码没有发现对proctime的处理。
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message