Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CB244187C8 for ; Wed, 9 Mar 2016 01:32:45 +0000 (UTC) Received: (qmail 69020 invoked by uid 500); 9 Mar 2016 01:32:45 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 68957 invoked by uid 500); 9 Mar 2016 01:32:45 -0000 Mailing-List: contact dev-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 dev@flink.apache.org Delivered-To: moderator for dev@flink.apache.org Received: (qmail 11698 invoked by uid 99); 9 Mar 2016 01:06:13 -0000 X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.997 X-Spam-Level: * X-Spam-Status: No, score=1.997 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, SPF_HELO_PASS=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (1024-bit key) header.d=hmcs.onmicrosoft.com DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=hmcs.onmicrosoft.com; s=selector1-here-com; h=From:To:Date:Subject:Message-ID:Content-Type:MIME-Version; bh=5VRZf3v3a3e+c2/7eP/SI1Z+ftynD6enfvbK1rRw6mM=; b=L0dBf/hYoKkRz5pwLCHhKbLWUNUjYds8ztqNrTL3eAMxRscq2sS1mz8/FmJFk8CRp6i7nRap0bgsmXbL75mjkPvShAOk1qqZlBugf8bo1+0y/1IqBNL4OmV3VHtojg1GNICByK32nhxgSorIh4bd6JH0MNPQUbaneNCmsk3ei4w= From: "Sharma, Samiksha" To: "dev@flink.apache.org" Subject: Query regarding using storm topology in Flink Thread-Topic: Query regarding using storm topology in Flink Thread-Index: AQHReZ/ZSMvy8nSS70ivyvH28wMTQA== Date: Wed, 9 Mar 2016 01:06:02 +0000 Message-ID: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: authentication-results: flink.apache.org; dkim=none (message not signed) header.d=none;flink.apache.org; dmarc=none action=none header.from=here.com; x-ms-exchange-messagesentrepresentingtype: 1 x-originating-ip: [131.228.197.12] x-ms-office365-filtering-correlation-id: 61bb59c5-66f5-4139-cb7b-08d347b6fc2f x-microsoft-exchange-diagnostics: 1;HE1PR04MB2089;5:f0KYLwJR1vbXnuzB9G12XWpXTuSt2bRlIH2cECvnFSc7y8rpiXESXq8IVCS2JbPiASw5mnv74cn5ZdCKlff0l7RVpQDyIfNk6BSLoS4/L/PU+OgZ214Ov/RpK3W1A+qKNBypKHCgiGbqgI5o2mUUoA==;24:6chjj3XDSob8zgGivqUT3RwhiLhw6f9qP8sL+esE3uSoeCXuQCKYBXmhViWBG9PibqqRxXI7a+h8YTGbvn+hnzi3ICzJ6OziNDu7XiodlPs= x-microsoft-antispam: UriScan:;BCL:0;PCL:0;RULEID:;SRVR:HE1PR04MB2089; x-microsoft-antispam-prvs: x-exchange-antispam-report-test: UriScan:; x-exchange-antispam-report-cfa-test: BCL:0;PCL:0;RULEID:(601004)(2401047)(8121501046)(5005006)(3002001)(10201501046);SRVR:HE1PR04MB2089;BCL:0;PCL:0;RULEID:;SRVR:HE1PR04MB2089; x-forefront-prvs: 0876988AF0 x-forefront-antispam-report: SFV:NSPM;SFS:(10019020)(6009001)(11100500001)(122556002)(1096002)(3846002)(1220700001)(6116002)(102836003)(3660700001)(3280700002)(36756003)(2501003)(107886002)(110136002)(189998001)(2906002)(10400500002)(66066001)(77096005)(586003)(16236675004)(5002640100001)(106116001)(19580395003)(54356999)(50986999)(5004730100002)(86362001)(81166005)(92566002)(450100001)(5008740100001)(87936001)(229853001)(2351001);DIR:OUT;SFP:1102;SCL:1;SRVR:HE1PR04MB2089;H:HE1PR04MB2092.eurprd04.prod.outlook.com;FPR:;SPF:None;MLV:sfv;LANG:en; spamdiagnosticoutput: 1:23 spamdiagnosticmetadata: NSPM Content-Type: multipart/alternative; boundary="_000_D304B7283086samikshasharmaherecom_" MIME-Version: 1.0 X-OriginatorOrg: here.com X-MS-Exchange-CrossTenant-originalarrivaltime: 09 Mar 2016 01:06:02.7638 (UTC) X-MS-Exchange-CrossTenant-fromentityheader: Hosted X-MS-Exchange-CrossTenant-id: 6d4034cd-7225-4f72-b853-91feaea64919 X-MS-Exchange-Transport-CrossTenantHeadersStamped: HE1PR04MB2089 --_000_D304B7283086samikshasharmaherecom_ Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable Hi, I am trying to run locally a storm topology in flink using the flink-storm = library , but I get the following error Exception in thread "main" java.lang.NoClassDefFoundError: scala/concurrent= /ExecutionContext at org.apache.flink.storm.api.FlinkLocalCluster.(FlinkLocalCluster.ja= va:54) at com.medio.services.avalanche.storm.common.BaseTopology.deploy(BaseTopolo= gy.java:116) at com.medio.services.avalanche.realtime.eventcounter.EventCounterTopology.= main(EventCounterTopology.java:18) Caused by: java.lang.ClassNotFoundException: scala.concurrent.ExecutionCont= ext at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 3 more It looks like the library is unable to find the ExecutionContext class and = I am not sure how to resolve this dependency. Thanks Samiksha Sharma --_000_D304B7283086samikshasharmaherecom_--