Skip to content
Snippets Groups Projects
Commit 87f00436 authored by Sören Henning's avatar Sören Henning
Browse files

Fix type info bug in UC1

parent 5c1d1f6b
Branches DCParadigm
No related tags found
No related merge requests found
Pipeline #3009 passed
Stage: build
Stage: test
Stage: check
Stage: deploy
Show whitespace changes
Inline Side-by-side
theodolite-benchmarks/uc1-flink/src/main/java/theodolite/uc1/application/HistoryServiceFlinkJob.java
+ 3
− 1
View file @ 87f00436
package theodolite.uc1.application; package theodolite.uc1.application;
import org.apache.commons.configuration2.Configuration; import org.apache.commons.configuration2.Configuration;
import org.apache.flink.api.common.typeinfo.Types;
import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer; import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer;
...@@ -61,7 +62,8 @@ public final class HistoryServiceFlinkJob { ...@@ -61,7 +62,8 @@ public final class HistoryServiceFlinkJob {
stream stream
.rebalance() .rebalance()
.map(new GsonMapper()) .map(new GsonMapper())
.flatMap((record, c) -> LOGGER.info("Record: {}", record)); .flatMap((record, c) -> LOGGER.info("Record: {}", record))
.returns(Types.GENERIC(Object.class)); // Will never be used
} }
/** /**
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment