[IOTDB-298]Last time-value query by wshao08 · Pull Request #821 · apache/iotdb

wshao08 · 2020-02-17T18:35:36Z

JIRA issue: https://issues.apache.org/jira/browse/IOTDB-298

This PR implements a new LAST query for IoTDB

The LAST query is to return the most recent value of the given timeseries in a time-value format.
The basic Sql syntax of Last query is:

select last <Path> [COMMA <Path>]* from <PrefixPath> [COMMA <PrefixPath>]*

In order to trace the latest timestamp and value as quick as possible, this PR adds a cache to store this latest time and value in MNodes. This cache will be updated when values with larger timestamps are written to the specific timeseries.

JackieTien97

First, you should pay attention to your code format.

our tab is two blanks. yours is four
you have lots of useless import statement, please remove them

Second, you should add some UTs and ITs.

Last, there are some wrong usage of IAggregateReader, I have commented.

server/src/main/java/org/apache/iotdb/db/metadata/MNode.java

JackieTien97 · 2020-02-18T08:54:53Z

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

+        while (seriesReader.hasNextChunk()) {
+            while (seriesReader.hasNextPage()) {
+                // cal by page data
+                while (seriesReader.hasNextOverlappedPage()) {
+                    BatchData nextOverlappedPageData = seriesReader.nextOverlappedPage();
+                    int maxIndex = nextOverlappedPageData.length() - 1;
+                    if (maxIndex < 0) {
+                        continue;
+                    }
+                    long time = nextOverlappedPageData.getTimeByIndex(maxIndex);
+                    if (time > maxTime) {
+                        maxTime = time;
+                        queryResult.setPairResult(maxTime, nextOverlappedPageData.getValueInTimestamp(time), tsDataType);
+                    }
+                    nextOverlappedPageData.resetBatchData();
+                }
+            }
+        }


You can use the chunk and page statistics if possible. The code will be like as:

while (seriesReader.hasNextChunk()) { if (seriesReader.canUseCurrentChunkStatistics()) { if (seriesReader.currentChunkStatistics().getEndTime() > maxTime) { maxTime = seriesReader.currentChunkStatistics().getEndTime(); queryResult.setPairResult(maxTime, seriesReader.currentChunkStatistics().getLastValue(), tsDataType); } seriesReader.skipCurrentChunk(); continue; } while (seriesReader.hasNextPage()) { if (seriesReader.canUseCurrentPageStatistics()) { if (seriesReader.currentPageStatistics().getEndTime() > maxTime) { maxTime = seriesReader.currentPageStatistics().getEndTime(); queryResult.setPairResult(maxTime, seriesReader.currentPageStatistics().getLastValue(), tsDataType); } seriesReader.skipCurrentPage(); continue; } // cal by page data while (seriesReader.hasNextOverlappedPage()) { BatchData nextOverlappedPageData = seriesReader.nextOverlappedPage(); int maxIndex = nextOverlappedPageData.length() - 1; if (maxIndex < 0) { continue; } long time = nextOverlappedPageData.getTimeByIndex(maxIndex); if (time > maxTime) { maxTime = time; queryResult.setPairResult(maxTime, nextOverlappedPageData.getValueInTimestamp(time), tsDataType); } nextOverlappedPageData.resetBatchData(); } } }

Yes, adopted

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

JackieTien97 · 2020-02-18T09:06:03Z

server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java

      }
      insertPlan.setDataTypes(dataTypes);
      storageEngine.insert(insertPlan);
+      insertPlan.updateMNodeLastValues(node);


It is not suitable to put the updateMNodeLastValues method in the InsertPlan.
You can update the last value in the before loop, there you already got the measurementNode.

The update function is moved into MNode structure.
I added a loop to update the last value after storageEngine.insert(). It is possible that insert() could fail and throw exceptions. In such case the last value cache will not be updated.

JackieTien97 · 2020-02-18T09:06:47Z

server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java

-      return storageEngine.insertBatch(batchInsertPlan);
-
+      Integer[] results = storageEngine.insertBatch(batchInsertPlan);
+      batchInsertPlan.updateMNodeLastValues(node);


The same as before

JackieTien97 · 2020-02-18T09:08:53Z

server/src/main/java/org/apache/iotdb/db/qp/logical/Operator.java

    SFW, JOIN, UNION, FILTER, GROUPBY, ORDERBY, LIMIT, SELECT, SEQTABLESCAN, HASHTABLESCAN,
    MERGEJOIN, FILEREAD, NULL, TABLESCAN, UPDATE, INSERT, BATCHINSERT, DELETE, BASIC_FUNC, IN, QUERY, MERGEQUERY,
-    AGGREGATION, AUTHOR, FROM, FUNC, LOADDATA, METADATA, PROPERTY, INDEX, INDEXQUERY, FILL,
+    AGGREGATION, AUTHOR, FROM, FUNC, LOADDATA, METADATA, PROPERTY, INDEX, INDEXQUERY, FILL, LAST,


It's better to add it to the last, because you don't know whether the programmers are using the enum's ordinal() function

JackieTien97 · 2020-02-18T09:10:37Z

server/src/main/java/org/apache/iotdb/db/qp/physical/crud/BatchInsertPlan.java

+  public void updateMNodeLastValues(MNode node) {
+    long maxTime = Long.MIN_VALUE;
+    int maxIndex = 0;
+    for (int i = 0; i < times.length; i++) {
+      if (times[i] > maxTime) {
+        maxTime = times[i];
+        maxIndex = i;
+      }
+    }
+    for (int i = 0; i < measurements.length; i++) {
+      if (node.hasChild(measurements[i])) {
+        Object[] column = (Object[]) columns[i];
+        node.getChild(measurements[i]).updateCachedLast(maxTime, column[maxIndex], dataTypes[i]);
+      }
+    }
+  }
+


This function is not the InsertPlan's responsibility

Agree. Moved it out of InsertPlan

JackieTien97 · 2020-02-18T09:10:51Z

server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertPlan.java

+  public void updateMNodeLastValues(MNode node) throws QueryProcessException {
+    for (int i = 0; i < measurements.length; i++) {
+      if (node.hasChild(measurements[i])) {
+        Object value = CommonUtils.parseValue(dataTypes[i], values[i]);
+        node.getChild(measurements[i]).updateCachedLast(time, value, dataTypes[i]);
+      }
+    }
+  }


Same as before

server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java

JackieTien97

There are still some places need to be changed.

UTs and ITs are needed.

You should also add documents in both EN and CH docs, tell us about the last grammar and show us some examples.

server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java

JackieTien97 · 2020-02-19T01:42:13Z

server/src/main/java/org/apache/iotdb/db/qp/physical/crud/BatchInsertPlan.java

+    long maxTime = Long.MIN_VALUE;
+    int maxIndex = 0;
+    for (int i = 0; i < times.length; i++) {
+      if (times[i] > maxTime) {
+        maxTime = times[i];
+        maxIndex = i;
+      }
+    }


No matter what measurementIndex is, this calculation process is the same. It only needs to be called once.
You can extract that method outside the the calling loop.

…ries_reader

qiaojialin · 2020-02-21T03:32:36Z

server/src/main/java/org/apache/iotdb/db/metadata/MNode.java

+      return;
+    if (cachedLastValuePair == null) {
+      cachedLastValuePair = new TimeValuePair(timeValuePair.getTimestamp(), timeValuePair.getValue());
+    } else if (timeValuePair.getTimestamp() > cachedLastValuePair.getTimestamp()) {


Suggested change

} else if (timeValuePair.getTimestamp() > cachedLastValuePair.getTimestamp()) {

} else if (timeValuePair.getTimestamp() >= cachedLastValuePair.getTimestamp()) {

insert time-value 1-1
insert time-value 1-2
the vlaue of 1 should be updated to 2

qiaojialin · 2020-02-21T08:57:09Z

server/src/main/java/org/apache/iotdb/db/qp/physical/crud/BatchInsertPlan.java

+  public TimeValuePair composeLastTimeValuePair(int measurementIndex) {
+    long maxTime = Long.MIN_VALUE;
+    int maxIndex = 0;
+    for (int i = 0; i < times.length; i++) {


the time in BatchInsertPlan is always in ascending order, you could directly get the last

qiaojialin · 2020-02-21T08:58:52Z

server/src/main/java/org/apache/iotdb/db/qp/strategy/LogicalGenerator.java

+    LastFunctionCallContext functionCallContext = ctx.lastFunctionCall();
+    Path path = parseSuffixPath(functionCallContext.suffixPath());
+    selectOp.addLastPath(path, functionCallContext.LAST().getText());
+    queryOp.setSelectOperator(selectOp);


the sql needs update

Sql syntax updated

qiaojialin · 2020-02-21T09:01:09Z

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

+      lastQueryResultList.add(lastQueryResult);
+    }
+
+    RowRecord resultRecord = constructLastRowRecord(lastQueryResultList);


The result format should be updated to path, time, value

Result set updated

qiaojialin · 2020-02-21T09:04:14Z

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

+    return resultRecord;
+  }
+
+  class LastQueryResult {


I think this class is not needed, you could use TimeValuePair directly unless you store the path of a series in this class.

Removed in the new version

qiaojialin · 2020-02-21T09:24:28Z

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

+    }
+
+    // construct series reader without value filter
+    Filter timeFilter = null;


remove this field and use null directly

qiaojialin · 2020-02-21T09:36:10Z

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

+      }
+    }
+    if (queryResult.hasResult())
+      node.setCachedLast(queryResult.getPairResult());


Notice: considering inserting a point while querying.

It's better to remove the setCachedLast and change updateCachedLast method to a synchronized one. Then, extend updateCachedLast with a parameter: boolean highPriority, which is to determine whether update the value if the time is equal to the previous cached one.

Then, in the normal inserting process, update the cache with high priority. Here, update the cache with low priority.
This could resolve the condition: there is an insert (10,11) when you get the last point (10,10) from disk.

Updated, thanks

…ries_reader

qiaojialin · 2020-02-27T06:10:42Z

docs/Documentation-CHN/UserGuide/5-Operation Manual/2-DML (Data Manipulation Language).md

+
+下面的例子中查询时间序列root.ln.wf01.wt01.status最近时间戳的数据:
+```
+select last(status) from root.ln.wf01.wt01 disable align


qiaojialin · 2020-02-27T06:13:31Z

server/src/main/java/org/apache/iotdb/db/metadata/mnode/MNode.java

   */
  protected String fullPath;

+  private TimeValuePair cachedLastValuePair = null;


move this to LeafMNode

qiaojialin · 2020-02-27T06:14:11Z

server/src/main/java/org/apache/iotdb/db/metadata/mnode/MNode.java

+    return cachedLastValuePair;
+  }
+
+  public synchronized void updateCachedLast(


add javadoc for highPriorityUpdate

qiaojialin · 2020-02-27T06:16:04Z

server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SelectOperator.java


  private List<Path> suffixList;
  private List<String> aggregations;
+  private boolean hasLast;


Suggested change

private boolean hasLast;

private boolean lastQuery;

qiaojialin · 2020-02-27T06:17:04Z

server/src/main/java/org/apache/iotdb/db/qp/strategy/PhysicalGenerator.java

      queryPlan = new AggregationPlan();
      ((AggregationPlan) queryPlan)
          .setAggregations(queryOperator.getSelectOperator().getAggregations());
+    } else if (queryOperator.hasLast()) {


Suggested change

} else if (queryOperator.hasLast()) {

} else if (queryOperator.isLastQuery()) {

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java

qiaojialin · 2020-02-27T06:29:38Z

server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java

    plan.setDataTypeConsistencyChecker(null);
  }

+  private void getLastQueryHeaders(


I don't remember, doesn't the respColumns contain time column?

qiaojialin · 2020-02-28T12:08:40Z

server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java

      throw new QueryProcessException(e);
    }
  }
-


add a blank line...

qiaojialin · 2020-02-28T12:10:11Z

server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java

@@ -178,6 +180,12 @@ public class StorageGroupProcessor {
   * file.
   */
  private Map<Long, Map<String, Long>> latestFlushedTimeForEachDevice = new HashMap<>();


rename this to latestDeviceFlushedTimeInEachPartition distinguish with globalLatestFlushedTimeForEachDevice

qiaojialin · 2020-02-28T12:23:18Z

server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java

      latestFlushedTimeForEachDevice.computeIfAbsent(timePartitionId, id -> new HashMap<>())
          .putIfAbsent(insertPlan.getDeviceId(), Long.MIN_VALUE);

+      long latestFlushedTime = globalLatestFlushedTimeForEachDevice.computeIfAbsent(


Suggested change

long latestFlushedTime = globalLatestFlushedTimeForEachDevice.computeIfAbsent(

long globalLatestFlushTime = globalLatestFlushedTimeForEachDevice.computeIfAbsent(

qiaojialin · 2020-02-28T12:24:43Z

server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java

+      if (latestFlushedTime < insertPlan.getTime())
+        globalLatestFlushedTimeForEachDevice.put(insertPlan.getDeviceId(), insertPlan.getTime());


Suggested change

if (latestFlushedTime < insertPlan.getTime())

globalLatestFlushedTimeForEachDevice.put(insertPlan.getDeviceId(), insertPlan.getTime());

if (latestFlushedTime < insertPlan.getTime()) {

globalLatestFlushedTimeForEachDevice.put(insertPlan.getDeviceId(), insertPlan.getTime());

}

Then, move these three lines to insertToTsFileProcessor(), make it updated at the same time as the lastFlushTimeForEachDevice

Yes moved, looks better now.

qiaojialin · 2020-02-28T12:38:00Z

server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java

    }
  }

+  public void updateInsertPlanLast(InsertPlan plan, Long latestFlushedTime)


Suggested change

public void updateInsertPlanLast(InsertPlan plan, Long latestFlushedTime)

public void tryToUpdateCache(InsertPlan plan, Long latestFlushedTime)

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

qiaojialin · 2020-02-28T12:57:35Z

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

+
+    TimeValuePair resultPair = new TimeValuePair(Long.MIN_VALUE, null);
+
+    for (int i = seqFileResources.size() - 1; i >= 0; i--) {


no need to loop, get the last one directly

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

qiaojialin · 2020-02-28T13:01:05Z

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

+    }
+
+    // Update cached last value with low priority
+    ((LeafMNode)node).updateCachedLast(resultPair, false, Long.MIN_VALUE);


when I saw this line, I think maybe move the lastFlushTime out of the updateCachedLast mehod and check in the insertion is better

qiaojialin · 2020-02-28T13:04:18Z

server/src/main/java/org/apache/iotdb/db/query/executor/LastQueryExecutor.java

+    List<TsFileResource> seqFileResources = dataSource.getSeqResources();
+    List<TsFileResource> unseqFileResources = dataSource.getUnseqResources();
+
+    TimeValuePair resultPair = new TimeValuePair(Long.MIN_VALUE, null);


Suggested change

TimeValuePair resultPair = new TimeValuePair(Long.MIN_VALUE, null);

TimeValuePair resultPair;

qiaojialin

add design doc

qiaojialin · 2020-03-02T11:11:42Z

docs/Documentation-CHN/SystemDesign/5-DataQuery/6-LastQuery.md

+
+## Last 缓存更新策略
+
+Last缓存更新的逻辑位于`LeafNode`的`updateCachedLast`方法内，这里引入两个额外的参数`highPriorityUpdate`和`latestFlushTime`。`highPriorityUpdate`用来表示本次更新是否是高优先级的，新数据写入而导致的缓存更新都被认为是高优先级更新，而查询时更新缓存默认为低优先级更新。`latestFlushTime`用来记录当前已被写回到磁盘的数据的最大时间戳。


Suggested change

Last缓存更新的逻辑位于`LeafNode`的`updateCachedLast`方法内，这里引入两个额外的参数`highPriorityUpdate`和`latestFlushTime`。`highPriorityUpdate`用来表示本次更新是否是高优先级的，新数据写入而导致的缓存更新都被认为是高优先级更新，而查询时更新缓存默认为低优先级更新。`latestFlushTime`用来记录当前已被写回到磁盘的数据的最大时间戳。

Last缓存更新的逻辑位于`LeafMNode`的`updateCachedLast`方法内，这里引入两个额外的参数`highPriorityUpdate`和`latestFlushTime`。`highPriorityUpdate`用来表示本次更新是否是高优先级的，新数据写入而导致的缓存更新都被认为是高优先级更新，而查询时更新缓存默认为低优先级更新。`latestFlushTime`用来记录当前已被写回到磁盘的数据的最大时间戳。

JackieTien97

No need to judge whether the chunkLoader is null, otherwise it will cause the file closed exception like before, please fix it.

JackieTien97 · 2020-03-02T12:21:14Z

server/src/main/java/org/apache/iotdb/db/utils/FileLoaderUtils.java

+      if (data.getChunkLoader() == null) {
+        TsFileSequenceReader tsFileSequenceReader =
+            FileReaderManager.getInstance().get(resource, resource.isClosed());
+        data.setChunkLoader(new DiskChunkLoader(tsFileSequenceReader));
+      }


Remove the if judgement, it will cause the file closed null pointer exception.
like:
for (ChunkMetaData data : currentChunkMetaDataList) {
TsFileSequenceReader tsFileSequenceReader =
FileReaderManager.getInstance().get(resource, resource.isClosed());
data.setChunkLoader(new DiskChunkLoader(tsFileSequenceReader));
}

it's ok to do so. because tsFileSequenceReader has been cached.

samperson1997

Good design!

JackieTien97

LGTM

wshao08 added 4 commits February 17, 2020 15:28

Add Last query implement without cache

553ae3c

Add Last query cache in MTree node

b4f7c6f

Fix null measurement display for last query

6112371

Add Missing license comments

8ba2e96

JackieTien97 requested changes Feb 18, 2020

View reviewed changes

wshao08 added 4 commits February 18, 2020 17:45

Remove unused import and adjust code format

b03c708

Fix compilation error

55f9a83

Clarify last related function behavior

97cfadc

Use chunk and page stats when calculating last data

3f02f7c

wshao08 requested a review from JackieTien97 February 18, 2020 17:29

JackieTien97 requested changes Feb 19, 2020

View reviewed changes

wshao08 added 6 commits February 20, 2020 23:30

Fix last query syntax bug

21e7615

Add java doc for last

afbc093

Update java doc

0abe34f

Merge remote-tracking branch 'upstream/new_series_reader' into new_se…

c2ee32b

…ries_reader

Add unit test for last

409a7b9

Fix ut compilation error

f43426a

qiaojialin requested changes Feb 21, 2020

View reviewed changes

wshao08 closed this Feb 24, 2020

wshao08 deleted the new_series_reader branch February 24, 2020 08:33

wshao08 reopened this Feb 24, 2020

Merge remote-tracking branch 'upstream/new_series_reader' into new_se…

1f1f2c0

…ries_reader

wshao08 changed the base branch from new_series_reader to master February 24, 2020 09:10

wshao08 added 7 commits February 24, 2020 17:18

Merge branch 'master' into new_series_reader

3e175b5

Fix compilation error

92c4391

Update new version of LAST query in java doc

e10aa61

Modify Last query syntax

5736f86

Update last query behavior

c561dc5

Merge remote-tracking branch 'upstream/master' into new_series_reader

1e65ee3

Fix test compile issue

c137074

Update unit tests for new syntax

f6fb25b

qiaojialin requested changes Feb 27, 2020

View reviewed changes

wshao08 added 3 commits February 28, 2020 15:08

Optimize last query process and fix review issues

548e0af

Modify last cache update strategy

c4039c2

Move last cache insert into StorageGroupProcessor

2492f8a

qiaojialin requested changes Feb 28, 2020

View reviewed changes

Fix review issues and make code more readable

39974ad

qiaojialin approved these changes Mar 1, 2020

View reviewed changes

wshao08 added 3 commits March 2, 2020 10:14

Add more java docs and rename some variables

6e15c19

Merge remote-tracking branch 'upstream/master' into new_series_reader

f136bcc

add sync property file to pass sync test case

8aa9e2b

qiaojialin approved these changes Mar 2, 2020

View reviewed changes

JackieTien97 requested changes Mar 2, 2020

View reviewed changes

wshao08 added 2 commits March 2, 2020 21:04

Fix unit test bugs

bebfc0e

Add Integration test for last query

c26b2b5

samperson1997 approved these changes Mar 2, 2020

View reviewed changes

Add missing licence

6d009ad

JackieTien97 approved these changes Mar 2, 2020

View reviewed changes

qiaojialin merged commit 6404d6d into apache:master Mar 3, 2020

	} else if (timeValuePair.getTimestamp() > cachedLastValuePair.getTimestamp()) {
	} else if (timeValuePair.getTimestamp() >= cachedLastValuePair.getTimestamp()) {

	} else if (queryOperator.hasLast()) {
	} else if (queryOperator.isLastQuery()) {

	long latestFlushedTime = globalLatestFlushedTimeForEachDevice.computeIfAbsent(
	long globalLatestFlushTime = globalLatestFlushedTimeForEachDevice.computeIfAbsent(

		if (latestFlushedTime < insertPlan.getTime())
		globalLatestFlushedTimeForEachDevice.put(insertPlan.getDeviceId(), insertPlan.getTime());

	public void updateInsertPlanLast(InsertPlan plan, Long latestFlushedTime)
	public void tryToUpdateCache(InsertPlan plan, Long latestFlushedTime)


		TimeValuePair resultPair = new TimeValuePair(Long.MIN_VALUE, null);

		for (int i = seqFileResources.size() - 1; i >= 0; i--) {

	TimeValuePair resultPair = new TimeValuePair(Long.MIN_VALUE, null);
	TimeValuePair resultPair;


		## Last 缓存更新策略

		Last缓存更新的逻辑位于`LeafNode`的`updateCachedLast`方法内，这里引入两个额外的参数`highPriorityUpdate`和`latestFlushTime`。`highPriorityUpdate`用来表示本次更新是否是高优先级的，新数据写入而导致的缓存更新都被认为是高优先级更新，而查询时更新缓存默认为低优先级更新。`latestFlushTime`用来记录当前已被写回到磁盘的数据的最大时间戳。

Conversation

wshao08 commented Feb 17, 2020 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

JackieTien97 left a comment

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Choose a reason for hiding this comment

Uh oh!

wshao08 Feb 18, 2020 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Uh oh!

JackieTien97 left a comment

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

wshao08 commented Feb 17, 2020 •

edited

Loading

wshao08 Feb 18, 2020 •

edited

Loading