-
Type:
Bug
-
Status: Resolved
-
Priority:
P2
-
Resolution: Fixed
-
Affects Version/s: 2.27.0
-
Fix Version/s: 2.28.0
-
Component/s: beam-community, io-py-aws, runner-flink
-
Labels:None
-
Environment:Python 3.8
TFX 0.27.0
Beam 0.27.0
Flink Cluster 1.10.1 with 2 slaves. One beam worker per each taskmanager
When i use FlinkRunner i got an error inside beam worker pool container. As you see by logs, s3 options are provided.
Logs are available onĀ https://gist.github.com/ferryvg/d6be9f5b1ca739bc378d7743cb1b8e07
- relates to
-
BEAM-11790 Error when trying to read from S3 with Python SDK and external runners
-
- Resolved
-