flink-extended/flink-scala-api
Flink Scala API is a thin wrapper on top of Flink Java API which support Scala Types for serialisation as well the latest Scala version
ScalaApache-2.0
Issues
- 13
- 4
Too many dependencies
#178 opened by kirksw - 0
- 15
Savepoint incompatibility between 1.1.4 and 1.1.5
#121 opened by IgnasD - 7
- 15
`scala.MatchError: None (of class scala.None$)` during `CaseClassSerializer`
#148 opened by chollinger93 - 2
- 2
- 5
Derive type information for scala Map
#134 opened by lilyevsky - 1
Review Java Code
#127 opened by novakov-alexey - 0
Add build for Flink 1.19
#126 opened by novakov-alexey - 5
- 8
How to package with sbt assembly?
#122 opened by qcfu-bu - 1
Describe schema evolution for case classes
#117 opened by novakov-alexey - 3
Concurrency issue in subclasses of TypeInformation
#111 opened by sonowz - 21
- 9
[Feature request] Add 'unorderedWaitWithRetry' method to `AsyncDataStream`
#99 opened by piotrwieckiewicz - 9
Not being able to restore stateful operator
#96 opened by buinauskas - 5
Fix Unstable Test
#70 opened by novakov-alexey - 1
Mixed test runners
#91 opened by buinauskas - 2
Behave like the grown ups
#78 opened by hicolour - 3
UUID type information support
#84 opened by buinauskas - 9
BigDecMaper not serializable
#81 opened by buinauskas - 2
- 3
Head of empty list error in tests
#13 opened by TheDIM47 - 0
Add CI build for 3 Flink versions
#9 opened by novakov-alexey - 3
Implement Giter8 Template
#4 opened by novakov-alexey - 3
Runtime error when using a List in a case class
#8 opened by erwan - 2
- 0
Merge flink-adt into this repo
#5 opened by novakov-alexey - 3
Push initial version
#1 opened by novakov-alexey - 3
- 1
Configure GitHub CI build
#3 opened by novakov-alexey