You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Beam JIRA Bot (Jira)" <ji...@apache.org> on 2021/04/05 17:20:01 UTC

[jira] [Assigned] (BEAM-7379) Flink runner build instructions need updating

     [ https://issues.apache.org/jira/browse/BEAM-7379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Beam JIRA Bot reassigned BEAM-7379:
-----------------------------------

    Assignee:     (was: David Huntsperger)

> Flink runner build instructions need updating
> ---------------------------------------------
>
>                 Key: BEAM-7379
>                 URL: https://issues.apache.org/jira/browse/BEAM-7379
>             Project: Beam
>          Issue Type: Bug
>          Components: website
>            Reporter: Chad Dombrova
>            Priority: P3
>              Labels: stale-assigned
>
> Hi,
> I'm new to the project and trying to follow the instructions on [https://beam.apache.org/documentation/runners/flink/] for the portable flink runner, but they are out of date. I'd love to see the docs updated so that users like myself can do this successfully.
> The first issue is that all of the source releases that I downloaded, from both github and the downloads page, had the gradlew file removed.  I had to clone the repo to solve this problem.
> The next problem that I encountered was this:
> {code:java}
> chad$ ./gradlew :sdks:python:container:docker
> Configuration on demand is an incubating feature.
> FAILURE: Build failed with an exception.
> * What went wrong:
> Project 'sdks' not found in root project 'beam'.
> {code}
>   
> The proper command is: 
> {code:java}
> ./gradlew :beam-sdks-python-container:docker{code}
>  
> Likewise, the next command should be:
> {code:java}
> ./gradlew :beam-runners-flink-1.7-job-server:runShadow -PflinkMasterUrl=localhost:8081{code}
>   
> After that I was able to get the flink beam example working.  I recommend adding this to the docs:
> {code:java}
> (.venv) chad$ python -m apache_beam.examples.flink.flink_streaming_impulse{code}
>  
> also, since the docs specify only flink 1.7 is compatible with beam 2.12 (the latest as of this writing), I had to do a little extra work to get flink 1.7 built instead of 1.8, but this is probably outside the scope of the beam docs:
> {code:java}
> brew install https://raw.github.com/Homebrew/homebrew-core/97b7a467beb81412bef2fbc497671c8ad3d407e5/Formula/apache-flink.rb
> /usr/local/Cellar/apache-flink/1.7.2/libexec/bin/start-cluster.sh{code}
> thanks!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)