Neville Li

Actually we could make `checkForUpdate()` return `Option[R]`, where `R` would be a new URI for immutable snapshots, but the same DB connection for your case? The method will abstract away...

Main concern re 2, it might cause method overload issues? If there's a way around it then 👍

From @jto https://github.com/sbt/sbt-assembly#shading A better solution is to rename our versions of the conflicting packages. ``` ++ 2.11.12 set libraryDependencies += "org.apache.beam" %% "beam-runners-flink" % "2.4.0" set assemblyShadeRules in assembly...

@Igosuki @bkirwi FYI, would love to collaborate on this.

`DirectRunner` is intended for local testing and does a lot more checks, e.g. mutability, serialization. You should NOT run production pipeline with it. That said, you can turn those checks...

Awesome. Feel free to submit issues or PRs.

Yeah this is one area the 2 styles don't mix well, i.e. default arguments vs the ever growing Beam builder setters. :shrug: I don't have a better idea for this....

Can't repro with the following snippet and local runner. Can you provide more details or work the snippet to a state that can repro the issue? ```scala object Test {...

It's the one I posted above.

Thanks. I can verify that this reproduces the issue. Will look into it.