beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From echauc...@apache.org
Subject [beam] 13/45: Improve visibility of debug messages
Date Tue, 09 Jul 2019 13:18:30 GMT
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 ee91d24ec5f99929503bc7ba250133075f489e67
Author: Etienne Chauchot <echauchot@apache.org>
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


Mime
View raw message