Re: PyFlink 写入ES

[Xingbo Huang]

Hi,

其实报错信息已经说清楚了你用的方式的问题了，这个host方法是需要传入三个参数的，第一个是你的hostname，第二个是你的port，第三个是你使用的protocol。
可以采用下面这种方式试一下
.host("es9223.db.58dns.org", 9223, "http")

Best,
Xingbo

guaishushu1...@163.com  于2020年8月17日周一 下午5:12写道：

> PyFlink 从kafka写入ES 抛这个异常，但是host是正确的有哪位知道吗
> File "main-0-8.py", line 74, in 
> .host("http://es9223.db.58dns.org:9223;)
> TypeError: host() missing 2 required positional arguments: 'port' and
> 'protocol'
>
>
>
>
> guaishushu1...@163.com
>

PyFlink 写入ES

[guaishushu1...@163.com]

PyFlink 从kafka写入ES 抛这个异常，但是host是正确的有哪位知道吗
File "main-0-8.py", line 74, in 
.host("http://es9223.db.58dns.org:9223;)
TypeError: host() missing 2 required positional arguments: 'port' and 'protocol'




guaishushu1...@163.com