[
https://issues.apache.org/jira/browse/BEAM-7632?focusedWorklogId=463709&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-463709
]
ASF GitHub Bot logged work on BEAM-7632:
----------------------------------------
Author: ASF GitHub Bot
Created on: 29/Jul/20 07:24
Start Date: 29/Jul/20 07:24
Worklog Time Spent: 10m
Work Description: ibzib edited a comment on pull request #12397:
URL: https://github.com/apache/beam/pull/12397#issuecomment-665351269
> For an existing cluster, isn't it as simple as passing the flink master
URL? If so, I think that's worth stating.
For a local cluster, yes (we can just use loopback). Or at least I thought
so. I tried this on my local Flink 1.10 cluster:
```sh
python -m apache_beam.examples.wordcount --input /path/to/inputfile \
--output /path/to/write/counts \
--runner FlinkRunner \
--environment_type LOOPBACK \
--flink_master localhost:8081 \
--flink_version 1.10
```
But I got an error:
`ERROR:root:org.apache.flink.runtime.rest.util.RestClientException: [Failed
to deserialize JobGraph.]`
This [Stack Overflow
post](https://stackoverflow.com/questions/58358308/flink-submitting-job-failed-to-deserialize-jobgraph)
suggests a Flink version incompatibility might be the cause, but both the job
server jar and the Flink cluster are Flink 1.10, so I'm not sure what's going
on.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 463709)
Time Spent: 1h 10m (was: 1h)
> Update Python quickstart guide for Flink and Spark
> --------------------------------------------------
>
> Key: BEAM-7632
> URL: https://issues.apache.org/jira/browse/BEAM-7632
> Project: Beam
> Issue Type: Improvement
> Components: website
> Reporter: Kyle Weaver
> Priority: P3
> Time Spent: 1h 10m
> Remaining Estimate: 0h
>
> Currently, the documentation says "This runner is not yet available for the
> Python SDK.", which is out of date.
> [https://beam.apache.org/get-started/quickstart-py/]
> Edit: when Beam 2.15 is released, we should update the quickstart to use the
> new Python FlinkRunner [1].
>
> [1]
> [https://github.com/apache/beam/blob/master/sdks/python/apache_beam/runners/portability/flink_runner.py]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
