github  

Messages by Thread

• • Re: [PR] [YAML]: add optional schema config for all transforms [beam] via GitHub
• Re: [PR] Introduce Beartype Dependency for Type Checking [beam] via GitHub
  • Re: [PR] Introduce Beartype Dependency for Type Checking [beam] via GitHub
  • Re: [PR] Introduce Beartype Dependency for Type Checking [beam] via GitHub
• Re: [I] [Bug]: XmlIO Exception in thread "main" java.lang.NoClassDefFoundError: javax/xml/bind/ValidationEventHandler [beam] via GitHub
  • Re: [I] [Bug]: XmlIO Exception in thread "main" java.lang.NoClassDefFoundError: javax/xml/bind/ValidationEventHandler [beam] via GitHub
  • Re: [I] [Bug]: XmlIO Exception in thread "main" java.lang.NoClassDefFoundError: javax/xml/bind/ValidationEventHandler [beam] via GitHub
  • Re: [I] [Bug]: XmlIO Exception in thread "main" java.lang.NoClassDefFoundError: javax/xml/bind/ValidationEventHandler [beam] via GitHub
• Re: [PR] Bump github.com/nats-io/nats.go from 1.43.0 to 1.45.0 in /sdks [beam] via GitHub
• [I] [Bug]: Re-enable GoUsingJava xlang suites [beam] via GitHub
  • Re: [I] [Bug]: Re-enable GoUsingJava xlang suites [beam] via GitHub
  • Re: [I] [Bug]: Re-enable GoUsingJava xlang suites [beam] via GitHub
  • Re: [I] [Bug]: Re-enable GoUsingJava xlang suites [beam] via GitHub
• Re: [I] [Bug]: java.lang.IllegalStateException: Expected output stream to be empty [beam] via GitHub
• Re: [I] [Failing Test]: Utilization of 'Source' and 'Sink' [beam] via GitHub
  • Re: [I] [Failing Test]: Utilization of 'Source' and 'Sink' [beam] via GitHub
  • Re: [I] [Failing Test]: Utilization of 'Source' and 'Sink' [beam] via GitHub
• Re: [I] [Task]: Improve README.md for https://github.com/apache/beam-starter-java-provider [beam] via GitHub
  • Re: [I] [Task]: Improve README.md for https://github.com/apache/beam-starter-java-provider [beam] via GitHub
  • Re: [I] [Task]: Improve README.md for https://github.com/apache/beam-starter-java-provider [beam] via GitHub
• Re: [I] [Bug]: BigqueryIO is very slow if using storage api and dynamic destination to write data to over thousand different tables with high data skew [beam] via GitHub
  • Re: [I] [Bug]: BigqueryIO is very slow if using storage api and dynamic destination to write data to over thousand different tables with high data skew [beam] via GitHub
• Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
  • Re: [PR] Add Kafka to Kafka RAW example pipeline configuration [beam] via GitHub
• Re: [PR] [GrowableOffsetRangeTracker] Use UnsignedLong instead of BigDecimal to calculate progress [beam] via GitHub
  • Re: [PR] [GrowableOffsetRangeTracker] Use UnsignedLong instead of BigDecimal to calculate progress [beam] via GitHub
  • Re: [PR] [GrowableOffsetRangeTracker] Use UnsignedLong instead of BigDecimal to calculate progress [beam] via GitHub
• Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] via GitHub
  • Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] via GitHub
  • Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] via GitHub
  • Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] via GitHub
  • Re: [PR] [BEAM-6394] Add support to write protobuf data using ProtoParquetReader [beam] via GitHub
• Re: [PR] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] via GitHub
  • Re: [PR] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] via GitHub
  • Re: [PR] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] via GitHub
  • Re: [PR] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] via GitHub
  • Re: [PR] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] via GitHub
  • Re: [PR] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] via GitHub
  • Re: [PR] Concat protos in BQStorageWriteAPI - solve edge cases during mering of nested repeated fields [beam] via GitHub
• [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
  • Re: [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
  • Re: [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
  • Re: [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
  • Re: [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
  • Re: [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
  • Re: [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
  • Re: [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
  • Re: [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
  • Re: [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
  • Re: [PR] Add test to cover SDF with side input data correctness [beam] via GitHub
• [PR] Fix StressTests Java KafkaIO job [beam] via GitHub
  • Re: [PR] Fix StressTests Java KafkaIO job [beam] via GitHub
  • Re: [PR] Fix StressTests Java KafkaIO job [beam] via GitHub
  • Re: [PR] Fix StressTests Java KafkaIO job [beam] via GitHub
• Re: [PR] [Java] Ensure Pipeline Execution Requires Configuration Options or Logs Warning [beam] via GitHub
• [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
  • Re: [PR] [Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission [beam] via GitHub
• [PR] fix(parquetio): handle missing nullable fields in row conversion [beam] via GitHub
  • Re: [PR] fix(parquetio): handle missing nullable fields in row conversion [beam] via GitHub
  • Re: [PR] fix(parquetio): handle missing nullable fields in row conversion [beam] via GitHub
• Re: [I] Performance Regression or Improvement: cogbk_python_batch_load_test_reiterate_4times_2MB_values:runtime [beam] via GitHub
• Re: [I] Performance Regression or Improvement: gbk_python_batch_load_test_fanout_4_times_with_2GB_10byte_records_total:runtime [beam] via GitHub
• Re: [PR] adds pre-commit hook to standardize whitespaces, adds EditorConfig to set the indents [beam] via GitHub
  • Re: [PR] adds pre-commit hook to standardize whitespaces, adds EditorConfig to set the indents [beam] via GitHub
  • Re: [PR] adds pre-commit hook to standardize whitespaces, adds EditorConfig to set the indents [beam] via GitHub
• [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
  • Re: [PR] Add YAML Editor and Visualization Panel [beam] via GitHub
• Re: [I] [Bug]: Error in BaseErrorProneJavaCompiler when building a local beam container. [beam] via GitHub
  • Re: [I] [Bug]: Error in BaseErrorProneJavaCompiler when building a local beam container. [beam] via GitHub
  • Re: [I] [Bug]: Error in BaseErrorProneJavaCompiler when building a local beam container. [beam] via GitHub
• Re: [I] [Feature Request]: Enabling long-running jobs to use federated STS assume role authentication for AWS resources [beam] via GitHub
  • Re: [I] [Feature Request]: Enabling long-running jobs to use federated STS assume role authentication for AWS resources [beam] via GitHub
  • Re: [I] [Feature Request]: Enabling long-running jobs to use federated STS assume role authentication for AWS resources [beam] via GitHub
• Re: [I] [Feature Request]: Enable AWS SQS reads for Python SDK [beam] via GitHub
  • Re: [I] [Feature Request]: Enable AWS SQS reads for Python SDK [beam] via GitHub
• [PR] [Test-only] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
  • Re: [PR] [Test-only] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
  • Re: [PR] [Test-only] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
  • Re: [PR] [Test-only] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
  • Re: [PR] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
  • Re: [PR] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
  • Re: [PR] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
  • Re: [PR] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
  • Re: [PR] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
  • Re: [PR] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
  • Re: [PR] feat(mongodb): upgrade MongoDB Java driver to version 5.5.0 [beam] via GitHub
• Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_1key_percent_dict:runtime [beam] via GitHub
• Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] via GitHub
  • [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime [beam] via GitHub
• Re: [I] Performance Regression or Improvement: sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable:runtime [beam] via GitHub
  • Re: [I] Performance Regression or Improvement: sideinpts_python_batch_10gb_1kb_10workers_1000window_first_iterable:runtime [beam] via GitHub
• Re: [PR] add a thread to flush buffered metrics [beam] via GitHub
  • Re: [PR] add a thread to flush buffered metrics [beam] via GitHub
  • Re: [PR] add a thread to flush buffered metrics [beam] via GitHub
• Re: [PR] Minstant [beam] via GitHub
  • Re: [PR] Minstant [beam] via GitHub
  • Re: [PR] Minstant [beam] via GitHub
• Re: [I] [Task]: Remove powermock dependency [beam] via GitHub
  • Re: [I] [Task]: Remove powermock dependency [beam] via GitHub
• Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
  • Re: [PR] Fix bug when execute DataframeTransform a dictionary of Pcoll [beam] via GitHub
• Re: [PR] Update async_dofn.py [beam] via GitHub
• [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
  • Re: [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
  • Re: [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
  • Re: [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
  • Re: [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
  • Re: [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
  • Re: [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
  • Re: [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
  • Re: [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
  • Re: [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
  • Re: [PR] [YAML]: add import jinja pipeline example [beam] via GitHub
• [PR] [2/2] sdks/python: sink data with Milvus Search I/O connector [beam] via GitHub
  • Re: [PR] [2/2] sdks/python: sink data with Milvus Search I/O connector [beam] via GitHub
  • Re: [PR] [2/2] sdks/python: sink data with Milvus Search I/O connector [beam] via GitHub
  • Re: [PR] [2/2] sdks/python: sink data with Milvus Search I/O connector [beam] via GitHub
  • Re: [PR] [2/2] sdks/python: sink data with Milvus Search I/O connector [beam] via GitHub
• [I] [Feature Request]: Worker Control Host Naming argument/parameter [beam] via GitHub
• [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
  • Re: [PR] [Java]Fix IllegalStateException in WindmillSink by Clearing Stream Before Encoding (#31914) [beam] via GitHub
• [PR] Add the readme link to new YAML examples [beam] via GitHub
  • Re: [PR] Add the readme link to new YAML examples [beam] via GitHub
  • Re: [PR] Add the readme link to new YAML examples [beam] via GitHub
  • Re: [PR] Add the readme link to new YAML examples [beam] via GitHub
• Re: [PR] [1/2] sdks/python: enrich data with CloudSQL [PostgreSQL, MySQL, SQLServer] [beam] via GitHub
• [I] [Bug]: IcebergIO- RecordWriterManager fails with "Expected all data writers to be closed" when exceptions occur during write [beam] via GitHub
  • Re: [I] [Bug]: IcebergIO- RecordWriterManager fails with "Expected all data writers to be closed" when exceptions occur during write [beam] via GitHub
  • Re: [I] [Bug]: IcebergIO- RecordWriterManager fails with "Expected all data writers to be closed" when exceptions occur during write [beam] via GitHub
  • Re: [I] [Bug]: IcebergIO- RecordWriterManager fails with "Expected all data writers to be closed" when exceptions occur during write [beam] via GitHub
  • Re: [I] [Bug]: IcebergIO- RecordWriterManager fails with "Expected all data writers to be closed" when exceptions occur during write [beam] via GitHub
  • Re: [I] [Bug]: IcebergIO- RecordWriterManager fails with "Expected all data writers to be closed" when exceptions occur during write [beam] via GitHub
• Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
  • Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
  • Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
  • Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
  • Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
  • Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
  • Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
  • Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
  • Re: [PR] [Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) [beam] via GitHub
• Re: [I] [Feature Request]: Yaml JdbcIO partitioning [beam] via GitHub
  • Re: [I] [Feature Request]: Yaml JdbcIO partitioning [beam] via GitHub
• Re: [PR] Start pushing ml containers [beam] via GitHub
  • Re: [PR] Start pushing ml containers [beam] via GitHub
  • Re: [PR] Start pushing ml containers [beam] via GitHub

• Earlier messages
• Later messages