diff --git a/pkg/apiserver/rest/dualwriter_mode1.go b/pkg/apiserver/rest/dualwriter_mode1.go
index fa248063bb5..63883573100 100644
--- a/pkg/apiserver/rest/dualwriter_mode1.go
+++ b/pkg/apiserver/rest/dualwriter_mode1.go
@@ -283,8 +283,9 @@ func (d *DualWriterMode1) Destroy() {
 }
 
 func (d *DualWriterMode1) Watch(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error) {
-	d.Log.Error(errors.New("Watch not implemented in mode 1"), "Watch not implemented in mode 1")
-	return nil, nil
+	err := errors.New("Watch not implemented in mode 1")
+	d.Log.Error(err, err.Error())
+	return nil, err
 }
 
 func (d *DualWriterMode1) GetSingularName() string {
diff --git a/pkg/apiserver/rest/dualwriter_mode2.go b/pkg/apiserver/rest/dualwriter_mode2.go
index 77ce9f3fc0c..c1c70c40dc0 100644
--- a/pkg/apiserver/rest/dualwriter_mode2.go
+++ b/pkg/apiserver/rest/dualwriter_mode2.go
@@ -331,8 +331,9 @@ func (d *DualWriterMode2) Update(ctx context.Context, name string, objInfo rest.
 }
 
 func (d *DualWriterMode2) Watch(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error) {
-	d.Log.Error(errors.New("Watch not implemented in mode 2"), "Watch not implemented in mode 2")
-	return nil, nil
+	err := errors.New("Watch not implemented in mode 2")
+	d.Log.Error(err, err.Error())
+	return nil, err
 }
 
 func (d *DualWriterMode2) Destroy() {