From user-zh-return-2312-archive-asf-public=cust-asf.ponee.io@flink.apache.org Fri Mar 6 09:21:04 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 C844B18057A for ; Fri, 6 Mar 2020 10:21:03 +0100 (CET) Received: (qmail 82762 invoked by uid 500); 6 Mar 2020 09:21:02 -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 82750 invoked by uid 99); 6 Mar 2020 09:21:02 -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; Fri, 06 Mar 2020 09:21:02 +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 EF37F1813BC for ; Fri, 6 Mar 2020 09:21:01 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-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: spamd3-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 (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id qw2e4JKFfkTD for ; Fri, 6 Mar 2020 09:20:58 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=2607:f8b0:4864:20::530; helo=mail-pg1-x530.google.com; envelope-from=gejunwei110@gmail.com; receiver= Received: from mail-pg1-x530.google.com (mail-pg1-x530.google.com [IPv6:2607:f8b0:4864:20::530]) by mx1-he-de.apache.org (ASF Mail Server at mx1-he-de.apache.org) with ESMTPS id 48FCE7DD39 for ; Fri, 6 Mar 2020 09:20:57 +0000 (UTC) Received: by mail-pg1-x530.google.com with SMTP id x7so809551pgh.5 for ; Fri, 06 Mar 2020 01:20:57 -0800 (PST) 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=DOBjxL0cplYi0fwGq2rPsR79EAHfcrxX65bZvpdskNU=; b=iWY+ZP6iwKRXhuUrrFbBmK4/olcl4JwF4OtXthKchreVHSLpnO6nqgmTy1jr8oTeZH C9z0hrsGNSLE6YzNFl2ySJKQg3aZJEerl3ZPnDEOcgApn9c/mppH9Nn6suLyOO3bm4v/ vQOfv/2P/oMzUZgVKMZNJWAUiNELNvqvf/auMqCEWr769n4fCOq1c6oQqvc8B6NzU9Gi Aej2ik0Vi9JvapCYQ3UpxsK/TsCX+KsvSVrmPE7b9Q+dm9qFo4ryJvZmgAy7CiVy01vF nn27cnTFZ5MdXhJGxvXzRXOGBNcJaeyJTCz0pYmrVqz9L2auDYqDeGY2+VNcLt7mNcYA f8zQ== 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=DOBjxL0cplYi0fwGq2rPsR79EAHfcrxX65bZvpdskNU=; b=LaPeaeJYIjkWQ7CkH4OBwdEV8YBGmoa82mU0m5jyPI+fsbtZbP2FimGZKuW1f3TXj7 UydTL49HSKdrOaQ7NBO1siLQ244DL7seZBnKvBc2dKLGRYLg/ktjC4QCVJNi0w8TlAq/ Tzy+hbskYhfWZzoYyhiHaysfsGgMnH9QZDyFw0X67/WS9Q0cUYQkvdg6FV9S+E4+Ezd4 DhUeWTQ3ns/e3fGycaG+4wxa3nmGSwnOwmGtnVf31fz4nCd4U3mX76EtpRXfKvLGwHx9 KgSlC1gTb19P2M9Nq09krOOz/Urh+Be0IXnGOGffom9r3EbNy8GmCCR+OZwMOwtIWiJc lxQA== X-Gm-Message-State: ANhLgQ03efJYJAhDPFq0fX6L0iSsIH1tdAkbrj7r2uMvoENuPf33itqG 9LovLUaFJVFwg195GHfJPrt3h/CExgzEKA== X-Google-Smtp-Source: ADFU+vtWzEU9U4Nl8s2OzhaoBQ8GvwgFV4zD1zpUZb0QFuRKeVgL4+dze6r98BDo+zfo9Q+2WDBb8w== X-Received: by 2002:a62:1594:: with SMTP id 142mr2925754pfv.120.1583486449591; Fri, 06 Mar 2020 01:20:49 -0800 (PST) Received: from [127.0.0.1] (dv.ptr196.ptrcloud.net. [153.122.116.100]) by smtp.gmail.com with ESMTPSA id w24sm2119437pjh.26.2020.03.06.01.20.47 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Fri, 06 Mar 2020 01:20:49 -0800 (PST) Date: Fri, 6 Mar 2020 17:20:39 +0800 From: Utopia To: user-zh , user-zh@flink.apache.org Message-ID: <6d479a49-3383-470f-937d-9e1ba77fec4d@Spark> In-Reply-To: References: Subject: Re: =?utf-8?Q?keyby=E5=90=8E=E6=BB=9A=E5=8A=A8=E7=AA=97=E5=8F=A3=EF=BC=8Cwatermark=E5=A6=82=E4=BD=95=E5=8F=AA=E8=A7=A6=E5=8F=91=E6=89=80=E5=9C=A8=E7=9A=84=E7=BB=84=EF=BC=8C=E8=80=8C=E4=B8=8D=E8=A7=A6=E5=8F=91=E6=89=80=E6=9C=89=E7=9A=84=E7=BB=84?= X-Readdle-Message-ID: 6d479a49-3383-470f-937d-9e1ba77fec4d@Spark MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="5e6215ed_ded7263_1fb0" --5e6215ed_ded7263_1fb0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: quoted-printable Content-Disposition: inline Hi, =46link =E7=9A=84=E6=B0=B4=E5=8D=B0=E5=9C=A8=E5=90=8C=E4=B8=80=E4=B8=AA=E7= =AE=97=E5=AD=90=E4=B8=8A=E9=83=BD=E6=98=AF=E4=B8=80=E6=A0=B7=E7=9A=84=EF=BC= =8C=E6=89=80=E4=BB=A5=E6=AF=8F=E4=B8=AA keyed stream =E5=85=B1=E4=BA=AB=E7= =9A=84=E6=98=AF=E4=B8=80=E4=B8=AA=E6=B0=B4=E5=8D=B0=EF=BC=8C=E4=B8=8D=E8=83= =BD=E5=88=86=E5=88=AB=E8=A7=A6=E5=8F=91=E5=99=A8=E3=80=82 Best =C2=A0regards Utopia =E5=9C=A8 2020=E5=B9=B43=E6=9C=886=E6=97=A5 +0800 17:10=EF=BC=8C=E5=B0=8F= =E6=97=8B=E9=94=8B =EF=BC=8C=E5=86=99=E9=81=93=EF=BC=9A= > =E5=A4=A7=E5=AE=B6=E5=A5=BD=EF=BC=9A >         =E6=95=B0=E6=8D=AE=E6=B5=81=E7=BB=8F=E8=BF=87= keyby =E5=88=86=E7=BB=84=E5=90=8E=EF=BC=8C=E5=9C=A8=E5=88=86=E5=88=AB=E8= =BF=9B=E5=85=A5=E6=BB=9A=E5=8A=A8=E7=AA=97=E5=8F=A3=EF=BC=9A >          sourceDataStream .keyBy(id) .window(T= umblingEventTimeWindows.of(Time.seconds(10L))) .reduce() .print() >          >         =E6=B5=8B=E8=AF=95=E6=95=B0=E6=8D=AE=EF=BC=9A= id =E4=BB=8E1=7E1500=EF=BC=8C=E6=AF=8F=E4=B8=AAid=E7=94=B1=E4=B8=A4=E6=9D= =A1=E6=95=B0=E6=8D=AE=EF=BC=8C=E6=AF=8F=E6=9D=A1=E6=95=B0=E6=8D=AE=E7=9A=84= eventtime=E6=98=AF=E4=B8=80=E6=A0=B7=E7=9A=84=EF=BC=8C=E6=9C=80=E5=90=8E= =E4=B8=80=E6=9D=A1=E6=98=AFid=E4=B8=BA1=EF=BC=8Ceventtime=E5=A4=A7=E4=BA=86= 20=E7=A7=92=E7=94=A8=E6=9D=A5=E8=A7=A6=E5=8F=91=E7=AA=97=E5=8F=A3=E8=AE=A1= =E7=AE=97=E7=9A=84=E6=95=B0=E6=8D=AE >          =E5=AE=9E=E9=AA=8C=E7=BB=93=E6=9E=9C=EF= =BC=9A=E6=9C=80=E5=90=8E=E4=B8=80=E6=9D=A1=E7=94=A8=E6=9D=A5=E8=A7=A6=E5=8F= =91=E7=9A=84=E6=95=B0=E6=8D=AE=E5=8F=91=E5=87=BA=E5=90=8E=EF=BC=8C=E6=89=80= =E6=9C=89=E7=9A=84=E7=AA=97=E5=8F=A3=E9=83=BD=E8=AE=A1=E7=AE=97=E8=BE=93=E5= =87=BA=E4=BA=86 >        >          =E8=AF=B7=E9=97=AE=E5=A6=82=E4=BD=95=E9= =85=8D=E7=BD=AE =E6=9C=80=E5=90=8E=E4=B8=80=E6=9D=A1id=E4=B8=BA1=E7=9A=84= =E6=95=B0=E6=8D=AE=E5=8F=AA=E8=A7=A6=E5=8F=91 id=3D1=E6=89=80=E5=9C=A8=E7= =9A=84=E7=BB=84=E7=9A=84=E7=AA=97=E5=8F=A3=E5=91=A2=EF=BC=9F > > > =E6=84=9F=E8=B0=A2 --5e6215ed_ded7263_1fb0--