好的 谢谢
| |
jimandlice
|
|
邮箱:jimandl...@163.com
|
Signature is customized by Netease Mail Master
在2020年05月21日 19:42,Jingsong Li 写道:
1.11还没发布,文档还在编写中
Best,
Jingsong Lee
On Thu, May 21, 2020 at 7:33 PM jimandlice wrote:
> 1.11的话 能提供一个demo么
>
>
>
>
> | |
> jimandlice
> |
> |
>
1.11的话 能提供一个demo么
| |
jimandlice
|
|
邮箱:jimandl...@163.com
|
Signature is customized by Netease Mail Master
在2020年05月21日 19:31,Jingsong Li 写道:
> 写入之后 还需要用脚本倒数据入hive么
- 用Datastream来写,需要
- 1.11的Table层来写,配置下就自动add partition到hive metastore了
Best,
Jingsong Lee
On Thu, May 21, 2020 at 7:11 PM
写入之后 还需要用脚本倒数据入hive么
| |
jimandlice
|
|
邮箱:jimandl...@163.com
|
Signature is customized by Netease Mail Master
在2020年05月21日 15:02,Jingsong Li 写道:
看起来是因为你客户端和Server端的依赖不一致导致的问题,你检查下客户端的jars?
Best,
Jingsong Lee
On Thu, May 21, 2020 at 2:57 PM 阿华田 wrote:
> public static void main(String[]
public static void main(String[] args) throws Exception {
//初始化任务参数
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
Job job = Job.getInstance();
//自定义input读取hdfs
HadoopInputFormat hadoopIF = new
HadoopInputFormat(
new TextInputFormat(), LongWritable.class, Text.class,
flink 写入hive 使用api 思路是怎么的呢
| |
jimandlice
|
|
邮箱:jimandl...@163.com
|
Signature is customized by Netease Mail Master
在2020年05月21日 10:57,阿华田 写道:
flink如何支持正则读取一个目录下的文件,比如读取文件名(时间格式命名)满足一定时间范围的文件
| |
王志华
|
|
a15733178...@163.com
|
签名由网易邮箱大师定制