You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ec...@apache.org on 2019/05/28 07:33:21 UTC
[beam] 06/06: Improve visibility of debug messages
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 <ec...@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