I am trying to use Apache-Flink in my Android-Project with "minSdkVersion 24".
Unfortunately, the following code causes an error:
   
 
    val env: StreamExecutionEnvironment = LocalStreamEnvironment.getExecutionEnvironment()
    env.streamTimeCharacteristic = TimeCharacteristic.ProcessingTime
    val integerStream: DataStream<Int> = env.fromCollection(mutableListOf(1,2,3,4,5))
    
    integerStream.print()
    env.execute()

 
java.lang.NoClassDefFoundError: Failed resolution of: Ljava/time/Instant;
        at org.apache.flink.api.common.typeinfo.BasicTypeInfo.<clinit>(BasicTypeInfo.java:89)
        at org.apache.flink.api.common.typeinfo.BasicTypeInfo.getInfoFor(BasicTypeInfo.java:214)
        at org.apache.flink.api.java.typeutils.TypeExtractor.privateGetForClass(TypeExtractor.java:1705)
        at org.apache.flink.api.java.typeutils.TypeExtractor.privateGetForClass(TypeExtractor.java:1643)
        at org.apache.flink.api.java.typeutils.TypeExtractor.privateGetForObject(TypeExtractor.java:2038)
        at org.apache.flink.api.java.typeutils.TypeExtractor.getForObject(TypeExtractor.java:1983)
        at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromCollection(StreamExecutionEnvironment.java:782)
 
 
 
The java.time API was introduced in API Level 26. So is it impossible to run Flink on older Android-Verions?

Reply via email to