Re: flink 1.10 createTemporaryTable丢失proctime问题
真是谢谢你。翻了下源码发现不太对劲，下次我先搜搜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 wrote: > 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”); > > > 修改后 > tEnv.connect().withFormat().withSchema( > xxx.proctime() > ).createTemporaryTable(“foo”); > > > 修改后.proctime()就失效了，所以我proctime window也用不了了。 > > > 原始邮件 > 发件人: deadwind4 > 收件人: user-zh > 发送时间: 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 > 收件人: user-zh > 发送时间: 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 > 写道： > > 我其实是想用processing time window 但是我把过期的API > registerTableSource换成createTemporaryTable，proctime就不起作用了。这种情况我应该如何使用呢？谢谢您，叨扰了。 > > > > 原始邮件 > 发件人: Jark Wu > 收件人: 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 < > deadwi...@outlook.com> wrote: > > > 我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。 > > 如果我想使用createTemporaryTable该怎么办。 > > 并且我debug了createTemporaryTable的源码没有发现对proctime的处理。
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 wrote: > 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”); > > > 修改后 > tEnv.connect().withFormat().withSchema( > xxx.proctime() > ).createTemporaryTable(“foo”); > > > 修改后.proctime()就失效了，所以我proctime window也用不了了。 > > > 原始邮件 > 发件人: deadwind4 > 收件人: user-zh > 发送时间: 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 > 收件人: user-zh > 发送时间: 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 > 写道： > > 我其实是想用processing time window 但是我把过期的API > registerTableSource换成createTemporaryTable，proctime就不起作用了。这种情况我应该如何使用呢？谢谢您，叨扰了。 > > > > 原始邮件 > 发件人: Jark Wu > 收件人: 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 < > deadwi...@outlook.com> wrote: > > > 我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。 > > 如果我想使用createTemporaryTable该怎么办。 > > 并且我debug了createTemporaryTable的源码没有发现对proctime的处理。
Re: flink 1.10 createTemporaryTable丢失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”); 修改后 tEnv.connect().withFormat().withSchema( xxx.proctime() ).createTemporaryTable(“foo”); 修改后.proctime()就失效了，所以我proctime window也用不了了。 原始邮件 发件人: deadwind4 收件人: user-zh 发送时间: 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 收件人: user-zh 发送时间: 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 写道： > > 我其实是想用processing time window 但是我把过期的API registerTableSource换成createTemporaryTable，proctime就不起作用了。这种情况我应该如何使用呢？谢谢您，叨扰了。 > > > 原始邮件 > 发件人: Jark Wu > 收件人: user-zh > 发送时间: 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 wrote: > > 我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。 > 如果我想使用createTemporaryTable该怎么办。 > 并且我debug了createTemporaryTable的源码没有发现对proctime的处理。
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 收件人: user-zh 发送时间: 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 收件人: user-zh 发送时间: 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 写道： > > 我其实是想用processing time window 但是我把过期的API registerTableSource换成createTemporaryTable，proctime就不起作用了。这种情况我应该如何使用呢？谢谢您，叨扰了。 > > > 原始邮件 > 发件人: Jark Wu > 收件人: user-zh > 发送时间: 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 wrote: > > 我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。 > 如果我想使用createTemporaryTable该怎么办。 > 并且我debug了createTemporaryTable的源码没有发现对proctime的处理。
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 上没有 createTemporaryTable 方法，只有createTemporaryView方法，而且 registerTableSource 和 createTemporaryView 的参数是不一样的。 Best, Jark > 2020年4月1日 23:13，deadwind4 写道： > > 我其实是想用processing time window 但是我把过期的API registerTableSource换成createTemporaryTable，proctime就不起作用了。这种情况我应该如何使用呢？谢谢您，叨扰了。 > > > 原始邮件 > 发件人: Jark Wu > 收件人: user-zh > 发送时间: 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 wrote: > > 我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。 > 如果我想使用createTemporaryTable该怎么办。 > 并且我debug了createTemporaryTable的源码没有发现对proctime的处理。
Re: flink 1.10 createTemporaryTable丢失proctime问题
Hi, 你能描述下你的改动前后的代码吗？据我所知 TableEnvironment 上没有 createTemporaryTable 方法，只有createTemporaryView方法，而且 registerTableSource 和 createTemporaryView 的参数是不一样的。 Best, Jark > 2020年4月1日 23:13，deadwind4 写道： > > 我其实是想用processing time window 但是我把过期的API > registerTableSource换成createTemporaryTable，proctime就不起作用了。这种情况我应该如何使用呢？谢谢您，叨扰了。 > > > 原始邮件 > 发件人: Jark Wu > 收件人: user-zh > 发送时间: 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 > wrote: > > > 我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。 > > 如果我想使用createTemporaryTable该怎么办。 > > 并且我debug了createTemporaryTable的源码没有发现对proctime的处理。
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 wrote: > > 我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。 > 如果我想使用createTemporaryTable该怎么办。 > 并且我debug了createTemporaryTable的源码没有发现对proctime的处理。
flink 1.10 createTemporaryTable丢失proctime问题
我使用1.10版本的createTemporaryTable发现proctime字段全是null但是换成过时的registerTableSource就可以。 如果我想使用createTemporaryTable该怎么办。 并且我debug了createTemporaryTable的源码没有发现对proctime的处理。
