diff --git a/pkg/registry/pod/manifest_factory_test.go b/pkg/registry/pod/manifest_factory_test.go
index 7410341372e..cac16752ede 100644
--- a/pkg/registry/pod/manifest_factory_test.go
+++ b/pkg/registry/pod/manifest_factory_test.go
@@ -107,19 +107,19 @@ func TestMakeManifestServices(t *testing.T) {
 			Value: "tcp://machine:8080",
 		},
 		{
-			Name:  "TEST_PORT_900_TCP",
+			Name:  "TEST_PORT_8080_TCP",
 			Value: "tcp://machine:8080",
 		},
 		{
-			Name:  "TEST_PORT_900_TCP_PROTO",
+			Name:  "TEST_PORT_8080_TCP_PROTO",
 			Value: "tcp",
 		},
 		{
-			Name:  "TEST_PORT_900_TCP_PORT",
+			Name:  "TEST_PORT_8080_TCP_PORT",
 			Value: "8080",
 		},
 		{
-			Name:  "TEST_PORT_900_TCP_ADDR",
+			Name:  "TEST_PORT_8080_TCP_ADDR",
 			Value: "machine",
 		},
 		{
@@ -197,19 +197,19 @@ func TestMakeManifestServicesExistingEnvVar(t *testing.T) {
 			Value: "tcp://machine:8080",
 		},
 		{
-			Name:  "TEST_PORT_900_TCP",
+			Name:  "TEST_PORT_8080_TCP",
 			Value: "tcp://machine:8080",
 		},
 		{
-			Name:  "TEST_PORT_900_TCP_PROTO",
+			Name:  "TEST_PORT_8080_TCP_PROTO",
 			Value: "tcp",
 		},
 		{
-			Name:  "TEST_PORT_900_TCP_PORT",
+			Name:  "TEST_PORT_8080_TCP_PORT",
 			Value: "8080",
 		},
 		{
-			Name:  "TEST_PORT_900_TCP_ADDR",
+			Name:  "TEST_PORT_8080_TCP_ADDR",
 			Value: "machine",
 		},
 		{
diff --git a/pkg/registry/service/rest.go b/pkg/registry/service/rest.go
index b7506fd0292..7226b0a7250 100644
--- a/pkg/registry/service/rest.go
+++ b/pkg/registry/service/rest.go
@@ -222,25 +222,23 @@ func makeEnvVariableName(str string) string {
 
 func makeLinkVariables(service api.Service, machine string) []api.EnvVar {
 	prefix := makeEnvVariableName(service.ID)
-	var port string
-	if service.ContainerPort.Kind == util.IntstrString {
-		port = service.ContainerPort.StrVal
-	} else {
-		port = strconv.Itoa(service.ContainerPort.IntVal)
+	protocol := "TCP"
+	if service.Protocol != "" {
+		protocol = service.Protocol
 	}
-	portPrefix := prefix + "_PORT_" + makeEnvVariableName(port) + "_TCP"
+	portPrefix := fmt.Sprintf("%s_PORT_%d_%s", prefix, service.Port, strings.ToUpper(protocol))
 	return []api.EnvVar{
 		{
 			Name:  prefix + "_PORT",
-			Value: fmt.Sprintf("tcp://%s:%d", machine, service.Port),
+			Value: fmt.Sprintf("%s://%s:%d", strings.ToLower(protocol), machine, service.Port),
 		},
 		{
 			Name:  portPrefix,
-			Value: fmt.Sprintf("tcp://%s:%d", machine, service.Port),
+			Value: fmt.Sprintf("%s://%s:%d", strings.ToLower(protocol), machine, service.Port),
 		},
 		{
 			Name:  portPrefix + "_PROTO",
-			Value: "tcp",
+			Value: strings.ToLower(protocol),
 		},
 		{
 			Name:  portPrefix + "_PORT",
diff --git a/pkg/registry/service/rest_test.go b/pkg/registry/service/rest_test.go
index b9d3d99585e..970086a0bec 100644
--- a/pkg/registry/service/rest_test.go
+++ b/pkg/registry/service/rest_test.go
@@ -18,6 +18,7 @@ package service
 
 import (
 	"fmt"
+	"reflect"
 	"testing"
 
 	"github.com/GoogleCloudPlatform/kubernetes/pkg/api"
@@ -27,7 +28,6 @@ import (
 	"github.com/GoogleCloudPlatform/kubernetes/pkg/labels"
 	"github.com/GoogleCloudPlatform/kubernetes/pkg/registry/minion"
 	"github.com/GoogleCloudPlatform/kubernetes/pkg/registry/registrytest"
-	"github.com/GoogleCloudPlatform/kubernetes/pkg/util"
 )
 
 func TestServiceRegistryCreate(t *testing.T) {
@@ -237,23 +237,65 @@ func TestServiceRegistryDeleteExternal(t *testing.T) {
 }
 
 func TestServiceRegistryMakeLinkVariables(t *testing.T) {
-	service := api.Service{
-		JSONBase:      api.JSONBase{ID: "foo-bar"},
-		Selector:      map[string]string{"bar": "baz"},
-		ContainerPort: util.IntOrString{Kind: util.IntstrString, StrVal: "a-b-c"},
-	}
 	registry := registrytest.NewServiceRegistry()
 	registry.List = api.ServiceList{
-		Items: []api.Service{service},
+		Items: []api.Service{
+			{
+				JSONBase: api.JSONBase{ID: "foo-bar"},
+				Selector: map[string]string{"bar": "baz"},
+				Port:     8080,
+				Protocol: "TCP",
+			},
+			{
+				JSONBase: api.JSONBase{ID: "abc-123"},
+				Selector: map[string]string{"bar": "baz"},
+				Port:     8081,
+				Protocol: "UDP",
+			},
+			{
+				JSONBase: api.JSONBase{ID: "q-u-u-x"},
+				Selector: map[string]string{"bar": "baz"},
+				Port:     8082,
+				Protocol: "",
+			},
+		},
 	}
 	machine := "machine"
 	vars, err := GetServiceEnvironmentVariables(registry, machine)
 	if err != nil {
 		t.Errorf("Unexpected err: %v", err)
 	}
-	for _, v := range vars {
-		if !util.IsCIdentifier(v.Name) {
-			t.Errorf("Environment variable name is not valid: %v", v.Name)
+	expected := []api.EnvVar{
+		{Name: "FOO_BAR_SERVICE_HOST", Value: "machine"},
+		{Name: "FOO_BAR_SERVICE_PORT", Value: "8080"},
+		{Name: "FOO_BAR_PORT", Value: "tcp://machine:8080"},
+		{Name: "FOO_BAR_PORT_8080_TCP", Value: "tcp://machine:8080"},
+		{Name: "FOO_BAR_PORT_8080_TCP_PROTO", Value: "tcp"},
+		{Name: "FOO_BAR_PORT_8080_TCP_PORT", Value: "8080"},
+		{Name: "FOO_BAR_PORT_8080_TCP_ADDR", Value: "machine"},
+		{Name: "ABC_123_SERVICE_HOST", Value: "machine"},
+		{Name: "ABC_123_SERVICE_PORT", Value: "8081"},
+		{Name: "ABC_123_PORT", Value: "udp://machine:8081"},
+		{Name: "ABC_123_PORT_8081_UDP", Value: "udp://machine:8081"},
+		{Name: "ABC_123_PORT_8081_UDP_PROTO", Value: "udp"},
+		{Name: "ABC_123_PORT_8081_UDP_PORT", Value: "8081"},
+		{Name: "ABC_123_PORT_8081_UDP_ADDR", Value: "machine"},
+		{Name: "Q_U_U_X_SERVICE_HOST", Value: "machine"},
+		{Name: "Q_U_U_X_SERVICE_PORT", Value: "8082"},
+		{Name: "Q_U_U_X_PORT", Value: "tcp://machine:8082"},
+		{Name: "Q_U_U_X_PORT_8082_TCP", Value: "tcp://machine:8082"},
+		{Name: "Q_U_U_X_PORT_8082_TCP_PROTO", Value: "tcp"},
+		{Name: "Q_U_U_X_PORT_8082_TCP_PORT", Value: "8082"},
+		{Name: "Q_U_U_X_PORT_8082_TCP_ADDR", Value: "machine"},
+		{Name: "SERVICE_HOST", Value: "machine"},
+	}
+	if len(vars) != len(expected) {
+		t.Errorf("Expected %d env vars, got: %+v", len(expected), vars)
+		return
+	}
+	for i := range expected {
+		if !reflect.DeepEqual(vars[i], expected[i]) {
+			t.Errorf("expected %#v, got %#v", vars[i], expected[i])
 		}
 	}
 }