我正在尝试在我的android项目中使用ApacheFlink和“minsdkversion24”。
很遗憾,以下代码会导致错误:
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:解析失败:ljava/time/instant;在org.apache.flink.api.common.typeinfo.basictypeinfo。java:89)在org.apache.flink.api.common.typeinfo.basictypeinfo.getinfofor(basictypeinfo。java:214)在org.apache.flink.api.java.typeutils.typeextractor.privategetforclass(typeextractor。java:1705)在org.apache.flink.api.java.typeutils.typeextractor.privategetforclass(类型提取器。java:1643)在org.apache.flink.api.java.typeutils.typeextractor.privategetforobject(typeextractor。java:2038)在org.apache.flink.api.java.typeutils.typeextractor.getforobject(typeextractor。java:1983)在org.apache.flink.streaming.api.environment.streamexecutionenvironment.fromcollection(streamexecutionenvironment。java:782)
java.time api是在AndroidAPI级别26中引入的。那么,在老版本的android版本上运行flink是不可能的吗?
暂无答案!
目前还没有任何答案,快来回答吧!