Re: flink 读写hive问题

2020-05-26 Thread Enzo wang
Hi Wldd, 谢谢回复。 1. datanode 是可用的 ❯ docker-compose exec namenode hadoop fs -ls /tmp Found 1 items drwx-wx-wx - root supergroup 0 2020-05-26 05:40 /tmp/hive namenode 的webui 也可以看到: [image: image.png] 2. 设置set execution.type=batch; 以后,执行报错,错误如下 Caused by: org.apache.hadoop.ipc.RemoteEx

Re: Re: flink 读写hive问题

2020-05-26 Thread Enzo wang
Hi Wldd, Hive 是可以访问的,我把之前的2个gist内容贴在这个邮件里,你看一下,里面有hive查询数据的返回结果。 还需要什么信息我再提供。 flink insert into hive error org.apache.flink.table.api.TableException: Exception in close at org.apache.flink.table.filesystem.FileSystemOutputFormat.close(FileSystemOutputFormat.java:13

Re:Re: Re: flink 读写hive问题

2020-05-26 Thread wldd
hive写数据测了么,按照你提供的异常信息,显示的是hdfs的问题 -- Best, wldd 在 2020-05-26 17:49:56,"Enzo wang" 写道: >Hi Wldd, > >Hive 是可以访问的,我把之前的2个gist内容贴在这个邮件里,你看一下,里面有hive查询数据的返回结果。 > >还需要什么信息我再提供。 > > > > flink insert into hive error > >org.apache.flink.table.api.TableException: Exception

Re: Re: Re: flink 读写hive问题

2020-05-26 Thread Enzo wang
Hi Wldd, Hive 写测试了,没问题。 0: jdbc:hive2://localhost:1> select count(*) from pokes; WARNING: Hive-on-MR is deprecated in Hive 2 and may not be available in the future versions. Consider using a different execution engine (i.e. spark, tez) or using Hive 1.X releases. +--+ | _c0 | +--+ |