Issues
- 2
ExpectedRecords cannot have type Collection
#42 opened by Eric-Arellano - 2
unmaintained?
#96 opened by facboy - 0
unresolved dependencies scala 2.12
#95 opened by 123avi - 6
Is there any plan to support flink 1.8?
#91 opened by yunzhongniao - 6
setParallelism changes test outcome
#92 opened by haf - 4
- 3
Release 0.8.5?
#87 opened by facboy - 5
- 2
Run pipeline without flushing all the windows
#81 opened by Xeli - 0
Improve runtime of sequentiell tests
#25 opened by lofifnc - 11
IllegalStateException at the end of CEP test
#59 opened by debelyoo - 2
Consider splitting out JUnit 4 functionality into separate module and documenting
#77 opened by mkobit - 6
assertStream always passes
#78 opened by aschuhl - 1
There is no DataStreamTestBase.emit variant that accepts an arbitrary timestamp
#80 opened by eliaslevy - 6
NPE in test
#75 opened by etishka - 5
Publish 0.8.2 to Maven Central
#74 opened by mkobit - 4
- 6
- 2
Publish versions to OSS Repository Hosting
#70 opened by olibye - 2
Global Windows don't emit data on time
#68 opened by philipsdoctor - 0
Convert Message Headers to Long
#67 opened by lofifnc - 1
Random message ordering
#64 opened by etishka - 2
Tests don't work while making mvn test on CircleCI
#66 opened by Sefirq - 1
Low performance when using EventTimeInputBuilder
#65 opened by fschoell - 1
- 1
- 2
Tests don't fail if the output stream is empty
#55 opened by lofifnc - 0
Make high level Api less restrictive
#57 opened by lofifnc - 3
- 5
- 5
Flink Spector throws please specify the TypeInformation manually via StreamExecutionEnvironment#fromElements(Collection, TypeInformation) error
#52 opened by rohanbolar - 1
Datastream test examples URL is broken
#53 opened by debelyoo - 0
- 4
Find a way to manipulate ProcessingTime
#29 opened by rami-alisawi - 1
Sane retry strategies
#39 opened by lofifnc - 1
Less aggressive shutdown
#40 opened by lofifnc - 4
AssertionError for executeTest() always saying "timeout", even if not relevant
#38 opened by Eric-Arellano - 7
Support for Flink 1.2
#35 opened by affo - 0
No ${env} placeholder in external view settings
#34 opened by lofifnc - 3
Update Flink dependencies to 1.1.4
#32 opened by kaelumania - 2
before/after do they refer to processing time?
#31 opened by kaelumania - 5
Tests fail under Flink 1.1
#26 opened by wanderingbort - 2
Fix test cases not working on travis ci
#10 opened by lofifnc - 0
- 0
Overhaul of EventTimeInputBuilder semantics.
#13 opened by lofifnc - 3
Upgrade to Flink 1.0.0
#8 opened by knaufk - 1
Update wiki
#4 opened by lofifnc