!1422 [I44QYL] Fix for Hive Split Source is already closed Issue

Merge pull request !1422 from i-robot/pull328
This commit is contained in:
i-robot 2022-03-24 12:01:08 +00:00 committed by Gitee
commit d1d87d04f9
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
1 changed files with 2 additions and 0 deletions

View File

@ -374,6 +374,8 @@ public class MarkerSplitSource
public void close()
{
announcer.deactivateSplitSource(this);
// In case of closing split source before source is exhausted. (e.g. query with limit function).
sourceExhausted = true;
source.close();
}