diff --git a/pkg/provisioners/container/controller/resources/deployment.go b/pkg/provisioners/container/controller/resources/deployment.go
index 5886f5758d3..d02e696abf5 100644
--- a/pkg/provisioners/container/controller/resources/deployment.go
+++ b/pkg/provisioners/container/controller/resources/deployment.go
@@ -18,6 +18,7 @@ package resources
 
 import (
 	"fmt"
+
 	"github.com/knative/eventing/pkg/apis/eventing/v1alpha1"
 	"github.com/knative/eventing/pkg/controller"
 
@@ -39,8 +40,8 @@ func MakeDeployment(source *v1alpha1.Source, org *appsv1.Deployment, channel *v1
 			containerArgs = append(containerArgs, fmt.Sprintf("--%s=%q", k, v))
 		}
 	}
-	remote := fmt.Sprintf("--remote=http://%s", channel.Status.Sinkable.DomainInternal)
-	containerArgs = append(containerArgs, remote)
+	sink := fmt.Sprintf("--sink=http://%s", channel.Status.Sinkable.DomainInternal)
+	containerArgs = append(containerArgs, sink)
 
 	deploy := &appsv1.Deployment{
 		TypeMeta: metav1.TypeMeta{
diff --git a/pkg/sources/heartbeats/cmd/main.go b/pkg/sources/heartbeats/cmd/main.go
index 99a94f02568..29de7391a50 100644
--- a/pkg/sources/heartbeats/cmd/main.go
+++ b/pkg/sources/heartbeats/cmd/main.go
@@ -18,7 +18,7 @@ type Heartbeat struct {
 }
 
 var (
-	remote    string
+	sink      string
 	label     string
 	periodStr string
 	period    int
@@ -27,7 +27,7 @@ var (
 )
 
 func init() {
-	flag.StringVar(&remote, "remote", "", "the host url to heartbeat to")
+	flag.StringVar(&sink, "sink", "", "the host url to heartbeat to")
 	flag.StringVar(&label, "label", "", "a special label")
 	flag.StringVar(&periodStr, "period", "5", "the number of seconds between heartbeats")
 }
@@ -53,7 +53,7 @@ func main() {
 
 func send() {
 	hb.Sequence++
-	resp, err := http.Post(remote, "application/json", body())
+	resp, err := http.Post(sink, "application/json", body())
 	if err != nil {
 		log.Printf("Unable to make request: %+v, %v", hb, err)
 		return