You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Sebastián Magrí <se...@gmail.com> on 2021/02/18 15:17:22 UTC
[Flink SQL] FLOOR(timestamp TO WEEK) not working
While using said function in a query I'm getting a query compilation error
saying that there's no applicable method for the given arguments. The
parameter types displayed in the error are
org.apache.flink.table.data.TimestampData,
org.apache.flink.table.data.TimestampData
And there's no overload listed for
`org.apache.calcite.runtime.SqlFunctions.floor` that matches those
parameters.
Is this supported at all?
Is there anything in particular which should be imported or added to the
build to make this work?
--
Sebastián Ramírez Magrí
Re: [Flink SQL] FLOOR(timestamp TO WEEK) not working
Posted by Sebastián Magrí <se...@gmail.com>.
I'm using the latest Flink 1.12 and the timestamps precision is coming from
Debezium, which I think is a standard ISO-8601 timestamp.
On Thu, 18 Feb 2021 at 16:19, Timo Walther <tw...@apache.org> wrote:
> Hi Sebastián,
>
> which Flink version are you using? And which precision do the timestamps
> have?
>
> This looks clearly like a bug to me. We should open an issue in JIRA.
>
> Regards,
> Timo
>
> On 18.02.21 16:17, Sebastián Magrí wrote:
> > While using said function in a query I'm getting a query compilation
> > error saying that there's no applicable method for the given arguments.
> > The parameter types displayed in the error are
> >
> > org.apache.flink.table.data.TimestampData,
> > org.apache.flink.table.data.TimestampData
> >
> > And there's no overload listed for
> > `org.apache.calcite.runtime.SqlFunctions.floor` that matches those
> > parameters.
> >
> > Is this supported at all?
> > Is there anything in particular which should be imported or added to the
> > build to make this work?
> >
> > --
> > Sebastián Ramírez Magrí
>
>
--
Sebastián Ramírez Magrí
Re: [Flink SQL] FLOOR(timestamp TO WEEK) not working
Posted by Timo Walther <tw...@apache.org>.
Hi Sebastián,
which Flink version are you using? And which precision do the timestamps
have?
This looks clearly like a bug to me. We should open an issue in JIRA.
Regards,
Timo
On 18.02.21 16:17, Sebastián Magrí wrote:
> While using said function in a query I'm getting a query compilation
> error saying that there's no applicable method for the given arguments.
> The parameter types displayed in the error are
>
> org.apache.flink.table.data.TimestampData,
> org.apache.flink.table.data.TimestampData
>
> And there's no overload listed for
> `org.apache.calcite.runtime.SqlFunctions.floor` that matches those
> parameters.
>
> Is this supported at all?
> Is there anything in particular which should be imported or added to the
> build to make this work?
>
> --
> Sebastián Ramírez Magrí