diff --git a/cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java b/cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java
index 2e23aced..dd56e49c 100644
--- a/cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java
+++ b/cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java
@@ -298,6 +298,7 @@ public class CassandraReaderHelper {
           record.addColumn(new LongColumn(rs.getInt(i)));
           break;
 
+        case COUNTER:
         case BIGINT:
           record.addColumn(new LongColumn(rs.getLong(i)));
           break;