jiwei created FLINK-11387:
-----------------------------
Summary: Flink task can not restart from failed after running two
days.
Key: FLINK-11387
URL: https://issues.apache.org/jira/browse/FLINK-11387
Project: Flink
Issue Type: Bug
Components: Table API & SQL, YARN
Affects Versions: 1.7.0
Environment:
Reporter: jiwei
Attachments: image-2019-01-18-15-15-36-281.png,
image-2019-01-18-15-17-57-250.png
The sql statement is as below.
SELECT k AS key, SUM(p) AS pv, SUM(u) AS uv
FROM (
SELECT concat_ws('|', udf_pcmplat(site_id), action, position_mark,
udf_hour(_time)) AS k
, COUNT(*) AS p
, udf_countdistinct(cuid) AS u
FROM xxxx
WHERE action NOT IN (
'unknown',
'nil',
'null',
'UNKNOWN',
'NIL',
'NULL'
)
AND udf_pcmplat(site_id) IS NOT NULL
GROUP BY md5_2(cuid),udf_hour(_time), udf_pcmplat(site_id), action,
position_mark
) t
GROUP BY k
This is the error log.
!image-2019-01-18-15-17-57-250.png!
Do you have any idea?
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
