flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From " Mario Georgiev (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (FLINK-12172) Flink fails to close pending BucketingSink
Date Thu, 18 Apr 2019 08:28:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-12172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820841#comment-16820841
] 

 Mario Georgiev edited comment on FLINK-12172 at 4/18/19 8:27 AM:
------------------------------------------------------------------

Hi Biao,
 I read all the documentation regarding the BucketingSink, could you please where this "disregarding"
of pending files happen and that they are substituted with new files from the savepoint? Could
anyone else also confirm this?


was (Author: mariogeorgievft):
Hi Biao,
I read all the documentation regarding the BucketingSink, could you please where this "disregarding"
of pending files happen and that they are substituted with new files from the savepoint? Could
anyone else also confirm this?Cancel

> Flink fails to close pending BucketingSink
> ------------------------------------------
>
>                 Key: FLINK-12172
>                 URL: https://issues.apache.org/jira/browse/FLINK-12172
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / FileSystem
>    Affects Versions: 1.7.2
>            Reporter:  Mario Georgiev
>            Priority: Major
>
> Hello,
> The problem is if you have a BucketingSink, the following case may occur :
> Let's say you have a 2019-04-12–12 bucket created with several files inside which are
pending/finished
>  You create a savepoint and shut down the job
>  After an hour for instance you start the job from the savepoint and a new bucket is
created, 2019-04-16 for instance. 
>  The problem is that the .pending ones from the old buckets seem to never be moved to
finished state if there is a new hourly bucket created.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message