Radosław Stankiewicz

icon indicating an email [email protected]

icon location Polska

Results 35 comments of Radosław Stankiewicz

[Bug]: SolaceIO seems to lose messages during Dataflow scaling/rebalancing events

Paweł, I think you can run it with 2.70 and only use 2.71 snapshot for solace - https://repository.apache.org/content/groups/snapshots/org/apache/beam/beam-sdks-java-io-solace/2.71.0-SNAPSHOT/

Cache DynamicDestinationsHelper.ConstantTimePartitioningClusteringDestination clustering & partitioning

/gemini review

Cache DynamicDestinationsHelper.ConstantTimePartitioningClusteringDestination clustering & partitioning

/gemini review

Add table information to BigQueryStorageApiInsertError

@hekk-kaori-maeda I really like PR! To be more consistent with BigQueryInsertError please use TableReference as field and expose it.

BigQueryIO : control StorageWrite parallelism in batch, by reshuffling before write on the number of streams set for BigQueryIO.write() using .withNumStorageWriteApiStreams(numStorageWriteApiStreams)

Run Java_GCP_IO_Direct PreCommit