From user-zh-return-1280-archive-asf-public=cust-asf.ponee.io@flink.apache.org Fri Oct 11 06:48:32 2019 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id 68FEC180656 for ; Fri, 11 Oct 2019 08:48:32 +0200 (CEST) Received: (qmail 71789 invoked by uid 500); 11 Oct 2019 06:48:31 -0000 Mailing-List: contact user-zh-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user-zh@flink.apache.org Delivered-To: mailing list user-zh@flink.apache.org Received: (qmail 71777 invoked by uid 99); 11 Oct 2019 06:48:31 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 11 Oct 2019 06:48:31 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 771021A457B for ; Fri, 11 Oct 2019 06:48:30 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.2 X-Spam-Level: X-Spam-Status: No, score=-0.2 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, RCVD_IN_DNSWL_NONE=-0.0001, SPF_HELO_NONE=0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (1024-bit key) header.d=126.com Received: from mx1-ec2-va.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id 7Fru6I2FZVac for ; Fri, 11 Oct 2019 06:48:28 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=103.129.252.12; helo=proxy25212.mail.163.com; envelope-from=miraisenshi@126.com; receiver= Received: from proxy25212.mail.163.com (proxy25212.mail.163.com [103.129.252.12]) by mx1-ec2-va.apache.org (ASF Mail Server at mx1-ec2-va.apache.org) with ESMTP id B47BEBC59E for ; Fri, 11 Oct 2019 06:48:27 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=126.com; s=s110527; h=Mime-Version:Subject:From:Date:Message-Id; bh=6bRaI c9ccTxbKvKxoRh3dESvIJ/09X/DNjTF6wkcGKU=; b=kg0owey3GK8ZBLxDPUzT2 upP19wyGGJQ4TzqCMR5TckG9pR6gAoPa7qcmlPFwUHqKfMzVUTE9kFG9ECWiVl7v mptHaM3p96k9+fvJ58epxGNDLZYXOBlLbD+T1+MiGkM62eacqHpTIxpzzLw/Apcx d10W+yFQLMlp1Io/FMl90o= Received: from [172.16.30.148] (unknown [36.110.21.210]) by smtp7 (Coremail) with SMTP id DsmowAA3Ht+SJaBdVvMfCA--.41954S3; Fri, 11 Oct 2019 14:47:48 +0800 (CST) Content-Type: text/plain; charset=utf-8 Mime-Version: 1.0 (Mac OS X Mail 12.4 \(3445.104.11\)) Subject: =?utf-8?B?UmU6IGZsaW5rIOe8k+WtmOacrOWcsOaWh+S7tuiiq+WIoOmZpA==?= =?utf-8?B?55aR6Zeu?= From: Qi Kang X-Priority: 3 In-Reply-To: <5d9ff036.1c69fb81.41d92.71db@mx.google.com> Date: Fri, 11 Oct 2019 14:47:46 +0800 Content-Transfer-Encoding: quoted-printable Message-Id: <37C6B5B0-6725-4C42-B8D3-D3C4E43BFBD2@126.com> References: <5d9ff036.1c69fb81.41d92.71db@mx.google.com> To: user-zh@flink.apache.org X-Mailer: Apple Mail (2.3445.104.11) X-CM-TRANSID:DsmowAA3Ht+SJaBdVvMfCA--.41954S3 X-Coremail-Antispam: 1Uf129KBjvJXoW3WFWUKr15WF1rAw4rAF15CFg_yoW7AF4fpr 4DZw1rKw1xKa13Xr47X3y8JasI9F1rGw45Xw1xC3W0vFn8Kr9IvFy0ya1kXayfuwnrua4q qr4jvw4UZwn8CFJanT9S1TB71UUUUUUqnTZGkaVYY2UrUUUUjbIjqfuFe4nvWSU5nxnvy2 9KBjDUYxBIdaVFxhVjvjDU0xZFpf9x07jQku7UUUUU= X-Originating-IP: [36.110.21.210] X-CM-SenderInfo: 5plutxpvhq2xbl6rjloofrz/1tbi2RRLBVpD9wMkewAAsx Hi, = =E4=BB=8E=E6=8A=A5=E9=94=99=E7=9C=8B=EF=BC=8C=E5=8F=AF=E8=83=BD=E6=98=AF=E5= =9B=A0=E4=B8=BA=E8=87=AA=E5=8A=A8=E7=94=9F=E6=88=90=E7=9A=84=E7=AE=97=E5=AD= =90ID=E6=94=B9=E5=8F=98=EF=BC=8C=E6=97=A0=E6=B3=95=E5=8F=96=E5=BE=97state = backend=E9=87=8C=E5=AD=98=E5=82=A8=E7=9A=84=E7=8A=B6=E6=80=81=E3=80=82=E6=A3= =80=E6=9F=A5=E7=82=B9=E7=BB=B4=E6=8A=A4=E7=9A=84=E6=98=AF[=E7=AE=97=E5=AD=90= ID -> = =E7=8A=B6=E6=80=81]=E7=9A=84=E6=98=A0=E5=B0=84=E5=85=B3=E7=B3=BB=EF=BC=8C=E6= =89=80=E4=BB=A5Flink=E6=8E=A8=E8=8D=90=E7=94=A8uid()=E6=96=B9=E6=B3=95=E7=BB= =99=E7=AE=97=E5=AD=90=E6=98=BE=E5=BC=8F=E8=AE=BE=E7=BD=AEID=EF=BC=8C=E6=89= =8D=E8=83=BD=E4=BF=9D=E8=AF=81=E6=AD=A3=E5=B8=B8=E6=81=A2=E5=A4=8D=E7=8E=B0= =E5=9C=BA=E3=80=82=E5=8F=AF=E4=BB=A5=E5=8F=82=E8=80=83=E6=96=87=E6=A1=A3[1= ]=E3=80=82 [1] = https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/state/save= points.html#assigning-operator-ids > On Oct 11, 2019, at 11:00, =E6=88=B4=E5=98=89=E8=AF=9A = wrote: >=20 > =E5=A4=A7=E5=AE=B6=E5=A5=BD=EF=BC=9A > =E6=9C=80=E8=BF=91=E6=88=91=E7=9A=84=E7=A8=8B=E5=BA=8F=E8=BF=81=E7= =A7=BB=E5=88=B0=E4=BA=86flink1.9 on yarn = session=E5=90=8E=EF=BC=8C=E5=8E=9F=E6=9C=AC=E6=9C=89=E4=B8=AA=E7=A8=8B=E5=BA= =8F=E6=98=AF=E8=AF=BB=E5=8F=96kafka=E6=B6=88=E6=81=AF=EF=BC=8C=E7=84=B6=E5= =90=8Ekey=E5=88=86=E7=BB=84=EF=BC=8Cwindow=E8=81=9A=E9=9B=86=E4=B8=80=E7=A7= =92=E5=90=8E=EF=BC=8C=E6=89=B9=E9=87=8F=E5=BC=82=E6=AD=A5=E5=86=99=E5=85=A5= hbase=E4=B8=AD=E7=BB=8F=E5=B8=B8=E5=8F=91=E7=94=9F=E5=BC=82=E5=B8=B8=EF=BC= =8C=E5=85=B6=E4=B8=AD=E5=BC=82=E5=B8=B8=E4=B8=BA=EF=BC=9A > java.lang.Exception: Exception while creating = StreamOperatorStateContext. > at = org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.st= reamOperatorStateContext(StreamTaskStateInitializerImpl.java:195) > at = org.apache.flink.streaming.api.operators.AbstractStreamOperator.initialize= State(AbstractStreamOperator.java:253) > at = org.apache.flink.streaming.runtime.tasks.StreamTask.initializeState(Stream= Task.java:878) > at = org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java= :392) > at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:705) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:530) > at java.lang.Thread.run(Thread.java:748) > Caused by: org.apache.flink.util.FlinkException: Could not restore = keyed state backend for = WindowOperator_3572e2ca02acab3056013a7c1c4fa645_(6/6) from any of the 1 = provided restore options. > at = org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAn= dRestore(BackendRestorerProcedure.java:135) > at = org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.ke= yedStatedBackend(StreamTaskStateInitializerImpl.java:307) > at = org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.st= reamOperatorStateContext(StreamTaskStateInitializerImpl.java:135) > ... 6 more > Caused by: org.apache.flink.runtime.state.BackendBuildingException: = Caught unexpected exception. > at = org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder.b= uild(RocksDBKeyedStateBackendBuilder.java:326) > at = org.apache.flink.contrib.streaming.state.RocksDBStateBackend.createKeyedSt= ateBackend(RocksDBStateBackend.java:520) > at = org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.la= mbda$keyedStatedBackend$1(StreamTaskStateInitializerImpl.java:291) > at = org.apache.flink.streaming.api.operators.BackendRestorerProcedure.attemptC= reateAndRestore(BackendRestorerProcedure.java:142) > at = org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAn= dRestore(BackendRestorerProcedure.java:121) > ... 8 more > Caused by: java.nio.file.NoSuchFileException: = /data/hadoop/yarn/local/usercache/hdfs/appcache/application_1569065892199_= 0031/flink-io-6bcd299a-00e7-4f6a-8466-09d8d13d831d/job_add9718b9fe3e505457= 7d8b9e5799829_op_WindowOperator_3572e2ca02acab3056013a7c1c4fa645__6_6__uui= d_53528904-c829-431a-ba0a-b76041cd2d2b/db/000835.sst -> = /data/hadoop/yarn/local/usercache/hdfs/appcache/application_1569065892199_= 0031/flink-io-6bcd299a-00e7-4f6a-8466-09d8d13d831d/job_add9718b9fe3e505457= 7d8b9e5799829_op_WindowOperator_3572e2ca02acab3056013a7c1c4fa645__6_6__uui= d_53528904-c829-431a-ba0a-b76041cd2d2b/14634105-83be-429e-9cdc-36dbff14a7f= a/000835.sst > at = sun.nio.fs.UnixException.translateToIOException(UnixException.java:86) > at = sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102) > at = sun.nio.fs.UnixFileSystemProvider.createLink(UnixFileSystemProvider.java:4= 76) > at java.nio.file.Files.createLink(Files.java:1086) > at = org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestore= Operation.restoreInstanceDirectoryFromPath(RocksDBIncrementalRestoreOperat= ion.java:473) > at = org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestore= Operation.restoreFromLocalState(RocksDBIncrementalRestoreOperation.java:21= 2) > at = org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestore= Operation.restoreFromRemoteState(RocksDBIncrementalRestoreOperation.java:1= 88) > at = org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestore= Operation.restoreWithoutRescaling(RocksDBIncrementalRestoreOperation.java:= 162) > at = org.apache.flink.contrib.streaming.state.restore.RocksDBIncrementalRestore= Operation.restore(RocksDBIncrementalRestoreOperation.java:148) > at = org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackendBuilder.b= uild(RocksDBKeyedStateBackendBuilder.java:270) > ... 12 more >=20 >=20 > = =E6=88=91=E8=BF=99=E9=87=8C=E7=9A=84session=E4=B8=AD=E6=98=AF=E6=9C=89=E5=A4= =9A=E4=B8=AAjob=E5=9C=A8session=E4=B8=8A=E8=BF=90=E8=A1=8C=EF=BC=8C=E4=BD=86= =E6=98=AF=E8=BF=99=E9=87=8Cjob=E9=83=BD=E6=98=AF=E5=86=99=E5=85=A5hbase=E4= =B8=AD=E7=9A=84=E3=80=82 > = =E8=BF=99=E9=87=8C=E7=9C=8B=E4=B8=8A=E5=8E=BB=E6=98=AF=E6=9C=AC=E5=9C=B0=E6= =9C=BA=E5=99=A8=E4=B8=8A=E7=9A=84=E7=9B=AE=E5=BD=95=E6=96=87=E4=BB=B6=E8=A2= =AB=E5=88=A0=E9=99=A4=E4=BA=86=EF=BC=9F=E4=BD=86=E6=98=AF=E8=BF=99=E4=B8=AA= =E6=96=87=E4=BB=B6=E6=88=91=E6=98=AF=E6=B2=A1=E6=9C=89=E5=88=A0=E9=99=A4=E8= =BF=87=E7=9A=84=E2=80=A6 >=20 >=20