Blink Planner fails to generate RowtimeAttribute for custom TableSource

[Yuval Itzchakov]

Hi,

While migrating from Flink 1.9 -> 1.10 and from the old planner to Blink, I've ran into an issue where the Blink Planner doesn't take into account the RowtimeAttribute defined on a custom table source. I've opened an issue: https://issues.apache.org/jira/browse/FLINK-17600 and was wondering if anyone else ran into this?

--

[r_khachatryan]

Hi Yuval,

Thanks for reporting this issue. I'm pulling in Timo and Jark who are working on the SQL component. They might be able to help you with your problem.

Regards,

On Mon, May 11, 2020 at 9:10 AM Yuval Itzchakov <[hidden email]> wrote:

Hi,

While migrating from Flink 1.9 -> 1.10 and from the old planner to Blink, I've ran into an issue where the Blink Planner doesn't take into account the RowtimeAttribute defined on a custom table source. I've opened an issue: https://issues.apache.org/jira/browse/FLINK-17600 and was wondering if anyone else ran into this?

--

Best Regards,
Yuval Itzchakov.

[Jark Wu-3]

Thanks for the investigation, and I think yes, this is a bug and is going to be fixed in FLINK-16160.

Best,

Jark

On Tue, 12 May 2020 at 02:28, Khachatryan Roman <[hidden email]> wrote:

Hi Yuval,

Thanks for reporting this issue. I'm pulling in Timo and Jark who are working on the SQL component. They might be able to help you with your problem.

Regards,

Roman

On Mon, May 11, 2020 at 9:10 AM Yuval Itzchakov <[hidden email]> wrote:

Hi,

While migrating from Flink 1.9 -> 1.10 and from the old planner to Blink, I've ran into an issue where the Blink Planner doesn't take into account the RowtimeAttribute defined on a custom table source. I've opened an issue: https://issues.apache.org/jira/browse/FLINK-17600 and was wondering if anyone else ran into this?

--

Best Regards,
Yuval Itzchakov.