Hi James,
the TypeInformation must be available at the call site, not in the case
class definition. In your WindowFunction you are using a TestGen[String] so
it should suffice to add this line at some point before the call to apply():
implicit val testGenType = createTypeInformation[TestGen[String
Hi,
I have been trying to get a case class with a generic parameter working with
Filnk 1.0.3 and have been having some trouble. However when I compile I get the
following error:
debug-type-bug/src/main/scala/com/example/flink/jobs/CaseClassWithGeneric.scala:40:
error: could not find implicit va
