Wondering if anyone has seen this before, and has any suggestions. I have a
UDTF with the following signature:
public void eval(LocalDateTime startTime, LocalDateTime endTime, Duration
> step) {
According to the docs, this should be mapped from the following SQL snippet:
... LATERAL TABLE func(t1, t2, INTERVAL '5' MINUTES)
However, when I run a query in sql-client I get:
Caused by: java.lang.UnsupportedOperationException: Unsupported type when
> convertTypeToSpec: INTERVAL_DAY_SECOND
> at
> org.apache.calcite.sql.type.SqlTypeUtil.convertTypeToSpec(SqlTypeUtil.java:1059)
> ~[flink-table-blink_2.11-1.12.0.jar:1.12.0]
> at
> org.apache.calcite.sql.type.SqlTypeUtil.convertTypeToSpec(SqlTypeUtil.java:1081)
> ~[flink-table-blink_2.11-1.12.0.jar:1.12.0]
> at
> org.apache.flink.table.planner.functions.inference.TypeInferenceOperandChecker.castTo(TypeInferenceOperandChecker.java:165)
> ~[flink-table-blink_2.11-1.12.0.jar:1.12.0]
I tried all sorts of DataTypeHints (including bridgedTo specification) to
no avail. Any pointers?
Thanks in advance.
- P
