From issues-return-157884-archive-asf-public=cust-asf.ponee.io@flink.apache.org Mon Mar 12 12:19:06 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 D89F618064D for ; Mon, 12 Mar 2018 12:19:05 +0100 (CET) Received: (qmail 24904 invoked by uid 500); 12 Mar 2018 11:19:04 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 24891 invoked by uid 99); 12 Mar 2018 11:19:04 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 12 Mar 2018 11:19:04 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 759C41828FF for ; Mon, 12 Mar 2018 11:19:04 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -109.811 X-Spam-Level: X-Spam-Status: No, score=-109.811 tagged_above=-999 required=6.31 tests=[ENV_AND_HDR_SPF_MATCH=-0.5, KAM_NUMSUBJECT=0.5, RCVD_IN_DNSWL_MED=-2.3, SPF_PASS=-0.001, T_RP_MATCHES_RCVD=-0.01, USER_IN_DEF_SPF_WL=-7.5, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id dwJ8eb0PTYka for ; Mon, 12 Mar 2018 11:19:02 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 1538E5F2EC for ; Mon, 12 Mar 2018 11:19:02 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 1AFFAE002F for ; Mon, 12 Mar 2018 11:19:00 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 26F332146E for ; Mon, 12 Mar 2018 11:19:00 +0000 (UTC) Date: Mon, 12 Mar 2018 11:19:00 +0000 (UTC) From: "Chesnay Schepler (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FLINK-8795) Scala shell broken for Flip6 MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: quoted-printable X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/FLINK-8795?page=3Dcom.atlassian= .jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D1639= 5084#comment-16395084 ]=20 Chesnay Schepler commented on FLINK-8795: ----------------------------------------- The given port is where the client expected the clusters REST server to run= . The problem is that the scala shell was not updated for Flip6; it still sta= rts a legacy {{StandaloneClusterClient}} but tries to connect with a Flip6 = {{RestClusterClient}}. As a workaround please add {{mode: old}} to {{conf/flink-conf.yaml}}. > Scala shell broken for Flip6 > ---------------------------- > > Key: FLINK-8795 > URL: https://issues.apache.org/jira/browse/FLINK-8795 > Project: Flink > Issue Type: Bug > Reporter: kant kodali > Priority: Blocker > Fix For: 1.5.0 > > > I am trying to run the simple code below after building everything from F= link's github master branch for various reasons. I get an exception below a= nd I wonder what runs on port 9065? and How to fix this exception? > I followed the instructions from the Flink master branch so I did the fol= lowing. > {code:java} > git clone https://github.com/apache/flink.git=C2=A0 > cd flink mvn clean package -DskipTests=C2=A0 > cd build-target > ./bin/start-scala-shell.sh local{code} > {{And Here is the code I ran}} > {code:java} > val dataStream =3D senv.fromElements(1, 2, 3, 4) > dataStream.countWindowAll(2).sum(0).print() > senv.execute("My streaming program"){code} > {{And I finally get this exception}} > {code:java} > Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed= to submit JobGraph. at org.apache.flink.client.program.rest.RestClusterCli= ent.lambda$submitJob$18(RestClusterClient.java:306) at java.util.concurrent= .CompletableFuture.uniExceptionally(CompletableFuture.java:870) at java.uti= l.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.j= ava:852) at java.util.concurrent.CompletableFuture.postComplete(Completable= Future.java:474) at java.util.concurrent.CompletableFuture.completeExceptio= nally(CompletableFuture.java:1977) at org.apache.flink.runtime.rest.RestCli= ent.lambda$submitRequest$222(RestClient.java:196) at org.apache.flink.shade= d.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPro= mise.java:680) at org.apache.flink.shaded.netty4.io.netty.util.concurrent.D= efaultPromise.notifyListeners0(DefaultPromise.java:603) at org.apache.flink= .shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(Defa= ultPromise.java:563) at org.apache.flink.shaded.netty4.io.netty.util.concur= rent.DefaultPromise.tryFailure(DefaultPromise.java:424) at org.apache.flink= .shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fu= lfillConnectPromise(AbstractNioChannel.java:268) at org.apache.flink.shaded= .netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishCon= nect(AbstractNioChannel.java:284) at org.apache.flink.shaded.netty4.io.nett= y.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:528) at org= .apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelect= edKeysOptimized(NioEventLoop.java:468) at org.apache.flink.shaded.netty4.io= .netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) = at org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(Nio= EventLoop.java:354) at org.apache.flink.shaded.netty4.io.netty.util.concurr= ent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111) at = org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultThreadFactor= y$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) at java.lang.= Thread.run(Thread.java:745) Caused by: java.util.concurrent.CompletionExcep= tion: java.net.ConnectException: Connection refused: localhost/127.0.0.1:90= 65 at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFut= ure.java:292) at java.util.concurrent.CompletableFuture.completeThrowable(C= ompletableFuture.java:308) at java.util.concurrent.CompletableFuture.uniCom= pose(CompletableFuture.java:943) at java.util.concurrent.CompletableFuture$= UniCompose.tryFire(CompletableFuture.java:926) ... 16 more Caused by: java.= net.ConnectException: Connection refused: localhost/127.0.0.1:9065 at sun.n= io.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketCha= nnelImpl.finishConnect(SocketChannelImpl.java:717) at org.apache.flink.shad= ed.netty4.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioS= ocketChannel.java:224) at org.apache.flink.shaded.netty4.io.netty.channel.n= io.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.ja= va:281){code} > =C2=A0 -- This message was sent by Atlassian JIRA (v7.6.3#76005)