Re: flink1.11 流式读取hive怎么设置 process_time 和event_time?

2020-08-30 文章 Zou Dan
Event time 是通过 DDL 中 watermark 语句设置的，具体可以参考文档 [1] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/sql/create.html#create-table Best, Dan Zou > 2020年8月30日 下午9:42，me

Re: 1.11版本，关于TableEnvironment.executeSql("insert into ...")，job名称设置的问题

2020-08-23 文章 Zou Dan
据我所知，这种执行方式目前没法设置 jobName > 2020年8月21日 上午11:11，Asahi Lee <978466...@qq.com> 写道： > > 你好！ > 我通过表环境执行insert into语句提交作业，我该如何设置我的job名称呢？ > > > 程序： > EnvironmentSettings bbSettings = > EnvironmentSettings.newInstance().useBlinkPlanner().build(); > TableEnvironment bsTableEnv =

Re: taskmanager引用通用jdbc连接池的问题

2020-08-23 文章 Zou Dan
每个 taskmanager 对应一个独立的 JVM，如果你的实现是一个 JVM 中唯一一个连接池，那么就是 50 * 2 > 2020年8月21日 上午11:09，Bruce 写道： > > M

Re: flink on yarn配置问题

2020-08-23 文章 Zou Dan
Hi, 一旦， root cause 应该是下面这个日志 The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster. 我简单看了一下代码，应该是你们 yarn 节点上没有可用的资源，numYarnMaxVcores = 0 > 2020年8月21日 下午11:11，赵一旦 mailto:hinobl...@gmail.com>> 写道： > > The number

Re: flink 1.11 udtf动态定义返回类型

2020-08-12 文章 Zou Dan
动态定义你指的是说字段的类型和数量都不是固定的吗？这个应该是不行的。你举的 1.10 例子也不是动态的呀 > 2020年8月12日 下午5:32，李强 写道： > > flink 1.11 udtf可以像1.10那样自定义返回类型不我希望可以像flink 1.10这样： > > @Override > public TypeInformation return new RowTypeInfo(Types.STRING, > Types.STRING); > } > > > 不希望像flink 1.11这样 > @FunctionHint(output =