We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f2b88e9 commit ffd459aCopy full SHA for ffd459a
sdks/go/test/integration/integration.go
@@ -184,16 +184,6 @@ var flinkFilters = []string{
184
"TestSetStateClear",
185
"TestSetState",
186
187
- // With TestStream Flink adds extra length prefixs some data types, causing SDK side failures.
188
- "TestTestStreamStrings",
189
- "TestTestStreamByteSliceSequence",
190
- "TestTestStreamTwoUserTypeSequences",
191
- "TestTestStreamInt16Sequence",
192
- "TestTestStreamSimple",
193
- "TestTestStreamSimple_InfinityDefault",
194
- "TestTestStreamToGBK",
195
- "TestTestStreamTimersEventTime",
196
-
197
"TestTimers_EventTime_Unbounded", // (failure when comparing on side inputs (NPE on window lookup))
198
"TestTimers_ProcessingTime.*", // Flink doesn't support processing time timers.
199
0 commit comments