Hi Sendoh,
at a first glance this looks like a Maven issue to me. Are you sure you
are using a consistent version for both core Flink and flink-table (also
consistent Scala version 2.11)?
Maybe you can share your pom.xml with us. It seems that flink-table is a
newer version that your Flink core.
Regards,
Timo
Am 12/8/17 um 5:37 PM schrieb Sendoh:
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 setup the
event time column as rowtime
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/
