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.da...@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 >
