Skip to content
Snippets Groups Projects

Migrate Beam benchmark implementation

Merged Migrate Beam benchmark implementation
stu203404/theodolite:feature/147-add-beam-implementations into master
Merged Lorenz Boguhn requested to merge stu203404/theodolite:feature/147-add-beam-implementations into master
Viewing commit 70492a50
Prev Next
Show latest version
Compare changes
  • Side-by-side
  • Inline
Files
7
  • 70492a50
    Lorenz Boguhn
    Add uc4-beam-flink · 70492a50
    Lorenz Boguhn authored 
    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