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.