-- Forwarded message -
发件人： yangpengklf007
Date: 2019年11月7日周四 下午3:00
Subject: 广播状态是否可以设置ttl过期时间
To: user-zh@flink.apache.org
如下图是我设置得测试代码：在类中定义一个mapstatedesc，然后在processBroadcastElement方法中获取广播数据放入到state中
设置ttl是1s然后让程序sleep10s
可以试试1.9，引入了DataView的机制，可以在Acc中使用state了。
On Thu, 7 Nov 2019 at 09:22, Chennet Steven wrote:
> 尝试在Flink的自定义聚合函数中使用State，发现open函数中通过FunctionContext无法获取到RuntimeContext
> 如何在聚合函数中使用State?
>
>
> import org.apache.flink.api.common.typeinfo.{BasicTypeInfo,
> TypeInformation}
> import
尝试在Flink的自定义聚合函数中使用State，发现open函数中通过FunctionContext无法获取到RuntimeContext
如何在聚合函数中使用State?
import org.apache.flink.api.common.typeinfo.{BasicTypeInfo, TypeInformation}
import org.apache.flink.api.java.tuple.{Tuple2 => JTuple2}
import org.apache.flink.api.java.typeutils.TupleTypeInfo
import
当我用flink-connector-elasticsearch6_2.11的1.9.0版本，将数据写入elaticsearch的时候，遇到了
ConcurrentModificationException
.
我的错误是这么处理的，每当失败的时候，就加入到失败列表里，等着重试
//每当bluk异步响应回来的时候，都会检查这次发送出去的有没有成功，未成功的就会调用下面的方法
public class ElasticSearchRequestFailureHandler implements
ActionRequestFailureHandler {
@Override
针对于使用 SQL查询，select current_timestamp,creaetTime from sourceTable ;其中 createTime
注册成 SQL_TIMESTMAP 类型
问题描述：
无论是流中的原有数据 createTime,还是 current_time 函数
打印的结果都出现格式的问题
2019-11-06T11:01:24.047,2019-11-06T18:53:54
请问：
如何避免格式中 T 的出现
针对于上封邮件进行补充:
做了类型检测：flink 1.9.1 对于执行完SQL之后的类型，date 使用
针对于使用 SQL查询，select current_timestamp,creaetTime from sourceTable ;其中 createTime
注册成 SQL_TIMESTMAP 类型
问题描述：
无论是流中的原有数据 createTime,还是 current_time 函数
打印的结果都出现格式的问题
2019-11-06T11:01:24.047,2019-11-06T18:53:54
请问：
如何避免格式中 T 的出现
