María GH created BEAM-4223:
------------------------------

             Summary: game_stats.py not working with the DataflowRunner
                 Key: BEAM-4223
                 URL: https://issues.apache.org/jira/browse/BEAM-4223
             Project: Beam
          Issue Type: Bug
          Components: sdk-py-core
    Affects Versions: 2.4.0
            Reporter: María GH
            Assignee: Ahmet Altay


Command used:

python apache_beam/examples/complete/game/game_stats.py \
 --project=google.com:clouddfe \
 --topic projects/google.com:clouddfe/topics/leader_board-$USER-topic-1 \
 --dataset ${USER}_bq_dataset \
 --runner DataflowRunner \
 --temp_location gs://<...> \
 --sdk_location /<...>/dist/apache-beam-2.5.0.dev0.tar.gz

 

BigQuery at:

[https://bigquery.cloud.google.com/dataset/google.com:clouddfe:mariagh_bq_dataset?pli=1]

Nothing gets output to game_stats_sessions.

 

Job:

https://pantheon.corp.google.com/dataflow/jobsDetail/locations/us-central1/jobs/2018-04-30_12_56_57-10424752922445606094?project=google.com:clouddfe



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to