You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "TisonKun (JIRA)" <ji...@apache.org> on 2019/01/18 07:36:00 UTC
[jira] [Commented] (FLINK-11387) Flink task can not restart from
failed after running two days.
[ https://issues.apache.org/jira/browse/FLINK-11387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16745856#comment-16745856 ]
TisonKun commented on FLINK-11387:
----------------------------------
[~jiweiautohome] I would suggest you to ask/post this question on the user mail list [user@flink.apache.org|mailto:user@flink.apache.org]
There is where Flink community answers question like this.
> 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
> Priority: Blocker
> 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)