luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge pull request #8 from fivetran/failure-on-garbage-incomplete-leases

Browse source 
fix(worker): fix NPE
This commit is contained in:
bencvdb 2021-07-07 09:28:22 -07:00 committed by GitHub
commit 69077e1fe2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/main/java/com/fivetran/external/com/amazonaws/services/kinesis/clientlibrary/lib/worker/Worker.java vendored
View file

@ -574,11 +574,10 @@ public class Worker implements Runnable {
private <T extends Throwable> Optional<T> getCauseOfType(Class<T> clazz, Throwable t) { private <T extends Throwable> Optional<T> getCauseOfType(Class<T> clazz, Throwable t) {
if (t.getClass().equals(clazz)) { if (t.getClass().equals(clazz)) {
return Optional.of( (T) t); return Optional.of( (T) t);
}
if (t.getCause().getClass().equals(clazz)) {
return Optional.of( (T) t.getCause());
} else if (t.getCause() == null) { } else if (t.getCause() == null) {
return Optional.empty(); return Optional.empty();
} else if (t.getCause().getClass().equals(clazz)) {
return Optional.of( (T) t.getCause());
} }
return getCauseOfType(clazz, t.getCause()); return getCauseOfType(clazz, t.getCause());