From dev-return-22544-archive-asf-public=cust-asf.ponee.io@beam.apache.org Thu Apr 2 18:21:27 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 652E5180626 for ; Thu, 2 Apr 2020 20:21:27 +0200 (CEST) Received: (qmail 17898 invoked by uid 500); 2 Apr 2020 18:21:26 -0000 Mailing-List: contact dev-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list dev@beam.apache.org Received: (qmail 17875 invoked by uid 99); 2 Apr 2020 18:21:26 -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; Thu, 02 Apr 2020 18:21:25 +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 7397BC1E2A for ; Thu, 2 Apr 2020 18:21:25 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-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, 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=frantil-com.20150623.gappssmtp.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 PXe_31x74-fJ for ; Thu, 2 Apr 2020 18:21:20 +0000 (UTC) Received-SPF: Pass (mailfrom) identity=mailfrom; client-ip=2607:f8b0:4864:20::32b; helo=mail-ot1-x32b.google.com; envelope-from=robert@frantil.com; receiver= Received: from mail-ot1-x32b.google.com (mail-ot1-x32b.google.com [IPv6:2607:f8b0:4864:20::32b]) by mx1-he-de.apache.org (ASF Mail Server at mx1-he-de.apache.org) with ESMTPS id D31BE7E186 for ; Thu, 2 Apr 2020 18:21:19 +0000 (UTC) Received: by mail-ot1-x32b.google.com with SMTP id 111so4419083oth.13 for ; Thu, 02 Apr 2020 11:21:19 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=frantil-com.20150623.gappssmtp.com; s=20150623; h=mime-version:references:in-reply-to:from:date:message-id:subject:to; bh=VYnWTAzRqypqrZXYoNBhUzL9BxTO1LbnSEDXpch0o90=; b=AyhY7vVQ8WdLi9m6TU6LbpWg4D3ErgCL1f4fB9FSb4kusghvefAueFt4SK3vUrnTMA o1LVTqJtWom5+YPxMLolkXRsaX7cfEH3P6KVNFuD+yNl9KW6LFoqHpf28CMV8o0DRjd8 Yh6Ze26DYQ6SKwCBs62olpXMT3WUNP60G5vabmBgNsW4sbEn1CtYqgtt+YJ1HEZoeD8K fZEdr8KUtEaCOeOQu7Eylv++OCfi+B0ZIGU/B5RajcSFxRF+XkFrSLV4jhpoC9NuD9q8 rIgRkBQlT241CTZ1ytGxSerC1yXhqKOMDsB+L3vannN0ZMCh1h/LkdYQjhsnLRzCOnI6 GErQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:references:in-reply-to:from:date :message-id:subject:to; bh=VYnWTAzRqypqrZXYoNBhUzL9BxTO1LbnSEDXpch0o90=; b=XzoKuqlLsiMb67q4lo8jVnfo65G/9hXe/ZAL3DfYvYt+LpHF97Jjy9JgFsXLCUdpBi hrz1SvACF9/onztlOQLJak9ohMtXd+b0e4ttm6lkyxfQnlKVsuNy2+XEd616QeMicxzQ G3o5mqnGhhxBCHRB+agLoa8PRSHgrry/UOT2q9nhJggLi2oKxm20M6E84h8TE6/5VErt payA8+qUHqmJlLnhVrTVUPaOOyEqn7meRVyYagRZMaGzM1sHaBw79MC8xisamErr7YQh ULRgBzjlZmxjc5Fu6gFFeIVGN2nri8zLlMMOxtWubzakz0+iS6dDK0sHoXA91kK6nfb8 FcmQ== X-Gm-Message-State: AGi0PuY0wrcoH4RbQ7b5+ko4KTChNXwWVZTzgbBWZKrmUW75BAqSIWEI InYxOUUSiqrj/1m4TsX5XYLAvKwIKihk8e1CLNCaYKJU X-Google-Smtp-Source: APiQypIxodArZHmhuSUKkz3rYvWzl5AwZz2NF4Px57S3Ou6BCFWPyT1pqTKwCV9c+sohIpJTKISWfhyEyrS5JVInyU0= X-Received: by 2002:a05:6830:18eb:: with SMTP id d11mr3471676otf.243.1585851671487; Thu, 02 Apr 2020 11:21:11 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: Robert Burke Date: Thu, 2 Apr 2020 11:21:00 -0700 Message-ID: Subject: Re: Golang SDK Katas To: dev@beam.apache.org Content-Type: multipart/alternative; boundary="0000000000008bbd8c05a252dde4" --0000000000008bbd8c05a252dde4 Content-Type: text/plain; charset="UTF-8" Welcome to the community! It was great talking to you this morning too. As discussed: https://issues.apache.org/jira/browse/BEAM-9676 filed for Go SDK Katas The current Go SDK roadmap https://beam.apache.org/roadmap/go-sdk/ The general contribution guide https://beam.apache.org/contribute And Go SDK specific dev environment set up: https://github.com/apache/beam/tree/master/SDKs/go#contributing-to-the-go-sdk As for running Flink locally, it's not as bad as I thought for the most part, though the flink version might need updating. Copying from Daniel Oliveira's SDF example instructions: 1. From a command line, navigate to the top-level beam directory and run the Flink Job Server: ./gradlew :runners:flink:1.9:job-server:runShadow -Djob-host=localhost -Dflink-master=local 2. The job server is ready to receive jobs once it outputs a log line like the following `JobService started on localhost:8099`. Take note of the endpoint in that message (in this case, localhost: 3. In a second command line terminal, run your job. Eg wordcount, assuming your working directory is the same top level beam directory go run sdks/go/examples/wordcount/wordcount.go --runner=universal --endpoint=localhost:8099 On Thu, Apr 2, 2020, 10:29 AM Damon Douglas wrote: > Hello Everyone, > > I would like to start an initiative to contribute to the Apache Beam katas > for the golang SDK. My JIRA username is `damondouglas`. I will be adding > subtasks under https://issues.apache.org/jira/browse/BEAM-9676 > > Thank you for including me in this exciting project. > > Sincerely, > > Damon > --0000000000008bbd8c05a252dde4 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Welcome to the community!

It was great talking to you this morning too. As discussed:


The current Go SDK roadmap

The general c= ontribution guide

And Go SDK specific dev environment set up:


As for running Flink locally, it's not as bad as I thought= for the most part, though the flink version might need updating.

Copying from Daniel Oliveira's SDF exa= mple instructions:
=
1. From a comm= and line, navigate to the top-level beam directory and run the Flink Job Se= rver:
=C2=A0 ./grad= lew :runners:flink:1.9:job-server:runShadow -Djob-host=3Dlocalhost -Dflink-= master=3Dlocal

=
2. The job server = is ready to receive jobs once it outputs a log line like the following `Job= Service started on localhost:8099`.=C2=A0
Take note of the endpoint in that message (in this c= ase, localhost:<port>

3. In= a second command line terminal, run your job. Eg wordcount, assuming your = working directory is the same top level beam directory
=C2=A0 go run sdks/go/examples/wordcoun= t/wordcount.go --runner=3Duniversal --endpoint=3Dlocalhost:8099


=C2=A0=C2=A0


On Th= u, Apr 2, 2020, 10:29 AM Damon Douglas <douglas.damon@gmail.com= > wrote:
Hello = Everyone,

I would like to start an initiative to contrib= ute to the Apache Beam katas for the golang SDK.=C2=A0 My JIRA username is = `damondouglas`.=C2=A0 I will be adding subtasks under=C2=A0https://issues.apache.org/jira/browse/BEAM-9676
<= div>
Thank you for including me in this exciting project.

Sincerely,

Damon
--0000000000008bbd8c05a252dde4--