Re:Re: IllegalArgumentException when using elasticsearch as a sink

2017-08-15 Thread mingleizhang
A PB object is an object that is build from Protobuf. It belongs to google's data interchange format. You can get more from https://github.com/google/protobuf At 2017-08-15 13:42:58, "Hai Zhou" wrote: I would like to ask what is “PB object”? Thanks. Hai Zhou 在 2017年8月15日,09:53,minglei

Re: IllegalArgumentException when using elasticsearch as a sink

2017-08-14 Thread Hai Zhou
I would like to ask what is “PB object”? Thanks. Hai Zhou > 在 2017年8月15日,09:53,mingleizhang <18717838...@163.com> 写道: > > Thanks, Nico. I tried flink1.3.2. Works now. Thank you very much! I think > there should be something else to cause this error to happen. Not only the PR > I patched before

Re:Re: IllegalArgumentException when using elasticsearch as a sink

2017-08-14 Thread mingleizhang
Thanks, Nico. I tried flink1.3.2. Works now. Thank you very much! I think there should be something else to cause this error to happen. Not only the PR I patched before. Thanks. mingleizhang At 2017-08-15 00:29:28, "Nico Kruber" wrote: >Just to be sure, can you try flink 1.3.2 which is

Re: IllegalArgumentException when using elasticsearch as a sink

2017-08-14 Thread Nico Kruber
Just to be sure, can you try flink 1.3.2 which is supposed to fix FLINK-7133 and was released recently? Nico On Monday, 14 August 2017 03:19:06 CEST mingleizhang wrote: > BTW, My elastic search version is 2.3.3, not the jira FLINK-7133 by 1.7.1. > And I found 2.3.3 is not based on asm. My flink

IllegalArgumentException when using elasticsearch as a sink

2017-08-13 Thread mingleizhang
Hello, flink experts and friends! It is my first time to write flink application in my company. But I met the following error when I used a elasticsearch as my sink. I searched the solution for it and found a jira https://issues.apache.org/jira/browse/FLINK-7133 . then, I added the PR to my co