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 that you have downloaded, bad things could happen.
Piotrek
> On 26 Feb 2020, at 12:56, David Magalhães <speeddra...@gmail.com> wrote:
>
> 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 behaviour, like it changes the place where values goes.
>
> Example:
>
> val account_id = "account0"
> val partitionDate = "202002"
> val fileName = "2020-02-26_11-09-46.parquet"
>
> s"account_id=$accountId/partition_date=$partitionDate/$fileName"
>
> Should be:
> account_id=account0/partition_date=202002/2020-02-26_11-09-46.parquet
> Actual result:
> account_id=account0/partition_date=2020-02-26_11-09-46.parquet/202002
>
> The variables values after the string interpolation do change values.
>
> Concat behaviour is not affected:
>
> "account_id=".concat(accountId).concat("/partition_date=").concat(partitionDate).concat("/").concat(fileName)
>
> If I remove the flink-streaming-java dependency is works as expected.
>
> Any thoughts why is behaving this way ?
