From ffd459a7424281c12a25db92103795a370d70cf6 Mon Sep 17 00:00:00 2001
From: lostluck <13907733+lostluck@users.noreply.github.com>
Date: Mon, 9 Dec 2024 11:01:53 -0800
Subject: [PATCH] Unblock TestStream over Flink tests.

---
 sdks/go/test/integration/integration.go | 10 ----------
 1 file changed, 10 deletions(-)

diff --git a/sdks/go/test/integration/integration.go b/sdks/go/test/integration/integration.go
index de782daa2d5d..2b4fb35dad3f 100644
--- a/sdks/go/test/integration/integration.go
+++ b/sdks/go/test/integration/integration.go
@@ -184,16 +184,6 @@ var flinkFilters = []string{
 	"TestSetStateClear",
 	"TestSetState",
 
-	// With TestStream Flink adds extra length prefixs some data types, causing SDK side failures.
-	"TestTestStreamStrings",
-	"TestTestStreamByteSliceSequence",
-	"TestTestStreamTwoUserTypeSequences",
-	"TestTestStreamInt16Sequence",
-	"TestTestStreamSimple",
-	"TestTestStreamSimple_InfinityDefault",
-	"TestTestStreamToGBK",
-	"TestTestStreamTimersEventTime",
-
 	"TestTimers_EventTime_Unbounded", // (failure when comparing on side inputs (NPE on window lookup))
 	"TestTimers_ProcessingTime.*",    // Flink doesn't support processing time timers.