Return-Path: 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 02FD3200BBB for ; Thu, 10 Nov 2016 14:24:28 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 01331160B01; Thu, 10 Nov 2016 13:24:28 +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 DAE91160AF6 for ; Thu, 10 Nov 2016 14:24:24 +0100 (CET) Received: (qmail 3941 invoked by uid 500); 10 Nov 2016 13:24:23 -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 Received: (qmail 3925 invoked by uid 99); 10 Nov 2016 13:24:23 -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; Thu, 10 Nov 2016 13:24:23 +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 82D96182912 for ; Thu, 10 Nov 2016 13:24:22 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.96 X-Spam-Level: ** X-Spam-Status: No, score=2.96 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=2, HTML_TAG_BALANCE_BODY=0.712, KAM_LOTSOFHASH=0.25, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, SPF_HELO_PASS=-0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] 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 ELUnvoAkgqcr for ; Thu, 10 Nov 2016 13:23:52 +0000 (UTC) Received: from na01-bl2-obe.outbound.protection.outlook.com (mail-bl2on0137.outbound.protection.outlook.com [65.55.169.137]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id C67235F483 for ; Thu, 10 Nov 2016 13:23:49 +0000 (UTC) Received: from CO1P114CA0012.NAMP114.PROD.OUTLOOK.COM (129.75.40.146) by DM3P114MB0025.NAMP114.PROD.OUTLOOK.COM (129.75.29.88) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384_P384) id 15.1.707.6; Thu, 10 Nov 2016 13:23:07 +0000 Received: from BL2FFO11FD064.protection.gbl (2a01:111:f400:7c09::196) by CO1P114CA0012.outlook.office365.com (2603:10b6:110:3::18) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384_P384) id 15.1.707.6 via Frontend Transport; Thu, 10 Nov 2016 13:23:07 +0000 Authentication-Results: spf=pass (sender IP is 170.252.43.196) smtp.mailfrom=accenture.com; flink.apache.org; dkim=none (message not signed) header.d=none;flink.apache.org; dmarc=bestguesspass action=none header.from=accenture.com; Received-SPF: Pass (protection.outlook.com: domain of accenture.com designates 170.252.43.196 as permitted sender) receiver=protection.outlook.com; client-ip=170.252.43.196; helo=AMRXE4001.accenture.com; Received: from AMRXE4001.accenture.com (170.252.43.196) by BL2FFO11FD064.mail.protection.outlook.com (10.173.161.160) with Microsoft SMTP Server (version=TLS1_0, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA_P384) id 15.1.707.3 via Frontend Transport; Thu, 10 Nov 2016 13:23:06 +0000 X-IncomingTopHeaderMarker: OriginalChecksum:;UpperCasedChecksum:;SizeAsReceived:2483;Count:36 Received: from AMRXH4002.dir.svc.accenture.com (10.63.34.61) by AMRXE4001.dir.svc.accenture.com (10.63.35.191) with Microsoft SMTP Server id 14.3.319.2; Thu, 10 Nov 2016 08:22:28 -0500 Received: from 048-smtp-out.accenture.com (141.251.97.215) by AMRXH4002.dir.svc.accenture.com (10.63.34.92) with Microsoft SMTP Server (TLS) id 14.3.319.2; Thu, 10 Nov 2016 08:22:27 -0500 Received: from CO2PR42MB028.048d.mgd.msft.net (141.251.97.215) by CO2PR42MB028.048d.mgd.msft.net (141.251.97.215) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384_P384) id 15.1.707.6; Thu, 10 Nov 2016 13:22:25 +0000 Received: from CO2PR42MB028.048d.mgd.msft.net ([141.251.97.215]) by CO2PR42MB028.048d.mgd.msft.net ([141.251.97.215]) with mapi id 15.01.0707.013; Thu, 10 Nov 2016 13:22:25 +0000 From: To: Subject: RocksDB IO error Thread-Topic: RocksDB IO error Thread-Index: AQHSO1V6vl8PHsWl+EWiRRtXkoleYg== Date: Thu, 10 Nov 2016 13:22:25 +0000 Message-ID: Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: x-ms-exchange-messagesentrepresentingtype: 1 x-originating-ip: [90.216.134.197] X-MS-Office365-Filtering-Correlation-Id: 2d46fc01-4e31-431e-e958-08d4096cb54b Content-Type: multipart/alternative; boundary="_000_D44A250C146E3zhenhaoliaccenturecom_" MIME-Version: 1.0 X-OrganizationHeadersPreserved: AMRXH4002.dir.svc.accenture.com X-CrossPremisesHeadersFiltered: AMRXE4001.dir.svc.accenture.com X-OrganizationHeadersPreserved: AMRXE4001.dir.svc.accenture.com X-IncomingHeaderCount: 36 X-EOPAttributedMessage: 0 X-MS-Office365-Filtering-HT: Tenant X-Forefront-Antispam-Report: CIP:170.252.43.196;IPV:CAL;SCL:-1;CTRY:US;EFV:NLI;SFV:NSPM;SFS:(10019020)(6009001)(7916002)(2980300002)(438002)(199003)(189002)(377424004)(288314003)(87936001)(512954002)(106116001)(4546004)(86146001)(106466001)(5660300001)(92566002)(66066001)(2351001)(30436002)(626004)(36756003)(84326002)(2876002)(6116002)(3846002)(2900100001)(76966002)(2906002)(26826002)(3480700004)(102836003)(54356999)(586003)(50986999)(86362001)(189998001)(6916009)(7116003)(246002)(7846002)(8676002)(260700001)(356003)(7636002)(7736002)(8936002)(15974865002)(107886002)(450100001)(86152002)(575784001)(110136003)(569005);DIR:OUT;SFP:1102;SCL:1;SRVR:DM3P114MB0025;H:AMRXE4001.accenture.com;FPR:;SPF:Pass;PTR:amrxe4001.accenture.com;A:1;MX:1;LANG:en; X-Microsoft-Exchange-Diagnostics: 1;BL2FFO11FD064;1:tgjZIv+v/SsXOoFH3hN8E5GMokelWD6RPe5MqI/lwAvwrxCVvjnR28lb/6mdqJNOQz5FX2krwsFO98+VuSga6ckhtjoZwUAHtgzN+sLSMXF025pUXPHDJQMkMhzVj3e3MNA7muYKXJEA8gswnDyulXPypx2GemI/bk6wtN0anVXeAO0WpFtZrHvRLsu73tFQC5B9DhczupOTlB1ReF6KgklLNYkZhwPAJBtCYmL6F99HYMqFTwPkw/XeT2SFw8eFIPHYviY+atkQf24ULTwGOa0b/IckyzS6DNDl/gQ8A+3RjxJPMK7fSamRZGlvGJgfYt0Mb19DqgBhPrzbGTVncZlpdCwtDey+R5+60rzixSXuDzkUL2jHXI394Vljp4bGYqN828iAuF+Q6Eal1bMmuLjFM6TCYsvSLGdK0BKyJZGk20S7NjcrwvqAogvB3leCd9KlwyjE9HItlNxbzksnMFj3+KlqnF3RBnIAqB5L6XrRJX4zVtjLkyfS9pMbs8S/wi/2UhNZ3YR852qeY4ZbataWoaK6HUogPihUbR0flJOGld9Nc8jUzrxrRH2S3wmOPiVp+qSsUQQh6GLTK0jYtA== X-CrossPremisesHeadersPromoted: BL2FFO11FD064.protection.gbl X-CrossPremisesHeadersFiltered: BL2FFO11FD064.protection.gbl X-Microsoft-Exchange-Diagnostics: 1;DM3P114MB0025;2:STj64uhSWo8HORtc5unE6JuE7IB3QmxQURSLVgnIgglR0Scu2M22VuJyuDwOV3uTl8M7Qy9a9HTJK7ViJhFXjLPZDEMrgTultTGlAEwkjydY1cW1Ex3AwN3mpjyrgeJccgwNnT41uozGiq6Ai9IRh+ooNnKXEYC6g1wR1L1rQAE=;3:XUaVYhj44kxS49okxHAun1hGqJuQsG9e/xPHdeP24iC8svtjTjFYudVVN+7Ke6YIdIizDPUuMiLV5xFzGyjTAPQ6V1rDnC1wYa+VC+3bVKiYiC8AiTDY3KXYioqtqUtdLO7J5Hv/pnBorgzzJoA5dByrkeOyXvda23XSGP4ceZVs8QIKnxS3GetPyRTlWKNvqszMX57sWH90sazOYlWsYB3uHvpOvcsOJ+BhpTJfvTC5xTCsC7jFVpJrH0R0lU4LwonsHwcaF9hHOaIsz/ppniS+7o16pWbkrNmU1zhha6o=;25:V87umgOGF5+xxTFi9fmD/jrLBGnWrmvJxJxs8EKEYq3iUc38jS5dBnaFfUdz7l8TXsvIjuXhikQa4Yu7T8EXtB0z+FAGew2NO5sQebZ59ymiGHG01SNkBYZ4dEO+8hKvdIN9AZsn3GKNOLlBUPmlu/rejuw5yssMYLLzH822pbY57cJoMSlVnTrncy0424QnA+t0V7oX5YBChVO313rG0o6wOSuxJ/zrTg5+xU5W4G9qugrllcytW7HrRq6YtbejXe5aTLxvu9Cr/6R9bs0QT/PiNCwuUOfwNPg+5xM+6c8ovDMlNKr1PiXi3GGOH+k8O/v1akIYqIqUD4oym7lkBy431DBbDheHShMN0S3/jTyKXbnn2eSx1iknCur9bNvuqFz09WH/ZCqVkGbWQc36WveepzAon7IJs7CzqqOa9Mvy5zWqrFpjYaVzoitTdaWm X-Microsoft-Antispam: UriScan:;BCL:0;PCL:0;RULEID:(22001)(8251501002);SRVR:DM3P114MB0025; X-Microsoft-Exchange-Diagnostics: 1;DM3P114MB0025;31:PIvWxJgmx+bFahIuGTmjjn8YOgAX3bVybcUkAAP9c2qfZQcZSXMm/OJ8X3yoc4YbsdiRiTLnO4X2ChIEb5qxUSQMXER000bHH3IDa4ccyj86bOpkoQB3PbVACJsDsj1d9L/3S1FpBYgbjinzJS/VXBC+Xhp6etHCrjC1yE1Qhh9l6lKKTmfTv/MPPh3wDjdcuog790fbfpaLv0vE9vJt1Xn7xoGIRGgBz1BGWe2JMYu6V1mWmuJsKj1K6Q6+iq8EB9dOm5qo7mmh27BYbFzMKw==;20:zN0MJq0aRRgpW77pm79zCyoHBeCth1X/jmT5t6OHnY+I+B6s7EJpX6zdvuKbRIy06Z7RfLe/20Tlo1VzNWLG9529iAGodM0hdK4KgXbVLwT/zTtUuvQiOzimREmLYKdZjfE4RnLxgaE8zSJqsLm6Az+AMbwBG2851/saTkKea9oPpcBu678PfgZyFuVWkm+sGVF0HAHw2VT4UZ6TwJxHJ/Xe39B36oRZYHTR4bWHFlyIvEJqjao8Z2Hdk/0uCtcCJyYoq4tgkKYRPcnxynjilqNG33mYV/sSCBCzQfY6B9IbUl46jadYRne0wjWquTJpyee6f2rwZ73QBb2x2/CEctL/fDul6an/oVyxZk2xT6jOGRlEaTOdy44XomC0VfcndzqrNNX2T3O7bvHDGcjlyV9Jaq5BsR0s3VSKXI2i0vf9g3eERgMNflbB50mwsAG9qHRcUKBNU+sJ9GFpHFoPwycB5IbuUXqA/1fCgey8/cGaqVETQ0nmTUNDgSfPiqRObpltwYWf7cqm+V19rNJt1NvwhzmkaZWUEJPAO1qdBVQFk16P+YbQLQHuauv8L8Y/EXGbhVk1R9supUJ6Y5t+a0cfinv9mUoxqS3xRf2s3j8= X-Microsoft-Antispam-PRVS: X-Exchange-Antispam-Report-Test: UriScan:(169223907730125)(192374486261705)(191869523173324); X-Exchange-Antispam-Report-CFA-Test: BCL:0;PCL:0;RULEID:(61425038)(6040176)(2401047)(5005006)(13020025)(13023025)(13013025)(8121501046)(13024025)(3002001)(10201501046)(6055026)(61426038)(61427038);SRVR:DM3P114MB0025;BCL:0;PCL:0;RULEID:;SRVR:DM3P114MB0025; X-Microsoft-Exchange-Diagnostics: 1;DM3P114MB0025;4:OT0hE8yadDnUKnjvAIvmBC6y2UjvR8HKrlbhBQR1pYgf6dULvuQf1WLdpGYmKkhCeRTirww53ib3AO69vC2VqriJ9dsibZCfeKAJrZNmpno5wr4uFAGNl9n8zrK6dWNOuBrvCu/+Zppzt7xte3AlhDB8uiBItxI7K4de+nV+rzWqlkjfE6m7XI38xoHm6WJFFkQ/VncOSaj41h5xhcR2Q/adCZWCcQtbr+6ZHvN8AqRJhPp5bRj3XKc3cTaB/s0suBXAujWk6MjBIQI40ewxKMc6WNomAT7pmxUvl78T8O9J5A5/76M/b5uQC1slZE8U4A3Q8rOLLxfSh3QBy6Iq+QqrquNwjedZmH3Ori5CriFlF2whNAopcMf8bbl1CLhuuoem+rX696hmpsAFoVWchouSjDod/Po4srtk7M5NGIo17idGCXpCJwVIOOlN8g86mnDKxqRebmAr6ME0KeOhgKMNBuilbm/SdIaEBfKmWgGYbpfFfpRXyeixR9a1NM4MeqoOQAG1kRnx1TOWF+fi61qWzom2cdrbqfk+tiRlybHk7qlHmzTmyscKLXrkg4YDWA3P/dyWhl8XZXEsHNv2WNxCMA0Zm2d3nU6mUjURl2qFrJRfuh1KzJhKwdg8L14h4005EKxfiyqOX2Gw01vNJQ== X-Forefront-PRVS: 01221E3973 X-Microsoft-Exchange-Diagnostics: =?us-ascii?Q?1;DM3P114MB0025;23:WMup0vxMNMn+1w1AQEFzIzCBkWVdXHmbA9bfH0Fb7?= =?us-ascii?Q?Y3jUaxW11XOnK9WMsHCfbrCoVequoOJZTot4e136EgSOnxjwLbnA8m5vohv5?= =?us-ascii?Q?GC5xXS3GcogrKJM341wT0HSwcIYXJcSvq+W9sCJ9pDUSvumQVKT62Z51kz9U?= =?us-ascii?Q?s4chdALZzR3snXpqtAZfHfKelI/Fu+oeYlBdK4r8th6/m/VKlgi5Lq7PuR6T?= =?us-ascii?Q?IG3J06vZNo0nr1ubkmbndKGoaqETyVLZOFQ0INtuzDolZlvj0Iv5nY/7unMl?= =?us-ascii?Q?pAJP5eWEJ5pmf6+l5wgWx4ECZIqWXVNU0KkVP1mBTbOhPwj92JFWnOahyNWQ?= =?us-ascii?Q?or9Jo0ZHcTXZSv7w2g4Go1QKk46TfigjrozHhjtmTyuU0myQanlovTF5BkuJ?= =?us-ascii?Q?iv0CmYseRcwNLdnGtFKwcKAU1UCIDqjaPLazjS4dUQ/16BMMb5AOs70Dl+1+?= =?us-ascii?Q?2k/4Z1UL+BK8Sj3dmBUvL1kiQciGpD8q/1/69BuPIc8cBKXGwoB0UjFK//iO?= =?us-ascii?Q?f5FENDs8NF8wDdQw+OJkqxYwYBEuS5LQ/BPwesa2JKDAuJaDqce2jhNcX5aE?= =?us-ascii?Q?kE4Ppv5Gh10sRrfTx0tP+pDSfNTu1VMuO/+iYgyow4J7B2K45LEvfMfB9/ns?= =?us-ascii?Q?f+EkMm50mT5gPxcjIt/KxJFrNGggIfatWfTewpBXb5+kljnxodhhvDFgsQYy?= =?us-ascii?Q?35dPIe20h2AVZRQErtseMSoerdYxbQ/GJGygBHG/ylR7KxsQgJn7YexUt/ud?= =?us-ascii?Q?mWdCcw9bkchsrenaj45wwzPqP7ofPmKPm9C402vo2yi0j5X3AKalsDZzmgXj?= =?us-ascii?Q?rjBEf+W9Swgj0TB+x5/UKBqbghnWEU54hkkPArUGEwNTPM23zjHQSmOf61EE?= =?us-ascii?Q?M76GpJDbciT7fjEdfM1BZ8oh53qN0bYBw5FnN8DUv3O6PBeOSDK+B8Zq33+Y?= =?us-ascii?Q?543L3ErwfEw2mRm3CFTkxUmjvfZXDzZXJ0FS/8uZ3vNplVJqkJjanq8KYvm9?= =?us-ascii?Q?IOhl5EyN6NoJeJdwhWc5q71RYTq9/HxF59vV7jj/wyoB3Jv0QpCuliXBGGnL?= =?us-ascii?Q?bIKNRrPGJ4+hEE/6JaqEyDhg0XpEo/B/XUFpwWc3tQPZDKJRQHpQMo2x8OUZ?= =?us-ascii?Q?yfh+mOjtawId+mIjuGHPpZJTXPfTXFdMTEXwEcgZovEO4zCsfHSmlTPRMGTf?= =?us-ascii?Q?NprBcmtz16aiyH0GE9/DZvpvD69L0/lxw2Q2b5wqUJQK1pwX7KmctpvcyWvK?= =?us-ascii?Q?nem8UzYMd+qsQszaJihwlhpn+5CgCq9eQXriKne?= X-Microsoft-Exchange-Diagnostics: 1;DM3P114MB0025;6:gsHcTtXOTro3RX9XjP8XzN8FGuj9dWYj0Iv3I+SFoybV7vSxU8CGzhk6MAiRisImBM2QMYviKI2v35+5U0q220RHQo0ndFedl1m3HMtBSjMpkua7VfEsO1PstziOHLHA9KakrNMRA6AdmITogBhuraf22dErYbnbl144M6IO/4Shcqm2DHndVqxgI8/BiFnoP6JRFnBhC4MLJ5rcs3MnNWOikOoyq4+MPa/PJnmL4vkS6WNHbG1NV/fV6R98QKfoVPBMrfDiaDvAz8DvEk6h6tvyWRXXgSIiJFAFhxuxWhPmnYQttGhaLtvf+7gG7QQimzNW3YAo8rVvjRca1gnAH5yRKgY1sh3pQaslNdh8hiI=;5:mTk69uO1RplYewBolrx0M2UofVd433IXgYOXzSf6nSYrIwoZqTtL4ZKSyTUKU4YhHZLvsHxhYvkUY8sjit9LCJZcczashWvqS+0PCzUwU96vN96F5vF1rCqA+SgUx6y8+p0WC5OctL4gmSJj1kR5wg==;24:BJzLbsZnns36neOj9Bzq4RAX09fSZT0URVL1MmrOu8Ps8dvfXTnnvhdwzXKed3Q0sO9hLPwLJEd0+WseoBFC9PoVjXJWPgGWxmrW4bc7Axo= SpamDiagnosticOutput: 1:99 SpamDiagnosticMetadata: NSPM X-Microsoft-Exchange-Diagnostics: 1;DM3P114MB0025;7:wQNV1/dFOkQOjfEH5t8fKHWKbScC05JlJa8dwdO4EMWeQ/IdjPph8H5Epbka889Kf/h7hwJktuYvYalpD5BmrS1BYQna1bxpseFWc/K6Y4RYmpYIWto4t4RAxUQQwq8JjvUrCd8pp/oi70R4YA0H1FKUjpYW6pNpkeDEqjam4Su06TXFNPsAyluKDDkMo7oIBmI30ivX/GaRf7cxYAWDuENoOQcktkhnphcV08l8mDLjcT/RsAAaE08gufHQtRSKdniQ7O4SSRz5bPtI6TxVIi3Kt+v+u6q0ZYSEf7lsmjSYfqRTsQJylleh3bRP28COBjpBDGudqbPMTzrpEvKRRbYdrkuR8ZkSdmaGGZKsjPg= X-OriginatorOrg: accenture.com X-MS-Exchange-CrossTenant-OriginalArrivalTime: 10 Nov 2016 13:23:06.6667 (UTC) X-MS-Exchange-CrossTenant-Id: e0793d39-0939-496d-b129-198edd916feb X-MS-Exchange-CrossTenant-OriginalAttributedTenantConnectingIp: TenantId=e0793d39-0939-496d-b129-198edd916feb;Ip=[170.252.43.196];Helo=[AMRXE4001.accenture.com] X-MS-Exchange-CrossTenant-FromEntityHeader: HybridOnPrem X-MS-Exchange-Transport-CrossTenantHeadersStamped: DM3P114MB0025 archived-at: Thu, 10 Nov 2016 13:24:28 -0000 --_000_D44A250C146E3zhenhaoliaccenturecom_ Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable Hi team, Could you please investigate on this? It seems that we may face data loss w= hen using RocksDB with enableFullyAsyncSnapshots. It was Flink 1.1.3. Regards, Zhenhao 2016-11-03 13:42:47,071 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (13/24) (e7f285485da95aaf42d634a8340ef692) switched from RUNNING to FAI= LED 2016-11-03 13:42:47,071 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (1/24) (4f40190f5340b685c1e43c57e462a745) switched from RUNNING to CANC= ELING 2016-11-03 13:42:47,071 INFO org.apache.flink.yarn.YarnJobManager = - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09 (Prod_Que= ry_Engine) changed to FAILING. java.lang.RuntimeException: Unable to find a leader for partitions: [Partit= ion: KafkaTopicPartition{topic=3D'raw_log_prod', partition=3D12}, KafkaPart= itionHandle=3D[raw_log_prod,12], offset=3D13291723] at org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fet= cher.findLeaderForPartitions(Kafka08Fetcher.java:453) at org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fet= cher.runFetchLoop(Kafka08Fetcher.java:184) at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBa= se.run(FlinkKafkaConsumerBase.java:240) at org.apache.flink.streaming.api.operators.StreamSource.run(Stream= Source.java:80) at org.apache.flink.streaming.api.operators.StreamSource.run(Stream= Source.java:53) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(So= urceStreamTask.java:56) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(Strea= mTask.java:266) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584) at java.lang.Thread.run(Thread.java:745) 2016-11-03 13:42:47,071 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (2/24) (3b71c9111769678b9fcd55ab15778eb2) switched from RUNNING to CANC= ELING 2016-11-03 13:42:47,072 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (3/24) (6a232b503d9d21a6ad069d2760115616) switched from RUNNING to CANC= ELING 2016-11-03 13:42:47,072 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (4/24) (ad2186f1447f72d2066d3f7e20ae9343) switched from RUNNING to CANC= ELING 2016-11-03 13:42:47,072 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (5/24) (d932b2c9eeaf8a28d12630c51aa61ff5) switched from RUNNING to CANC= ELING 2016-11-03 13:42:47,072 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (6/24) (1bcf1913643f83879b8eb94588898813) switched from RUNNING to CANC= ELING 2016-11-03 13:42:47,072 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (7/24) (02cbc25dece24970d1e87b9549499834) switched from RUNNING to CANC= ELING 2016-11-03 13:42:47,072 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (8/24) (66a59bc422fb3132ab7747e04b36d064) switched from RUNNING to CANC= ELING 2016-11-03 13:42:47,072 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (9/24) (257e6c5fb4c8b5465958508aa74fbf26) switched from RUNNING to CANC= ELING 2016-11-03 13:42:47,073 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (10/24) (88ef2e009895f1fcd4bf93fc05eb88bd) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,073 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (11/24) (02dabd198974c85617c18fb271ef1ea7) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,073 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (12/24) (90a713fd5dbccb33cf9c909c059feb69) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,073 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (14/24) (a73da99ee13391c99db6f1997843c4f9) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,073 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (15/24) (2759f49abeeaea4795f6b51d07fe7948) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,073 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (16/24) (72f825013459bad6280af21daf5cf8be) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,073 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (17/24) (07b1043609b0f37476b7af581d27182f) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,073 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (18/24) (ba9628f18848bc12c58a6b2ad1421550) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,074 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (19/24) (c0ffb1341439d97469fee8b2400be031) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,074 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (20/24) (002727749f2dfc5c027b3a130a62f909) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,074 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (21/24) (626f071febc35ee677519c17db27e639) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,074 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (22/24) (bb39943f87c2543545cbf6fe4c51868b) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,074 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (23/24) (6128fa7b3629ae4f712e188d677dc3ba) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,074 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (24/24) (f5cde73e13011e459ed8fb67ec7c6936) switched from RUNNING to CAN= CELING 2016-11-03 13:42:47,074 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (1/24) (20691339482ef2975a8aafa58bea2327) switched from RUNNING to CA= NCELING 2016-11-03 13:42:47,074 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (2/24) (52b76f0d9680d7d51b5bb8a000cde9b2) switched from RUNNING to CA= NCELING 2016-11-03 13:42:47,074 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (3/24) (fa07e74406ed7f894ad3f40c3a8b5c7c) switched from RUNNING to CA= NCELING 2016-11-03 13:42:47,075 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (4/24) (ef54f380b80f5154827e5e4a2ca0d26c) switched from RUNNING to CA= NCELING 2016-11-03 13:42:47,075 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (5/24) (2e0b64f839368a56430447fcf3d021b4) switched from RUNNING to CA= NCELING 2016-11-03 13:42:47,075 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (6/24) (25cb281f31736ed3374dd0ddacbd6410) switched from RUNNING to CA= NCELING 2016-11-03 13:42:47,075 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (7/24) (a705eda503df72135faebbcbf6ff3b50) switched from RUNNING to CA= NCELING 2016-11-03 13:42:47,075 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (8/24) (f02aeea2b57678885203f025d5505a14) switched from RUNNING to CA= NCELING 2016-11-03 13:42:47,075 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (9/24) (b04e4010ea3f9836b5173c5c904a54d6) switched from RUNNING to CA= NCELING 2016-11-03 13:42:47,075 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (10/24) (902d697b6196fb4fb4e42dc3e10dff2e) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,075 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (11/24) (925a32f2d260c91debb211a9e4bdd950) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,076 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (12/24) (2a6fde4972073924fea473a9e4f351d8) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,076 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (13/24) (88c63f793aa4348764a4ad3f949fdfc9) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,076 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (14/24) (375968643fd929aac19c5a9ef85738d3) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,076 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (15/24) (acd3dbc304ddf6184721c8c24d1027d4) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,076 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (16/24) (07147b57eb7a0aa75434b0c1253dc7a0) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,076 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (17/24) (3e68a564f9292dda58bad464e9fb2605) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,076 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (18/24) (1946356177df8086e4514ffd811f9309) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,076 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (19/24) (2cd85be968f6a8b7ec00b57319b22075) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,077 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (20/24) (b46d81f3850846d334af4498e2971596) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,077 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (21/24) (e003ab4b29181900820dd4c78bba5b42) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,077 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (22/24) (fc140c374ab270c3907143ac04a62419) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,077 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (23/24) (0995c67b6fc9dee9f4d37d5794a5550c) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,077 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (24/24) (c03b0183ee6939a90e54719f8c857223) switched from RUNNING to C= ANCELING 2016-11-03 13:42:47,077 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (b56ad1de= 01fd610a21448aa6d904137a) switched from RUNNING to CANCELING 2016-11-03 13:42:47,077 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (63ada3e9= d24c6582324778b65330268c) switched from RUNNING to CANCELING 2016-11-03 13:42:47,077 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (e7691dcd= 8165f4df11b7674f01c77fb3) switched from RUNNING to CANCELING 2016-11-03 13:42:47,077 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (8223acac= 0433316a595def80881d7fef) switched from RUNNING to CANCELING 2016-11-03 13:42:47,078 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (d4573114= 9b0a57499a195b7db49fd2e6) switched from RUNNING to CANCELING 2016-11-03 13:42:47,078 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (725d7ebf= 870cd425215a0f69beda892b) switched from RUNNING to CANCELING 2016-11-03 13:42:47,078 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (2a78a376= 4c5cb50c30cd2b750b2d12c2) switched from RUNNING to CANCELING 2016-11-03 13:42:47,078 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (5ba4294f= caa08e972a46bb2abd75dde3) switched from RUNNING to CANCELING 2016-11-03 13:42:47,078 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (edfbc825= 731b434f904f06098c129dfe) switched from RUNNING to CANCELING 2016-11-03 13:42:47,078 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (59573a3= d480f4c4c25dbd553edef7eff) switched from RUNNING to CANCELING 2016-11-03 13:42:47,078 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (2482284= 9627b681f56f7c327393fc8d2) switched from RUNNING to CANCELING 2016-11-03 13:42:47,078 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (1272609= 6e3b8d3f125a6e6c9a91eb729) switched from RUNNING to CANCELING 2016-11-03 13:42:47,078 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (ea4dcd8= 1466172eb6b7972489eff897c) switched from RUNNING to CANCELING 2016-11-03 13:42:47,079 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (3e34df2= 6676687d87e3215432dc00f51) switched from RUNNING to CANCELING 2016-11-03 13:42:47,079 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (92dd5c5= bb3a6e50965ef3900efa134bd) switched from RUNNING to CANCELING 2016-11-03 13:42:47,079 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (ca54cee= 421ddb67962a369cafa9d532a) switched from RUNNING to CANCELING 2016-11-03 13:42:47,079 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (2600fed= ee2b14a309e9a81761fcc4a59) switched from RUNNING to CANCELING 2016-11-03 13:42:47,079 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (ba68318= 17b3b7aeb918e67416f01a5aa) switched from RUNNING to CANCELING 2016-11-03 13:42:47,079 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (e1b21f0= 3b7dba0fccca778e1a7d1519b) switched from RUNNING to CANCELING 2016-11-03 13:42:47,079 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (636dd3d= e17bc2d6f08f1f0da08eba58e) switched from RUNNING to CANCELING 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (6837f13= 4eb74536e5092de110689c5ce) switched from RUNNING to CANCELING 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (59a0009= 1f4d063e6bc9c809e54afa1d3) switched from RUNNING to CANCELING 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (e962ced= 55951bf695f0b1fe5629912c5) switched from RUNNING to CANCELING 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (41fb026= 7c6a18256b770ade5a5fbde3e) switched from RUNNING to CANCELING 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (e4e860b6= be3f4f364266cbd3af20a154) switched from RUNNING to CANCELING 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (bc2176de= be67db69e54403e4fe70e7d6) switched from RUNNING to CANCELING 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (14/24) (a73da99ee13391c99db6f1997843c4f9) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (1b2a99a4= efc52201d20a4c678938f3d4) switched from RUNNING to CANCELING 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (c48870a8= cc3460ed0052281b1a3ff964) switched from RUNNING to CANCELING 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (e0f380d9= e90c44591056f7bd9bc1d2a3) switched from RUNNING to CANCELING 2016-11-03 13:42:47,080 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (42156a2c= 610fe455c27e50e377816ffa) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (51efcc87= dde178b498fd6e07b75b88a2) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (ed980803= b091e73687dd0be751354f69) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (ccf24c53= e3188fe92acd480af49b2fb5) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (64c9ab7= f7350fbcb054054a5f31fd6c9) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (bc4a23d= 4a1d251b4215c15a126cc0d47) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (05bcd51= f35ceb57292bffaf57ff424f5) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (ebb5d51= 7f966f535241dac389dcffec3) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (22e6571= c51c1292dcf78597b3f7eed0c) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (94bd1b1= f69f72971a9c7c551b5f0f61c) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (3b2a57d= fc9dbfe2210f95c32cec33af2) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (d97b945= c9fe5add0301aed02fcb58646) switched from RUNNING to CANCELING 2016-11-03 13:42:47,081 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (2497248= 9627b0e1b261fd6ee183b47cc) switched from RUNNING to CANCELING 2016-11-03 13:42:47,082 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (9d263d3= b7ebb7a9d316ac075c20a7fba) switched from RUNNING to CANCELING 2016-11-03 13:42:47,082 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (83b7d36= a7bd0960772532bcdceaf5e88) switched from RUNNING to CANCELING 2016-11-03 13:42:47,082 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (88d5ba9= 698387989f27f7c68c5539cf6) switched from RUNNING to CANCELING 2016-11-03 13:42:47,082 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (7ca8b68= a6478f6774b6141cd4154d053) switched from RUNNING to CANCELING 2016-11-03 13:42:47,082 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (925f744= 01292ce293caadbac4e353efb) switched from RUNNING to CANCELING 2016-11-03 13:42:47,082 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (46579e2= 315960422d172cb33c426f920) switched from RUNNING to CANCELING 2016-11-03 13:42:47,083 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (3e34df2= 6676687d87e3215432dc00f51) switched from CANCELING to CANCELED 2016-11-03 13:42:47,085 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (2482284= 9627b681f56f7c327393fc8d2) switched from CANCELING to CANCELED 2016-11-03 13:42:47,085 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (92dd5c5= bb3a6e50965ef3900efa134bd) switched from CANCELING to CANCELED 2016-11-03 13:42:47,087 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (19/24) (c0ffb1341439d97469fee8b2400be031) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,087 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (725d7ebf= 870cd425215a0f69beda892b) switched from CANCELING to CANCELED 2016-11-03 13:42:47,087 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (1/24) (20691339482ef2975a8aafa58bea2327) switched from CANCELING to = CANCELED 2016-11-03 13:42:47,087 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (2/24) (52b76f0d9680d7d51b5bb8a000cde9b2) switched from CANCELING to = CANCELED 2016-11-03 13:42:47,087 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (3/24) (fa07e74406ed7f894ad3f40c3a8b5c7c) switched from CANCELING to = CANCELED 2016-11-03 13:42:47,087 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (4/24) (ef54f380b80f5154827e5e4a2ca0d26c) switched from CANCELING to = CANCELED 2016-11-03 13:42:47,090 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (ea4dcd8= 1466172eb6b7972489eff897c) switched from CANCELING to CANCELED 2016-11-03 13:42:47,092 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (636dd3d= e17bc2d6f08f1f0da08eba58e) switched from CANCELING to CANCELED 2016-11-03 13:42:47,092 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (2a78a376= 4c5cb50c30cd2b750b2d12c2) switched from CANCELING to CANCELED 2016-11-03 13:42:47,097 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (d4573114= 9b0a57499a195b7db49fd2e6) switched from CANCELING to CANCELED 2016-11-03 13:42:47,097 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (6/24) (25cb281f31736ed3374dd0ddacbd6410) switched from CANCELING to = CANCELED 2016-11-03 13:42:47,097 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (20/24) (002727749f2dfc5c027b3a130a62f909) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,097 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (64c9ab7= f7350fbcb054054a5f31fd6c9) switched from CANCELING to CANCELED 2016-11-03 13:42:47,097 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (8/24) (f02aeea2b57678885203f025d5505a14) switched from CANCELING to = CANCELED 2016-11-03 13:42:47,097 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (5/24) (2e0b64f839368a56430447fcf3d021b4) switched from CANCELING to = CANCELED 2016-11-03 13:42:47,098 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (7/24) (a705eda503df72135faebbcbf6ff3b50) switched from CANCELING to = CANCELED 2016-11-03 13:42:47,103 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (bc4a23d= 4a1d251b4215c15a126cc0d47) switched from CANCELING to CANCELED 2016-11-03 13:42:47,106 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (8223acac= 0433316a595def80881d7fef) switched from CANCELING to CANCELED 2016-11-03 13:42:47,107 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (1272609= 6e3b8d3f125a6e6c9a91eb729) switched from CANCELING to CANCELED 2016-11-03 13:42:47,109 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (e962ced= 55951bf695f0b1fe5629912c5) switched from CANCELING to CANCELED 2016-11-03 13:42:47,110 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (e7691dcd= 8165f4df11b7674f01c77fb3) switched from CANCELING to CANCELED 2016-11-03 13:42:47,111 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (16/24) (72f825013459bad6280af21daf5cf8be) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,111 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (4/24) (ad2186f1447f72d2066d3f7e20ae9343) switched from CANCELING to CA= NCELED 2016-11-03 13:42:47,111 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (21/24) (626f071febc35ee677519c17db27e639) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,111 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (10/24) (88ef2e009895f1fcd4bf93fc05eb88bd) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,111 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (14/24) (375968643fd929aac19c5a9ef85738d3) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,111 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (9d263d3= b7ebb7a9d316ac075c20a7fba) switched from CANCELING to CANCELED 2016-11-03 13:42:47,111 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (13/24) (88c63f793aa4348764a4ad3f949fdfc9) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,111 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (15/24) (acd3dbc304ddf6184721c8c24d1027d4) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,112 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (16/24) (07147b57eb7a0aa75434b0c1253dc7a0) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,112 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (2497248= 9627b0e1b261fd6ee183b47cc) switched from CANCELING to CANCELED 2016-11-03 13:42:47,112 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (ccf24c53= e3188fe92acd480af49b2fb5) switched from CANCELING to CANCELED 2016-11-03 13:42:47,116 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (ebb5d51= 7f966f535241dac389dcffec3) switched from CANCELING to CANCELED 2016-11-03 13:42:47,118 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (22e6571= c51c1292dcf78597b3f7eed0c) switched from CANCELING to CANCELED 2016-11-03 13:42:47,119 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (2600fed= ee2b14a309e9a81761fcc4a59) switched from CANCELING to CANCELED 2016-11-03 13:42:47,120 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (41fb026= 7c6a18256b770ade5a5fbde3e) switched from CANCELING to CANCELED 2016-11-03 13:42:47,120 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (ba68318= 17b3b7aeb918e67416f01a5aa) switched from CANCELING to CANCELED 2016-11-03 13:42:47,121 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (e0f380d9= e90c44591056f7bd9bc1d2a3) switched from CANCELING to CANCELED 2016-11-03 13:42:47,121 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (3/24) (6a232b503d9d21a6ad069d2760115616) switched from CANCELING to CA= NCELED 2016-11-03 13:42:47,121 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (6837f13= 4eb74536e5092de110689c5ce) switched from CANCELING to CANCELED 2016-11-03 13:42:47,121 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (24/24) (f5cde73e13011e459ed8fb67ec7c6936) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,121 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (15/24) (2759f49abeeaea4795f6b51d07fe7948) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,121 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (9/24) (b04e4010ea3f9836b5173c5c904a54d6) switched from CANCELING to = CANCELED 2016-11-03 13:42:47,122 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (63ada3e9= d24c6582324778b65330268c) switched from CANCELING to CANCELED 2016-11-03 13:42:47,122 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (12/24) (2a6fde4972073924fea473a9e4f351d8) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,122 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (11/24) (925a32f2d260c91debb211a9e4bdd950) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,122 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (10/24) (902d697b6196fb4fb4e42dc3e10dff2e) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,122 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (94bd1b1= f69f72971a9c7c551b5f0f61c) switched from CANCELING to CANCELED 2016-11-03 13:42:47,122 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (9/24) (257e6c5fb4c8b5465958508aa74fbf26) switched from CANCELING to CA= NCELED 2016-11-03 13:42:47,123 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (5ba4294f= caa08e972a46bb2abd75dde3) switched from CANCELING to CANCELED 2016-11-03 13:42:47,123 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (59a0009= 1f4d063e6bc9c809e54afa1d3) switched from CANCELING to CANCELED 2016-11-03 13:42:47,125 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (59573a3= d480f4c4c25dbd553edef7eff) switched from CANCELING to CANCELED 2016-11-03 13:42:47,125 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (b56ad1de= 01fd610a21448aa6d904137a) switched from CANCELING to CANCELED 2016-11-03 13:42:47,127 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (e4e860b6= be3f4f364266cbd3af20a154) switched from CANCELING to CANCELED 2016-11-03 13:42:47,127 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (e1b21f0= 3b7dba0fccca778e1a7d1519b) switched from CANCELING to CANCELED 2016-11-03 13:42:47,128 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (11/24) (02dabd198974c85617c18fb271ef1ea7) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,128 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (5/24) (d932b2c9eeaf8a28d12630c51aa61ff5) switched from CANCELING to CA= NCELED 2016-11-03 13:42:47,128 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (2/24) (3b71c9111769678b9fcd55ab15778eb2) switched from CANCELING to CA= NCELED 2016-11-03 13:42:47,128 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (edfbc825= 731b434f904f06098c129dfe) switched from CANCELING to CANCELED 2016-11-03 13:42:47,129 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (42156a2c= 610fe455c27e50e377816ffa) switched from CANCELING to CANCELED 2016-11-03 13:42:47,129 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (05bcd51= f35ceb57292bffaf57ff424f5) switched from CANCELING to CANCELED 2016-11-03 13:42:47,128 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (ca54cee= 421ddb67962a369cafa9d532a) switched from CANCELING to CANCELED 2016-11-03 13:42:47,129 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (12/24) (90a713fd5dbccb33cf9c909c059feb69) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,129 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (18/24) (ba9628f18848bc12c58a6b2ad1421550) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,129 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (17/24) (07b1043609b0f37476b7af581d27182f) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,129 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (21/24) (e003ab4b29181900820dd4c78bba5b42) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,129 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (18/24) (1946356177df8086e4514ffd811f9309) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,129 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (23/24) (6128fa7b3629ae4f712e188d677dc3ba) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,129 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (19/24) (2cd85be968f6a8b7ec00b57319b22075) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,130 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (20/24) (b46d81f3850846d334af4498e2971596) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,130 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (17/24) (3e68a564f9292dda58bad464e9fb2605) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,130 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (925f744= 01292ce293caadbac4e353efb) switched from CANCELING to CANCELED 2016-11-03 13:42:47,130 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (22/24) (fc140c374ab270c3907143ac04a62419) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,131 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (22/24) (bb39943f87c2543545cbf6fe4c51868b) switched from CANCELING to C= ANCELED 2016-11-03 13:42:47,131 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (23/24) (0995c67b6fc9dee9f4d37d5794a5550c) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,132 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (24/24) (c03b0183ee6939a90e54719f8c857223) switched from CANCELING to= CANCELED 2016-11-03 13:42:47,132 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (c48870a8= cc3460ed0052281b1a3ff964) switched from CANCELING to CANCELED 2016-11-03 13:42:47,132 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (7ca8b68= a6478f6774b6141cd4154d053) switched from CANCELING to CANCELED 2016-11-03 13:42:47,133 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (83b7d36= a7bd0960772532bcdceaf5e88) switched from CANCELING to CANCELED 2016-11-03 13:42:47,133 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (1b2a99a4= efc52201d20a4c678938f3d4) switched from CANCELING to CANCELED 2016-11-03 13:42:47,137 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (d97b945= c9fe5add0301aed02fcb58646) switched from CANCELING to CANCELED 2016-11-03 13:42:47,139 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (bc2176de= be67db69e54403e4fe70e7d6) switched from CANCELING to CANCELED 2016-11-03 13:42:47,140 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (51efcc87= dde178b498fd6e07b75b88a2) switched from CANCELING to CANCELED 2016-11-03 13:42:47,140 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (88d5ba9= 698387989f27f7c68c5539cf6) switched from CANCELING to CANCELED 2016-11-03 13:42:47,144 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (3b2a57d= fc9dbfe2210f95c32cec33af2) switched from CANCELING to CANCELED 2016-11-03 13:42:47,146 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (46579e2= 315960422d172cb33c426f920) switched from CANCELING to CANCELED 2016-11-03 13:42:47,156 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (ed980803= b091e73687dd0be751354f69) switched from CANCELING to CANCELED 2016-11-03 13:42:47,160 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (6/24) (1bcf1913643f83879b8eb94588898813) switched from CANCELING to CA= NCELED 2016-11-03 13:42:47,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (7/24) (02cbc25dece24970d1e87b9549499834) switched from CANCELING to CA= NCELED 2016-11-03 13:42:47,297 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (1/24) (4f40190f5340b685c1e43c57e462a745) switched from CANCELING to CA= NCELED 2016-11-03 13:42:48,223 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (8/24) (66a59bc422fb3132ab7747e04b36d064) switched from CANCELING to CA= NCELED 2016-11-03 13:42:48,223 INFO org.apache.flink.runtime.executiongraph.resta= rt.ExecutionGraphRestarter - Delaying retry of job execution for 10000 ms = ... 2016-11-03 13:42:48,223 INFO org.apache.flink.yarn.YarnJobManager = - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09 (Prod_Que= ry_Engine) changed to RESTARTING. 2016-11-03 13:42:58,224 INFO org.apache.flink.yarn.YarnJobManager = - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09 (Prod_Que= ry_Engine) changed to CREATED. 2016-11-03 13:42:58,224 INFO org.apache.flink.yarn.YarnJobManager = - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09 (Prod_Que= ry_Engine) changed to RUNNING. 2016-11-03 13:42:58,224 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (1/24) (8a477f7a9f26ae73f92a45a5692939cd) switched from CREATED to SCHE= DULED 2016-11-03 13:42:58,224 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (1/24) (8a477f7a9f26ae73f92a45a5692939cd) switched from SCHEDULED to DE= PLOYING 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (1/24) (attempt #10) to cldnode08 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (2/24) (2b99eb238bd3e8612dd1dc2393ac5428) switched from CREATED to SCHE= DULED 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (2/24) (2b99eb238bd3e8612dd1dc2393ac5428) switched from SCHEDULED to DE= PLOYING 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (2/24) (attempt #10) to cldnode06 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (3/24) (0d1559814918cb456c304ccf3030b0f7) switched from CREATED to SCHE= DULED 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (3/24) (0d1559814918cb456c304ccf3030b0f7) switched from SCHEDULED to DE= PLOYING 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (3/24) (attempt #10) to cldnode03 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (4/24) (910271b03af991b3427cd1100f99a064) switched from CREATED to SCHE= DULED 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (4/24) (910271b03af991b3427cd1100f99a064) switched from SCHEDULED to DE= PLOYING 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (4/24) (attempt #10) to cldnode07 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (5/24) (b39571fd91ad48de7f2f7d3600350404) switched from CREATED to SCHE= DULED 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (5/24) (b39571fd91ad48de7f2f7d3600350404) switched from SCHEDULED to DE= PLOYING 2016-11-03 13:42:58,225 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (5/24) (attempt #10) to cldnode04 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (6/24) (c9a12b9d6be6b43b59bf854164051515) switched from CREATED to SCHE= DULED 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (6/24) (c9a12b9d6be6b43b59bf854164051515) switched from SCHEDULED to DE= PLOYING 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (6/24) (attempt #10) to cldnode05 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (7/24) (84d185938655476323407afc3be9cb07) switched from CREATED to SCHE= DULED 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (7/24) (84d185938655476323407afc3be9cb07) switched from SCHEDULED to DE= PLOYING 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (7/24) (attempt #10) to cldnode08 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (8/24) (e016baf5af215a3d524cd9513d1ba63d) switched from CREATED to SCHE= DULED 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (8/24) (e016baf5af215a3d524cd9513d1ba63d) switched from SCHEDULED to DE= PLOYING 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (8/24) (attempt #10) to cldnode06 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (9/24) (7bc9c8563ab4fb5c55bd70d7c541e314) switched from CREATED to SCHE= DULED 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (9/24) (7bc9c8563ab4fb5c55bd70d7c541e314) switched from SCHEDULED to DE= PLOYING 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (9/24) (attempt #10) to cldnode03 2016-11-03 13:42:58,226 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (10/24) (fca5bc78f05504a5199289afed8a5923) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (10/24) (fca5bc78f05504a5199289afed8a5923) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (10/24) (attempt #10) to cldnode07 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (11/24) (6a38e04d57245634ba6cce91a6c98ac4) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (11/24) (6a38e04d57245634ba6cce91a6c98ac4) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (11/24) (attempt #10) to cldnode04 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (12/24) (bc2bea1a21655b7f03415522840da8d3) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (12/24) (bc2bea1a21655b7f03415522840da8d3) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (12/24) (attempt #10) to cldnode05 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (13/24) (a0ecaff73a6c3ebc0fd557887e778eb5) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (13/24) (a0ecaff73a6c3ebc0fd557887e778eb5) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (13/24) (attempt #10) to cldnode08 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (14/24) (9f2d0d7de5f66e80b243733ea8d8fa9c) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (14/24) (9f2d0d7de5f66e80b243733ea8d8fa9c) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,227 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (14/24) (attempt #10) to cldnode06 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (15/24) (8d7df0c283c259a8fb95812d1bc78608) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (15/24) (8d7df0c283c259a8fb95812d1bc78608) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (15/24) (attempt #10) to cldnode03 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (16/24) (b359c281228c857cd49b5af1bfc82290) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (16/24) (b359c281228c857cd49b5af1bfc82290) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (16/24) (attempt #10) to cldnode07 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (17/24) (ec709d95b8456210cdd821846b2f1ee2) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (17/24) (ec709d95b8456210cdd821846b2f1ee2) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (17/24) (attempt #10) to cldnode04 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (18/24) (bd3c09b0d4a580ede8e4d8fab88cf807) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (18/24) (bd3c09b0d4a580ede8e4d8fab88cf807) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (18/24) (attempt #10) to cldnode05 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (19/24) (46072d491d7c11f1e4406da939407aeb) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (19/24) (46072d491d7c11f1e4406da939407aeb) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,228 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (19/24) (attempt #10) to cldnode08 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (20/24) (72f3aad0236dca73a172766d2a4afa1c) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (20/24) (72f3aad0236dca73a172766d2a4afa1c) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (20/24) (attempt #10) to cldnode06 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (21/24) (2b529d27d0989aaa45e74847900b9bd2) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (21/24) (2b529d27d0989aaa45e74847900b9bd2) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (21/24) (attempt #10) to cldnode03 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (22/24) (cc2c67552af2d54e3e412f2fd453042e) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (22/24) (cc2c67552af2d54e3e412f2fd453042e) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (22/24) (attempt #10) to cldnode07 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (23/24) (10494b739882ad7feb43e0247190dfc6) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (23/24) (10494b739882ad7feb43e0247190dfc6) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (23/24) (attempt #10) to cldnode04 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (24/24) (06b7fceb9df52ee6643c788061f11261) switched from CREATED to SCH= EDULED 2016-11-03 13:42:58,229 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (24/24) (06b7fceb9df52ee6643c788061f11261) switched from SCHEDULED to D= EPLOYING 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> (Flat Map -> Map, Fla= t Map -> Map) (24/24) (attempt #10) to cldnode05 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (1/24) (aeeea1e1eeea141ae6199e927a568dfe) switched from CREATED to SC= HEDULED 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (1/24) (aeeea1e1eeea141ae6199e927a568dfe) switched from SCHEDULED to = DEPLOYING 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (1/24) (attempt #10) to cldnode08 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (2/24) (c275f7f1fcbc1f448d8c976c5b7e161b) switched from CREATED to SC= HEDULED 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (2/24) (c275f7f1fcbc1f448d8c976c5b7e161b) switched from SCHEDULED to = DEPLOYING 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (2/24) (attempt #10) to cldnode08 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (3/24) (96d5901b42e3d90546c565fa87737333) switched from CREATED to SC= HEDULED 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (3/24) (96d5901b42e3d90546c565fa87737333) switched from SCHEDULED to = DEPLOYING 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (3/24) (attempt #10) to cldnode08 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (4/24) (827355f9c98cd9962be947578327da87) switched from CREATED to SC= HEDULED 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (4/24) (827355f9c98cd9962be947578327da87) switched from SCHEDULED to = DEPLOYING 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (4/24) (attempt #10) to cldnode08 2016-11-03 13:42:58,230 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (5/24) (eb87d63985d400312d84205dd3a08e21) switched from CREATED to SC= HEDULED 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (5/24) (eb87d63985d400312d84205dd3a08e21) switched from SCHEDULED to = DEPLOYING 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (5/24) (attempt #10) to cldnode06 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (6/24) (f46bf849d5a73caffb2ab07b7820f915) switched from CREATED to SC= HEDULED 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (6/24) (f46bf849d5a73caffb2ab07b7820f915) switched from SCHEDULED to = DEPLOYING 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (6/24) (attempt #10) to cldnode06 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (7/24) (5b9c1f50a9a5cf71ef8c9dcb1f23cc0a) switched from CREATED to SC= HEDULED 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (7/24) (5b9c1f50a9a5cf71ef8c9dcb1f23cc0a) switched from SCHEDULED to = DEPLOYING 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (7/24) (attempt #10) to cldnode06 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (8/24) (9b17e65e7bea2384cf92ae625f2addf8) switched from CREATED to SC= HEDULED 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (8/24) (9b17e65e7bea2384cf92ae625f2addf8) switched from SCHEDULED to = DEPLOYING 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (8/24) (attempt #10) to cldnode06 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (9/24) (0984ebe3d594a7009916c2e95ea5d532) switched from CREATED to SC= HEDULED 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (9/24) (0984ebe3d594a7009916c2e95ea5d532) switched from SCHEDULED to = DEPLOYING 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (9/24) (attempt #10) to cldnode03 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (10/24) (daee6064608145b06088666b7babdca7) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,231 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (10/24) (daee6064608145b06088666b7babdca7) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (10/24) (attempt #10) to cldnode03 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (11/24) (76624c6abd0769f75eaa07711d44e964) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (11/24) (76624c6abd0769f75eaa07711d44e964) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (11/24) (attempt #10) to cldnode03 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (12/24) (f448c1bf173ea7f12dc02e4b18c3545c) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (12/24) (f448c1bf173ea7f12dc02e4b18c3545c) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (12/24) (attempt #10) to cldnode03 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (13/24) (7e606bd4b24076d8c14d44b03676cc6b) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (13/24) (7e606bd4b24076d8c14d44b03676cc6b) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (13/24) (attempt #10) to cldnode07 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (14/24) (290f3384e4819ca8a209c288de0de498) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (14/24) (290f3384e4819ca8a209c288de0de498) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (14/24) (attempt #10) to cldnode07 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (15/24) (1d6ce9ffc4e430064271d408cc8bc29a) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,232 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (15/24) (1d6ce9ffc4e430064271d408cc8bc29a) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (15/24) (attempt #10) to cldnode07 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (16/24) (27592f00a6cd545d043eccffb00bb19d) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (16/24) (27592f00a6cd545d043eccffb00bb19d) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (16/24) (attempt #10) to cldnode07 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (17/24) (024d06427a98144a85b3fd7168e49d45) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (17/24) (024d06427a98144a85b3fd7168e49d45) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (17/24) (attempt #10) to cldnode04 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (18/24) (d5abd030d970fe399c0bbb60885ab8f2) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (18/24) (d5abd030d970fe399c0bbb60885ab8f2) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (18/24) (attempt #10) to cldnode04 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (19/24) (ed5e99e3763c6750a7cab5f1032dd746) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (19/24) (ed5e99e3763c6750a7cab5f1032dd746) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (19/24) (attempt #10) to cldnode04 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (20/24) (c8bff8478ae3788bad8ce5af463735e3) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,233 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (20/24) (c8bff8478ae3788bad8ce5af463735e3) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (20/24) (attempt #10) to cldnode04 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (21/24) (778de29fb0826a276340ae284531c179) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (21/24) (778de29fb0826a276340ae284531c179) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (21/24) (attempt #10) to cldnode05 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (22/24) (fdfa402e13b4914493fa04c153f415ff) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (22/24) (fdfa402e13b4914493fa04c153f415ff) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (9882efa4= e42ab981527f5111f80692ff) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (22/24) (attempt #10) to cldnode05 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (c60a887f= 493cf6e95a78dfb4e7375c46) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (9882efa4= e42ab981527f5111f80692ff) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (4bf8a429= fc44579751cbe964ffcfbaa0) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (d426f24= 5f247e09e292353675f213d28) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (7aae319= 76d48d69f1e77ad54e4aa93b1) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (db8e88b= 7ce833f5a3652ee7ecb285103) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (84a67e7= 7b96e81c59a5af0cf41c8bbea) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,235 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (7e8fce0= aa62eb2279a8b228aa8f2d375) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (1/24)= (attempt #10) to cldnode04 2016-11-03 13:42:58,235 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (4b75e61= 8f2de1b527863250a918c6b7e) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (c60a887f= 493cf6e95a78dfb4e7375c46) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,236 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (4b75e61= 8f2de1b527863250a918c6b7e) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,237 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (82e7e88= 83e9d32b7f71022f4e1fe925e) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (1/24) (8a477f7a9f26ae73f92a45a5692939cd) switched from DEPLOYING to RU= NNING 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (6acf1ab5= 59e8582dc60a54b4b37d6728) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (f3641e77= 026ce337dd7b75eaad5841c2) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (01d8a274= 9f51e2e30bafaa12724ff631) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (23/24) (254a1d29bae123c554d0b0c5c113bf3f) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (0dfd37bd= b6a1b26d519a7beac04a1164) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (9c3bf96b= f0595a898ba2ea8b58af2092) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,237 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (0dfd37bd= b6a1b26d519a7beac04a1164) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (81693344= e2c2a9a8ca92e9ad4da9dc11) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,238 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (4/24)= (attempt #10) to cldnode06 2016-11-03 13:42:58,238 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (2/24) (2b99eb238bd3e8612dd1dc2393ac5428) switched from DEPLOYING to RU= NNING 2016-11-03 13:42:58,237 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (9c3bf96b= f0595a898ba2ea8b58af2092) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,238 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (6/24)= (attempt #10) to cldnode06 2016-11-03 13:42:58,237 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (23/24) (254a1d29bae123c554d0b0c5c113bf3f) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,238 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (23/24) (attempt #10) to cldnode05 2016-11-03 13:42:58,237 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (01d8a274= 9f51e2e30bafaa12724ff631) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,237 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (f3641e77= 026ce337dd7b75eaad5841c2) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,237 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (6acf1ab5= 59e8582dc60a54b4b37d6728) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,237 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (23/24= ) (attempt #10) to cldnode03 2016-11-03 13:42:58,237 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (82e7e88= 83e9d32b7f71022f4e1fe925e) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,239 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (24/24= ) (attempt #10) to cldnode03 2016-11-03 13:42:58,236 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (2/24)= (attempt #10) to cldnode04 2016-11-03 13:42:58,239 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (9/24) (7bc9c8563ab4fb5c55bd70d7c541e314) switched from DEPLOYING to RU= NNING 2016-11-03 13:42:58,236 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (7/24) (84d185938655476323407afc3be9cb07) switched from DEPLOYING to RU= NNING 2016-11-03 13:42:58,239 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (d6eb3065= ca19775516da7c8621b3cb58) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,235 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (7e8fce0= aa62eb2279a8b228aa8f2d375) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,239 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (20/24= ) (attempt #10) to cldnode08 2016-11-03 13:42:58,235 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (84a67e7= 7b96e81c59a5af0cf41c8bbea) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,235 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (db8e88b= 7ce833f5a3652ee7ecb285103) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,235 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (7aae319= 76d48d69f1e77ad54e4aa93b1) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (1c50624= a7caa9f2fc253927633c4625c) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (8f658ae= 6b80ea55549b42db50a86953c) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (4a906e1= 8975415d514443341568ace88) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (546b61c= 32e7a9f12188622c76efaece2) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (9497478= f64c68ae37d53795ee6594de9) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (546b61c= 32e7a9f12188622c76efaece2) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (4bf8a429= fc44579751cbe964ffcfbaa0) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,241 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (19/24= ) (attempt #10) to cldnode05 2016-11-03 13:42:58,241 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (10/24) (daee6064608145b06088666b7babdca7) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (ed455b4= 1f40894d8c75fe01873e21126) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (d426f24= 5f247e09e292353675f213d28) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,241 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (ed455b4= 1f40894d8c75fe01873e21126) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (5177ee6= 82491dc7f93b1bb4f2a0ddb99) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,234 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (29bcca6= a60b068e1e6891827d1be8efd) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,241 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (5177ee6= 82491dc7f93b1bb4f2a0ddb99) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,241 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (18/24= ) (attempt #10) to cldnode07 2016-11-03 13:42:58,241 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (29bcca6= a60b068e1e6891827d1be8efd) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,241 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (12/24= ) (attempt #10) to cldnode04 2016-11-03 13:42:58,241 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (3/24)= (attempt #10) to cldnode04 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (9497478= f64c68ae37d53795ee6594de9) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (9/24) (0984ebe3d594a7009916c2e95ea5d532) switched from DEPLOYING to = RUNNING 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (4a906e1= 8975415d514443341568ace88) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (b5d04c3a= 253ccea139af5f66df5e1423) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (8f658ae= 6b80ea55549b42db50a86953c) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,243 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (b5d04c3a= 253ccea139af5f66df5e1423) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (1c50624= a7caa9f2fc253927633c4625c) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (21/24) (2b529d27d0989aaa45e74847900b9bd2) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (16/24= ) (attempt #10) to cldnode08 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (21/24= ) (attempt #10) to cldnode08 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (10/24= ) (attempt #10) to cldnode08 2016-11-03 13:42:58,240 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (85e9c2d6= dcfd289c15e4b59c404a9ced) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,239 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (15/24) (8d7df0c283c259a8fb95812d1bc78608) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,239 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (d6eb3065= ca19775516da7c8621b3cb58) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,244 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (3/24)= (attempt #10) to cldnode04 2016-11-03 13:42:58,239 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (f1e0a533= af1afa0ff698f3bf9db7b294) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,239 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (59c07c06= 1529ca27485272f69b14d942) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,239 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (7/24)= (attempt #10) to cldnode03 2016-11-03 13:42:58,239 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (9/24)= (attempt #10) to cldnode03 2016-11-03 13:42:58,238 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (3/24) (0d1559814918cb456c304ccf3030b0f7) switched from DEPLOYING to RU= NNING 2016-11-03 13:42:58,238 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (3c26447b= 675a7c01e0d3ab9e8c9281e7) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,238 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (8/24)= (attempt #10) to cldnode06 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (3c26447b= 675a7c01e0d3ab9e8c9281e7) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,238 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (24/24) (f0febafb5535d67a50d9f8c3225d7d98) switched from CREATED to S= CHEDULED 2016-11-03 13:42:58,238 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (8/24) (e016baf5af215a3d524cd9513d1ba63d) switched from DEPLOYING to RU= NNING 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (a2487e2= 5fb076c97a9bc80a686168e0e) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,238 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (81693344= e2c2a9a8ca92e9ad4da9dc11) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (a2487e2= 5fb076c97a9bc80a686168e0e) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (15/24= ) (attempt #10) to cldnode08 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (14/24) (9f2d0d7de5f66e80b243733ea8d8fa9c) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (24/24) (f0febafb5535d67a50d9f8c3225d7d98) switched from SCHEDULED to= DEPLOYING 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Source: Custom Source -> Flat Map -> (Map -> M= ap, Map -> Map) (24/24) (attempt #10) to cldnode05 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (1/24)= (attempt #10) to cldnode08 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (97d5575= ea2503adced5fe58b452f9436) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (6fa9416= df26c842f7fd14a66aa05f182) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (1f4285e= 85b1faf6030b1256d43dd7cce) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (59c07c06= 1529ca27485272f69b14d942) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (6c88b25= 07f7fed1f3c0f69fa75f89869) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (f1e0a533= af1afa0ff698f3bf9db7b294) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (6c88b25= 07f7fed1f3c0f69fa75f89869) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (20/24= ) (attempt #10) to cldnode03 2016-11-03 13:42:58,244 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (7e6af27= 7adf044a6757a02d6c5a8be67) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,244 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (85e9c2d6= dcfd289c15e4b59c404a9ced) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,244 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (11/24) (6a38e04d57245634ba6cce91a6c98ac4) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,247 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (b841412= 77cae159ac4241dc6aa89d189) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,244 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (19/24) (46072d491d7c11f1e4406da939407aeb) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,244 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (5/24) (b39571fd91ad48de7f2f7d3600350404) switched from DEPLOYING to RU= NNING 2016-11-03 13:42:58,244 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (22/24= ) (attempt #10) to cldnode05 2016-11-03 13:42:58,244 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (6/24)= (attempt #10) to cldnode04 2016-11-03 13:42:58,247 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (11/24) (76624c6abd0769f75eaa07711d44e964) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,243 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (11/24= ) (attempt #10) to cldnode05 2016-11-03 13:42:58,243 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (17/24= ) (attempt #10) to cldnode05 2016-11-03 13:42:58,243 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (10/24) (fca5bc78f05504a5199289afed8a5923) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,243 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (d9eef1e= a95ae5fbd921442d3c722d586) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,248 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (12/24) (f448c1bf173ea7f12dc02e4b18c3545c) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,242 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (643a6c81= 28d3783b767110b65e6c3e0d) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,248 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (643a6c81= 28d3783b767110b65e6c3e0d) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,242 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (15/24= ) (attempt #10) to cldnode07 2016-11-03 13:42:58,248 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (fb48d6f= 89abfa27e3fd26868e746369a) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,242 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (55397b72= 4a8e9c325d377f5912d8f281) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,248 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (fb48d6f= 89abfa27e3fd26868e746369a) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,249 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (23/24= ) (attempt #10) to cldnode06 2016-11-03 13:42:58,242 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (4/24) (910271b03af991b3427cd1100f99a064) switched from DEPLOYING to RU= NNING 2016-11-03 13:42:58,242 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (86523bbd= c396790b03f7f6d541eea648) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,242 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (13/24= ) (attempt #10) to cldnode07 2016-11-03 13:42:58,241 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (14/24= ) (attempt #10) to cldnode07 2016-11-03 13:42:58,241 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (13/24) (a0ecaff73a6c3ebc0fd557887e778eb5) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,249 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (1/24) (aeeea1e1eeea141ae6199e927a568dfe) switched from DEPLOYING to = RUNNING 2016-11-03 13:42:58,249 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (86523bbd= c396790b03f7f6d541eea648) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,249 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (17/24) (ec709d95b8456210cdd821846b2f1ee2) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,249 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (7/24)= (attempt #10) to cldnode05 2016-11-03 13:42:58,249 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (16/24) (b359c281228c857cd49b5af1bfc82290) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,248 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (55397b72= 4a8e9c325d377f5912d8f281) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,250 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (8/24)= (attempt #10) to cldnode05 2016-11-03 13:42:58,248 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (ba6709c= bb744df73f7ea620e216bac4a) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,248 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (9/24)= (attempt #10) to cldnode06 2016-11-03 13:42:58,248 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (8079e2e= 2ff7d57e9acedbc483e48c9dd) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,250 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (23/24) (10494b739882ad7feb43e0247190dfc6) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,248 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (d9eef1e= a95ae5fbd921442d3c722d586) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,247 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (b841412= 77cae159ac4241dc6aa89d189) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,250 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (21/24= ) (attempt #10) to cldnode06 2016-11-03 13:42:58,247 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (5/24)= (attempt #10) to cldnode04 2016-11-03 13:42:58,247 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (7e6af27= 7adf044a6757a02d6c5a8be67) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,251 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (11/24= ) (attempt #10) to cldnode03 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (4/24)= (attempt #10) to cldnode04 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (2/24)= (attempt #10) to cldnode08 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (1f4285e= 85b1faf6030b1256d43dd7cce) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (97d5575= ea2503adced5fe58b452f9436) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,251 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (14/24= ) (attempt #10) to cldnode08 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (6fa9416= df26c842f7fd14a66aa05f182) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (a88f821= b4ed237a03f97bd17cb700b3b) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (779f97a= 0113a018f9af791a2e2d3d7d7) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (620b28d= 3bc045c09b340496db0b5c3c3) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (20/24) (72f3aad0236dca73a172766d2a4afa1c) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,252 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (620b28d= 3bc045c09b340496db0b5c3c3) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,246 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (e94bd27= b797bdc19ad468ae97cf47863) switched from CREATED to SCHEDULED 2016-11-03 13:42:58,245 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (5/24)= (attempt #10) to cldnode06 2016-11-03 13:42:58,252 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (e94bd27= b797bdc19ad468ae97cf47863) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,252 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (17/24= ) (attempt #10) to cldnode07 2016-11-03 13:42:58,251 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (779f97a= 0113a018f9af791a2e2d3d7d7) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,252 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (19/24= ) (attempt #10) to cldnode07 2016-11-03 13:42:58,251 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (a88f821= b4ed237a03f97bd17cb700b3b) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,252 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (18/24= ) (attempt #10) to cldnode07 2016-11-03 13:42:58,251 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (13/24= ) (attempt #10) to cldnode03 2016-11-03 13:42:58,251 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (12/24= ) (attempt #10) to cldnode03 2016-11-03 13:42:58,250 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (6/24) (c9a12b9d6be6b43b59bf854164051515) switched from DEPLOYING to RU= NNING 2016-11-03 13:42:58,250 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (10/24= ) (attempt #10) to cldnode06 2016-11-03 13:42:58,250 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (8079e2e= 2ff7d57e9acedbc483e48c9dd) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,250 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (ba6709c= bb744df73f7ea620e216bac4a) switched from SCHEDULED to DEPLOYING 2016-11-03 13:42:58,250 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (13/24) (7e606bd4b24076d8c14d44b03676cc6b) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,249 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (22/24) (cc2c67552af2d54e3e412f2fd453042e) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,253 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (24/24= ) (attempt #10) to cldnode05 2016-11-03 13:42:58,253 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (22/24= ) (attempt #10) to cldnode05 2016-11-03 13:42:58,253 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (5/24) (eb87d63985d400312d84205dd3a08e21) switched from DEPLOYING to = RUNNING 2016-11-03 13:42:58,252 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (16/24= ) (attempt #10) to cldnode07 2016-11-03 13:42:58,256 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (3/24) (96d5901b42e3d90546c565fa87737333) switched from DEPLOYING to = RUNNING 2016-11-03 13:42:58,256 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (2/24) (c275f7f1fcbc1f448d8c976c5b7e161b) switched from DEPLOYING to = RUNNING 2016-11-03 13:42:58,257 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (4/24) (827355f9c98cd9962be947578327da87) switched from DEPLOYING to = RUNNING 2016-11-03 13:42:58,258 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (14/24) (290f3384e4819ca8a209c288de0de498) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,259 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (15/24) (1d6ce9ffc4e430064271d408cc8bc29a) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,259 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (12/24) (bc2bea1a21655b7f03415522840da8d3) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,260 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (18/24) (bd3c09b0d4a580ede8e4d8fab88cf807) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,260 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (6/24) (f46bf849d5a73caffb2ab07b7820f915) switched from DEPLOYING to = RUNNING 2016-11-03 13:42:58,261 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (17/24) (024d06427a98144a85b3fd7168e49d45) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,261 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (18/24) (d5abd030d970fe399c0bbb60885ab8f2) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,262 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (16/24) (27592f00a6cd545d043eccffb00bb19d) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,262 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (24/24) (06b7fceb9df52ee6643c788061f11261) switched from DEPLOYING to R= UNNING 2016-11-03 13:42:58,263 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (7/24) (5b9c1f50a9a5cf71ef8c9dcb1f23cc0a) switched from DEPLOYING to = RUNNING 2016-11-03 13:42:58,267 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (82e7e88= 83e9d32b7f71022f4e1fe925e) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,267 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (4b75e61= 8f2de1b527863250a918c6b7e) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,268 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (8/24) (9b17e65e7bea2384cf92ae625f2addf8) switched from DEPLOYING to = RUNNING 2016-11-03 13:42:58,268 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (84a67e7= 7b96e81c59a5af0cf41c8bbea) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,268 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (7aae319= 76d48d69f1e77ad54e4aa93b1) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,268 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (db8e88b= 7ce833f5a3652ee7ecb285103) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,268 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (7e8fce0= aa62eb2279a8b228aa8f2d375) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,269 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (21/24) (778de29fb0826a276340ae284531c179) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,271 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (19/24) (ed5e99e3763c6750a7cab5f1032dd746) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,271 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (a2487e2= 5fb076c97a9bc80a686168e0e) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,272 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (9497478= f64c68ae37d53795ee6594de9) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,272 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (ed455b4= 1f40894d8c75fe01873e21126) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,273 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (5177ee6= 82491dc7f93b1bb4f2a0ddb99) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,273 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (29bcca6= a60b068e1e6891827d1be8efd) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,273 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (779f97a= 0113a018f9af791a2e2d3d7d7) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,273 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (20/24) (c8bff8478ae3788bad8ce5af463735e3) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,274 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (3c26447b= 675a7c01e0d3ab9e8c9281e7) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,274 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (22/24) (fdfa402e13b4914493fa04c153f415ff) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,276 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (a88f821= b4ed237a03f97bd17cb700b3b) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,280 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (23/24) (254a1d29bae123c554d0b0c5c113bf3f) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,280 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (0dfd37bd= b6a1b26d519a7beac04a1164) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,280 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (9c3bf96b= f0595a898ba2ea8b58af2092) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,280 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (01d8a274= 9f51e2e30bafaa12724ff631) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,281 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (59c07c06= 1529ca27485272f69b14d942) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,282 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (fb48d6f= 89abfa27e3fd26868e746369a) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,282 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (97d5575= ea2503adced5fe58b452f9436) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,283 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (d426f24= 5f247e09e292353675f213d28) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,283 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (9882efa4= e42ab981527f5111f80692ff) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,283 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (643a6c81= 28d3783b767110b65e6c3e0d) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,283 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (c60a887f= 493cf6e95a78dfb4e7375c46) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,286 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (4bf8a429= fc44579751cbe964ffcfbaa0) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,300 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (6acf1ab5= 59e8582dc60a54b4b37d6728) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,300 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (f3641e77= 026ce337dd7b75eaad5841c2) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,300 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (6c88b25= 07f7fed1f3c0f69fa75f89869) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,300 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (7e6af27= 7adf044a6757a02d6c5a8be67) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,301 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (6fa9416= df26c842f7fd14a66aa05f182) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,301 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (1f4285e= 85b1faf6030b1256d43dd7cce) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,304 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (d6eb3065= ca19775516da7c8621b3cb58) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,304 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (b5d04c3a= 253ccea139af5f66df5e1423) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,304 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (f1e0a533= af1afa0ff698f3bf9db7b294) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,305 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (85e9c2d6= dcfd289c15e4b59c404a9ced) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,305 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (546b61c= 32e7a9f12188622c76efaece2) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,306 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> Flat Map -> (Map -> Map, Map ->= Map) (24/24) (f0febafb5535d67a50d9f8c3225d7d98) switched from DEPLOYING to= RUNNING 2016-11-03 13:42:58,310 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (620b28d= 3bc045c09b340496db0b5c3c3) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,310 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (e94bd27= b797bdc19ad468ae97cf47863) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,311 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (b841412= 77cae159ac4241dc6aa89d189) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,311 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (81693344= e2c2a9a8ca92e9ad4da9dc11) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,311 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (d9eef1e= a95ae5fbd921442d3c722d586) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,313 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (1c50624= a7caa9f2fc253927633c4625c) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,314 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (4a906e1= 8975415d514443341568ace88) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,315 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (8f658ae= 6b80ea55549b42db50a86953c) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,316 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (55397b72= 4a8e9c325d377f5912d8f281) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,319 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (86523bbd= c396790b03f7f6d541eea648) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,320 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (ba6709c= bb744df73f7ea620e216bac4a) switched from DEPLOYING to RUNNING 2016-11-03 13:42:58,324 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (8079e2e= 2ff7d57e9acedbc483e48c9dd) switched from DEPLOYING to RUNNING 2016-11-03 13:43:01,806 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (620b28d= 3bc045c09b340496db0b5c3c3) switched from RUNNING to FAILED 2016-11-03 13:43:01,807 INFO org.apache.flink.runtime.executiongraph.Execu= tionGraph - Source: Custom Source -> (Flat Map -> Map, Flat Map -> M= ap) (1/24) (8a477f7a9f26ae73f92a45a5692939cd) switched from RUNNING to CANC= ELING 2016-11-03 13:43:01,807 INFO org.apache.flink.yarn.YarnJobManager = - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09 (Prod_Que= ry_Engine) changed to FAILING. java.lang.Exception: Could not restore checkpointed state to operators and = functions at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreState= (StreamTask.java:552) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(Strea= mTask.java:250) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584) at java.lang.Thread.run(Thread.java:745) Caused by: org.rocksdb.RocksDBException: IO error: /data/1/yarn/nm/usercach= e/build/appcache/application_1475672282170_2572/flink-io-53ce70e0-0541-4681= -949b-a92d86a4a69d/597b4f8d8fc825cfbfaba9419cbb7e09/StreamMap_13_16/dummy_s= tate/e305d426-0248-4f02-9541-5f2ce613b9b9/db/000058.log: No such file or di= rectory at org.rocksdb.RocksDB.put(Native Method) at org.rocksdb.RocksDB.put(RocksDB.java:416) at org.apache.flink.contrib.streaming.state.RocksDBStateBackend.res= toreFromFullyAsyncSnapshot(RocksDBStateBackend.java:600) at org.apache.flink.contrib.streaming.state.RocksDBStateBackend.inj= ectKeyValueStateSnapshots(RocksDBStateBackend.java:493) at org.apache.flink.streaming.api.operators.AbstractStreamOperator.= restoreState(AbstractStreamOperator.java:202) at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperat= or.restoreState(AbstractUdfStreamOperator.java:154) at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreState= (StreamTask.java:544) ... 3 more ________________________________ This message is for the designated recipient only and may contain privilege= d, proprietary, or otherwise confidential information. If you have received= it in error, please notify the sender immediately and delete the original.= Any other use of the e-mail by you is prohibited. Where allowed by local l= aw, electronic communications with Accenture and its affiliates, including = e-mail and instant messaging (including content), may be scanned by our sys= tems for the purposes of information security and assessment of internal co= mpliance with Accenture policy. ___________________________________________________________________________= ___________ www.accenture.com --_000_D44A250C146E3zhenhaoliaccenturecom_--