?????? blinkSQL????????????????????state??

    tableEnv.registerDataStream("testCountTable", waterMarkStream, 'curuserid,'timelong,'rowtime.rowtime)          val result = tableEnv.sqlQuery(s"SELECT COUNT(0) as pv,COUNT(distinct curuserid)" +       s" as uv,TUMBLE_END(rowtime, INTERVAL '10' MINUTE) FR

Re: blinkSQL架构会自动清理过期的state吗

Hi， 能提供下 SQL 么？ blink sql 的 window 理论上是会自动清理的。 > 在 2019年9月11日，18:56，守护 <346531...@qq.com> 写道： > > 社区各位大佬： > 请教一个问题，flink1.9中使用blink > SQL语句，设置时间窗口，state存储方式选择FSStateBackend，现在发现State一直在增大，过了窗口后也没有删除过期state，是blink架构就不支持窗口自动清理state吗，还是我哪使用的不对，我测试1.9的flinkSQL是不会有这个问题的。

Re: Flink 写ES ConcurrentModificationException 异常

不是代码的问题，代码里边没有遍历List时进行了remove。看报错是从org.apache.flink.streaming.connectors.elasticsearch.BufferingNoOpRequestIndexer类里报出来的。 BufferingNoOpRequestIndexer 类不是线程安全的。 wang jinhai 于2019年9月10日周二 下午4:36写道： > 这不是flink问题吧。你代码遍历List时进行了remove操作，导致这个问题。解决方案是iterator遍历，并iterator.remove即可 > > 在 2019/9/10 下午4:

答复: flink sql中怎么表达窗口的提前触发或延迟触发

感谢大佬解答，对于处理窗口迟到数据的话是不是可以通过setIdleStateRetentionTime方法来设置？ 发送自 Windows 10 版邮件应用 发件人: Benchao Li 发送时间: Wednesday, September 11, 2019 6:38:44 PM 收件人: user-zh@flink.apache.org 主题: Re: flink sql中怎么表达窗口的提前触发或延迟触发 目前

blinkSQL????????????????????state??

?? ??flink1.9??blink SQLstateFSStateBackend??Statestateblinkstate??1.9??flinkSQL

Re: flink sql中怎么表达窗口的提前触发或延迟触发

目前社区的1.9版本的blink-planner在parser层面还不支持，可以通过全局config来配置： table.exec.emit.early-fire.enabled table.exec.emit.early-fire.delay 可以尝试一下。 苏 欣 于2019年9月11日周三 上午11:45写道： > Blink文档中有介绍到EMIT Strategy，可以用WITH DELAY '1' MINUTE BEFORE WATERMARK或者EMIT > WITHOUT DELAY AFTER WATERMARK等类似的语法来控制窗口触发。 > 但是我使用这种语法作业

回复: 编译flink 1.9 flink-table-api-java 编译不过

非常感谢，jdk 升到 1.8.0_111 解决了 -邮件原件- 发件人: user-zh-return-1139-wxchunjhyy=163@flink.apache.org 代表 Zili Chen 发送时间: Wednesday, September 11, 2019 10:35 AM 收件人: user-zh 主题: Re: 编译flink 1.9 flink-table-api-java 编译不过 看起来是一个 JDK 的 bug https://stackoverflow.com/questions/25523375/java8-lambd