Michel Davit

Fixes #140 When `WebSocket.disconnec(closeCode, reason, closeDelay)` is called and the close frame is not received from the server, the `CloseTask` fires. However, in this case, no `cancelCloseTask` is called, leading...

A bigger number of java libraries require java 11+ now. It is probably time to wish Java 8 farewell for scio too.

Deadlock in AsyncLookupDoFn

1

Some dead-lock have been observed on the `GrpcDoFn` with the following trace ``` Operation ongoing in step Perform Terminator request/parDo:1 for at least 10m00s without outputting or completing in state...

When using `largeHashIntersectByKey`, we've experienced pipelines hanging when running with dataflow default runnuer. It seems that enabling the [runner v2](https://cloud.google.com/dataflow/docs/runner-v2) unblocks the situation, but we should check why sparkey blocks...

Move to hbase bigtable

2

Missing hbase magnolify in the example

Add JDBC partitioned read support

1

Fix #4955

We have implemented a custom JDBC parallel read API because at the time, beam did not support that. Now beam has [readWitPartition](https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/jdbc/JdbcIO.html#readWithPartitions-org.apache.beam.sdk.values.TypeDescriptor-) supporting `Long` and `DateTime`. We should probably considering...

Integration test logs indicate that bigquery is not closed properly ```log 2022-12-08 16:39:43.502-0500 error [ManagedChannelOrphanWrapper] *~*~*~ Channel {0} was not shutdown properly!!! ~*~*~* Make sure to call shutdown()/shutdownNow() and wait...