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/
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
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/
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
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