ilto:user-zh@flink.apache.org
gt;
主题: 回复：flink-1.11 ddl kafka-to-hive问题
hi
hive表是一直没有数据还是过一段时间就有数据了？
| |
JasonLee
|
|
邮箱：17610775...@163.com
|
Signature is customized by Netease Mail Master
在2020年07月21日 19:09，kcz 写道：
hive-1.2.1
chk 已经成功了（去chk目录查看了的确有chk数据，kafka也有数据），但是hi
t; >
> > 一直都木有数据 我也不知道哪里不太对 hive有这个表了已经。我测试写ddl hdfs 是OK的
> >
> >
> >
> >
> >
> > -- 原始邮件 --
> > 发件人: JasonLee <17610775...@163.com <mailto:17610775...@163.com>
> > 发送时间: 2020年7月21日 20:39
> > 收件人: user
日 20:39
> 收件人: user-zh mailto:user-zh@flink.apache.org>
> 主题: 回复：flink-1.11 ddl kafka-to-hive问题
>
>
>
> hi
> hive表是一直没有数据还是过一段时间就有数据了？
>
>
> | |
> JasonLee
> |
> |
> 邮箱：17610775...@163.com
> |
>
> Signature is customized by Netease Mail Master
一直都木有数据 我也不知道哪里不太对 hive有这个表了已经。我测试写ddl hdfs 是OK的
-- 原始邮件 --
发件人: JasonLee <17610775...@163.com
发送时间: 2020年7月21日 20:39
收件人: user-zh
rolling 策略配一下？
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/filesystem.html#sink-rolling-policy-rollover-interval
Best,
Jark
On Tue, 21 Jul 2020 at 20:38, JasonLee <17610775...@163.com> wrote:
> hi
> hive表是一直没有数据还是过一段时间就有数据了？
>
>
> | |
> JasonLee
> |
> |
>
hi
hive??
| |
JasonLee
|
|
??17610775...@163.com
|
Signature is customized by Netease Mail Master
??2020??07??21?? 19:09??kcz ??
hive-1.2.1
chk
??chkchk??kafkahive??
hive-1.2.1
chk
??chkchk??kafkahive??
String hiveSql = "CREATE TABLE stream_tmp.fs_table (\n" +
" host STRING,\n" +
" url STRING," +
" public_date STRING" +
") partitioned by
