Return-Path: <user-return-16721-archive-asf-public=cust-asf.ponee.io@flink.apache.org>
X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io
Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io
Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183])
	by cust-asf2.ponee.io (Postfix) with ESMTP id 94693200D49
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Fri, 24 Nov 2017 13:18:02 +0100 (CET)
Received: by cust-asf.ponee.io (Postfix)
	id 92FE5160BF2; Fri, 24 Nov 2017 12:18:02 +0000 (UTC)
Delivered-To: archive-asf-public@cust-asf.ponee.io
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by cust-asf.ponee.io (Postfix) with SMTP id 64222160BEE
	for <archive-asf-public@cust-asf.ponee.io>; Fri, 24 Nov 2017 13:18:01 +0100 (CET)
Received: (qmail 9744 invoked by uid 500); 24 Nov 2017 12:18:00 -0000
Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flink.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flink.apache.org>
List-Post: <mailto:user@flink.apache.org>
List-Id: <user.flink.apache.org>
Delivered-To: mailing list user@flink.apache.org
Received: (qmail 9729 invoked by uid 99); 24 Nov 2017 12:17:59 -0000
Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 24 Nov 2017 12:17:59 +0000
Received: from localhost (localhost [127.0.0.1])
	by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 12EA7C1C2A
	for <user@flink.apache.org>; Fri, 24 Nov 2017 12:17:59 +0000 (UTC)
X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 2.599
X-Spam-Level: **
X-Spam-Status: No, score=2.599 tagged_above=-999 required=6.31
	tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1,
	HTML_MESSAGE=2, KAM_NUMSUBJECT=0.5, KB_WAM_FROM_NAME_SINGLEWORD=0.2,
	RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001,
	WEIRD_PORT=0.001] autolearn=disabled
Authentication-Results: spamd1-us-west.apache.org (amavisd-new);
	dkim=pass (2048-bit key) header.d=gmail.com
Received: from mx1-lw-us.apache.org ([10.40.0.8])
	by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024)
	with ESMTP id Lak8ZYg-yhZ7 for <user@flink.apache.org>;
	Fri, 24 Nov 2017 12:17:57 +0000 (UTC)
Received: from mail-ua0-f171.google.com (mail-ua0-f171.google.com [209.85.217.171])
	by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 57F1C5FB0B
	for <user@flink.apache.org>; Fri, 24 Nov 2017 12:17:57 +0000 (UTC)
Received: by mail-ua0-f171.google.com with SMTP id 31so9455261uaj.6
        for <user@flink.apache.org>; Fri, 24 Nov 2017 04:17:57 -0800 (PST)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=20161025;
        h=mime-version:in-reply-to:references:from:date:message-id:subject:to
         :cc;
        bh=apMlp5S3daPZCoSSqlcAcpqW+KQZX28pXLqbsr6U8PQ=;
        b=LuHjSG2lQYkeY/mHjER2EUm8E/nvfPsqzy6jwbEJ7Sbn9XDZzvai9s/VqF8ANd/QKs
         s1uM8XJmC5F7Il50efyeX6/NtC6J8wE0WWHh8EnMK6+6lCvm6oaeRjfu/WRL7KSMoBGy
         tKK98lvPp860i25NHsSx9+9uahpiBiizXv1BQpHmhiheQGzu9iEdlilTvr7Gjzen3lbI
         VcISfgZd6ABBEA3xi91MydekKZveefDbw9W5hMIj2SmrQ+yxWDO7g9p9kZbETJ4rNePf
         LOvkh8zXBt4wWH/xgvzZxg869P/ZQUVB1AyxxQNScLW8hm99uzSyd0/gnjpzVn8Z25Z2
         heJw==
X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=1e100.net; s=20161025;
        h=x-gm-message-state:mime-version:in-reply-to:references:from:date
         :message-id:subject:to:cc;
        bh=apMlp5S3daPZCoSSqlcAcpqW+KQZX28pXLqbsr6U8PQ=;
        b=bGQJ1qMZyvW8gRghL5vbGaBZHLsV5yEvqPOhirzLVZhtuC1x4wbv/CilxXjAg4lyxt
         KAnhF+c5fFhbGNo3BcIQCNhuzc9sMsOzp5854oURFTfquS3SDR8l6LpAI3uEBmElFAvL
         I49t+t6UhhBfuCSrR8/LPUd6f4cLI39ah6jwZzgZXlfHZ0wJoKk2MbgpkdYM3pfan6/J
         IFD6zJxRug3RdZzslFfrYo50N19xmjNfAOWYqQldUb2wt3zwuiyUaOce77RzbS5bNHhK
         YGaR0UwkWJKurht1D+3cPrxJ6ecyDoToyvKNzZ5ucX8KRllS5jWggikbhpy0prlHo968
         OKqg==
X-Gm-Message-State: AJaThX5u7k8DVdlhDuqhKszRNwWJtgaeOMw3NFGGhIs8yGIpXYmbWDdV
	wS9xJl95Dyg7JAH6D+C+R3f0Hz1GMKLxDLxKgrc=
X-Google-Smtp-Source: AGs4zMZ75Laaq2sN3Ok0YvoGfA4RZV4utFhg1QxYBhSuTaEOpZQi3sBxCJB+JG9z76mNdfAPo+HhN7HAspJHPXMSrX0=
X-Received: by 10.159.33.161 with SMTP id 30mr5164123uac.48.1511525871159;
 Fri, 24 Nov 2017 04:17:51 -0800 (PST)
MIME-Version: 1.0
Received: by 10.103.106.70 with HTTP; Fri, 24 Nov 2017 04:17:10 -0800 (PST)
In-Reply-To: <2AEE707B-49BD-4394-B15C-FC670D2DC2B4@icloud.com>
References: <F95F5CA5-23B7-43E1-AF6E-C3975F47FF58@icloud.com> <2AEE707B-49BD-4394-B15C-FC670D2DC2B4@icloud.com>
From: Fabian Hueske <fhueske@gmail.com>
Date: Fri, 24 Nov 2017 13:17:10 +0100
Message-ID: <CAAdrtT3MQFoRRvS8fWiLp1RhsxigNy+Zozedz5FjCb=f1hqWUw@mail.gmail.com>
Subject: Re: ElasticSearch 6
To: Fritz Budiyanto <fbudiyan@icloud.com>
Cc: user <user@flink.apache.org>, Aljoscha Krettek <aljoscha@data-artisans.com>
Content-Type: multipart/alternative; boundary="001a1137193e9e8fa4055eb98af2"
archived-at: Fri, 24 Nov 2017 12:18:02 -0000

--001a1137193e9e8fa4055eb98af2
Content-Type: text/plain; charset="UTF-8"

Hi Fritz,

the ElasticSearch connector has not been updated for ES6 yet.
There is a JIRA issue [1] to add support for ES6 and somebody working on it
as it seems.

Best, Fabian

[1] https://issues.apache.org/jira/browse/FLINK-8101

2017-11-18 2:24 GMT+01:00 Fritz Budiyanto <fbudiyan@icloud.com>:

> Hi,
>
> I've tried Flink with ES6, and its causing exception thrown in ES6. Is the
> fix just matter of bumping es client version to 5.6 ?
> Could anyone familiar with ES connector confirm ? If this is just a matter
> of bumping the es client version, can we have this simple change in Flink
> 1.4 ?
>
> Thanks,
> Fritz
>
>
> [2017-11-17T17:06:31,833][WARN ][o.e.t.n.Netty4Transport  ] [a6z4L9y]
> exception caught on transport layer [[id: 0xc77396b0, L:/10.32.0.85:9300
> - R:/10.32.0.82:34814]], closing connection
>                                                      *java.lang.IllegalStateException:
> Received message from unsupported version: [5.0.0] minimal compatible
> version is: [5.6.0]*
>         at org.elasticsearch.transport.TcpTransport.
> ensureVersionCompatibility(TcpTransport.java:1415)
> ~[elasticsearch-6.0.0.jar:6.0.0]
>         at org.elasticsearch.transport.TcpTransport.messageReceived(TcpTransport.java:1362)
> ~[elasticsearch-6.0.0.jar:6.0.0]
>         at org.elasticsearch.transport.netty4.Netty4MessageChannelHandler.
> channelRead(Netty4MessageChannelHandler.java:60)
> ~[transport-netty4-6.0.0.jar:6.0.0]
>         at io.netty.channel.AbstractChannelHandlerContext.
> invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.
> invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
> AbstractChannelHandlerContext.java:340) [netty-transport-4.1.13.Final.
> jar:4.1.13.Final]
>         at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
> [netty-codec-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:297)
> [netty-codec-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:413)
> [netty-codec-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
> [netty-codec-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.
> invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.
> invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
> AbstractChannelHandlerContext.java:340) [netty-transport-4.1.13.Final.
> jar:4.1.13.Final]
>         at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(
> ChannelInboundHandlerAdapter.java:86) [netty-transport-4.1.13.Final.
> jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.
> invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.
> invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
> AbstractChannelHandlerContext.java:340) [netty-transport-4.1.13.Final.
> jar:4.1.13.Final]
>         at io.netty.handler.logging.LoggingHandler.channelRead(LoggingHandler.java:241)
> [netty-handler-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.
> invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.
> invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
> AbstractChannelHandlerContext.java:340) [netty-transport-4.1.13.Final.
> jar:4.1.13.Final]
>         at io.netty.channel.DefaultChannelPipeline$
> HeadContext.channelRead(DefaultChannelPipeline.java:1334)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>
>                    at io.netty.channel.AbstractChannelHandlerContext.
> invokeChannelRead(AbstractChannelHandlerContext.java:362)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>
>             at io.netty.channel.AbstractChannelHandlerContext.
> invokeChannelRead(AbstractChannelHandlerContext.java:348)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>
>             at io.netty.channel.DefaultChannelPipeline.fireChannelRead(
> DefaultChannelPipeline.java:926) [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>
>                                                       at
> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(
> AbstractNioByteChannel.java:134) [netty-transport-4.1.13.Final.
> jar:4.1.13.Final]
>         at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:644)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.nio.NioEventLoop.processSelectedKeysPlain(NioEventLoop.java:544)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:498)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:458)
> [netty-transport-4.1.13.Final.jar:4.1.13.Final]
>         at io.netty.util.concurrent.SingleThreadEventExecutor$5.
> run(SingleThreadEventExecutor.java:858) [netty-common-4.1.13.Final.
> jar:4.1.13.Final]
>         at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131]
>
> On Nov 15, 2017, at 12:07 PM, Fritz Budiyanto <fbudiyan@icloud.com> wrote:
>
> Hi All,
>
> ES6 is GA today, and I wonder if Flink-ES5 connector fully support ES6 ?
> Any caveat we need to know ?
>
> Thanks,
> Fritz
>
>
>

--001a1137193e9e8fa4055eb98af2
Content-Type: text/html; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div><div><div>Hi Fritz,<br><br></div>the ElasticSearch co=
nnector has not been updated for ES6 yet.<br></div>There is a JIRA issue [1=
] to add support for ES6 and somebody working on it as it seems.<br><br></d=
iv>Best, Fabian<br><div><br>[1] <a href=3D"https://issues.apache.org/jira/b=
rowse/FLINK-8101">https://issues.apache.org/jira/browse/FLINK-8101</a><br><=
/div></div><div class=3D"gmail_extra"><br><div class=3D"gmail_quote">2017-1=
1-18 2:24 GMT+01:00 Fritz Budiyanto <span dir=3D"ltr">&lt;<a href=3D"mailto=
:fbudiyan@icloud.com" target=3D"_blank">fbudiyan@icloud.com</a>&gt;</span>:=
<br><blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-lef=
t:1px #ccc solid;padding-left:1ex"><div style=3D"word-wrap:break-word;line-=
break:after-white-space"><div>Hi,</div><div><br></div><div>I&#39;ve tried F=
link with ES6, and its causing exception thrown in ES6. Is the fix just mat=
ter of bumping es client version to 5.6 ?</div><div>Could anyone familiar w=
ith ES connector confirm ? If this is just a matter of bumping the es clien=
t version, can we have this simple change in Flink 1.4 ?</div><div><br></di=
v><div>Thanks,</div><div>Fritz</div><div><br></div><div><br></div><div>[201=
7-11-17T17:06:31,833][WARN ][o.e.t.n.Netty4Transport =C2=A0] [a6z4L9y] exce=
ption caught on transport layer [[id: 0xc77396b0, L:/<a href=3D"http://10.3=
2.0.85:9300" target=3D"_blank">10.32.0.85:9300</a> - R:/10.32.0.82:34814]],=
 closing connection =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0=
 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0<b>java.lang.<wbr>IllegalStateException: Received message =
from unsupported version: [5.0.0] minimal compatible version is: [5.6.0]</b=
></div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.elasticsearch.transport.<wbr=
>TcpTransport.<wbr>ensureVersionCompatibility(<wbr>TcpTransport.java:1415) =
~[elasticsearch-6.0.0.jar:6.0.<wbr>0]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0=
 at org.elasticsearch.transport.<wbr>TcpTransport.messageReceived(<wbr>TcpT=
ransport.java:1362) ~[elasticsearch-6.0.0.jar:6.0.<wbr>0]</div><div>=C2=A0 =
=C2=A0 =C2=A0 =C2=A0 at org.elasticsearch.transport.<wbr>netty4.<wbr>Netty4=
MessageChannelHandler.<wbr>channelRead(<wbr>Netty4MessageChannelHandler.<wb=
r>java:60) ~[transport-netty4-6.0.0.jar:<wbr>6.0.0]</div><div>=C2=A0 =C2=A0=
 =C2=A0 =C2=A0 at io.netty.channel.<wbr>AbstractChannelHandlerContext.<wbr>=
invokeChannelRead(<wbr>AbstractChannelHandlerContext.<wbr>java:362) [netty-=
transport-4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=
=A0 =C2=A0 at io.netty.channel.<wbr>AbstractChannelHandlerContext.<wbr>invo=
keChannelRead(<wbr>AbstractChannelHandlerContext.<wbr>java:348) [netty-tran=
sport-4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =
=C2=A0 at io.netty.channel.<wbr>AbstractChannelHandlerContext.<wbr>fireChan=
nelRead(<wbr>AbstractChannelHandlerContext.<wbr>java:340) [netty-transport-=
4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 a=
t io.netty.handler.codec.<wbr>ByteToMessageDecoder.<wbr>fireChannelRead(<wb=
r>ByteToMessageDecoder.java:310) [netty-codec-4.1.13.Final.jar:<wbr>4.1.13.=
Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.handler.codec.<wbr=
>ByteToMessageDecoder.<wbr>fireChannelRead(<wbr>ByteToMessageDecoder.java:2=
97) [netty-codec-4.1.13.Final.jar:<wbr>4.1.13.Final]</div><div>=C2=A0 =C2=
=A0 =C2=A0 =C2=A0 at io.netty.handler.codec.<wbr>ByteToMessageDecoder.<wbr>=
callDecode(<wbr>ByteToMessageDecoder.java:413) [netty-codec-4.1.13.Final.ja=
r:<wbr>4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.hand=
ler.codec.<wbr>ByteToMessageDecoder.<wbr>channelRead(<wbr>ByteToMessageDeco=
der.java:265) [netty-codec-4.1.13.Final.jar:<wbr>4.1.13.Final]</div><div>=
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.channel.<wbr>AbstractChannelHandler=
Context.<wbr>invokeChannelRead(<wbr>AbstractChannelHandlerContext.<wbr>java=
:362) [netty-transport-4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0=
 =C2=A0 =C2=A0 =C2=A0 at io.netty.channel.<wbr>AbstractChannelHandlerContex=
t.<wbr>invokeChannelRead(<wbr>AbstractChannelHandlerContext.<wbr>java:348) =
[netty-transport-4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=
=A0 =C2=A0 =C2=A0 at io.netty.channel.<wbr>AbstractChannelHandlerContext.<w=
br>fireChannelRead(<wbr>AbstractChannelHandlerContext.<wbr>java:340) [netty=
-transport-4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=
=A0 =C2=A0 at io.netty.channel.<wbr>ChannelInboundHandlerAdapter.<wbr>chann=
elRead(<wbr>ChannelInboundHandlerAdapter.<wbr>java:86) [netty-transport-4.1=
.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at i=
o.netty.channel.<wbr>AbstractChannelHandlerContext.<wbr>invokeChannelRead(<=
wbr>AbstractChannelHandlerContext.<wbr>java:362) [netty-transport-4.1.13.Fi=
nal.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.nett=
y.channel.<wbr>AbstractChannelHandlerContext.<wbr>invokeChannelRead(<wbr>Ab=
stractChannelHandlerContext.<wbr>java:348) [netty-transport-4.1.13.Final.<w=
br>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.chan=
nel.<wbr>AbstractChannelHandlerContext.<wbr>fireChannelRead(<wbr>AbstractCh=
annelHandlerContext.<wbr>java:340) [netty-transport-4.1.13.Final.<wbr>jar:4=
.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.handler.logg=
ing.<wbr>LoggingHandler.channelRead(<wbr>LoggingHandler.java:241) [netty-ha=
ndler-4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =
=C2=A0 at io.netty.channel.<wbr>AbstractChannelHandlerContext.<wbr>invokeCh=
annelRead(<wbr>AbstractChannelHandlerContext.<wbr>java:362) [netty-transpor=
t-4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0=
 at io.netty.channel.<wbr>AbstractChannelHandlerContext.<wbr>invokeChannelR=
ead(<wbr>AbstractChannelHandlerContext.<wbr>java:348) [netty-transport-4.1.=
13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io=
.netty.channel.<wbr>AbstractChannelHandlerContext.<wbr>fireChannelRead(<wbr=
>AbstractChannelHandlerContext.<wbr>java:340) [netty-transport-4.1.13.Final=
.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.c=
hannel.<wbr>DefaultChannelPipeline$<wbr>HeadContext.channelRead(<wbr>Defaul=
tChannelPipeline.java:<wbr>1334) [netty-transport-4.1.13.Final.<wbr>jar:4.1=
.13.Final] =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at io.=
netty.channel.<wbr>AbstractChannelHandlerContext.<wbr>invokeChannelRead(<wb=
r>AbstractChannelHandlerContext.<wbr>java:362) [netty-transport-4.1.13.Fina=
l.<wbr>jar:4.1.13.Final] =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.channel=
.<wbr>AbstractChannelHandlerContext.<wbr>invokeChannelRead(<wbr>AbstractCha=
nnelHandlerContext.<wbr>java:348) [netty-transport-4.1.13.Final.<wbr>jar:4.=
1.13.Final] =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.channel.<wbr>DefaultC=
hannelPipeline.<wbr>fireChannelRead(<wbr>DefaultChannelPipeline.java:<wbr>9=
26) [netty-transport-4.1.13.Final.<wbr>jar:4.1.13.Final] =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 at io=
.netty.channel.nio.<wbr>AbstractNioByteChannel$<wbr>NioByteUnsafe.read(<wbr=
>AbstractNioByteChannel.java:<wbr>134) [netty-transport-4.1.13.Final.<wbr>j=
ar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.channel.=
nio.<wbr>NioEventLoop.<wbr>processSelectedKey(<wbr>NioEventLoop.java:644) [=
netty-transport-4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0=
 =C2=A0 =C2=A0 at io.netty.channel.nio.<wbr>NioEventLoop.<wbr>processSelect=
edKeysPlain(<wbr>NioEventLoop.java:544) [netty-transport-4.1.13.Final.<wbr>=
jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.channel=
.nio.<wbr>NioEventLoop.<wbr>processSelectedKeys(<wbr>NioEventLoop.java:498)=
 [netty-transport-4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=
=A0 =C2=A0 =C2=A0 at io.netty.channel.nio.<wbr>NioEventLoop.run(NioEventLoo=
p.<wbr>java:458) [netty-transport-4.1.13.Final.<wbr>jar:4.1.13.Final]</div>=
<div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at io.netty.util.concurrent.<wbr>SingleThr=
eadEventExecutor$5.<wbr>run(SingleThreadEventExecutor.<wbr>java:858) [netty=
-common-4.1.13.Final.<wbr>jar:4.1.13.Final]</div><div>=C2=A0 =C2=A0 =C2=A0 =
=C2=A0 at java.lang.Thread.run(Thread.<wbr>java:748) [?:1.8.0_131]</div><di=
v><div class=3D"h5"><div><br><blockquote type=3D"cite"><div>On Nov 15, 2017=
, at 12:07 PM, Fritz Budiyanto &lt;<a href=3D"mailto:fbudiyan@icloud.com" t=
arget=3D"_blank">fbudiyan@icloud.com</a>&gt; wrote:</div><br class=3D"m_-26=
04088751216926890Apple-interchange-newline"><div><div>Hi All,<br><br>ES6 is=
 GA today, and I wonder if Flink-ES5 connector fully support ES6 ? Any cave=
at we need to know ?<br><br>Thanks,<br>Fritz</div></div></blockquote></div>=
<br></div></div></div></blockquote></div><br></div>

--001a1137193e9e8fa4055eb98af2--