Skip to content

Commit 0f402ed

Browse files
committed
Make renewGlobalStateOwnershipForPartitionCreation private
Signed-off-by: Siqi Ding <dingdd@amazon.com>
1 parent 793f5d3 commit 0f402ed

2 files changed

Lines changed: 1 addition & 7 deletions

File tree

data-prepper-api/src/main/java/org/opensearch/dataprepper/model/source/coordinator/SourceCoordinator.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -164,9 +164,4 @@ public interface SourceCoordinator<T> {
164164
void renewPartitionOwnership(final String partitionKey);
165165

166166
void deletePartition(final String partitionKey);
167-
168-
/**
169-
* Renews the global state ownership for partition creation to prevent timeout during long-running operations
170-
*/
171-
void renewGlobalStateOwnershipForPartitionCreation();
172167
}

data-prepper-core/src/main/java/org/opensearch/dataprepper/core/sourcecoordination/LeaseBasedSourceCoordinator.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -523,8 +523,7 @@ private Optional<SourcePartitionStoreItem> acquireGlobalStateForPartitionCreatio
523523
return globalStateItemForPartitionCreation;
524524
}
525525

526-
@Override
527-
public void renewGlobalStateOwnershipForPartitionCreation() {
526+
private void renewGlobalStateOwnershipForPartitionCreation() {
528527
try {
529528
final Optional<SourcePartitionStoreItem> globalStateItem = sourceCoordinationStore.getSourcePartitionItem(
530529
sourceIdentifierWithGlobalStateType, GLOBAL_STATE_SOURCE_PARTITION_KEY_FOR_CREATING_PARTITIONS);

0 commit comments

Comments
 (0)