beam-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Burke <rob...@frantil.com>
Subject Re: Golang SDK Katas
Date Thu, 02 Apr 2020 18:21:00 GMT
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:<port>

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 <douglas.damon@gmail.com> 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
>

Mime
View raw message