This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git
commit 09e62077dab53fd69cd0151eb0f9404c82112ef8 Author: Etienne Chauchot <[email protected]> AuthorDate: Tue May 28 09:31:59 2019 +0200 Improve visibility of debug messages --- .../spark/structuredstreaming/translation/TranslationContext.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TranslationContext.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TranslationContext.java index 4d17120..411aec3 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TranslationContext.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TranslationContext.java @@ -201,7 +201,7 @@ public class TranslationContext { // code. List<WindowedValue> windowedValues = ((Dataset<WindowedValue>) dataset).collectAsList(); for (WindowedValue windowedValue : windowedValues) { - LOG.debug(windowedValue.toString()); + LOG.debug("**** dataset content {} ****", windowedValue.toString()); } } else { // apply a dummy fn just to apply for each action that will trigger the pipeline run in
