://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/jdbc.html#lookup-cache
希望对你有帮助
在 2021-04-19 18:54:38,"anonnius" 写道:
>hi: 今天又试了下, 我这边出现问题是因为: join时使用的问题 照成的
>
>应该使用这种语法
>-- temporal join the JDBC table as a d
/projects/flink/flink-docs-release-1.11/dev/table/connectors/jdbc.html#lookup-cache
希望对你有帮助
在 2021-04-14 16:47:04,"anonnius" 写道:
>+1, 目前也遇到了
>在 2021-01-21 17:52:06,"刘海" 写道:
>>HI!
>>这边做测试时遇到一个问题:
>>在流应用中使用了一个mysql jdbc的source作为维表,为了优化处理效率使用了Lookup Ca
+1, 目前也遇到了
在 2021-01-21 17:52:06,"刘海" 写道:
>HI!
>这边做测试时遇到一个问题:
>在流应用中使用了一个mysql jdbc的source作为维表,为了优化处理效率使用了Lookup Cache,下面是注册的表:
>bsTableEnv.executeSql("CREATE TABLE tm_dealers (dealer_code STRING,is_valid
>DECIMAL(10,0),proctime AS PROCTIME(),PRIMARY KEY (dealer_code) NOT ENFORCED\n"
>+
>")
gt;Ball's Holy <873925...@qq.com> 于2021年1月13日周三 上午9:42写道:
>
>> hi张锴,
>> 如果我没记错的话,默认时间间隔是200毫秒,具体设置细节可以看flink.api.common.ExecutionConfig
>> 对应的属性autoWatermarkInterval
>>
>>
>>
>>
>> --原始邮件--
>> 发件人: &q
可以看一下 ExecutionConfig这个类
在 2021-01-12 17:55:47,"张锴" 写道:
>hi,我使用的flink版本是1.10,我想问一下watermark的默认时间间隔是多少,以及所对应的源码位置在哪里,我并没有找到。
select count(nullif(if(name not like '南京%', '其他', '南京'), '其他'))
在 2020-09-27 17:23:07,"zya" 写道:
>你好,链接无法显示,能麻烦再贴下吗
>
>
>--原始邮件--
>发件人:
>
hi:select count(nullif(if(name not like '%',
'', ''), ''))
?? 2020-09-27 17:07:39??"zya" ??
>
>
>
>
>
>----
>??:
>
2
> 2
>2020-09-18T09:18 2020-09-18T09:20 8
> 3
>2020-09-18T09:20 2020-09-18T09:22 2
> 2
>
>
>
>
>发件人: anonnius
>发送时间: 2020-09-18 11:24
>收件人: user-zh
>主题: Fl
hi: [求助] 我这里用flink-sql消费kafka数据, 通过窗口做pvuv的计算, 第一次和第二次计算的结果不一致, 不太了解为什么
0> mac本地环境
1> flink 1.11.1
2> kafka 0.10.2.2, topic为message-json, 分区为3, 副本为1
3> 使用的是sql-client.sh 环境
4> 先在sql-cli中创建了iservVisit表
create table iservVisit (
type string comment '时间类型',
uuid string comment '用户uri',