[
https://issues.apache.org/jira/browse/FLINK-16589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059534#comment-17059534
]
Viet Pham commented on FLINK-16589:
-----------------------------------
[~libenchao]: please see below an excerpt. The actual query is actually twice
as long (which generates the exception above). Yes there is an aggregation, but
very simple one.
{code:java}
SELECT
id AS id,
LAST_VALUE(platform_domain) AS platform_domain,
MAX(now) AS now,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 0, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 1, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_WTD0,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 1, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 2, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_WTD1,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 2, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 3, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_WTD2,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 3, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 4, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_WTD3,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 4, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 5, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_WTD4,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 5, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 6, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_WTD5,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 6, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 7, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_WTD6,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 0, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 1, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H0,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 1, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 2, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H1,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 2, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 3, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H2,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 3, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 4, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H3,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 4, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 5, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H4,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 5, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 6, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H5,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 6, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 7, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H6,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 7, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 8, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H7,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 8, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 9, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H8,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 9, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 10, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H9,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 10, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 11, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H10,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 11, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 12, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H11,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 12, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 13, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H12,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 13, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 14, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H13,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 14, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 15, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H14,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 15, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 16, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H15,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 16, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 17, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H16,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 17, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 18, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H17,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 18, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 19, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H18,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 19, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 20, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H19,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 20, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 21, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H20,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 21, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 22, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H21,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 22, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 23, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H22,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 23, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 24, now))) AND pws_status =
'delivered', revenue, 0)) AS nmv_trend_today_H23,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 0, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 1, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD0,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 1, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 2, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD1,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 2, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 3, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD2,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 3, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 4, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD3,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 4, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 5, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD4,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 5, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 6, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD5,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 6, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 7, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD6,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 7, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 8, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD7,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 8, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 9, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD8,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 9, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 10, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD9,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 10, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 11, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD10,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 11, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 12, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD11,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 12, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 13, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD12,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 13, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 14, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD13,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 14, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 15, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD14,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 15, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 16, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD15,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 16, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 17, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD16,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 17, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 18, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD17,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 18, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 19, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD18,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 19, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 20, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD19,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 20, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 21, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD20,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 21, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 22, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD21,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 22, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 23, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD22,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 23, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 24, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD23,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 24, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 25, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD24,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 25, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 26, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD25,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 26, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 27, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD26,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 27, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 28, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD27,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 28, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 29, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD28,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 29, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 30, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD29,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 30, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 31, now))) AND pws_status = 'delivered',
revenue, 0)) AS nmv_trend_MTD30,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 0, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 1, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_WTD0,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 1, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 2, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_WTD1,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 2, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 3, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_WTD2,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 3, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 4, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_WTD3,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 4, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 5, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_WTD4,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 5, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 6, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_WTD5,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -MOD(CAST(DAYOFWEEK(now) AS
INT) + 5, 7) + 6, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-MOD(CAST(DAYOFWEEK(now) AS INT) + 5, 7) + 7, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_WTD6,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 0, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 1, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD0,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 1, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 2, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD1,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 2, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 3, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD2,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 3, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 4, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD3,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 4, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 5, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD4,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 5, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 6, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD5,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 6, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 7, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD6,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 7, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 8, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD7,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 8, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 9, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD8,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 9, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 10, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD9,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 10, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 11, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD10,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 11, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 12, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD11,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 12, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 13, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD12,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 13, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 14, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD13,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 14, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 15, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD14,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 15, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 16, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD15,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 16, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 17, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD16,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 17, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 18, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD17,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 18, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 19, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD18,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 19, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 20, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD19,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 20, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 21, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD20,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 21, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 22, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD21,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 22, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 23, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD22,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 23, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 24, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD23,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 24, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 25, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD24,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 25, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 26, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD25,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 26, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 27, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD26,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 27, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 28, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD27,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 28, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 29, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD28,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 29, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 30, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD29,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(DAY, -CAST(DAYOFMONTH(now) AS
INT) + 1 + 30, now) AND TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(DAY,
-CAST(DAYOFMONTH(now) AS INT) + 1 + 31, now))) AND pws_status = 'shipped',
revenue, 0)) AS shipped_revenue_trend_MTD30,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 0, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 1, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H0,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 1, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 2, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H1,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 2, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 3, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H2,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 3, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 4, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H3,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 4, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 5, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H4,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 5, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 6, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H5,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 6, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 7, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H6,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 7, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 8, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H7,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 8, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 9, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H8,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 9, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 10, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H9,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 10, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 11, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H10,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 11, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 12, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H11,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 12, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 13, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H12,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 13, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 14, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H13,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 14, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 15, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H14,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 15, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 16, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H15,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 16, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 17, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H16,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 17, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 18, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H17,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 18, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 19, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H18,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 19, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 20, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H19,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 20, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 21, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H20,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 21, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 22, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H21,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 22, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 23, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H22,
SUM(IF((time_slot BETWEEN TIMESTAMPADD(HOUR, 23, now) AND
TIMESTAMPADD(SECOND, -1, TIMESTAMPADD(HOUR, 24, now))) AND pws_status =
'shipped', revenue, 0)) AS shipped_revenue_trend_today_H23
FROM
shop_items_stats
GROUP BY
id
{code}
> Flink Table SQL fails/crashes with big queries with lots of fields
> ------------------------------------------------------------------
>
> Key: FLINK-16589
> URL: https://issues.apache.org/jira/browse/FLINK-16589
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Affects Versions: 1.10.0
> Reporter: Viet Pham
> Assignee: Benchao Li
> Priority: Critical
> Fix For: 1.10.1, 1.11.0
>
>
> Hi,
> My use case is a streaming application with a few streaming tables.
> I was trying to build a SELECT query (and registering it as a temporary view)
> with about 200 fields/expressions out of another streaming table. The
> application is successfully submitted to Flink cluster. However the worker
> processes keep crashing, with the exception as quoted below.
> It clearly mentioned in the log that this is a bug, so I fire this ticket. By
> the way, if I lower the number of fields down to 100 then it works nicely.
> Please advice.
> Thanks a lot for all the efforts bring Flink up. It is really amazing!
> {code:java}
> java.lang.RuntimeException: Could not instantiate generated class
> 'GroupAggsHandler$9687' at
> org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:57)
> at
> org.apache.flink.table.runtime.operators.aggregate.MiniBatchGroupAggFunction.open(MiniBatchGroupAggFunction.java:136)
> at
> org.apache.flink.table.runtime.operators.bundle.AbstractMapBundleOperator.open(AbstractMapBundleOperator.java:84)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.initializeStateAndOpen(StreamTask.java:1007)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$0(StreamTask.java:454)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:449)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:461)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:707) at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:532) at
> java.lang.Thread.run(Thread.java:748)Caused by:
> org.apache.flink.util.FlinkRuntimeException:
> org.apache.flink.api.common.InvalidProgramException: Table program cannot be
> compiled. This is a bug. Please file an issue. at
> org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:68)
> at
> org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:78)
> at
> org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:52)
> ... 10 moreCaused by:
> org.apache.flink.shaded.guava18.com.google.common.util.concurrent.UncheckedExecutionException:
> org.apache.flink.api.common.InvalidProgramException: Table program cannot be
> compiled. This is a bug. Please file an issue. at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2203)
> at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache.get(LocalCache.java:3937)
> at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4739)
> at
> org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:66)
> ... 12 moreCaused by:
> org.apache.flink.api.common.InvalidProgramException: Table program cannot be
> compiled. This is a bug. Please file an issue. at
> org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:81)
> at
> org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:66)
> at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4742)
> at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527)
> at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2319)
> at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2282)
> at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2197)
> ... 15 moreCaused by: org.codehaus.janino.InternalCompilerException:
> Compiling "GroupAggsHandler$9687": Code of method
> "retract(Lorg/apache/flink/table/dataformat/BaseRow;)V" of class
> "GroupAggsHandler$9687" grows beyond 64 KB at
> org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:382) at
> org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:237) at
> org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:465)
> at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216) at
> org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207) at
> org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80) at
> org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75) at
> org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:78)
> ... 21 moreCaused by: org.codehaus.janino.InternalCompilerException: Code
> of method "retract(Lorg/apache/flink/table/dataformat/BaseRow;)V" of class
> "GroupAggsHandler$9687" grows beyond 64 KB at
> org.codehaus.janino.CodeContext.makeSpace(CodeContext.java:1009) at
> org.codehaus.janino.CodeContext.write(CodeContext.java:901) at
> org.codehaus.janino.CodeContext.writeShort(CodeContext.java:1026) at
> org.codehaus.janino.UnitCompiler.writeConstantLongInfo(UnitCompiler.java:12274)
> at org.codehaus.janino.UnitCompiler.pushConstant(UnitCompiler.java:10679)
> at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:4936)
> at org.codehaus.janino.UnitCompiler.access$8400(UnitCompiler.java:215) at
> org.codehaus.janino.UnitCompiler$16.visitUnaryOperation(UnitCompiler.java:4414)
> at
> org.codehaus.janino.UnitCompiler$16.visitUnaryOperation(UnitCompiler.java:4394)
> at org.codehaus.janino.Java$UnaryOperation.accept(Java.java:4719) at
> org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4394) at
> org.codehaus.janino.UnitCompiler.fakeCompile(UnitCompiler.java:3719) at
> org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5569)
> at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2580) at
> org.codehaus.janino.UnitCompiler.access$2700(UnitCompiler.java:215) at
> org.codehaus.janino.UnitCompiler$6.visitLocalVariableDeclarationStatement(UnitCompiler.java:1503)
> at
> org.codehaus.janino.UnitCompiler$6.visitLocalVariableDeclarationStatement(UnitCompiler.java:1487)
> at
> org.codehaus.janino.Java$LocalVariableDeclarationStatement.accept(Java.java:3511)
> at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487) at
> org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1567)
> at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3388) at
> org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1357)
> at
> org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1330)
> at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:822) at
> org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:432) at
> org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:215) at
> org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:411)
> at
> org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:406)
> at
> org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1414)
> at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:406) at
> org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:378) ... 28
> more
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
