Getting this:
DataStream<RawRecord> stream = env.addSource(new
FlinkKafkaConsumer08<>("raw", schema, properties)
).setParallelism(30).flatMap(new RecordSplit()).setParallelism(30).
name("Raw splitter").keyBy("id","keyByHelper","schema");
Field expression must be equal to '*' or '_' for non-composite types.
org.apache.flink.api.common.operators.Keys$ExpressionKeys.<init>(Keys.java:342)
org.apache.flink.streaming.api.datastream.DataStream.keyBy(DataStream.java:273)
com.company.ingest.stream.RawRecord.main(RawRecord.java:38)
I did add a new long compare
@Override public int compareTo(SchemaRecord o) { return
Long.compare(this.keyByHelper, o.keyByHelper);
I can't seem to get by this error...
