From user-zh-return-2399-archive-asf-public=cust-asf.ponee.io@flink.apache.org Fri Mar 13 03:31:21 2020 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 020E118064F for ; Fri, 13 Mar 2020 04:31:20 +0100 (CET) Received: (qmail 15469 invoked by uid 500); 13 Mar 2020 03:31:11 -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 15021 invoked by uid 99); 13 Mar 2020 03:31:10 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 13 Mar 2020 03:31:10 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 8549CC1DDE; Fri, 13 Mar 2020 03:31:09 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0 X-Spam-Level: X-Spam-Status: No, score=0 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, HTML_MESSAGE=0.2, RCVD_IN_DNSWL_NONE=-0.0001, SPF_HELO_NONE=0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-he-de.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id Cr1Us0Ft_3Wq; Fri, 13 Mar 2020 03:31:07 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=2a00:1450:4864:20::12e; helo=mail-lf1-x12e.google.com; envelope-from=shenleifighting@gmail.com; receiver= Received: from mail-lf1-x12e.google.com (mail-lf1-x12e.google.com [IPv6:2a00:1450:4864:20::12e]) by mx1-he-de.apache.org (ASF Mail Server at mx1-he-de.apache.org) with ESMTPS id 602A37E150; Fri, 13 Mar 2020 03:31:07 +0000 (UTC) Received: by mail-lf1-x12e.google.com with SMTP id i19so6672642lfl.1; Thu, 12 Mar 2020 20:31:07 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:from:date:message-id:subject:to; bh=FNfnK9PwnfJiGz9keLPL+ioxcYW350QmqBO1guoeN2E=; b=V6x7YoASTB5Iv4ZJ04+sYbTm3Ek/r7dFTIxuHkQP3ZNw8nuIoGwmA9lijAqIIITUkK XpvCTn/FXfk/l8bKYl0cMdcElEkT9xzh3PLJnn+RyMn/oOpmbFufjk/E9vATWfyfTDk7 n2e/6OJzglrSvHK1CuozI68vN5o9kYzr4eJ6UIMjuDAGoSN2sCXgf28l7I5eM7EpoN18 JmQWmpF2FoZIhWoT35w6Gqqh5hJEzGLIZXv8xznCg0vG+mATiJSTtlni00xiSaDtltfF TqUjYrAG5F6fpHufXwbH3Nh0d6jJ1nvAvbPlMOCAEajBpvgvqrph1N6CgNUnODew+SrY H7yA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:from:date:message-id:subject:to; bh=FNfnK9PwnfJiGz9keLPL+ioxcYW350QmqBO1guoeN2E=; b=C/JS5wKvr05QCeB41tPKmMiyrOED6eeWytKeh7hS4DyqXTIPa7e2f7VYQFXh+5XVrE WVzqLh/JCCpdbrfObXy45mpcPmdlcqkLnvn3gKnUiYpMdaYgajT8FUsWNQ0uXPVLlKoH wQysjql7rZ+iDteK79Wf8IaA29bXMXdtCnCA3FLG2fN+xFPQpUMUgBp9q8Dk5DeXlyMY t60PkDBx50xgtoVctKZj1PXsxZQkjfSLoLWofo6IutoUYmyWddQGzzqGw2C+gYsH4kzj 07EieX7bXqDTnDmiYZGAebA6e32SHqJWcTioFG4O3iD0nMzrsD8DrMfCCPwud+2hgIt1 kXPg== X-Gm-Message-State: ANhLgQ2N65E8XTyTazo8Xjoi7bMPFh20r0aSGGwayYMMECtcC+o9Jvd5 +Q7SurUSvHSuzo6bAIQfsH49DCzQJ4Ugwbn6jKMQxUpk X-Google-Smtp-Source: ADFU+vvErFt9i7aiK7PeJ4AtA3a0axgYHMNu+TK15JQilYrEE3l48wfqqGgOdxUdidwSZHSyRqJYSb5YCcEB47Yy2Uc= X-Received: by 2002:a19:c117:: with SMTP id r23mr7105865lff.41.1584070266485; Thu, 12 Mar 2020 20:31:06 -0700 (PDT) MIME-Version: 1.0 From: LakeShen Date: Fri, 13 Mar 2020 11:30:55 +0800 Message-ID: Subject: Cancel the flink task and restore from checkpoint ,can I change the flink operator's parallelism To: dev , user-zh@flink.apache.org, user Content-Type: multipart/alternative; boundary="000000000000887fe505a0b4193d" --000000000000887fe505a0b4193d Content-Type: text/plain; charset="UTF-8" Hi community, I have a question is that I cancel the flink task and retain the checkpoint dir, then restore from the checkpoint dir ,can I change the flink operator's parallelism,in my thoughts, I think I can't change the flink operator's parallelism,but I am not sure. Thanks to your reply. Best wishes, LakeShen --000000000000887fe505a0b4193d--