Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 1EE2118258 for ; Thu, 3 Dec 2015 17:41:00 +0000 (UTC) Received: (qmail 15035 invoked by uid 500); 3 Dec 2015 17:40:53 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 14950 invoked by uid 500); 3 Dec 2015 17:40:53 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 14940 invoked by uid 99); 3 Dec 2015 17:40:53 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 03 Dec 2015 17:40:53 +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 2FB29180975 for ; Thu, 3 Dec 2015 17:40:53 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.354 X-Spam-Level: ** X-Spam-Status: No, score=2.354 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=3, RP_MATCHES_RCVD=-0.554, SPF_HELO_PASS=-0.001, SPF_PASS=-0.001, T_KAM_HTML_FONT_INVALID=0.01] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=capitalone.com Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id uDx63dQ83L38 for ; Thu, 3 Dec 2015 17:40:52 +0000 (UTC) Received: from komail03.capitalone.com (outk.capitalone.com [199.244.214.13]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with ESMTPS id C58FC441C4 for ; Thu, 3 Dec 2015 17:40:51 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=simple/simple; d=capitalone.com; l=7890; q=dns/txt; s=SM2048Mar2015K; t=1449164452; x=1449250852; h=from:to:date:subject:message-id:mime-version; bh=HM9wxrqEvQ6WZDiJ0Wry/8rvmJh6ougWBoiUrsuK8EM=; b=O46UrrBAkRHvi+0ziEpE0fOtcAXkV/182WwRDErSC6TOAPujj8bra+EL bK5/b39L7AYW92IvBGS90TxeU675Sd8MKKUU+kGptRVd1wrLC9ldKnejs 7/Izo+wClnO2842KrEr1NB0pT4HampXLY/GaJHjsuxTYPti+SaUc2DbfC X0xBtUspKH7IceoMCQpvugf/5bNDOv/oQWtVepHN2Lf7TZ3SEagBscD5t 05YGReSers/rx+J0iWUMX3yUJbb1a6FGPrsnRIRJ9QjQBveZu5I0OkVEA BH9ULbKNabdZU521PxIZDt/AV++z+gKeY8/plAfso1XMnglFEF8V824iS w==; X-IronPort-AV: E=McAfee;i="5700,7163,8003"; a="303833324" X-IronPort-AV: E=Sophos;i="5.20,378,1444708800"; d="scan'208,217";a="303833324" X-AFNotificationDomain: TRUE X-HTML-Disclaimer: True Received: from kdcpexcasht03.cof.ds.capitalone.com ([10.37.194.13]) by komail03.kdc.capitalone.com with ESMTP/TLS/AES128-SHA; 03 Dec 2015 12:40:46 -0500 Received: from KDCPEXCMB08.cof.ds.capitalone.com ([fe80::c5c0:7fca:2b0c:6767]) by kdcpexcasht03.cof.ds.capitalone.com ([10.37.194.13]) with mapi; Thu, 3 Dec 2015 12:40:45 -0500 From: "Madhire, Naveen" To: "user@flink.apache.org" Date: Thu, 3 Dec 2015 12:40:43 -0500 Subject: Flink Storm Thread-Topic: Flink Storm Thread-Index: AdEt8bwxFTC6lO0vRn6MYjXXKh/+ug== Message-ID: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: user-agent: Microsoft-MacOutlook/14.5.7.151005 acceptlanguage: en-US Content-Type: multipart/alternative; boundary="_000_D285DABB2330VenkatNaveenKumarReddyMadhirecapitalonecom_" MIME-Version: 1.0 --_000_D285DABB2330VenkatNaveenKumarReddyMadhirecapitalonecom_ MIME-Version: 1.0 Content-Type: text/plain; charset="windows-1252" Content-Transfer-Encoding: quoted-printable Hi, I am trying to execute few storm topologies using Flink, I have a question = related to the documentation, Can anyone tell me which of the below code is correct, https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/storm_com= patibility.html https://ci.apache.org/projects/flink/flink-docs-master/apis/storm_compatibi= lity.html I want to use Flink-storm 1.0-SNAPSHOT version, I don=92t see any createTop= ology method in FlinkTopology class. Ex, cluster.submitTopology("WordCount", conf, FlinkTopology.createTopology(= builder)); Is the documentation incorrect for the 1.0-SNAPSHOT or may be I missing som= ething ;) Thanks, Naveen ________________________________________________________ The information contained in this e-mail is confidential and/or proprietary= to Capital One and/or its affiliates and may only be used solely in perfor= mance of work or services for Capital One. The information transmitted here= with is intended only for use by the individual or entity to which it is ad= dressed. If the reader of this message is not the intended recipient, you a= re hereby notified that any review, retransmission, dissemination, distribu= tion, copying or other use of, or taking of any action in reliance upon thi= s information is strictly prohibited. If you have received this communicati= on in error, please contact the sender and delete the material from your co= mputer. --_000_D285DABB2330VenkatNaveenKumarReddyMadhirecapitalonecom_ MIME-Version: 1.0 Content-Type: text/html; charset="windows-1252" Content-Transfer-Encoding: quoted-printable
Hi,

I a= m trying to execute few storm topologies using Flink, I have a question rel= ated to the documentation,

Can anyone tell me whic= h of the below code is correct,



Is the documentation incorrect for the 1.0-SNAPSHOT or may be I missing = something ;)

Thanks,
Naveen

=

The information contained in thi= s e-mail is confidential and/or proprietary to Capital One and/or its affil= iates and may only be used solely in performance of work or services for Ca= pital One. The information transmitted herewith is intended only for use by= the individual or entity to which it is addressed. If the reader of this m= essage is not the intended recipient, you are hereby notified that any revi= ew, retransmission, dissemination, distribution, copying or other use of, o= r taking of any action in reliance upon this information is strictly prohib= ited. If you have received this communication in error, please contact the = sender and delete the material from your computer.

--_000_D285DABB2330VenkatNaveenKumarReddyMadhirecapitalonecom_--