You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by "sivabalan narayanan (Jira)" <ji...@apache.org> on 2022/09/28 18:53:00 UTC

[jira] [Commented] (HUDI-4624) Make sure all DeltaStreamer Sources are Closeable

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

sivabalan narayanan commented on HUDI-4624:
-------------------------------------------

for now, lets tackle 

S3EventsSource to close/shutdown sqs client. 

> Make sure all DeltaStreamer Sources are Closeable
> -------------------------------------------------
>
>                 Key: HUDI-4624
>                 URL: https://issues.apache.org/jira/browse/HUDI-4624
>             Project: Apache Hudi
>          Issue Type: Bug
>          Components: deltastreamer
>            Reporter: Alexey Kudinkin
>            Assignee: sivabalan narayanan
>            Priority: Blocker
>             Fix For: 0.12.1
>
>
> Currently, many of the sources acquire resources (creating Kafka/Pulsar/SQS/etc clients) but are not releasing them properly, since they don't implement `Closeable` interface proeprly.
> We need to rectify that by making sure that any DS Source that acquires some resource, releases it properly in `close`.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)