This is an automated email from the ASF dual-hosted git repository.
karan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new 74a7eef01fc Kinesis: Remove some unused static constants. (#17918)
74a7eef01fc is described below
commit 74a7eef01fcc4febeb3e5c0c40a9b513ac2776c3
Author: Gian Merlino <[email protected]>
AuthorDate: Tue Apr 15 03:12:18 2025 -0700
Kinesis: Remove some unused static constants. (#17918)
---
.../apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfig.java | 6 ------
1 file changed, 6 deletions(-)
diff --git
a/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfig.java
b/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfig.java
index 83b111e9e96..97d63913bc1 100644
---
a/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfig.java
+++
b/extensions-core/kinesis-indexing-service/src/main/java/org/apache/druid/indexing/kinesis/KinesisIndexTaskTuningConfig.java
@@ -37,11 +37,6 @@ import java.util.Objects;
@JsonTypeName("KinesisTuningConfig")
public class KinesisIndexTaskTuningConfig extends
SeekableStreamIndexTaskTuningConfig
{
- // Assumed record buffer size is larger when dealing with aggregated
messages, because aggregated messages tend to
- // be larger, up to 1MB in size.
- static final int ASSUMED_RECORD_SIZE = 10_000;
- static final int ASSUMED_RECORD_SIZE_AGGREGATE = 1_000_000;
-
/**
* Together with {@link KinesisIndexTaskIOConfig#MAX_RECORD_FETCH_MEMORY},
don't take up more than 200MB per task.
*/
@@ -55,7 +50,6 @@ public class KinesisIndexTaskTuningConfig extends
SeekableStreamIndexTaskTuningC
private static final int DEFAULT_RECORD_BUFFER_OFFER_TIMEOUT = 5000;
private static final int DEFAULT_RECORD_BUFFER_FULL_WAIT = 5000;
- private static final int DEFAULT_MAX_RECORDS_PER_POLL = 100;
private static final int DEFAULT_MAX_BYTES_PER_POLL = 1_000_000;
private final Integer recordBufferSize;
private final Integer recordBufferSizeBytes;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
