From user-return-24681-archive-asf-public=cust-asf.ponee.io@flink.apache.org Fri Nov 30 15:56:40 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 3C5B4180671 for ; Fri, 30 Nov 2018 15:56:39 +0100 (CET) Received: (qmail 2084 invoked by uid 500); 30 Nov 2018 14:56:37 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 2073 invoked by uid 99); 30 Nov 2018 14:56:37 -0000 Received: from mail-relay.apache.org (HELO mailrelay1-lw-us.apache.org) (207.244.88.152) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 30 Nov 2018 14:56:37 +0000 Received: from [10.0.1.20] (dslb-002-205-086-134.002.205.pools.vodafone-ip.de [2.205.86.134]) by mailrelay1-lw-us.apache.org (ASF Mail Server at mailrelay1-lw-us.apache.org) with ESMTPSA id 8B994F86; Fri, 30 Nov 2018 14:56:36 +0000 (UTC) Subject: Re: Changes in Flink 1.6.2 To: Boris Lublinsky , =?UTF-8?Q?Dominik_Wosi=c5=84ski?= Cc: user References: From: Dawid Wysakowicz Openpgp: preference=signencrypt Autocrypt: addr=dwysakowicz@apache.org; keydata= xsFNBFlDn4sBEADAXnPD90xKDWhCifMUi7CQhC2x6YAAnkIAosTqtJiwKQWxD6H/gJof8h6u WryDyvg9aQa6svDYHjnhFlJ15QNUZM6ssqfwtsFx/wPn4NqkOnEXWyybRzv4++Hdci/3fQTu Ht+r69fnDQN/yDCK22KYLBj5r9aqX/M8L3pehulJXHSM/2A5FR5UocWgOh+pbc5ZXwxr72oF DOo+xG31/sMwYV/rQw+6ab5zdNOcuKPR1vxxMGFmYkP1fn3LEiVAq4TGB3y9tpH3jof0u0oS UNRMZg3lQfJxcyhJk+R2Pu+sg3TYI2mAm0sOwxWtl5nn1qxkK8fNsXA9c4Mjc8QWqVxaIQtz yVAhlNQmcKEP0fQhU6m1f6CADaR23J6MHOswfQUbSvKHjmKSo+IjFAYW4PaofXrZwVJmB4KD rsIVnEMeVdYtR3PmABhf3h8ugFKOxQmBpX/CbcH2ycCehRNQhM1uCBy+IF2OGoINuSLCGpy2 ABt1DVGy3G4hgPzlI2OK3xGs7XJWlnO/1uDC0QeSsgr0QwgPJGY/+dumRbadtDd0eae4+/HY zH7vtQd9gXv6qcqVDZr8yd2fzgfo1JJxc6we+ujVwMN0NQkFw6DK0Rob9T5Ip/JfVfOlbIj8 SgIdZBNEHdtB3HEZRZOCGSYBM/8Opa4qXs+3AG3W4Z3vW49ogwARAQABzS1EYXdpZCBXeXNh a293aWN6IDx3eXNha293aWN6LmRhd2lkQGdtYWlsLmNvbT7CwYAEEwEKACoCGwMFCQeGH4AF CwkIBwMFFQoJCAsFFgIDAQACHgECF4AFAllDn64CGQEACgkQMdLdEL/BWi2gOxAAlrC7Kag5 vq/lUhN3VSnqkklpbsDVOqHg8kyjLk3Sl2Wr3iMGQIQjm6aNb63SM7GpV3D6BDlT9znaXF8B Cy4bZ4MFJlABMCE3YdyjnLv2mnYOJc+mS3IiYMAr2D35/k1qDzQg3H9LqchVjUKVKLLC0J67 8bz9D7gTAb+EWcdyr3y2pzUtXNyp51nJ6zH1VfGcGec5O1uACgus6XT8S9QslimZKI42XB1I vW9ucZS0DiHZlwFmOnAcCDuxkaFPvhH++Q3FpuZ2kzAA/ccFoQ+iLshGs8EoaEgMpQA9BAjY oQGzMVnyfjQcN3eYm0bDA8jDckCHIFg2dLxR48w1s1c9LAdKaGhaYjlaa83dmDhGfn3zBprf O5S847v3+eAUFjsio8FOE8zfWdUs0CjUpkNHTmDtf+Hpu2R2uhL3cuqjL11C/fljqejx6Q88 y3EG+w3JqjZ5pRJzRy+ORuN1phjYyPb+MnsNC15Py4y1nNNp+B4r5wL05Svg37X7p2Lh0o9P D05L08RbH1WBghtbDrNoHPVYQy/KJTE2fulz3c35fwqU/mY5jHevtYf5+tR4BoEvk/ycVo5/ +JlO3jhtQLjQbsjKWvyrW+7X6emG0tGtg7f7W4vYQoDjyGef1AXOp/9K4hJuQcyVZk6lMbFz /GhjfmXTKInNFIKE35C2yrgjepfOwU0EWUOfiwEQALffFdOK3rCfsMc9LnPDBPiuX0yYiJW8 eD7bazMKjgh2wunqApw5XB2RP4qr+rU3GCc/M6x4pLaZpgWMrS9cfWtJVrWPFIwcvt7Y0Wpd kRQoKDKN11wuCZc/JHP+P6dmUGBSSpN+WOUf1KZ4K9rO5RyxV6MVoOk/QzMBDqE5emQvSRg5 YsmgO7F+ei7R8ZFyTf5BD7KaHkHpwNeDJ9impGL/BE97w9h11j5NxM5G8lNFs+1jqpMmKjRj A74xpfv1pSN6qo64L2J4e/lrgwaQrD/Tdpd153AMBojFmsnj07Lv5ZFHpgHtCy0fbq+R1O9N a1fYt26fVA9v8++1XDd5Fd/yiA6TCDxxhBsBap0lvNiifNX2v9WL2TNuOV1yDxX704yQavfg amz/jb8Os0vaYKzvKKN1WuHIFi+JUyjzmM0lkS3ollHqxUjhl0bvs37t848IcvYQqfw5Yj5A 7ybUkItDElrpue3JPEXsiBOsvCirmG5bylyVUHMWk3JCaZ8eYNFUCpLBh0moQ/wu2iC6eKzU DZMIzs8YdKrKAXvMqu+ly/e/r3u8gCzOTFLS7f+S3M5CP9hA7hpL15rTfDqaghQm6g/FCtvG 0d4O9bX7qe4lOq9Nvtuxk5LUZzFKV0Nv7vsQWYSiBJ2GPaxxC+5SY9xRZ7c3WzueSu6sDpJ+ C6NxABEBAAHCwWUEGAEKAA8FAllDn4sCGwwFCQeGH4AACgkQMdLdEL/BWi0s5Q//V79D2i3K Dwnoip4YZ4UEfWi3WrXwFgZ2volUg0pBPtoOlys5+rQY4eSfEszDVT38clIzAmY8Ft5M2zuh zpkKMKzWHYFOC+1rZ+d5GYqctc0Rr2QFMI8KrOCiOBlDyCt6q1XcgzwHPFjvMMuG8y7MjKuZ NUNFHfEQxUdNwAQ1ZBJVyJD4Xu7Z/E/ZL0OmqZ7CLzbNSGSagS7c6eO3+W1n7kiHY0IFTZ0I LHnk4NWNPHSA4L1nyQQLka8N4XZN4C59d0fL71C/OY7cq5N/+M5or8a5BLJZR8LZnaG0hOC5 iWbveLopQxXBwE9P2JI5nY+1nZ6WAHE0RcTJlYKErSRw/0eohEzgfHaMjvi9dtcQj8SQ1gzS PeZiMqZ/orlbnhhZnQ2At1dZwQsLiexL1THW+C5ldog0tNMC6iSH0XFWx5x4kfiIVVTnYNx+ LA28O5GOeUmCyPDbX/6qacHC91abzMXzZS+BI42pvn8bHwPEMbb6PFQgszaBSfDqQPjPJTMo 3JhdvSBsCq9fv2AxOSMwHwpsFPOSsAaRxsLfn78+oz51+30JVowG1JJ3OWf8rj9FBoOfjAMS Y8WYBtWcEtsBrFH8IhNver9NX1ABpyfMpblHDzg1/GcXx0kg1Heeg6/9sPqb8dOkY63fqWi9 ErMml6rahhxfOe3Xec5sLoVrq/4= Message-ID: Date: Fri, 30 Nov 2018 15:56:34 +0100 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:60.0) Gecko/20100101 Thunderbird/60.2.1 MIME-Version: 1.0 In-Reply-To: Content-Type: multipart/signed; micalg=pgp-sha256; protocol="application/pgp-signature"; boundary="ywmqzr4pCXLI5UzQjxD0HmJpiQjZFd5oM" This is an OpenPGP/MIME signed message (RFC 4880 and 3156) --ywmqzr4pCXLI5UzQjxD0HmJpiQjZFd5oM Content-Type: multipart/mixed; boundary="DQPPzlwhk2brOel8wnSy53IIrOHmnEPnU"; protected-headers="v1" From: Dawid Wysakowicz To: Boris Lublinsky , =?UTF-8?Q?Dominik_Wosi=c5=84ski?= Cc: user Message-ID: Subject: Re: Changes in Flink 1.6.2 References: In-Reply-To: --DQPPzlwhk2brOel8wnSy53IIrOHmnEPnU Content-Type: multipart/alternative; boundary="------------FD8F15B6F123CDC29788DD9B" Content-Language: en-US This is a multi-part message in MIME format. --------------FD8F15B6F123CDC29788DD9B Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable Hi Boris, I am not a scala expert, so I won't be able explain the root cause completely, but it is because you access empty-parameter java method as scala parameterless one (I don't know why it doesn't work). If you change your code to: env.getStreamGraph.getJobGraph().getJobID it will work. Best, Dawid On 30/11/2018 15:19, Boris Lublinsky wrote: > Dominik, > Any feedback on this? > > Boris Lublinsky > FDP Architect > boris.lublinsky@lightbend.com > https://www.lightbend.com/ > >> On Nov 28, 2018, at 2:56 PM, Boris Lublinsky >> > > wrote: >> >> Here is the code >> >> def executeLocal() : Unit =3D { >> val env =3D StreamExecutionEnvironment.getExecutionEnvironment build= Graph(env) >> System.out.println("[info] Job ID: " + env.getStreamGraph.getJobGrap= h.getJobID) >> env.execute() >> } >> And an error >> >> Error:(68, 63) ambiguous reference to overloaded definition, >> both method getJobGraph in class StreamGraph of type (x$1: >> org.apache.flink.api.common.JobID)org.apache.flink.runtime.jobgraph.Jo= bGraph >> and =C2=A0method getJobGraph in class StreamingPlan of type >> ()org.apache.flink.runtime.jobgraph.JobGraph >> match expected type ? >> =C2=A0 =C2=A0 System.out.println("[info] Job ID: " + >> env.getStreamGraph.getJobGraph.getJobID) >> >> Boris Lublinsky >> FDP Architect >> boris.lublinsky@lightbend.com >> https://www.lightbend.com/ >> >>> On Nov 28, 2018, at 2:47 PM, Dominik Wosi=C5=84ski >> > wrote: >>> >>> Hey,=C2=A0 >>> Could you show the message that You are getting?=C2=A0 >>> Best Regards, >>> Dom. >>> >>> =C5=9Br., 28 lis 2018 o 19:08=C2=A0Boris Lublinsky >>> >> > napisa=C5=82(a): >>> >>> >>> >>> Prior to Flink version 1.6.2 including 1.6.1 >>> env.getStreamGraph.getJobGraph was happily returning currently >>> defined Graph, but in 1.6.2 this fails to compile with a pretty >>> cryptic message >>> AM I missing something? >>> >>> >>> Boris Lublinsky >>> FDP Architect >>> boris.lublinsky@lightbend.com >>> https://www.lightbend.com/ >>> >> > --------------FD8F15B6F123CDC29788DD9B Content-Type: text/html; charset=utf-8 Content-Transfer-Encoding: quoted-printable

Hi Boris,

I am not a scala expert, so I won't be able explain the root cause completely, but it is because you access empty-parameter java method as scala parameterless one (I don't know why it doesn't work).

If you change your code to: env.getStreamGraph.getJobGraph().getJobID it will work.

Best,

Dawid

On 30/11/2018 15:19, Boris Lublinsky wrote:
Dominik,
Any feedback on this?

Boris Lublinsky
FDP Architect
boris.lublinsky@lightbend.com<= br class=3D""> https://www.lightbend.com/

On Nov 28, 2018, at 2:56 PM, Boris Lublinsky <boris.lublinsky@light= bend.com> wrote:

Here is the code 

def executeLocal() : Unit =3D {
  val e=
nv =3D StreamExecutionEnvironment.getExecutionEnvironment
  buildGraph(=
env)
  System.out<=
/span>.println("[info] Job ID: =
" + env.getStreamGraph.getJobGraph.getJobID)
  env.execute()
}
And an error

Error:(68, 63) ambiguous reference to overloaded definition,
both method getJobGraph in class StreamGraph of type (x$1: org.apache.flink.api.common.JobID)org.apache.flink.runtime.jobgraph.JobGr= aph
and =C2=A0method getJobGraph in class StreamingPlan of type ()org.apache.flink.runtime.jobgraph.JobGraph
match expected type ?
=C2=A0 =C2=A0 System.out.println("[info= ] Job ID: " + env.getStreamGraph.getJobGraph.getJobID)

Boris Lublinsky
FDP Architect
boris.lublins= ky@lightbend.com
https://www.lightbend.co= m/

On Nov 28, 2018, at 2:47 PM, Domini= k Wosi=C5=84ski <wossyn@gmai= l.com> wrote:

Hey,=C2=A0
Could you show the message that You are getting?=C2=A0
Best Regards,
Dom.

=C5=9Br., 28 lis 20= 18 o 19:08=C2=A0Boris Lublinsky <boris.l= ublinsky@lightbend.com> napisa=C5=82(a):

                              

                              


                              

                              


                              

                              
Prior to Flink version 1.6.=
2
                                including 1.6.1

                              
env.getStreamGraph.getJobGr=
aph
                                was happily returning currently defined
                                Graph, but in 1.6.2 this fails to
                                compile with a pretty cryptic message
                              
AM I missing something?
                              


                              

                              

                              

                                
Boris
                                  Lublinsky

                                  FDP Architect

                                  boris.lublin=
sky@lightbend.com

                                  https://www.=
lightbend.com/

                              

                              

                            

                          

                        

                      

                    

                  

                  

                

              

            

          

        

        

      

    

  


--------------FD8F15B6F123CDC29788DD9B--

--DQPPzlwhk2brOel8wnSy53IIrOHmnEPnU--

--ywmqzr4pCXLI5UzQjxD0HmJpiQjZFd5oM
Content-Type: application/pgp-signature; name="signature.asc"
Content-Description: OpenPGP digital signature
Content-Disposition: attachment; filename="signature.asc"

-----BEGIN PGP SIGNATURE-----

iQIzBAEBCAAdFiEE6pOkNbTiybTJ9TP2MdLdEL/BWi0FAlwBT6MACgkQMdLdEL/B
Wi1/TxAAp2mYrNVzwQFfYKUBhq7+iHOcgUcCEX20Oen3T1R8aF9M5BHr9W7T09SO
xGjAo867T68NQBV6jXwt8h4RA4mNOKBWfVhTy4BOUZx79p4/xKS+rfZuq9YCm+KA
14gQ8lGfHCUee33k75hgpIahiWKFmWHKLhSJMr4VPj0cHtBPsE4dBzqWRAc0Vcch
pRLcD9r/40niZFINxRwsitYnzUYXsC2eZlLN1GHnhHyoXgzG0SZdJRmYBwmeyMIm
4W/3TLZ/yXdFSGm0b6oFprkzAoaDTXM+wl1AmaHfR/5tU2I2ILptzlobTt2S14yX
aUvChz1Pv/nfIVxqiMt+5xpn6+8PiAAed7xY0uhSgM4DCTobA2Sohjq+IhrqGJlR
kmHDNJZUgcmsbz/D3+w/uKAkpQ9Tj2OX8Po61brH3OArmpbPH2adegmxDvQIlpBN
GTo2fL8yYyqg+PLms8EEYN0M8/UeF4ApFKRALnvTm1iYAtbXSVLQuB0bJf9H5j76
XByrU55Vp1IAHqkUnuhqUqAEoxDNb/grHWIEYlIYMVNyAsq8qiMcd4q4zUpKLxHn
momCMnq9BUjAh9pLyyWxn0bu5S1zw7Zy37JuHApeEiG43H4OtCjqK+cQ7YLoMkJ+
tR80A9vwq94cgIH37ixDXmz2yCmkXEPrp1SOLWOW/8IRcWXHIG0=
=/k6W
-----END PGP SIGNATURE-----

--ywmqzr4pCXLI5UzQjxD0HmJpiQjZFd5oM--