Hi Flink users,
I saw this error
12/08/2017 17:31:27 groupBy: (shipmentNumber), window:
(TumblingGroupWindow('w$, 'rowtime, 3600000.millis)), select:
(shipmentNumber, SUM(grandTotal) AS EXPR$1) -> to: Row(3/4) switched to
FAILED
java.lang.NoSuchMethodError:
org.apache.flink.api.common.functions.AggregateFunction.add(Ljava/lang/Object;Ljava/lang/Object;)V
The flink version is 1.4-SNAPSHOT. I already implemetend
DefinedRowtimeAttribute in my table source and return the
event time column as row time
I thought of mvn issue and, and also tried 1.3.2 and it shows the data type
is not supporting tumble window no matter using Types.LONG() or
Types.SQL_TIMESTAMP().
Is there anything I should also notice?
Best,
Sendoh
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
