Skip to content

[Bug]: Python Interactive Beam show() does not work #35129

Open
@Chenzo1001

Description

@Chenzo1001

What happened?

While on the JupyterLab notebook cell:

import apache_beam as beam
from apache_beam import Create, Map
from apache_beam.runners.interactive.interactive_runner import InteractiveRunner
import apache_beam.runners.interactive.interactive_beam as ib

N=7
p = beam.Pipeline(InteractiveRunner())
squares = (p | "Create Elements" >> Create(range(N))
             | "Squares" >> Map(lambda x: x**2))

ib.show(squares)

The ib.show(squares) does not show anything except:
Processing... show

But if you run:

squares = (p | "Create Elements" >> Create(range(N))
             | "Squares" >> Map(lambda x: x**2)
             | Map(print))
p.run()

Then it will show the correct result:

0
1
4
9
16
25
36

Issue Priority

Priority: 2 (default / most bugs should be filed as P2)

Issue Components

  • Component: Python SDK
  • Component: Java SDK
  • Component: Go SDK
  • Component: Typescript SDK
  • Component: IO connector
  • Component: Beam YAML
  • Component: Beam examples
  • Component: Beam playground
  • Component: Beam katas
  • Component: Website
  • Component: Infrastructure
  • Component: Spark Runner
  • Component: Flink Runner
  • Component: Samza Runner
  • Component: Twister2 Runner
  • Component: Hazelcast Jet Runner
  • Component: Google Cloud Dataflow Runner

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions