Could you send us the definition of the class or even better a small
code example on Github to reproduce your error?
If you are implementing a Flink job in Java you should not have any
org.apache.flink...scala import in your class file.
Regards,
Timo
Hi Timo
"You don't need to specify
Hi Boris,
each API is designed language-specific so they might not always be the
same. Scala has better type extraction features and let you write code
very precisely. Java requires sometime more code to archieve the same.
You don't need to specify the type in .flatMap() explicitly. It will b
More questions
In Scala my DataProcessor is defined as
class DataProcessorKeyed extends CoProcessFunction[WineRecord, ModelToServe,
Double] with CheckpointedFunction {
And it is used as follows
val models = modelsStream.map(ModelToServe.fromByteArray(_))
.flatMap(BadDataHandler[ModelToServe])
I am trying to covert Scala code (which works fine) to Java
The sacral code is:
// create a Kafka consumers
// Data
val dataConsumer = new FlinkKafkaConsumer010[Array[Byte]](
DATA_TOPIC,
new ByteArraySchema,
dataKafkaProps
)
// Model
val modelConsumer = new FlinkKafkaConsumer010[Array[Byte]]
