Vitaly Terentyev comments

Results 67 comments of


                                            Vitaly Terentyev

[CdapIO] Integration CdapIO with SparkReceiverIO

Run Java_Examples_Dataflow PreCommit

Add groupName attribute where it's needed

PR was split into 3 parts: https://github.com/GoogleCloudPlatform/DataflowTemplates/pull/1539 https://github.com/GoogleCloudPlatform/DataflowTemplates/pull/1541 https://github.com/GoogleCloudPlatform/DataflowTemplates/pull/1542

Implement BigQuery Stress Test

R: @damccorm @Abacn

Template parameters: update old types to new ones

> Running checks, will proceed with merge process once those complete Fixed Spotless

[Feature Request]: Enable withFormatRecordOnFailureFunction() equivalent for BigQuery STORAGE_WRITE_API

.take-issue

[Feature Request]: Enable withFormatRecordOnFailureFunction() equivalent for BigQuery STORAGE_WRITE_API

There are some difficulties for making such `withFormatRecordOnFailureFunction()` equivalent for BigQuerySTORAGE_WRITE_API: - StorageApi has different implementations: - - BeamRow implementation that transforms original `ElementT` to `Row` - - Proto implementation...

The PostCommit XVR Samza job is flaky

Job has been stable for 2 months. Closing as resolved.

The PostCommit XVR Samza job is flaky

Fixed by https://github.com/apache/beam/pull/34439

The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky

Job has been stable for 2 months. Closing as resolved.

The PostCommit XVR PythonUsingJavaSQL Dataflow job is flaky

Fixed by https://github.com/apache/beam/pull/34439