Upgrade Beam version

Depends on !187 (merged).

Fix #304 (closed).

Open issues:

• null can (probably) no longer be used as tombstone in UC4 as reported by spotbugs
• test all implementations (see below)
  • UC1 / Flink
  • UC1 / Samza
  • UC2 / Flink
  • UC2 / Samza
  • UC3 / Flink
  • UC3 / Samza
  • UC4 / Flink
  • UC4 / Samza

added modul/benchmarks label

changed the description

added 49 commits

• 15f6fcde...1a248290 - 47 commits from branch master
• 71094b16 - Merge branch 'master' into upgrade-beam
• b2b242de - Add spotbugs exclude filter for FP

Compare with previous version

mentioned in issue #312

assigned to @she

marked the checklist item null can (probably) no longer be used as tombstone in UC4 as reported by spotbugs as completed

null can (probably) no longer be used as tombstone in UC4 as reported by spotbugs

Seems to be a false positive, #312.

changed the description

added 2 commits

• 27783328 - 1 commit from branch master
• 5ee4b7dd - Merge branch 'master' into upgrade-beam

Compare with previous version

mentioned in issue #302 (closed)

added 55 commits

• 5ee4b7dd...3beafeec - 54 commits from branch master
• c69c6332 - Merge branch 'master' into upgrade-beam

Compare with previous version

changed the description

Samza 1.15 is currently not working due to exception:

Exception in thread "main" java.lang.IllegalArgumentException: Class interface org.apache.beam.sdk.options.PipelineOptions missing a property named 'configFactory'.

See also:

• https://samza.apache.org/releases/1.5.1
• https://cwiki.apache.org/confluence/display/SAMZA/SEP-23%3A+Simplify+Job+Runner#SEP23:SimplifyJobRunner-References
• https://github.com/apache/beam/blob/master/runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineOptions.java

We need to find out whether --configOverride="{\"job.coordinator.zk.connect\":\"$SAMZA_JOB_COORDINATOR_ZK_CONNECT\"}" is still required for Samza 1.5

Getting exception for Samza:

[main] ERROR org.apache.samza.util.ReflectionUtil - Unable to create instance for class: org.apache.samza.system.kafka.KafkaSystemFactory

added 2 commits

• a21e780c - Addd Samza kafka dependency
• 5e4937ea - Remove configFactory in Dockerfiles

Compare with previous version