You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ne...@apache.org on 2019/01/12 01:00:27 UTC
[incubator-pinot] 01/01: Change the realtime stats file to a new
name
This is an automated email from the ASF dual-hosted git repository.
nehapawar pushed a commit to branch fix_stats_file_realtime
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 718096ed1c5b20c365b63d01490e847a8e70a724
Author: Neha Pawar <np...@linkedin.com>
AuthorDate: Fri Jan 11 17:00:03 2019 -0800
Change the realtime stats file to a new name
---
.../data/manager/realtime/RealtimeTableDataManager.java | 2 +-
.../realtime/impl/RealtimeSegmentStatsHistoryTest.java | 4 ++--
.../resources/data/realtime-segment-stats-history-v1.ser | Bin 822 -> 0 bytes
.../resources/data/realtime-segment-stats-history.ser | Bin 0 -> 832 bytes
4 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeTableDataManager.java b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeTableDataManager.java
index ff8a8b8..327c612 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeTableDataManager.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeTableDataManager.java
@@ -65,7 +65,7 @@ public class RealtimeTableDataManager extends BaseTableDataManager {
private RealtimeSegmentStatsHistory _statsHistory;
private final Semaphore _segmentBuildSemaphore;
- private static final String STATS_FILE_NAME = "stats.ser";
+ private static final String STATS_FILE_NAME = "statsV2.ser";
private static final String CONSUMERS_DIR = "consumers";
// Topics tend to have similar cardinality for values across partitions consumed during the same time.
diff --git a/pinot-core/src/test/java/org/apache/pinot/core/realtime/impl/RealtimeSegmentStatsHistoryTest.java b/pinot-core/src/test/java/org/apache/pinot/core/realtime/impl/RealtimeSegmentStatsHistoryTest.java
index a1a3c79..09d9275 100644
--- a/pinot-core/src/test/java/org/apache/pinot/core/realtime/impl/RealtimeSegmentStatsHistoryTest.java
+++ b/pinot-core/src/test/java/org/apache/pinot/core/realtime/impl/RealtimeSegmentStatsHistoryTest.java
@@ -222,9 +222,9 @@ public class RealtimeSegmentStatsHistoryTest {
// This test attempts to ensure that future modifications to RealtimeSegmentStatsHistory does not prevent the software
// from reading data serialized by earlier versions. The serialized data has one segment, with 2 columns -- "v1col1" and
// "v1col2".
- //@Test
+ @Test
public void testVersion1() throws Exception {
- final String fileName = "realtime-segment-stats-history-v1.ser";
+ final String fileName = "realtime-segment-stats-history.ser";
File v1StatsFile = new File(TestUtils.getFileFromResourceUrl(RealtimeSegmentStatsHistoryTest.class.getClassLoader().getResource("data")), fileName);
RealtimeSegmentStatsHistory statsHistory = RealtimeSegmentStatsHistory.deserialzeFrom(v1StatsFile);
RealtimeSegmentStatsHistory.SegmentStats segmentStats = statsHistory.getSegmentStatsAt(0);
diff --git a/pinot-core/src/test/resources/data/realtime-segment-stats-history-v1.ser b/pinot-core/src/test/resources/data/realtime-segment-stats-history-v1.ser
deleted file mode 100644
index e0f09dc..0000000
Binary files a/pinot-core/src/test/resources/data/realtime-segment-stats-history-v1.ser and /dev/null differ
diff --git a/pinot-core/src/test/resources/data/realtime-segment-stats-history.ser b/pinot-core/src/test/resources/data/realtime-segment-stats-history.ser
new file mode 100644
index 0000000..06519f8
Binary files /dev/null and b/pinot-core/src/test/resources/data/realtime-segment-stats-history.ser differ
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org