From user-zh-return-1331-archive-asf-public=cust-asf.ponee.io@flink.apache.org Mon Oct 21 06:58:05 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 81D9D180626 for ; Mon, 21 Oct 2019 08:58:05 +0200 (CEST) Received: (qmail 2879 invoked by uid 500); 21 Oct 2019 06:58:04 -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 2867 invoked by uid 99); 21 Oct 2019 06:58:04 -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; Mon, 21 Oct 2019 06:58:04 +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 92548C0CEF for ; Mon, 21 Oct 2019 06:58:03 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.251 X-Spam-Level: X-Spam-Status: No, score=0.251 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, FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=0.2, RCVD_IN_DNSWL_NONE=-0.0001, SPF_HELO_NONE=0.001, SPF_PASS=-0.001, URIBL_BLOCKED=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 4pGfxesiRRGy for ; Mon, 21 Oct 2019 06:58:02 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=2607:f8b0:4864:20::432; helo=mail-pf1-x432.google.com; envelope-from=gejunwei110@gmail.com; receiver= Received: from mail-pf1-x432.google.com (mail-pf1-x432.google.com [IPv6:2607:f8b0:4864:20::432]) by mx1-he-de.apache.org (ASF Mail Server at mx1-he-de.apache.org) with ESMTPS id 2D7357E17D for ; Mon, 21 Oct 2019 06:58:01 +0000 (UTC) Received: by mail-pf1-x432.google.com with SMTP id q12so7789221pff.9 for ; Sun, 20 Oct 2019 23:58:01 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=date:from:to:message-id:in-reply-to:references:subject:mime-version; bh=3/yE65O1W3Si58U3uv52Ts6PwISm+pj76RZ4x6h1rTg=; b=t1Z6suH9B9HOATX8ZBqFs0AZNtpXv5OOedZjbIDbD+5Jnv+QzfaiOi3OHRjotc6vxk vPgB8LEhRrSV0wdL0BhgzQwNftlgFUrjfjgOt6uCkOKu8A7GNLabqlrfZ92xPvRvs3S5 3lkrg3A+jA1+X4MNRXpyN0ChUhP29ErR1HeTds6FNAxiSy0/WkGleP5jsuRT7XYkYX/W Gn5SGn8oNkm5JmBoHmnxX0pGelTpbUc1hRO4yeZf4PFl/oFLd7O8CXVUyClHD1yYIlWL us/LUDL5dv/1SHDw4MK+Hn11F1BGL5cuBKeAC6Kg0tNEOza39REHFOu3gT6xAQW4RgMm NHhA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:date:from:to:message-id:in-reply-to:references :subject:mime-version; bh=3/yE65O1W3Si58U3uv52Ts6PwISm+pj76RZ4x6h1rTg=; b=VJpaqoPQY0s8aNePUt9G56eGn2YwLWuhpSN/K7eExkzLQgNKuBEtCg5dh9HFDMK0+8 8KWgS9a3Jprj+U7JeC+YJbbqe0wwYTivJDglTqtElS6P6lfGKYrsAhw1fHRmKwJVARLj q9YRYxHNvem4tfiADD7ycO5RgFEIW7ewfrrIXJD3HFITLmB1K8gHsLbR4Ru5tIVp7S81 8bUvbWgn1r5USGCbOMqvN0IEmb+wDvsMJJfGRaJsmvEg3/NV25wmdP10FpQscaM3QOkJ nh8Jw4NC0JoDvDyW32o/bHC3cQe8IfRUAqQILU9ddNngTX2tQf6+2qFMMzkKIzersoxE JcvQ== X-Gm-Message-State: APjAAAWmOGSON4FY8HN3jxuTgBK+JmdCMCaMOgtDpG8IUpnUjuyPPlg0 PFv/hOHbt2KnW5ckEigtF3HlGrL0FUo= X-Google-Smtp-Source: APXvYqxKi5FIk/gEY3z/T7rqApOSMSOWlCQz7XuuktXn7Z7ezJPAmu3lRGQ7OXVRo4p8rr6tsG3rGw== X-Received: by 2002:a62:68c1:: with SMTP id d184mr21479853pfc.195.1571641079389; Sun, 20 Oct 2019 23:57:59 -0700 (PDT) Received: from [198.18.0.1] ([47.244.237.146]) by smtp.gmail.com with ESMTPSA id i184sm15240069pge.5.2019.10.20.23.57.56 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Sun, 20 Oct 2019 23:57:58 -0700 (PDT) Date: Mon, 21 Oct 2019 14:57:37 +0800 From: Utopia To: user-zh , user-zh@flink.apache.org Message-ID: In-Reply-To: References: Subject: Re: =?utf-8?Q?=E5=9B=9E=E5=A4=8D=EF=BC=9AFlink_=E6=B6=88=E8=B4=B9Kafka_Window=E4=B8=8D=E8=A7=A6=E5=8F=91=E8=AE=A1=E7=AE=97?= X-Readdle-Message-ID: ad51c1bf-7f88-4391-b619-b5dcb526391d@Spark MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="5dad56f2_1f16e9e8_f7d" --5dad56f2_1f16e9e8_f7d Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: quoted-printable Content-Disposition: inline idling sources =E5=8F=AA=E8=83=BD=E8=A7=A3=E5=86=B3 Kafka =E6=B2=A1=E6=9C= =89=E6=95=B0=E6=8D=AE=E7=9A=84=E9=97=AE=E9=A2=98=EF=BC=8C=E5=A6=82=E6=9E=9C= =E6=98=AF=E5=9C=A8=E4=B8=9A=E5=8A=A1=E9=80=BB=E8=BE=91=E9=87=8C=E9=95=BF=E6= =97=B6=E9=97=B4=E6=B2=A1=E6=9C=89=E6=94=B6=E5=88=B0=E6=9F=90=E4=B8=AA=E7=94= =A8=E6=88=B7=E6=96=B0=E7=9A=84=E6=95=B0=E6=8D=AE=E5=91=A2=EF=BC=9F=E6=88=91= =E6=83=B3=E5=88=B0=E7=9A=84=E4=B8=80=E4=B8=AA=E8=A7=A3=E5=86=B3=E6=96=B9=E6= =B3=95=E6=98=AF=E6=8E=A5=E6=94=B6=E5=88=B0=E6=95=B0=E6=8D=AE=E6=97=B6=E5=9C= =A8 Trigger =E7=9A=84 onElement =E6=96=B9=E6=B3=95=E4=B8=AD=E6=B3=A8=E5=86= =8C=E4=B8=80=E4=B8=AA ProcessingTimer =E7=94=A8=E6=9D=A5=E8=A7=A6=E5=8F=91= Window =E8=AE=A1=E7=AE=97=EF=BC=8C=E5=90=8E=E7=BB=AD=E6=9C=89=E6=96=B0=E7= =9A=84=E6=95=B0=E6=8D=AE=E5=B0=B1=E5=88=A0=E9=99=A4=E4=B9=8B=E5=89=8D=E7=9A= =84 ProcessingTimer. 2019=E5=B9=B410=E6=9C=8821=E6=97=A5 +0800 01:38 Ever <439674061=40qq.com>= =EF=BC=8C=E5=86=99=E9=81=93=EF=BC=9A > =E5=8F=82=E8=80=83=E4=B8=8B: > https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/event=5F= time.html > > idling sources=E7=9A=84=E8=AF=B4=E6=98=8E > > <> > > > ------------------=C2=A0=E5=8E=9F=E5=A7=8B=E9=82=AE=E4=BB=B6=C2=A0-----= ------------- > =E5=8F=91=E4=BB=B6=E4=BA=BA:=C2=A0=22=E7=8E=8B=E4=BD=A9=22; > =E5=8F=91=E9=80=81=E6=97=B6=E9=97=B4:=C2=A02019=E5=B9=B410=E6=9C=8820=E6= =97=A5(=E6=98=9F=E6=9C=9F=E5=A4=A9) =E4=B8=8A=E5=8D=8810:38 > =E6=94=B6=E4=BB=B6=E4=BA=BA:=C2=A0=22user-zh=22; > =E4=B8=BB=E9=A2=98:=C2=A0=46link =E6=B6=88=E8=B4=B9Kafka Window=E4=B8=8D= =E8=A7=A6=E5=8F=91=E8=AE=A1=E7=AE=97 > > =46link =E6=B6=88=E8=B4=B9Kafka, =E6=9C=89=E7=9A=84=E5=B9=B6=E5=8F=91=E6= =B2=A1=E6=95=B0=E6=8D=AE=EF=BC=8C=E5=AF=BC=E8=87=B4Watermark=E4=B8=8D=E6=9B= =B4=E6=96=B0=EF=BC=8C=E8=BF=9B=E8=80=8CWindow=E4=B8=8D=E8=A7=A6=E5=8F=91=E8= =AE=A1=E7=AE=97=E3=80=82 > > =E8=AF=B7=E6=95=99=E4=B8=8B: > > =C2=A0=C2=A0=C2=A0 =E5=83=8F=E8=BF=99=E7=A7=8D=E6=83=85=E5=86=B5=EF=BC=8C= =E4=B8=80=E8=88=AC=E8=A7=A3=E5=86=B3=E6=96=B9=E5=BC=8F=E6=9C=89=E9=82=A3=E4= =BA=9B=EF=BC=9F > > =E6=84=9F=E8=B0=A2=EF=BC=81 --5dad56f2_1f16e9e8_f7d--