File tree Expand file tree Collapse file tree
data-prepper-plugins/dynamodb-source
src/test/java/org/opensearch/dataprepper/plugins/source/dynamodb/stream Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -27,5 +27,5 @@ dependencies {
2727
2828
2929 testImplementation ' com.fasterxml.jackson.dataformat:jackson-dataformat-yaml'
30- testImplementation project(' :data-prepper-test-common' )
30+ testImplementation project(path : ' :data-prepper-test-common' )
3131}
Original file line number Diff line number Diff line change 2121import org .opensearch .dataprepper .plugins .source .dynamodb .DynamoDBSourceConfig ;
2222import org .opensearch .dataprepper .plugins .source .dynamodb .coordination .partition .StreamPartition ;
2323import org .opensearch .dataprepper .plugins .source .dynamodb .coordination .state .StreamProgressState ;
24- import org .opensearch .dataprepper .test .helper .ReflectivelySetField ;
2524
2625import java .time .Duration ;
2726import java .time .Instant ;
2827import java .util .Optional ;
2928import java .util .function .Consumer ;
3029
30+ import static org .opensearch .dataprepper .test .helper .ReflectivelySetField .setField ;
31+
3132import static org .junit .jupiter .api .Assertions .assertNotNull ;
3233import static org .junit .jupiter .api .Assertions .assertTrue ;
3334import static org .junit .jupiter .api .Assertions .assertDoesNotThrow ;
@@ -105,7 +106,7 @@ void testUpdateOwnershipForAllShardPartitions() throws Exception {
105106 shardAcknowledgementManager .createAcknowledgmentSet (streamPartition , "seq123" , false );
106107
107108 // Set lastCheckpointTime to past to trigger checkpoint interval
108- ReflectivelySetField . setField (ShardAcknowledgementManager .class , shardAcknowledgementManager ,
109+ setField (ShardAcknowledgementManager .class , shardAcknowledgementManager ,
109110 "lastCheckpointTime" , Instant .now ().minus (Duration .ofMinutes (5 )));
110111
111112 // Call updateOwnershipForAllShardPartitions directly
You can’t perform that action at this time.
0 commit comments