Revert "Revert "Revert "remove skips"""

This reverts commit 8781624.

integ/blue_green_deployment_test.go

@@ -10,6 +10,8 @@ import (
 )
 
 func WaitForUpdate(c *C, s *IntegSuite, name string, updateFn func(app *v1beta1.FlinkApplication), phase v1beta1.FlinkApplicationPhase, failurePhase v1beta1.FlinkApplicationPhase) *v1beta1.FlinkApplication {
+	c.Skip("local")
+
 	// update with new image.
 	app, err := s.Util.Update(name, updateFn)
 	c.Assert(err, IsNil)
@@ -32,6 +34,8 @@ func WaitForUpdate(c *C, s *IntegSuite, name string, updateFn func(app *v1beta1.
 }
 
 func (s *IntegSuite) TestUpdateWithBlueGreenDeploymentMode(c *C) {
+	c.Skip("local")
+
 	log.Info("Starting test TestUpdateWithBlueGreenDeploymentMode")
 
 	testName := "bluegreenupdate"

integ/checkpoint_failure_test.go

@@ -66,6 +66,8 @@ func failingJobTest(s *IntegSuite, c *C, testName string, causeFailure func()) {
 
 // Tests that we correctly handle updating a job with a checkpoint timeout
 func (s *IntegSuite) TestCheckpointTimeout(c *C) {
+	c.Skip("local")
+
 	log.Info("Starting test TestCheckpointTimeout")
 
 	failingJobTest(s, c, "checkpointtimeout", func() {
@@ -156,6 +158,7 @@ func failingTaskTest(s *IntegSuite, c *C, testName string, fallbackWithoutState
 
 // Tests that we correctly handle updating a job with task failures
 func (s *IntegSuite) TestJobWithTaskFailures(c *C) {
+
 	log.Info("Starting test TestJobWithTaskFailures")
 	failingTaskTest(s, c, "taskfailure", false, true, func() {
 		err := s.Util.ExecuteCommand("minikube", "ssh", "touch /tmp/checkpoints/fail && chmod 0644 /tmp/checkpoints/fail")
@@ -169,6 +172,8 @@ func (s *IntegSuite) TestJobWithTaskFailures(c *C) {
 }
 
 func (s *IntegSuite) TestSavepointCheckpointFailureFallback(c *C) {
+	c.Skip("local")
+
 	log.Info("Starting test TestSavepointCheckpointFailureFallback")
 	failingTaskTest(s, c, "recoveryfallback", true, false, func() {
 		err := s.Util.ExecuteCommand("minikube", "ssh", "touch /tmp/checkpoints/fail && chmod 0644 /tmp/checkpoints/fail")

integ/job_cancellation_test.go

@@ -58,6 +58,8 @@ func WaitUpdateAndValidate(c *C, s *IntegSuite, name string, updateFn func(app *
 
 // tests the workflow of job cancellation without savepoint
 func (s *IntegSuite) TestJobCancellationWithoutSavepoint(c *C) {
+	c.Skip("local")
+
 	log.Info("Starting test TestJobCancellationWithoutSavepoint")
 	testName := "cancelsuccess"
 	const finalizer = "simple.finalizers.test.com"
@@ -137,6 +139,8 @@ func (s *IntegSuite) TestJobCancellationWithoutSavepoint(c *C) {
 // tests a job update with the existing job already in cancelled state.
 // here, the new submitted job starts without a savepoint.
 func (s *IntegSuite) TestCancelledJobWithoutSavepoint(c *C) {
+	c.Skip("local")
+
 	log.Info("Starting test TestCancelledJobWithoutSavepoint")
 
 	testName := "invalidcancel"
@@ -213,6 +217,8 @@ func (s *IntegSuite) TestCancelledJobWithoutSavepoint(c *C) {
 
 // tests the recovery workflow of the job when savepoint is disabled.
 func (s *IntegSuite) TestJobRecoveryWithoutSavepoint(c *C) {
+	c.Skip("local")
+
 	log.Info("Starting test TestJobRecoveryWithoutSavepoint")
 
 	const finalizer = "simple.finalizers.test.com"

integ/simple_test.go

@@ -68,6 +68,8 @@ func updateAndValidate(c *C, s *IntegSuite, name string, updateFn func(app *v1be
 
 // Tests job submission, upgrade, rollback, and deletion
 func (s *IntegSuite) TestSimple(c *C) {
+	c.Skip("local")
+
 	log.Info("Starting test TestSimple")
 
 	const finalizer = "simple.finalizers.test.com"
@@ -266,6 +268,8 @@ func (s *IntegSuite) TestSimple(c *C) {
 }
 
 func (s *IntegSuite) TestRecovery(c *C) {
+	c.Skip("local")
+
 	log.Info("Starting test TestRecovery")
 
 	config, err := s.Util.ReadFlinkApplication("test_app.yaml")