some issues about WindowedValue$TimestampedValueInSingleWindow

am dependency:     org.apache.beam     beam-sdks-java-core     0.7.0-SNAPSHOT     org.apache.beam     beam-runners-direct-java     0.7.0-SNAPSHOT     runtime     org.apache.beam     beam-sdks-java-io-kafka     0.7.0-SNAPSHOT      org.apache.beam      beam-runners-spark      0.7.0-SNAPSHOT Sent f

Re: A problem about additional outputs

APSHOT     org.apache.beam     beam-runners-direct-java     0.7.0-SNAPSHOT     runtime     org.apache.beam     beam-sdks-java-io-kafka     0.7.0-SNAPSHOT      org.apache.beam      beam-runners-spark      0.7.0-SNAPSHOT Sent from Mailbird [http://www.getmailbird.com/?utm_source=Mailbird&utm_

Re: A problem about additional outputs

.apache.org/jira/browse/BEAM-2029 [https://issues.apache.org/jira/browse/BEAM-2029] Is this what you're facing? If so does pulling master and rebuilding help? On Thu, May 4, 2017 at 5:37 AM zhenglin.Tian mailto:zhenglin.t...@cafintech.com]> wrote: hi, i have a trouble about addition outpu

Re: A problem about additional outputs

hi, i have a trouble about addition outputs with SparkRunner. Here if my code, when i use DirectRunner, everything runs OK, but if i replace DirectRunner with SparkRunner, the code can't run normally. public class UnifiedDataExtraction {         private static TupleTag rawDataTag = new TupleTag()