From ce6e612a6226f7f6d905b3c944fa071a86b93106 Mon Sep 17 00:00:00 2001
From: Zhexuan Yang <yangzhexuan@pingcap.com>
Date: Wed, 27 Mar 2019 17:52:30 +0800
Subject: [PATCH] Fix col version change (#612)

---
 .../src/main/java/com/pingcap/tikv/types/TimestampType.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tikv-client/src/main/java/com/pingcap/tikv/types/TimestampType.java b/tikv-client/src/main/java/com/pingcap/tikv/types/TimestampType.java
index fe65c5db6f..cca347dbe0 100644
--- a/tikv-client/src/main/java/com/pingcap/tikv/types/TimestampType.java
+++ b/tikv-client/src/main/java/com/pingcap/tikv/types/TimestampType.java
@@ -73,7 +73,7 @@ protected Timestamp decodeNotNull(int flag, CodecDataInput cdi) {
 
   @Override
   public DateTime getOriginDefaultValueNonNull(String value, long version) {
-    if (version == DataType.COLUMN_VERSION_FLAG) {
+    if (version >= DataType.COLUMN_VERSION_FLAG) {
       LocalDateTime localDateTime =
           Converter.strToDateTime(value, UTC_TIME_FORMATTER)
               .withZone(DateTimeZone.getDefault())