diff --git a/Jenkinsfile b/Jenkinsfile
index 648b07e95..5a112c8a2 100755
--- a/Jenkinsfile
+++ b/Jenkinsfile
@@ -5,3 +5,11 @@ common {
   pintMerge = true
   downStreamValidate = false
 }
+
+def upgradeConnectorTest(body) {
+  build job: "confluentinc/connect-comprehensive-test-framework/master/", parameters: [
+          string(name: 'PLUGIN_NAME', value: 'kafka-connect-elasticsearch'),
+          string(name: 'BRANCH_TO_TEST', value: env.CHANGE_BRANCH)
+  ], wait: true
+}
+upgradeConnectorTest{}