Skip to content
Snippets Groups Projects
Commit 70492a50 authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

Add uc4-beam-flink

Also excption Exception in thread main java.lang.IllegalArgumentException:
 Cannot union streams of different types:
  CoderTypeInformation{coder=WindowedValue$
  FullWindowedValueCoder(KvCoder(NullableCoder(StringUtf8Coder)
  ,org.apache.beam.sdk.coders.AvroCoder@b03f3cea),IntervalWindow)}
  and
  CoderTypeInformation{coder=WindowedValue$
  FullWindowedValueCoder(KvCoder(NullableCoder(StringUtf8Coder)
  ,NullableCoder(org.apache.beam.sdk.coders.AvroCoder@b03f3cea)),IntervalWindow)}
 by just using the raw not NullableCoder
parent e9b3ac88
No related branches found
No related tags found
1 merge request!187Migrate Beam benchmark implementation
Loading
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment