diff --git a/sdks/python/apache_beam/runners/direct/direct_runner.py b/sdks/python/apache_beam/runners/direct/direct_runner.py index 1cd20550edf36..49b6622816ce9 100644 --- a/sdks/python/apache_beam/runners/direct/direct_runner.py +++ b/sdks/python/apache_beam/runners/direct/direct_runner.py @@ -516,7 +516,9 @@ def visit_transform(self, applied_ptransform): if isinstance(applied_ptransform.transform, ExternalTransform): raise RuntimeError( "Streaming Python direct runner " - "does not support cross-language pipelines.") + "does not support cross-language pipelines." + "Please use other runners such as FlinkRunner, " + "DataflowRunner, or PrismRunner.") pipeline.visit(VerifyNoCrossLanguageTransforms())