.
Regards,
Chris
-- Original Message --
From: "Timo Walther"
To: user@flink.apache.org
Sent: 06/02/2019 16:45:26
Subject: Re: AssertionError: mismatched type $5 TIMESTAMP(3)
Hi Chris,
the error that you've observed is a bug that might be related to another bug
that is not easil
Hi Chris,
the error that you've observed is a bug that might be related to another
bug that is not easily solvable.
I created an issue for it nevertheless:
https://issues.apache.org/jira/browse/FLINK-11543
In general, I think you need to adapt your program in any case. Because
you are
entTime column, but that is required for the
temporal table join.
Any other ideas on how I can work around this problem?
Many thanks,
Chris
-- Original Message --
From: "Timo Walther"
To: "Chris Miller" ; "user"
Sent: 29/01/2019 09:44:14
Subject: Re: Assertio
quired for the temporal
table join.
Any other ideas on how I can work around this problem?
Many thanks,
Chris
-- Original Message --
From: "Timo Walther"
To: "Chris Miller" ; "user"
Sent: 29/01/2019 09:44:14
Subject: Re: AssertionError: mismatched type $5 TIM
Hi Chris,
the exception message is a bit misleading. The time attribute (time
indicator) type is an internal type and should not be used by users.
The following line should solve your issue. Instead of:
DataStream> tradesByInstrStream =
tableEnv.toRetractStream(tradesByInstr, typeInfo);
I'm trying to group some data and then enrich it by joining with a
temporal table function, however my test code (attached) is failing with
the error shown below. Can someone please give me a clue as to what I'm
doing wrong?
Exception in thread "main" java.lang.AssertionError: mismatched type
