Поддерживаются ли эталонные методы в Apache Flink 1.0.0?

Этот код работает нормально:

.keyBy(value -> value.getSessionUid())

но это

.keyBy(LogItem::getSessionUid)

бросить исключение:

Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: -1
    at org.apache.flink.api.java.typeutils.TypeExtractor.getUnaryOperatorReturnType(TypeExtractor.java:294)
    at org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:253)
    at org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:246)
    at org.apache.flink.streaming.api.datastream.KeyedStream.<init>(KeyedStream.java:87)
    at org.apache.flink.streaming.api.datastream.DataStream.keyBy(DataStream.java:241)
    at streamer_sessions_aggregator.StreamerSessionAggregator.runFlow(StreamerSessionAggregator.java:40)
    at streamer_sessions_aggregator.Main.main(Main.java:10)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:497)
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)

Насколько я понимаю, Apache Flink 1.0.0 теперь не поддерживает эталонные методы. Верно?


person Maxim    schedule 25.03.2016    source источник


Ответы (1)


В настоящее время Flink не поддерживает эталонные методы. Вот JIRA для добавления поддержки: https://issues.apache.org/jira/browse/FLINK-3138

person Robert Metzger    schedule 04.04.2016