From 07acb4acef291db0d135baf2b7d7016740d894d3 Mon Sep 17 00:00:00 2001 From: Atul Mohan Date: Mon, 23 Dec 2019 15:02:14 -0600 Subject: [PATCH 1/2] Fix deserialization of maxBytesInMemory --- .../indexing/common/index/RealtimeAppenderatorTuningConfig.java | 1 + .../org/apache/druid/segment/indexing/RealtimeTuningConfig.java | 1 + 2 files changed, 2 insertions(+) diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/common/index/RealtimeAppenderatorTuningConfig.java b/indexing-service/src/main/java/org/apache/druid/indexing/common/index/RealtimeAppenderatorTuningConfig.java index b66ccc86f1d9..eec9b98d4973 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/common/index/RealtimeAppenderatorTuningConfig.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/common/index/RealtimeAppenderatorTuningConfig.java @@ -143,6 +143,7 @@ public int getMaxRowsInMemory() } @Override + @JsonProperty public long getMaxBytesInMemory() { return maxBytesInMemory; diff --git a/server/src/main/java/org/apache/druid/segment/indexing/RealtimeTuningConfig.java b/server/src/main/java/org/apache/druid/segment/indexing/RealtimeTuningConfig.java index a4679441ce4f..728e2ffac57b 100644 --- a/server/src/main/java/org/apache/druid/segment/indexing/RealtimeTuningConfig.java +++ b/server/src/main/java/org/apache/druid/segment/indexing/RealtimeTuningConfig.java @@ -174,6 +174,7 @@ public int getMaxRowsInMemory() } @Override + @JsonProperty public long getMaxBytesInMemory() { return maxBytesInMemory; From 92909363383a8bcf0d12869f795ac8d2921e417e Mon Sep 17 00:00:00 2001 From: Atul Mohan Date: Mon, 23 Dec 2019 16:02:07 -0600 Subject: [PATCH 2/2] Add maxBytes check --- .../apache/druid/indexing/common/task/TaskSerdeTest.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/indexing-service/src/test/java/org/apache/druid/indexing/common/task/TaskSerdeTest.java b/indexing-service/src/test/java/org/apache/druid/indexing/common/task/TaskSerdeTest.java index 2ba37ff0bd09..c5841eaa27b4 100644 --- a/indexing-service/src/test/java/org/apache/druid/indexing/common/task/TaskSerdeTest.java +++ b/indexing-service/src/test/java/org/apache/druid/indexing/common/task/TaskSerdeTest.java @@ -394,7 +394,7 @@ public void testRealtimeIndexTaskSerde() throws Exception new RealtimeTuningConfig( 1, - null, + 10L, new Period("PT10M"), null, null, @@ -445,6 +445,10 @@ public void testRealtimeIndexTaskSerde() throws Exception task.getRealtimeIngestionSchema().getTuningConfig().getWindowPeriod(), task2.getRealtimeIngestionSchema().getTuningConfig().getWindowPeriod() ); + Assert.assertEquals( + task.getRealtimeIngestionSchema().getTuningConfig().getMaxBytesInMemory(), + task2.getRealtimeIngestionSchema().getTuningConfig().getMaxBytesInMemory() + ); Assert.assertEquals( task.getRealtimeIngestionSchema().getDataSchema().getGranularitySpec().getSegmentGranularity(), task2.getRealtimeIngestionSchema().getDataSchema().getGranularitySpec().getSegmentGranularity()