[ 
https://issues.apache.org/jira/browse/BEAM-7924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908583#comment-16908583
 ] 

Kyle Weaver commented on BEAM-7924:
-----------------------------------

I just ran into a similar issue. Do either of you know why setting 
save_main_session causes an error? Is there a different workaround so we can 
enable this setting in Flink without causing an error?

> Failure in Python 2 postcommit: crossLanguagePythonJavaFlink
> ------------------------------------------------------------
>
>                 Key: BEAM-7924
>                 URL: https://issues.apache.org/jira/browse/BEAM-7924
>             Project: Beam
>          Issue Type: Bug
>          Components: test-failures
>            Reporter: Udi Meiri
>            Assignee: Heejong Lee
>            Priority: Major
>             Fix For: 2.15.0
>
>          Time Spent: 3.5h
>  Remaining Estimate: 0h
>
> This seems to be the root cause:
> {code}
> 11:32:59 [grpc-default-executor-1] WARN pipeline_options.get_all_options - 
> Discarding unparseable args: [u'--app_name=None', 
> u'--shutdown_sources_on_final_watermark', u'--flink_master=[auto]', 
> u'--direct_runner_use_stacked_bundle', u'--options_id=1', 
> u'--fail_on_checkpointing_errors', u'--enable_metrics', 
> u'--pipeline_type_check', u'--parallelism=2'] 
> 11:32:59 [grpc-default-executor-1] INFO sdk_worker_main.main - Python sdk 
> harness started with pipeline_options: {'runner': u'None', 'experiments': 
> [u'worker_threads=100', u'beam_fn_api'], 'environment_cache_millis': 
> u'10000', 'sdk_location': u'container', 'job_name': 
> u'BeamApp-root-0807183253-57a72c22', 'save_main_session': True, 'region': 
> u'us-central1', 'sdk_worker_parallelism': u'1'}
> 11:32:59 [grpc-default-executor-1] ERROR sdk_worker_main.main - Python sdk 
> harness failed: 
> 11:32:59 Traceback (most recent call last):
> 11:32:59   File 
> "/usr/local/lib/python2.7/site-packages/apache_beam/runners/worker/sdk_worker_main.py",
>  line 153, in main
> 11:32:59     sdk_pipeline_options.view_as(pipeline_options.ProfilingOptions))
> 11:32:59   File 
> "/usr/local/lib/python2.7/site-packages/apache_beam/options/pipeline_options.py",
>  line 334, in __getattr__
> 11:32:59     (type(self).__name__, name))
> 11:32:59 AttributeError: 'PipelineOptions' object has no attribute 
> 'ProfilingOptions' 
> {code}
> https://builds.apache.org/job/beam_PostCommit_Python2_PR/58/console



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)

Reply via email to