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

Updated Guava version, added backoff for ShardSync Integ test, and reintroduced SNAPSHOT version (#1214)

Browse source 
* Updated guava version to 32.1.1 and added backoff logic for ShardSync Integration test

* Added back snapshot version classifier

---------

Co-authored-by: Brendan Lynch <brenplyn@amazon.com>
This commit is contained in:
Brendan Lynch 2023-10-11 14:54:49 -07:00 committed by GitHub
parent 1e6506cf97
commit e731486b7f
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 11 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
pom.xml
View file

@ -6,7 +6,7 @@
<artifactId>amazon-kinesis-client</artifactId>
<packaging>jar</packaging>
<name>Amazon Kinesis Client Library for Java</name>
<version>1.15.0</version>
<version>1.15.1-SNAPSHOT</version>
<description>The Amazon Kinesis Client Library for Java enables Java developers to easily consume and process data
from Amazon Kinesis.
</description>
@ -55,7 +55,7 @@
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>31.0.1-jre</version>
<version>32.1.1-jre</version>
</dependency>
<dependency>
<groupId>com.google.protobuf</groupId>

11
src/test/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/ShardSyncTaskIntegrationTest.java
View file

@ -42,6 +42,7 @@ import com.amazonaws.services.kinesis.leases.impl.KinesisClientLease;
import com.amazonaws.services.kinesis.leases.impl.KinesisClientLeaseManager;
import com.amazonaws.services.kinesis.leases.interfaces.IKinesisClientLeaseManager;
import com.amazonaws.services.kinesis.model.StreamStatus;
import com.amazonaws.services.kinesis.model.LimitExceededException;
import static junit.framework.TestCase.fail;
@ -58,6 +59,8 @@ public class ShardSyncTaskIntegrationTest {
private IKinesisProxy kinesisProxy;
private final KinesisShardSyncer shardSyncer = new KinesisShardSyncer(new KinesisLeaseCleanupValidator());
private static final int retryBackoffMillis = 1000;
/**
* @throws java.lang.Exception
*/
@ -71,9 +74,13 @@ public class ShardSyncTaskIntegrationTest {
} catch (AmazonServiceException ase) {
}
StreamStatus status;
StreamStatus status = null;
do {
status = StreamStatus.fromValue(kinesis.describeStream(STREAM_NAME).getStreamDescription().getStreamStatus());
try {
status = StreamStatus.fromValue(kinesis.describeStream(STREAM_NAME).getStreamDescription().getStreamStatus());
} catch (LimitExceededException e) {
Thread.sleep(retryBackoffMillis + (long) (Math.random() * 100));
}
} while (status != StreamStatus.ACTIVE);
}