Guide on running Scio on Flink (fat jar)

[thanidev]

Guide on running Scio on Flink (fat jar)

[regadas]

@thanidev let me know if this works for you:

lazy val assemblySettings = Def.settings(
  assembly / test := {},
  assembly / assemblyJarName := "your-job.jar",
  assembly / assemblyMergeStrategy ~= { old =>
    {
      case s if s.endsWith(".properties") => MergeStrategy.filterDistinctLines
      case s if s.endsWith("public-suffix-list.txt") =>
        MergeStrategy.filterDistinctLines
      case s if s.endsWith(".class")                 => MergeStrategy.last
      case s if s.endsWith(".proto")                 => MergeStrategy.last
      case s if s.endsWith("reflection-config.json") => MergeStrategy.rename
      case s if s.endsWith(".pem")                   => MergeStrategy.rename
      case s if s.endsWith(".key")                   => MergeStrategy.rename
      case s                                         => old(s)
    }
  }
)

If it works and if you feel like doing a PR, please do!