beam-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Burke <>
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: filed for Go SDK Katas

The current Go SDK roadmap

The general contribution 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 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

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

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
> Thank you for including me in this exciting project.
> Sincerely,
> Damon

View raw message