Fix col version change (#612)

pingcap · Mar 27, 2019 · ce6e612 · ce6e612
1 parent 52f2b49
commit ce6e612
Showing 1 changed file with 1 addition and 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
@@ -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())