Added additional logging for savepoint creation monitoring (#29)

.travis.yml

@@ -6,7 +6,7 @@ services:
 language: go
 
 go:
-- 1.9.3
+- 1.11.5
 
 env:
   global:

Dockerfile

@@ -1,9 +1,9 @@
-FROM golang:1.10.4-alpine3.8 as build
+FROM golang:1.11.5-alpine3.9 as build
 WORKDIR /go/src/github.com/ing-bank/flink-deployer/
 COPY . .
 RUN go build ./cmd/cli
 
-FROM alpine:3.8
+FROM alpine:3.9
 WORKDIR /flink-deployer
 COPY --from=build /go/src/github.com/ing-bank/flink-deployer/cli .
 VOLUME [ "/data/flink" ]

cmd/cli/flink/savepoint.go

@@ -74,7 +74,12 @@ type MonitorSavepointCreationResponse struct {
 // MonitorSavepointCreation allows for monitoring the status of a savepoint creation
 // identified by the job ID and request ID
 func (c FlinkRestClient) MonitorSavepointCreation(jobID string, requestID string) (MonitorSavepointCreationResponse, error) {
-	res, err := c.Client.Get(c.constructURL(fmt.Sprintf("jobs/%v/savepoints/%v", jobID, requestID)))
+	req, err := c.newRequest("GET", c.constructURL(fmt.Sprintf("jobs/%v/savepoints/%v", jobID, requestID)), nil)
+	if err != nil {
+		return MonitorSavepointCreationResponse{}, err
+	}
+
+	res, err := c.Client.Do(req)
 	if err != nil {
 		return MonitorSavepointCreationResponse{}, err
 	}

cmd/cli/operations/update_job.go

@@ -38,16 +38,21 @@ func (o RealOperator) monitorSavepointCreation(jobID string, requestID string, m
 		log.Println("checking status of savepoint creation")
 		res, err := o.FlinkRestAPI.MonitorSavepointCreation(jobID, requestID)
 		if err != nil {
+			log.Println(err)
 			return err
 		}
 
 		switch res.Status.Id {
 		case "COMPLETED":
 			return nil
 		case "IN_PROGRESS":
-			return fmt.Errorf("savepoint creation for job \"%v\" is still pending", jobID)
+			err = fmt.Errorf("savepoint creation for job \"%v\" is still pending", jobID)
+			log.Println(err)
+			return err
 		default:
-			return fmt.Errorf("savepoint creation for job \"%v\" returned an unknown status \"%v\"", jobID, res.Status)
+			err = fmt.Errorf("savepoint creation for job \"%v\" returned an unknown status \"%v\"", jobID, res.Status)
+			log.Println(err)
+			return err
 		}
 	}
 	b := &backoff.ExponentialBackOff{

docker-compose.yml

@@ -2,7 +2,7 @@ version: '3.4'
 services:
 
   jobmanager:
-    image: flink:1.6-alpine
+    image: flink:1.7.2-scala_2.11
     ports:
       - "8081:8081"
       - "6123:6123"
@@ -13,7 +13,7 @@ services:
       - /tmp/flink-deployer:/data/flink
 
   taskmanager:
-    image: flink:1.6-alpine
+    image: flink:1.7.2-scala_2.11
     depends_on:
       - jobmanager
     command: taskmanager