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()
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)
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?