github  

Messages by Thread

• • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
  • Re: [PR] [Java] Support dynamic secret provider registration via SecretRegistrar [beam] via GitHub
• Re: [I] [Failing Test]: Python GCP xlang fails if a node run two test concurrently [beam] via GitHub
• Re: [I] [Failing Test]: beam_PostRelease_Python_Candidate script broken [beam] via GitHub
• Re: [I] [Feature Request][Go SDK]: Improve Native File IO Writes [beam] via GitHub
• [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
  • Re: [I] [Bug]: Latest.Globally() issues in global window [beam] via GitHub
• Re: [I] [Task]: Update BigQueryIO.setTriggeringFrequency documentation [beam] via GitHub
  • Re: [I] [Task]: Update BigQueryIO.setTriggeringFrequency documentation [beam] via GitHub
  • Re: [I] [Task]: Update BigQueryIO.setTriggeringFrequency documentation [beam] via GitHub
• Re: [I] [Feature Request]: Use unique id for Python BigQueryIO [beam] via GitHub
• [PR] [#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
  • Re: [PR] [Spark][#36841] Register Spark's streaming internals with Kryo for the Structured Streaming runner [beam] via GitHub
• Re: [I] [Bug]: BigQueryIO.read() requires GCS tempLocation when using BigQuery Emulator [beam] via GitHub
• [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
  • Re: [PR] [Java] Honor withMaxRetryJobs for bounded BigQueryIO file loads [beam] via GitHub
• [PR] Port Wait.On to the Go SDK [beam] via GitHub
  • Re: [PR] Port Wait.On to the Go SDK [beam] via GitHub
• [PR] [wip] formatting [beam] via GitHub
  • Re: [PR] upgrade spotless to 7.2.1 [beam] via GitHub
  • Re: [PR] upgrade spotless to 7.2.1 [beam] via GitHub
• [PR] [wip] formatting [beam] via GitHub
  • Re: [PR] [wip] formatting [beam] via GitHub
• Re: [I] [Bug]: Portable Java pipelines hang forever in artifact staging on Windows, staged file name embeds environment id colons [beam] via GitHub
• Re: [I] [Feature Request][Go SDK]: Rewrite the `dot` runner in terms of a Portable pipeline. [beam] via GitHub
• Re: [I] [Task]: Enable Checker framework on `it` module [beam] via GitHub
• [PR] AddFiles: read side of the schema pre-pass [beam] via GitHub
  • Re: [PR] AddFiles: read side of the schema pre-pass [beam] via GitHub
  • Re: [PR] AddFiles: read side of the schema pre-pass [beam] via GitHub
  • Re: [PR] AddFiles: read side of the schema pre-pass [beam] via GitHub
  • Re: [PR] AddFiles: read side of the schema pre-pass [beam] via GitHub
  • Re: [PR] AddFiles: read side of the schema pre-pass [beam] via GitHub
• Re: [I] [Feature Request]: Support pyarrow RecordBatch for MLTransform [beam] via GitHub
• Re: [I] [Feature Request]:[Go SDK]: BigTableIO should have scalable reads. [beam] via GitHub
• Re: [I] [Bug]: 16177 has type numpy.int64, but expected one of: bytes [beam] via GitHub
• Re: [I] [Task]: Remove archaic PubSubSource and PubSubSink [beam] via GitHub
• Re: [I] [Bug]: Read from datastore with inequality filters [beam] via GitHub
• [I] [IAC_DRIFT_SA_KEY] Action Required: Unmanaged Service Account Keys Detected [beam] via GitHub
• [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.5 to 2.14.6 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.5 to 2.14.6 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/nats-io/nats-server/v2 from 2.14.5 to 2.14.6 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.43.7 to 1.45.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.43.7 to 1.45.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.43.7 to 1.45.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2 from 1.43.7 to 1.45.1 in /sdks [beam] via GitHub
• [PR] Bump github/codeql-action from 4.37.8 to 4.37.9 [beam] via GitHub
  • Re: [PR] Bump github/codeql-action from 4.37.8 to 4.37.9 [beam] via GitHub
  • Re: [PR] Bump github/codeql-action from 4.37.8 to 4.37.9 [beam] via GitHub
• [PR] Bump google.golang.org/grpc from 1.83.1 to 1.83.2 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/grpc from 1.83.1 to 1.83.2 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/grpc from 1.83.1 to 1.83.2 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/grpc from 1.83.1 to 1.83.2 in /sdks [beam] via GitHub
• [PR] Bump google.golang.org/api from 0.293.0 to 0.294.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.293.0 to 0.294.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump google.golang.org/api from 0.293.0 to 0.294.0 in /sdks [beam] via GitHub
• [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.38 to 1.33.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.38 to 1.33.1 in /sdks [beam] via GitHub
  • Re: [PR] Bump github.com/aws/aws-sdk-go-v2/config from 1.32.38 to 1.33.1 in /sdks [beam] via GitHub
• [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.10.1 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.10.1 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.10.1 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless:spotless-plugin-gradle from 5.6.1 to 8.10.1 [beam] via GitHub
• [PR] Bump com.diffplug.spotless from 5.6.1 to 8.10.1 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 8.10.1 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 8.10.1 [beam] via GitHub
  • Re: [PR] Bump com.diffplug.spotless from 5.6.1 to 8.10.1 [beam] via GitHub
• [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
  • Re: [PR] Support TensorRT 10 and later in TensorRTEngineHandlerNumPy [beam] via GitHub
• Re: [I] Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps [beam] via GitHub
  • Re: [I] Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps [beam] via GitHub
  • Re: [I] Extract common class for WithTimestamps.AddTimestampsDoFn and Create.TimestampedValues.ConvertTimestamps [beam] via GitHub
• [PR] [Python] Speed up ApproximateUnique accumulator merging [beam] via GitHub
  • Re: [PR] [Python] Speed up ApproximateUnique accumulator merging [beam] via GitHub
  • Re: [PR] [Python] Speed up ApproximateUnique accumulator merging [beam] via GitHub
• Re: [I] [Task][Go SDK]: Determine canonical local temp directory. [beam] via GitHub
• Re: [I] [Task]: Bump HCLS API version from GA to Alpha/Beta [beam] via GitHub
• Re: [I] [Task]: Align Spark/Hadoop versions in Spark multiple-versions unit/VR tests [beam] via GitHub
• Re: [I] Speed up merge_accumulators for ApproximateUniqueGlobally [beam] via GitHub
• Re: [I] [Bug]: Update or Remove Integrations page [beam] via GitHub
• [PR] Deflake JmsIO authentication tests [beam] via GitHub
  • Re: [PR] Deflake JmsIO authentication tests [beam] via GitHub
  • Re: [PR] Deflake JmsIO authentication tests [beam] via GitHub
• Re: [I] [Feature Request][prism]: Add support for the multi-chunk iterable protocol [beam] via GitHub
• Re: [I] [Feature Request]: Retry policies for ParDo [beam] via GitHub
• Re: [I] [Bug]: [Java BQ] Race condition between copy jobs at different triggers in a streaming pipeline [beam] via GitHub
• Re: [I] [Feature Request]: Katas need new platform/host [beam] via GitHub
• Re: [I] [Bug]: Beam tag is not working properly [beam] via GitHub
• Re: [I] [Bug][Go SDK]: Native bigqueryio package doesn't have scalable writes. [beam] via GitHub
• Re: [I] [Bug]: Unable to use applyRowMutations() in bigquery IO apache beam java [beam] via GitHub
• Re: [I] [Task][Go SDK]: Update fhirio tests to not rely on direct runner. [beam] via GitHub
• Re: [I] [Task][Go SDK]: Update datastoreio tests to not rely on direct runner. [beam] via GitHub
• Re: [I] [Bug][Go SDK]: Xlang Bigquery IO doesn't appear to support Time type fields. [beam] via GitHub
• Re: [I] [Task][Go SDK][Cleanup]: Migrate passert package exclusively to the generic register package. [beam] via GitHub
• Re: [I] [Bug]: Avro schema support doesn't support UNION types (OneOf) for SpecificRecords [beam] via GitHub
• Re: [I] [Task]: Add Criteo perf test for MLTransform [beam] via GitHub
• Re: [I] How to run typescript apache beam pipeline in Flink Cluster [beam] via GitHub
• Re: [I] [Feature Request]: Allow metrics to be tagged or segmented [beam] via GitHub
• Re: [I] [Bug]: [SQL] BeamKafkaTable doesn't set commitOffsetsInFinalize to KafkaIO reader [beam] via GitHub
• Re: [I] [Task][Go SDK]: Add github precommits mini suites for each runner against the Go SDK [beam] via GitHub
• Re: [I] [Bug]: condition missed after a unnest [beam] via GitHub
• Re: [I] [Bug]: Okio present in beam-sdks-java-extensions-sql-jdbc [beam] via GitHub
• Re: [I] [Bug]: [Doc] Beam Capability Matrix space [beam] via GitHub
• [PR] [Java] Preserve CoderTranslatorRegistrar binary compatibility [beam] via GitHub
  • Re: [PR] [Java] Preserve CoderTranslatorRegistrar binary compatibility [beam] via GitHub
  • Re: [PR] [Java] Preserve CoderTranslatorRegistrar binary compatibility [beam] via GitHub
  • Re: [PR] [Java] Preserve CoderTranslatorRegistrar binary compatibility [beam] via GitHub
  • Re: [PR] [Java] Preserve CoderTranslatorRegistrar binary compatibility [beam] via GitHub
  • Re: [PR] [Java] Preserve CoderTranslatorRegistrar binary compatibility [beam] via GitHub
  • Re: [PR] [Java] Preserve CoderTranslatorRegistrar binary compatibility [beam] via GitHub
  • Re: [PR] [Java] Preserve CoderTranslatorRegistrar binary compatibility [beam] via GitHub
  • Re: [PR] [Java] Preserve CoderTranslatorRegistrar binary compatibility [beam] via GitHub
• [PR] Fix flaky Playground local cache test [beam] via GitHub
  • Re: [PR] Fix flaky Playground local cache test [beam] via GitHub
  • Re: [PR] Fix flaky Playground local cache tests [beam] via GitHub
• Re: [I] Migrate Jupyter Sidepanel extension to pip-based installation [beam] via GitHub
• Re: [I] [Task]: Add clients in the HCLS API in `dicomclient.py` [beam] via GitHub
• Re: [I] [Feature Request]: Predictable job names for tests running on Dataflow [beam] via GitHub
• Re: [I] [Failing Test]: PreCommit Python Integration Failing on Unrelated Changes [beam] via GitHub
• Re: [I] [Feature Request]: Support Java 14 records in `SchemaCoder` [beam] via GitHub
• Re: [I] [Bug]: Large PIPELINE_OPTIONS can lead to command line args list too long errors in SDK containers [beam] via GitHub
• [PR] ci: pin third-party GitHub Actions to commit SHA in IO_Iceberg_Unit_Tests.yml [beam] via GitHub
  • Re: [PR] ci: pin third-party GitHub Actions to commit SHA in IO_Iceberg_Unit_Tests.yml [beam] via GitHub
  • Re: [PR] ci: pin third-party GitHub Actions to commit SHA in IO_Iceberg_Unit_Tests.yml [beam] via GitHub
• Re: [PR] Fix/add experiment refactor [beam] via GitHub
  • Re: [PR] Fix/add experiment refactor [beam] via GitHub
  • Re: [PR] Fix/add experiment refactor [beam] via GitHub
• [PR] Fix artifact staging windows filename [beam] via GitHub
  • Re: [PR] Fix artifact staging windows filename [beam] via GitHub
  • Re: [PR] Fix artifact staging windows filename [beam] via GitHub
  • Re: [PR] Fix artifact staging windows filename [beam] via GitHub
  • Re: [PR] Fix artifact staging windows filename [beam] via GitHub
  • Re: [PR] Fix artifact staging windows filename [beam] via GitHub
  • Re: [PR] Fix artifact staging windows filename [beam] via GitHub
  • Re: [PR] Fix artifact staging windows filename [beam] via GitHub
  • Re: [PR] Fix artifact staging windows filename [beam] via GitHub
  • Re: [PR] Fix artifact staging windows filename [beam] via GitHub
• Re: [I] [Bug]: BigQuery Storage Write API: Output timestamps must be no earlier than the timestamp of the current input or timer [beam] via GitHub
• Re: [PR] Fix artifact staging filenames on Windows [beam] via GitHub
• Re: [I] [Feature Request]: Reduce expense of calculating quantiles [beam] via GitHub
  • Re: [I] [Feature Request]: Reduce expense of calculating quantiles [beam] via GitHub
• Re: [I] [Bug]: Flink fails with "cannot handle nodes with more than 64 outputs" [beam] via GitHub
  • Re: [I] [Bug]: Flink fails with "cannot handle nodes with more than 64 outputs" [beam] via GitHub
• Re: [I] [Bug]: Type inference failure with closure creation. [beam] via GitHub
  • Re: [I] [Bug]: Type inference failure with closure creation. [beam] via GitHub
• Re: [I] [Bug]: ignoreUnknownValues not working when using CreateDisposition.CREATE_IF_NEEDED [beam] via GitHub
• [PR] upgrade grpc to 1.82.1 [beam] via GitHub
  • Re: [PR] upgrade grpc to 1.82.1 for test infra and playground [beam] via GitHub
  • Re: [PR] upgrade grpc to 1.82.1 for test infra and playground [beam] via GitHub
  • Re: [PR] upgrade grpc to 1.82.1 for test infra and playground [beam] via GitHub
• Re: [I] [Feature Request]: [Java BQ] Support storageApiAppendThresholdRecordCount option when streaming with STORAGE_WRITE_API [beam] via GitHub
• Re: [I] [Feature Request]: Allow users to modify _BeamArgumentParser behavior [beam] via GitHub
  • Re: [I] [Feature Request]: Allow users to modify _BeamArgumentParser behavior [beam] via GitHub
• [PR] Update commons pool2 2.13.1 [beam] via GitHub
  • Re: [PR] Update commons pool2 2.13.1 [beam] via GitHub
• [I] Mongo document read with non hex objectid [beam] via GitHub
  • Re: [I] Mongo document read with non hex objectid [beam] via GitHub
  • Re: [I] Mongo document read with non hex objectid [beam] via GitHub
• [I] [Bug]: Mixed data types in _id field causing pipeline failures (SDK 2.53.0) [beam] via GitHub
• [PR] Bump cloud.google.com/go/spanner from 1.94.0 to 1.95.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/spanner from 1.94.0 to 1.95.0 in /sdks [beam] via GitHub
  • Re: [PR] Bump cloud.google.com/go/spanner from 1.94.0 to 1.95.0 in /sdks [beam] via GitHub

• Earlier messages
• Later messages