issues  

Messages by Thread

• [jira] [Commented] (BEAM-13081) Portable representation of "packed bitset indicating null fields" in beam Row format is not compatible with jvm representations Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13018) Java BigqueryIO source should have a "read all" feature Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13100) Python SDK harness should use runner capability to decide whether to send monitoring infos with short id. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13312) org.apache.beam.sdk.transforms.ParDoLifecycleTest.testTeardownCalledAfterExceptionInStartBundle is flaky in Java Spark ValidatesRunner suite Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13054) Release validation script should not use gnome-terminal Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13131) Support a non-exactly once StorageAPI BigQuery sink. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13375) Java PostCommits produce too many spanner databases Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12981) XmlIO should support XML namespaces Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13093) Enable JavaUsingPython CrossLanguageValidateRunner test for dataflow runner v2 Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12877) Beam Row Avro conversion: fixed and bytes decimals Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13225) Dataflow Prime job fails when providing resource hints on a transform Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13353) KafkaIO should raise an error if both .withReadCommitted() and .commitOffsetsInFinalize() are used Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13040) AsIter side input is not correctly recognized as a dependency. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12847) Error running Top transform in Dataflow Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13271) error-prone UnusedVariable check raises false positives for StateId and TimerId usages Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12915) No parallelism when using SDFBoundedSourceReader with Flink Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12871) Support for Confluent Schema Registry Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12924) Seemingly unnecessary NullPointerExceptions when using Latest.perKey(), Max.perKey() Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13215) Portable OSS runners do not support GCP credentials for GCP IOs. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13227) Security checklist for the runtime of Beam Playground Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13162) BigQueryIO Storage Write API method - suppress logging API errors for known use cases. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13319) Zstandard codec for Avro Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13169) Add sdk capability for MonitoringInfosMetadataRequest. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12932) File based sink doesn't respect temp_location pipeline option Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12881) Issue with Beam JDBC IO for GCP Dataflow Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13379) Incrementing a counter from a Python subthread doesn't seem to do anything Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12944) Apache Beam 2.31 over Flink 1.13 with Java 11 throw RuntimeException Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12863) BigQueryUtils doesn't process List or Map with nullables Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13020) Fragile reference to private synthetic this$ field Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13129) [Streaming][PubSub Lite][DataflowRunner] PubSub Lite IO doesn't sink message to PubSub Lite topic Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13043) Implementation encoding position sdk-go Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12933) Java runners should length prefix coders according to the capabilities of the environment. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13061) Introduce Union type coder Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12923) Add Comparator to SortValues PTransformation Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12930) add Amazon Kinesis as a supported commercial runner provider Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13117) Remove legacy dataflow support for Python Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13217) TypeCheckError due to CoGroupByKey output mis-deduction Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13261) JDBC IO: expose max pool connections as a setting Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13326) [RedisIO] - it's not possible to retrieve with PFCOUNT command the count of all the unique queries Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13270) Google Spanner dependency is too old; cannot deal with JSON type code Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13367) [beam_PostCommit_Python36] [ apache_beam.io.gcp.experimental.spannerio_read_it_test] Failure summary Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13214) StorageApi BQ sink should allow not specifying the schema for existing tables Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13342) Sliding CalendarWindows Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13057) Deprecate ProcessContext Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13181) FhirIO import functionality does unnecessary sharding of import files Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12880) KafkaIO Connector-updating/overwriting consumer groupid with random prefix Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12999) Improve Reshuffle Transform Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13220) Move release validation tests to Jenkins Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12903) Implement a solution to cleanup GCP resources in beam testing projects Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13320) KafkaIO: inconsistent behaviour with Beam Row coders Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13339) Beam Programming Guide: Add Go version of Section 6.6 "Using Schema Transforms" Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12904) Python DataflowRunner uses always default app_profile_id when writing to BigTable, when using custom write fn Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13373) Python PostCommits produce too many spanner databases Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13340) Beam Programming Guide: Add Python version of Section 6.4 "Logical Types" Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13185) Release scripts should be exempt from precommits Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13338) Beam Programming Guide: Add Python version of Section 6.6 "Using Schema Transforms" Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12900) Dataflow fails to materialize elements over 2GB Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12993) DebeziumIO cannot connect to cloud Postgres instances Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12947) ConstantTableDestinations sets the wrong coder when clustering enabled Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12854) Merge rather than override resource specs on substitution. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12872) Take GLB of types before and after type inference Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12866) TestStream should only emit bytes Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12902) Better error messages for misconfigured Beam worker Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13318) Python version of schema docs missing examples Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12921) PAssert ignore the Schema fields names for testing Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12955) Add support for inferring Beam Schemas from Python protobuf types Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12884) Support Gradle build for all runners. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12948) Add .withPipelineTempDirectory() Builder setting for file-based sinks Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13139) Support for R2DBC Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13141) Support to submit Jobs using HBaseIO to DataflowRunner without local access to HBase Cluster Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12986) WriteTables leaves behind temporary tables on job failure Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12980) Set sdk_harness_container_images for Dataflow prime jobs Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13066) IterableCoder often returns a List Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12991) Fix pylint warning: Consider explicitly re-raising using the 'from' keyword (raise-missing-from) Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13142) Ensure that the payload is consumed on Elements.Data and Elements.Timers when is_last = true Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13144) Update to TextIO to support ValueProviders breaks runner-chosen sharding Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13230) Deduplicate transform fails on Dataflow Runner v2 Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13179) Artifacts that use vendored calcite 1.28.0 fail with annotation processing error in :compileJava Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13160) Clarify windowing behavior in Javadoc Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12894) Enable org.apache.beam.sdk.io.WriteFilesTest.testWithRunnerDeterminedShardingUnbounded Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13186) Twister2 quickstart failing (2.34.0 release validation) Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12896) Enable org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoReadingFromUnknownSideInput Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13166) Versions after `2.28.0` fail to infer grouping decoders after a date is selected from a data structure Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12892) Enable org.apache.beam.sdk.io.TFRecordIOTest.testReadInvalidLengthMask Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13194) Call the stored procedure in dataflow pipeline Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12895) Enable org.apache.beam.sdk.transforms.ParDoTest$MultipleInputsAndOutputTests.testParDoWritingToUndeclaredTag Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13150) Integrate TFRecord/tf.train.Example with Beam Schemas and the DataFrame API Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13170) Update Beam documentation to include Schema type mapping between various SDK languages Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12897) Enable org.apache.beam.sdk.transforms.ViewTest.testMapSideInputWithNullValuesCatchesDuplicates Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12890) Enable org.apache.beam.sdk.io.TFRecordIOTest.testReadInvalidRecord Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12893) Enable org.apache.beam.sdk.io.TextIOReadTest$CompressedReadTest.testCompressedReadWithoutExtension Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12891) Enable org.apache.beam.sdk.io.TFRecordIOTest.testReadInvalidDataMask Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13148) Add ability to Write to GCP PubSub with an orderingKey Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12888) Enable org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testParDoShiftTimestampInvalidZeroAllowed Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12889) Enable org.apache.beam.sdk.transforms.DeduplicateTest.testEventTime Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12887) Enable org.apache.beam.sdk.transforms.ParDoTest$TimestampTests.testParDoShiftTimestampInvalid Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12994) Python SDK BigQuery `schemaUpdateOptions` Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13047) [Playground] Unable to scroll code editor in selecting the text Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13039) Update SQL (Calcite) aggregate functions list Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12874) Installing apache-beam after tensorflow on Macbook M1 fails with pyarrow error Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13212) [Go SDK] Add support for setting upper memory limit for side input cache Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13231) Globbing asterisk cannot be escaped in file reads. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13369) MutationDetector warns due to missing equals method in KinesisSource Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13065) Support Redis Cluster when reading with RedisIO Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12878) Wait.on() in Python Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12989) Implement Dynamic Work Rebalancing in the Python Read API Source Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13205) Dataset has wrong GCP project id in release validation Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12886) Enable org.apache.beam.sdk.transforms.GroupByKeyTest$WindowTests.testWindowFnPostMerging Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13002) Update to_dataframe API Docs to focus on schema use Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13075) [Go SDK] Update side input handling in the direct runner Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13122) [Playground] ctrl/command + z unstable behavioural Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12853) PubSubTableProvider tries to set windows after GroupByKey Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13123) [Playground] Shortcuts don't work on Linux (with Ctrl) Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12990) Implement per stream progress reporting Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12792) Multiple jobs running on Flink session cluster reuse the persistent Python environment. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12848) apache_beam.io.external.kafka.ReadFromKafka throws IndexError Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12598) Migrate to the next version of Python `requests` when released Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12673) apache_beam.examples.streaming_wordcount_it_test.StreamingWordCountIT.test_streaming_wordcount_it flakey Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12554) WriteToFiles destination no changing condition Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12793) beam_PostRelease_NightlySnapshot failed Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12484) JdbcIO date conversion is sensitive to OS Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12799) "Java IO IT Tests" - missing data in grafana Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12500) Dataflow SocketException (SSLException) error while trying to send message from Cloud Pub/Sub to BigQuery Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12807) Java creates an incorrect pipeline proto when core-construction-java jar is not in the CLASSPATH Danny McCormick (Jira)
• [jira] [Commented] (BEAM-13762) Get the latest GitHub Actions runners version and update the self-hosted runners Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12467) java.io.InvalidClassException With Flink Kafka Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12505) codecov/patch has poor behavior Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12809) testTwoTimersSettingEachOtherWithCreateAsInputBounded flaky Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12515) Python PreCommit flaking in PipelineOptionsTest.test_display_data Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12766) Already Exists: Dataset apache-beam-testing:python_bq_file_loads_NNN Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12525) SDF BoundedSource seems to execute significantly slower than 'normal' BoundedSource Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12812) Run Github Actions on GCP workers in the apache-beam-testing project Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12794) PortableRunnerTestWithExternalEnv.test_pardo_timers flaky Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12603) Flaky: apache_beam.runners.portability.fn_api_runner.fn_runner_test.FnApiRunnerTestWithGrpcAndMultiWorkers Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12824) Beam Connector for Reading Data from Delta Lake Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12697) SBE Extension Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12510) POM files with direct reference to maven repositories Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12572) All beam examples should get continuously exercised Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12482) BigQueryIO failed to load data to temp table when withSchemaUpdateOptions is set. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12542) Migrate GKE cluster off basic authentication Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12586) Python Direct Runner doesn't support both streaming & non streaming sources Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12526) Configure Automatic Updates via Dependabot Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12790) Projection pushdown in JDBC SchemaIO Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12776) Improve parallelism of closing files in FileIO Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12815) Flink Go XVR tests fail on TestXLang_Multi: Insufficient number of network buffers Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12839) Powered-by page requires so many clicks Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12658) Rust SDK Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12674) SqlTransform IllegalArgumentException: key already present: SchemaCoder Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12632) ElasticsearchIO: Enabling both User/Pass auth and SSL overwrites User/Pass Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12693) WriteToJdbc does not respect 'statement' parameter in python Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12762) java.io.InvalidClassException with Spark 3.1.2 Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12580) Add ability to specify gRPC server/worker ports Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12654) FileIO can produce duplicates in output files Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12633) How to get failed insert record for file load insertion in BigQuery. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12642) Flink's job server container attempts to invoke docker Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12791) Allow Queries from PCollection in datastore.v1new.datastoreio.ReadFromDatastore Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12655) Pip cannot install from git Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12814) Support External Environment For Java SDK Harness Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12835) BigQueryIO.readTableRows() throws NullPointerException Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12783) WriteToBigQuery ignores insert_retry_strategy on HttpErrors Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12610) Side inputs documentation is not clear about the model Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12811) [Website] Remove "They tried it out" block Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12555) Revisit process of dependency staging in Beam Python Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12536) Jenkins page should contain troubleshooting tips Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12690) GroupIntoBatches does not properly maintain watermarks Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12595) Flink (1.12) Beam (2.30) word count example missing a dependency for the uber jar Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12551) BigQueryStorageReader should produce Rows, rather than GenericRecords Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12568) Unable to Run Pytest in Dev Env Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12523) Number of connection issue Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12489) Python GCSIO upload does not retry Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12581) Row.toString() method is throwing NullPointerException while processing a nullable map Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12797) KafkaIO on Go SDK test hangs on Read with Python Portable Runner Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12599) Implement PipelineOptions validations in ExpansionService Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12736) Protobuf schema provider row functions break on camel-case field names Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12687) Update checkerframework to 3.16+ Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12732) MQTT IO connector for Python Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12501) subprocess_server.stop_process fails on Windows Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12827) Let TestStream primitive always produce bytes. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12795) KVs should not be needed when using schemas Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12837) JdbcIO Microsoft Sql Types are not supported Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12774) Clear ready timers before shutdown Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12659) WriteToBigQuery in BundleBasedDirectRunner fails when method is FILE_LOADS Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12592) using flink runner docker environment raise NameError name 'datetime' is not defined Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12606) Add support for progress reporting to Firestore Query Source Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12617) Samza Portable Runner: Support Merging Custom Window Fns Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12585) Consider making NullableCoder as a StandardCoder Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12461) Replace use of Joda Time with java.time Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12577) In stream mode, ElasticsearchIO transform becomes unavailable Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12618) Check state failed at IsmSideInputReader.createReadersFromSources Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12631) Allow Inheritance from KafkaUnboundedSource Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12614) Samza Runner: Support Distribution Metric Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12615) Samza Portable Runner: Support Bundle Finalization Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12605) Add dynamic work rebalancing to Firestore Query Source Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12468) Enable BigQueryIO to receive a project argument so that jobs will run on that project Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12616) Samza portable Runner: Support SDF Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12714) FileSystem.create does not pass full Metadata to GCS Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12747) Samza runner failing WithTimestampsTest Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12745) Samza runner failing AvroIOTest Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12743) Samza runner failing PCollectionCustomCoderTest Danny McCormick (Jira)
• [jira] [Commented] (BEAM-12746) Samza runner failing FileIOTest Danny McCormick (Jira)

• Earlier messages
• Later messages