Fwd: Beam Error downgrading from Flink 1.10 to 1.8

2020-06-15 Thread Roger
help is appreciated! Thanks. Roger *java.lang.VerifyError: Bad type on operand stackException Details: Location: org/apache/beam/runners/flink/FlinkStreamingTransformTranslators$CombinePerKeyTranslator.translateNode(Lorg/apache/beam/sdk/transforms/PTransform;Lorg/apache/beam/runners/

Re: Beam Error downgrading from Flink 1.10 to 1.8

2020-06-15 Thread Roger
Whelp. I think I might have just solved my own problem. It looks like when I downgraded, I was still using flink-runner version 1.10 in my pom.xml. I downgraded this to 1.8 and it seems to have worked! On Mon, Jun 15, 2020 at 12:41 PM Roger wrote: > Hello. > I am currently trying to get

window not advancing

2020-06-19 Thread Roger
ta. Things just stop. Any suggestions or ideas on what I've done wrong would be very much appreciated. Thanks for looking! Roger *Approach: Use withTimestampPolicyFactory from org.apache.beam.sdk.io.kafka here <https://beam.apache.org/releases/javadoc/2.4.0/org/apache/beam/sdk/io/

Re: window not advancing

2020-06-19 Thread Roger
Forgot to add that I'm using beam 2.21.0 and kafka version 2.3.1. On 2020/06/19 22:41:10, Roger wrote: > Hello.> > I am having issues with an unbounded streaming processing pipeline using> > event times for processing. I can confirm that all the pieces of the> > pipe

Re: window not advancing

2020-06-19 Thread Roger
also forgot to mention i am running this in Flink 1.8 using the flinkRunner. beam-runners-flink-1.8 On 2020/06/19 22:41:10, Roger wrote: > Hello.> > I am having issues with an unbounded streaming processing pipeline using> > event times for processing. I can confirm that all th