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 ?
