Good to hear that it’s working. I would doubt that this was a Flink issue, but
if it comes back, let us know.
Piotrek
> On 28 Feb 2020, at 16:48, David Magalhães wrote:
>
> Hi Piotr, the typo was on writing the example here, not on the code it self.
>
> Regarding to the mix of Scala versions,
Hi Piotr, the typo was on writing the example here, not on the code it self.
Regarding to the mix of Scala versions, I'm using 2.12 in every place. My
Java version is 1.8.0_221.
Currently it is working, but not sure what happened here.
Thanks!
On Fri, Feb 28, 2020 at 10:50 AM Piotr Nowojski wr
Also, don’t you have a typo in your pattern? In your pattern you are using
`$accountId`, while the variable is `account_id`? (Maybe I don’t understand it
as I don’t know Scala very well).
Piotrek
> On 28 Feb 2020, at 11:45, Piotr Nowojski wrote:
>
> Hey,
>
> What Java versions are you using?
Hey,
What Java versions are you using?
Also, could you check, if you are not mixing Scala versions somewhere? There
are two different Flink binaries for Scala 2.11 and Scala 2.12. I guess if you
mix them, of if you use incorrect Scala runtime not matching the supported
version of the binaries
I'm testing a custom sink that uses TwoPhaseCommit with the test harness
provided by flink-streaming-java.
"org.apache.flink" %% "flink-streaming-java" % flinkVersion % "test"
classifier "tests"
Using this, in some tests that I use scala string interpolation, the string
output have a strange beha
