diff --git a/Jenkinsfile b/Jenkinsfile
index 6dc55be4bd0e8a0c4c5cddfb0a265898d9211c3a..99e70407b11298945a881b2243b27f941da5ec63 100644
--- a/Jenkinsfile
+++ b/Jenkinsfile
@@ -1,18 +1,36 @@
-
+import hudson.model.Result
+import jenkins.model.CauseOfInterruption
 properties([pipelineTriggers([githubPush()])])
 node {
-    git url: 'https://github.com/taosdata/TDengine'
+    git url: 'https://github.com/taosdata/TDengine.git'
 }
 
 
-// execute this before anything else, including requesting any time on an agent
-if (currentBuild.rawBuild.getCauses().toString().contains('BranchIndexingCause')) {
-  print "INFO: Build skipped due to trigger being Branch Indexing"
-  currentBuild.result = 'ABORTED' // optional, gives a better hint to the user that it's been skipped, rather than the default which shows it's successful
-  return
-}
+def abortPreviousBuilds() {
+  def currentJobName = env.JOB_NAME
+  def currentBuildNumber = env.BUILD_NUMBER.toInteger()
+  def jobs = Jenkins.instance.getItemByFullName(currentJobName)
+  def builds = jobs.getBuilds()
+
+  for (build in builds) {
+    if (!build.isBuilding()) {
+      continue;
+    }
 
+    if (currentBuildNumber == build.getNumber().toInteger()) {
+      continue;
+    }
 
+    build.doKill()    //doTerm(),doKill(),doTerm()
+  }
+}
+//abort previous build
+abortPreviousBuilds()
+def abort_previous(){
+  def buildNumber = env.BUILD_NUMBER as int
+  if (buildNumber > 1) milestone(buildNumber - 1)
+  milestone(buildNumber)
+}
 def pre_test(){
     catchError(buildResult: 'SUCCESS', stageResult: 'FAILURE') {
                 sh '''
@@ -20,6 +38,7 @@ def pre_test(){
                 '''
     }
     sh '''
+    
     cd ${WKC}
     rm -rf *
     cd ${WK}
@@ -44,27 +63,35 @@ def pre_test(){
 }
 pipeline {
   agent none
+  
   environment{
       WK = '/var/lib/jenkins/workspace/TDinternal'
       WKC= '/var/lib/jenkins/workspace/TDinternal/community'
   }
-
+  
   stages {
+      
+    
       stage('Parallel test stage') {
+        //only build pr
+        when {
+              changeRequest()
+          }
       parallel {
-        stage('python p1') {
-          agent{label 'p1'}
+        stage('python') {
+          agent{label 'pytest'}
           steps {
+            
             pre_test()
             sh '''
             cd ${WKC}/tests
-            ./test-all.sh p1
+            ./test-all.sh pytest
             date'''
           }
         }
         stage('test_b1') {
           agent{label 'b1'}
-          steps {
+          steps {            
             pre_test()
             sh '''
             cd ${WKC}/tests
@@ -117,24 +144,10 @@ pipeline {
             date'''
           }
         }
-       stage('python p2'){
-         agent{label "p2"}
-         steps{
-            pre_test()         
-            sh '''
-            date
-            cd ${WKC}/tests
-            ./test-all.sh p2
-            date
-            '''
-          
-         }
-       }
-       
-          
-      }
+   
+        
     }
-
   }
-  
+  }
+   
 }
diff --git a/tests/pytest/query/bug2118.py b/tests/pytest/query/bug2118.py
new file mode 100644
index 0000000000000000000000000000000000000000..01515e1ac8bbc3bac9b7f669e17e1ad93b9ef6cd
--- /dev/null
+++ b/tests/pytest/query/bug2118.py
@@ -0,0 +1,52 @@
+###################################################################
+#           Copyright (c) 2016 by TAOS Technologies, Inc.
+#                     All rights reserved.
+#
+#  This file is proprietary and confidential to TAOS Technologies.
+#  No part of this file may be reproduced, stored, transmitted,
+#  disclosed or used in any form or by any means other than as
+#  expressly provided by the written permission from Jianhui Tao
+#
+###################################################################
+
+# -*- coding: utf-8 -*-
+
+import sys
+from util.log import *
+from util.cases import *
+from util.sql import *
+from util.dnodes import *
+class TDTestCase:
+    def init(self, conn, logSql):
+        tdLog.debug("start to execute %s" % __file__)
+        tdSql.init(conn.cursor(), logSql)
+
+    def run(self):
+        tdSql.prepare()
+        print("==========step1")
+        print("create table && insert data")
+        
+        tdSql.execute("create table mt0 (ts timestamp, c1 int, c2 float, c3 bigint, c4 smallint, c5 tinyint, c6 double, c7 bool,c8 binary(20),c9 nchar(20))")
+        insertRows = 1000
+        t0 = 1604298064000
+        tdLog.info("insert %d rows" % (insertRows))
+        for i in range(insertRows):
+            ret = tdSql.execute(
+                "insert into mt0 values (%d , %d,%d,%d,%d,%d,%d,%d,'%s','%s')" %
+                (t0+i,i%100,i/2.0,i%41,i%51,i%53,i*1.0,i%2,'taos'+str(i%43),'涛思'+str(i%41)))
+        print("==========step2")
+        print("test percentile with group by normal_col ")
+        tdSql.query('select percentile(c1,1),percentile(c2,1),percentile(c6,1) from mt0 group by c3 limit 3 offset 2')
+        
+        tdSql.checkData(0,0,2.48)
+        tdSql.checkData(0,0,2.48)
+        tdSql.checkData(0,2,11.84)
+        
+
+        
+    def stop(self):
+        tdSql.close()
+        tdLog.success("%s successfully executed" % __file__)
+
+tdCases.addWindows(__file__, TDTestCase())
+tdCases.addLinux(__file__, TDTestCase())
\ No newline at end of file