diff --git a/pkg/router/appmesh_v1beta2.go b/pkg/router/appmesh_v1beta2.go
index 1a6cd3bc..527099fc 100644
--- a/pkg/router/appmesh_v1beta2.go
+++ b/pkg/router/appmesh_v1beta2.go
@@ -269,7 +269,7 @@ func (ar *AppMeshv1beta2Router) reconcileVirtualRouter(canary *flaggerv1.Canary,
 		Listeners: []appmeshv1.VirtualRouterListener{
 			{
 				PortMapping: appmeshv1.PortMapping{
-					Port:     appmeshv1.PortNumber(canary.Spec.Service.Port),
+					Port:     ar.getContainerPort(canary),
 					Protocol: protocol,
 				},
 			},
diff --git a/pkg/router/appmesh_v1beta2_test.go b/pkg/router/appmesh_v1beta2_test.go
index 3054dd20..9425cc3f 100644
--- a/pkg/router/appmesh_v1beta2_test.go
+++ b/pkg/router/appmesh_v1beta2_test.go
@@ -52,7 +52,7 @@ func TestAppmeshv1beta2Router_Reconcile(t *testing.T) {
 	vnPrimary, err := router.appmeshClient.AppmeshV1beta2().VirtualNodes("default").Get(context.TODO(), primaryName, metav1.GetOptions{})
 	require.NoError(t, err)
 
-	primaryDNS := fmt.Sprintf("%s.%s.svc.cluster.local", primaryName, mocks.appmeshCanary.Namespace)
+	primaryDNS := fmt.Sprintf("%s.%s.svc.cluster.local.", primaryName, mocks.appmeshCanary.Namespace)
 	assert.Equal(t, primaryDNS, vnPrimary.Spec.ServiceDiscovery.DNS.Hostname)
 
 	// test backends update