[
https://issues.apache.org/jira/browse/BEAM-6956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16807249#comment-16807249
]
Jiayi Zhao commented on BEAM-6956:
----------------------------------
*set the following parameter to my flink in conf/flink-conf.yaml file solved my
issue*
*taskmanager.heap.mb: 10240*
> --experiments=worker_threads=100 issue
> --------------------------------------
>
> Key: BEAM-6956
> URL: https://issues.apache.org/jira/browse/BEAM-6956
> Project: Beam
> Issue Type: New Feature
> Components: runner-flink
> Reporter: Jiayi Zhao
> Priority: Major
>
> I noticed that without this "–experiments=worker_threads=100", pipeline will
> stuck,
> The weird thing is, I tried some complex pipeline using the in thread flink
> method (./gradlew :beam-runners-flink_2.11-job-server:runShadow)
> "–experiments=worker_threads=100" doesn't work, but
> "–experiments=worker_threads=1000" works fine
> Then I tried the same pipeline using the separate local flink cluster
> (./gradlew :beam-runners-flink_2.11-job-server:runShadow
> -PflinkMasterUrl=localhost:8081), flink version is 1.5.6 (other version
> doesn't work, see BEAM-6915)
> Neither did "–experiments=worker_threads=1000" or
> "–experiments=worker_threads=10000" work, pipeline stuck at certain stage
> (shows running in flink UI but won't finish forever)
> any real fix to that? Thanks!
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
