issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2022/06/04
[jira] [Commented] (BEAM-10341) Support drain in SDF
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10417) Shared - Library to simplify managing shared large memory objects
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10512) Add parsedData to Hl7v2Message to allows users not using schematized parsing to utilized HL7v2IO
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10526) Use grpc test rules for graceful server/channel shutdown in tests
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10458) Message limit for grpc message is set to default 4 MB
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10577) :sdks:java:io:azure uses legacy rawtypes
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10576) :sdks:java:extensions:hadoop-file-system uses legacy rawtypes
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10422) Python Chicago Taxi Jobs are failing
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10607) Support micro-second ZetaSQL TIMESTAMP in BeamSQL
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10556) Eliminate rawtype errors from Beam Java
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10780) Document that KeyParam only works in timer methods and/or actually implement it correctly for all methods.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10493) Unbounded sources unable to recover from checkpointMark when withMaxReadTime() is used
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10834) Reshuffle fails to redistribute to all threads on Spark
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10302) Respect timestamp OutputTime Windowing Strategy configuration in Lifted CombineFns.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10750) Add external transform JDBC it tests with overridden statement/query
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10382) Python SDK should set merge status to "ALREADY_MERGED"
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10592) HDFS file writing has intermittent failures from 2.16 (and above)
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10384) Dataflow can't pickle WeakRefDictionary
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10636) Dataflow deployments with FnAPI runner fail on python3.8 due to pycrypto
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10596) Sharding with fileio.WriteToFiles need to set `max_writers_per_bundle=0` when using InteractiveRunner or DirectRunner?
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10539) Java SDK Harness throws IllegalStateException with user states in finishBundle
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10448) Java + Universal Local Runner: custom WindowFn support seems incomplete
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10314) Writing containers containing nested Decimal to BigQuery fails
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10784) Spark portable streaming: failing window-related tests
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10621) Worker should retry 499 response on workItem:reportStatus messages
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10666) WriteToBigQuery: Schema auto-detection is not supported.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10516) Including TableProvider IO dependencies as `provided` can lead to ClassDefNotFoundErrors for users
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10625) tests fails on windows - PortableRunnerTestWithSubprocesses causes grpc Deadline Exceeded
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10406) BigQueryBatchFileLoads does not bundle rows correctly in streaming mode in python
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10372) JavaFieldSchema generates invalid code if class has a private constructor
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10483) pullLicenses failed for :sdks:python:test-suites:portable:py2:flinkValidatesRunner
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10789) Add support for checkpointing in Spark streaming
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10664) Enable kinesis read on localstack in python cross-language it test
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10692) Change org.apache.beam.sdk.extensions.ml.CloudVision to associate the AnnotateImageResponses with the image data used for the annotation
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10415) Remove FlinkStreamingImpulseSource or replace it with a timer-based version
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10440) Add Support for Azure Cosmos DB DataStream
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10389) SqlTransform only allows one registered RowCoder schema
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10509) Autovalue getters without get prefix not supported
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10793) Incorrect Flink runner documentation
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10443) Add Support for Azure Cognitive Search DataStream Connector
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10796) Python's Test Expansion Service for Combine transform returns pickled coder
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10851) Determine Spanner schema at pipeline construction in cross-language SpannerIO
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10246) FileIO.read + deleteOnCommit functionality
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10795) Inconsistent Implementation of Expansion Service spec
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10680) Give an option to override the default number of shards in BQ streaming inserts
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10823) Support running yapf for python files in release and .test-infra directories
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10441) Add Support for Azure Event Hub DataStream Connector
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10442) Add Support for Azure Event Grid DataStream Connector
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10228) Reshuffle seems to be dropping elements in streaming Dataflow pipeline.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10325) Create ZeroMqIO
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10478) Beam Zeta SQL docs should call out additional dependency
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10544) Select Types not equal with nested schema
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10782) Check that DoFn outputs are valid iterables when using the performance runtime type check feature
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10338) Use ServiceLoader to find all SchemaIO providers in SQL Wrapper
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10604) Remove "final" modifier from FileBasedSource#getEstimatedSizeBytes?
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10488) ZetaSQL OFFSET support for retrieving Array Values
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10755) Add support for timers in Spark portable streaming
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10754) Add support for state in Spark portable streaming
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10852) Combine Python streaming load test is too slow on Flink
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10774) GBK Python streaming load tests are too slow
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10390) Java PreCommit fails with no reason for failing
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10712) Add support for side inputs in Spark portable streaming
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10287) Improve Linkability for Beam Programming Guide
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10237) Clean up Experimental usage and come up with a graduation policy
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10380) Python SDK infers the PCollection.IsBounded the same way Java SDK.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10638) Update documentation of BQ InsertRetryPolicy
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10693) Improve error handling in org.apache.beam.sdk.extensions.ml.CloudVision
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10690) Python type hints: support constrained TypeVars
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10553) gen_protos doesn't retry after failure
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10231) Connecting data channel blocks getting ProcessBundleResponse
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10495) Document composite transforms with no input and/or output
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10299) sdk_worker_main needlessly warns about missing main session file
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10264) "Connection refused" in Flink/Spark python loopback tests
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10476) SparkPortableExecutionTest.testExecution failed to add jar
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10255) beam_PreCommit_PythonLint_Commit takes 50+ minutes to execute
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10719) Show metrics in a (more) human-readable format
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10583) Document Beam Python on Databricks
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10452) Java + Universal Local Runner: combine with hotkey + accumulating mode failure
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10446) Java + Universal Local Runner: committed distribution metrics test fail
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10521) Flaky test: org.apache.beam.runners.samza.adapter.UnboundedSourceSystemTest.testMultipleAdvanceWatermark
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10689) Unskip test_metrics (py) in Spark runner
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10451) Java + Universal Local Runner: windowed CombineTest failures
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10238) [Umbrella] Improve Beam ZetaSQL type system
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10316) Python container builds always create Python 3.6 environment
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10445) Java + Universal Local Runner: committed counter metrics test fail
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10507) support xlang custom window fn
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10405) Beam documentation translated to Spanish
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10374) Optionally use containerized workers in fn api runner
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10437) Add zeta SQL GREATEST support
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10626) tests fails on windows - pandas_doctests_test.DoctestTest
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10640) Return ERROR details from apache_beam.io.gcp.bigquery.WriteToBigQuery failed inserts
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10447) Java + Universal Local Runner: teardown not called when exception raised
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10709) SchemaIOProvider should differentiate between read-only and write-only configuration
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10456) Dataflow API client retry policy
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10588) SDKs should have sane retry strategy for submitting jobs
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10454) Java + Universal Local Runner: PAssertTest failure with window equal to
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10797) Make Spark validates portable runner batch a precommit
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10765) Support non-homogenous nested types in SchemaProvider implementations
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10326) Combine API to increase safety when accumulator is mutated
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10388) Add support for self-referential Beam schemas
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10340) Lost of precision when casting ZetaSQL time with microsecond-precision
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10550) Update solution for ZetaSQL DOUBLE NaN equals checks.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10386) Move Flink external transform dependencies into base job server project
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10696) unable to explicitly use element coder in CombiningValueStateSpec constructor
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10477) BeamSideInputJoinRel should swap nodes in the Rule, not in expand
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10850) Ability to set S3 object ACL when uploading
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10772) Add tests for AzureBlobStoreFileSystem match
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10297) Group.<Row>globally().aggregate(Count.combineFn())) Throws Error
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10413) Change default SDK worker parallelism to use the number of cpu cores
Danny McCormick (Jira)
2022/06/04
[jira] [Updated] (BEAM-12844) Cassandra IO Does not work with ssl enabled Cassandra/Cosmos DB on Azure
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Updated] (BEAM-14161) Add dynamic splitting to JdbcIO.readWithPartitions
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Updated] (BEAM-14273) Update BQ connector to support new JSON type (Python)
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Commented] (BEAM-12898) Flink Load Tests failure- UncheckedExecutionException - leaking vms
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Updated] (BEAM-14230) Python JDBC API don't recognize "statement" parameter
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Commented] (BEAM-14250) Coder registration doesn't work for types in main module.
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Commented] (BEAM-14161) Add dynamic splitting to JdbcIO.readWithPartitions
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Updated] (BEAM-12898) Flink Load Tests failure- UncheckedExecutionException - leaking vms
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Updated] (BEAM-14250) Coder registration doesn't work for types in main module.
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Commented] (BEAM-12844) Cassandra IO Does not work with ssl enabled Cassandra/Cosmos DB on Azure
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Commented] (BEAM-14273) Update BQ connector to support new JSON type (Python)
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Commented] (BEAM-14230) Python JDBC API don't recognize "statement" parameter
Beam JIRA Bot (Jira)
2022/06/04
[jira] [Commented] (BEAM-10226) BeamSQL might fail on test_distinct_bytes after migrated to Sets transform
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10328) IntegrationTest is flaky for CurrentTime
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10253) Improve beam package GoDoc with examples.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10296) Support Process environment on Mac OS (Java SDK)
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10579) Go Dynamic Splitting, use SDF input coder for encoding elements.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10425) Dependency conflict between botocore and Sphinx
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10256) Experiment with Jenkins Worker VM Sizes and # executors
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10216) SESSION TVF Optimizations
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10606) Support ZetaSQL DataTimePart "week with weekday" in EXTRACT and TRUNC
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10262) Jenkins truncates logs excessively for failing tests.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10323) Python type hints: make WindowedValue, TimestampedValue Generic
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10822) Spelling mistake: org.apache.beam.sdk.io.gcp.testing.BigqueryClient#getNewBigquerryClient
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10787) External sorter 2048MB memory limit should be Hadoop only
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9480) org.apache.beam.sdk.io.mongodb.MongoDbIOTest.testReadWithAggregate is flaky
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10100) FileIO writeDynamic with AvroIO.sink not writing all data
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9482) beam_PerformanceTests_Kafka_IO failing due to " provided port is already allocated"
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10309) Reorganize Go coder packages.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10101) Add a HttpIO / HttpFileSystem
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10061) Read files contents with filesname (FileIO.readMatches) but for Python
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9613) BigQuery IO not support convert double type for beam row
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10160) Add Apache Iceberg IO connector
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9965) Explain direct runner running modes
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9698) BeamUncollectRel UncollectDoFn NullPointerException
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10174) Update notebook generator after website migration
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9910) Add byte counters to SpannerIO.write
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9689) Update wordcount webpage with Spark/Flink + Go
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10039) Create a mechanism to run a custom worker intialization code on Python workers
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10193) Install docker-credential-gcloud on Jenkins VMs
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9547) Implement all pandas operations (or raise WontImplementError)
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10131) Patterns: Show pattern for key redistribution when there is no natural key
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9564) Remove insecure ssl options from MongoDBIO
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9969) Beam ZetaSQL test pure SQL user-defined table functions
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10030) Add CSVIO for Java SDK
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9873) Removing Invalid JSON messages from PCollection before starting BigQueryIO Operations
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10019) Keeping keys in a state for a very long time (keys expiry unknown)
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9837) example coder with kotlin serialization: kotlinx.serialization
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10105) Add more metadata fields to FileMetadata
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10020) Java transform executed as Python transform?
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10103) Add WasbIO / WasbFileSystem (Azure Blob Storage)
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9766) Add support for dynamic destinations when writing to Kinesis
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10104) Allow configuring credentials for access to S3FileSystem (Python)
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9728) PubsubIO.Read support for timestamp parsing
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10005) Unable to use ApproximateQuantiles.globally/ApproximateUnique.globally when inputs not windowed by GlobalWindows
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10072) RequiresTimeSortedInput not working for DoFns without state
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10200) Improve memory profiling for users of Portable Beam Python
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9543) BeamSQL Pattern Recognization Functionality
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9571) Add withMongoClientProvider to MongoDbIO
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9653) remove _AvroSource in favor of using _FastAvroSource
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9992) Migrate BeamSQL's SET operators to Sets transforms
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9611) Add a test for Iter/ReIter parameters in ParDos (such as after a GBK).
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9567) GCS needs to be testable
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9967) Add support for BigQuery job labels on ReadFrom/WriteTo(BigQuery) transforms
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10087) Flink 1.10 failing [Java 11]
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9579) ApproximateQuantilesCombineFn uses deprecated '-' operator
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10088) Examples Spark Runner tests failing [Java 11]
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9494) Remove workaround for BQ transform for Dataflow
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9614) Declare versioned capability for identifying the Go SDK.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10042) Add alternate constructor to improve byte encoding performance in SortValues
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9598) _CustomBigQuerySource checks valueprovider when it's not needed
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9563) TFRecordIO inefficient read from sideinput causing pipeline to be slow - fix
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10144) Update pipeline options snippets for best practices
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10090) Java 11 Precommit failing tasks
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10079) Samza tests failing [Java 11]
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9990) FhirIO should support conditional create / update methods
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10319) Support initial splitting in KafkaIO.ReadAll()
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9748) Refactor Reparallelize as an alternative Reshuffle implementation
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10083) Spark Runner Tests failing [Java 11]
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9533) Replace *-gcp/*-aws tox suites with *-cloud suites to run unit tests for both
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10320) Create external transform builder for KafkaIO.ReadAll()
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9977) Build Kafka Read on top of Java SplittableDoFn
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9500) Refactor load tests
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9616) [Go SDK] starcgen improvements
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9570) Update documentation to show how to use SerializableCoder more securely
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9729) Cleanup bundle registration now that SDKs can pull.
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10111) Create methods in fileio to read from / write to archive files
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-9700) Support ValueProvider for HCatalogIO
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10040) TestPubsubSignal not signalling success w/ Dataflow Runner
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10029) Add Spanner IO Performance Tests for Python SDK
Danny McCormick (Jira)
2022/06/04
[jira] [Commented] (BEAM-10016) Flink postcommits failing testFlattenWithDifferentInputAndOutputCoders2
Danny McCormick (Jira)
Earlier messages
Later messages