flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Telco Phone <tel...@yahoo.com>
Subject Odd error
Date Thu, 23 Mar 2017 03:35:00 GMT

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,

I can't seem to get by this error...

View raw message