issues  

Messages by Thread

• [jira] [Commented] (BEAM-10255) beam_PreCommit_PythonLint_Commit takes 50+ minutes to execute Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10719) Show metrics in a (more) human-readable format Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10583) Document Beam Python on Databricks Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10452) Java + Universal Local Runner: combine with hotkey + accumulating mode failure Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10446) Java + Universal Local Runner: committed distribution metrics test fail Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10521) Flaky test: org.apache.beam.runners.samza.adapter.UnboundedSourceSystemTest.testMultipleAdvanceWatermark Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10689) Unskip test_metrics (py) in Spark runner Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10451) Java + Universal Local Runner: windowed CombineTest failures Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10238) [Umbrella] Improve Beam ZetaSQL type system Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10316) Python container builds always create Python 3.6 environment Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10445) Java + Universal Local Runner: committed counter metrics test fail Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10507) support xlang custom window fn Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10405) Beam documentation translated to Spanish Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10374) Optionally use containerized workers in fn api runner Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10437) Add zeta SQL GREATEST support Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10626) tests fails on windows - pandas_doctests_test.DoctestTest Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10640) Return ERROR details from apache_beam.io.gcp.bigquery.WriteToBigQuery failed inserts Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10447) Java + Universal Local Runner: teardown not called when exception raised Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10709) SchemaIOProvider should differentiate between read-only and write-only configuration Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10456) Dataflow API client retry policy Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10588) SDKs should have sane retry strategy for submitting jobs Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10454) Java + Universal Local Runner: PAssertTest failure with window equal to Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10797) Make Spark validates portable runner batch a precommit Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10765) Support non-homogenous nested types in SchemaProvider implementations Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10326) Combine API to increase safety when accumulator is mutated Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10388) Add support for self-referential Beam schemas Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10340) Lost of precision when casting ZetaSQL time with microsecond-precision Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10550) Update solution for ZetaSQL DOUBLE NaN equals checks. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10386) Move Flink external transform dependencies into base job server project Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10696) unable to explicitly use element coder in CombiningValueStateSpec constructor Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10477) BeamSideInputJoinRel should swap nodes in the Rule, not in expand Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10850) Ability to set S3 object ACL when uploading Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10772) Add tests for AzureBlobStoreFileSystem match Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10297) Group.<Row>globally().aggregate(Count.combineFn())) Throws Error Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10413) Change default SDK worker parallelism to use the number of cpu cores Danny McCormick (Jira)
• [jira] [Updated] (BEAM-12844) Cassandra IO Does not work with ssl enabled Cassandra/Cosmos DB on Azure Beam JIRA Bot (Jira)
• [jira] [Updated] (BEAM-14161) Add dynamic splitting to JdbcIO.readWithPartitions Beam JIRA Bot (Jira)
• [jira] [Updated] (BEAM-14273) Update BQ connector to support new JSON type (Python) Beam JIRA Bot (Jira)
• [jira] [Commented] (BEAM-12898) Flink Load Tests failure- UncheckedExecutionException - leaking vms Beam JIRA Bot (Jira)
  • [jira] [Commented] (BEAM-12898) Flink Load Tests failure- UncheckedExecutionException - leaking vms Danny McCormick (Jira)
• [jira] [Updated] (BEAM-14230) Python JDBC API don't recognize "statement" parameter Beam JIRA Bot (Jira)
• [jira] [Commented] (BEAM-14250) Coder registration doesn't work for types in main module. Beam JIRA Bot (Jira)
  • [jira] [Commented] (BEAM-14250) Coder registration doesn't work for types in main module. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-14161) Add dynamic splitting to JdbcIO.readWithPartitions Beam JIRA Bot (Jira)
  • [jira] [Commented] (BEAM-14161) Add dynamic splitting to JdbcIO.readWithPartitions Danny McCormick (Jira)
• [jira] [Updated] (BEAM-12898) Flink Load Tests failure- UncheckedExecutionException - leaking vms Beam JIRA Bot (Jira)
• [jira] [Updated] (BEAM-14250) Coder registration doesn't work for types in main module. Beam JIRA Bot (Jira)
• [jira] [Commented] (BEAM-12844) Cassandra IO Does not work with ssl enabled Cassandra/Cosmos DB on Azure Beam JIRA Bot (Jira)
  • [jira] [Commented] (BEAM-12844) Cassandra IO Does not work with ssl enabled Cassandra/Cosmos DB on Azure Danny McCormick (Jira)
• [jira] [Commented] (BEAM-14273) Update BQ connector to support new JSON type (Python) Beam JIRA Bot (Jira)
  • [jira] [Commented] (BEAM-14273) Update BQ connector to support new JSON type (Python) Danny McCormick (Jira)
• [jira] [Commented] (BEAM-14230) Python JDBC API don't recognize "statement" parameter Beam JIRA Bot (Jira)
  • [jira] [Commented] (BEAM-14230) Python JDBC API don't recognize "statement" parameter Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10226) BeamSQL might fail on test_distinct_bytes after migrated to Sets transform Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10328) IntegrationTest is flaky for CurrentTime Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10253) Improve beam package GoDoc with examples. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10296) Support Process environment on Mac OS (Java SDK) Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10579) Go Dynamic Splitting, use SDF input coder for encoding elements. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10425) Dependency conflict between botocore and Sphinx Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10256) Experiment with Jenkins Worker VM Sizes and # executors Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10216) SESSION TVF Optimizations Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10606) Support ZetaSQL DataTimePart "week with weekday" in EXTRACT and TRUNC Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10262) Jenkins truncates logs excessively for failing tests. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10323) Python type hints: make WindowedValue, TimestampedValue Generic Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10822) Spelling mistake: org.apache.beam.sdk.io.gcp.testing.BigqueryClient#getNewBigquerryClient Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10787) External sorter 2048MB memory limit should be Hadoop only Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9480) org.apache.beam.sdk.io.mongodb.MongoDbIOTest.testReadWithAggregate is flaky Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10100) FileIO writeDynamic with AvroIO.sink not writing all data Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9482) beam_PerformanceTests_Kafka_IO failing due to " provided port is already allocated" Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10309) Reorganize Go coder packages. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10101) Add a HttpIO / HttpFileSystem Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10061) Read files contents with filesname (FileIO.readMatches) but for Python Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9613) BigQuery IO not support convert double type for beam row Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10160) Add Apache Iceberg IO connector Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9965) Explain direct runner running modes Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9698) BeamUncollectRel UncollectDoFn NullPointerException Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10174) Update notebook generator after website migration Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9910) Add byte counters to SpannerIO.write Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9689) Update wordcount webpage with Spark/Flink + Go Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10039) Create a mechanism to run a custom worker intialization code on Python workers Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10193) Install docker-credential-gcloud on Jenkins VMs Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9547) Implement all pandas operations (or raise WontImplementError) Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10131) Patterns: Show pattern for key redistribution when there is no natural key Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9564) Remove insecure ssl options from MongoDBIO Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9969) Beam ZetaSQL test pure SQL user-defined table functions Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10030) Add CSVIO for Java SDK Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9873) Removing Invalid JSON messages from PCollection before starting BigQueryIO Operations Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10019) Keeping keys in a state for a very long time (keys expiry unknown) Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9837) example coder with kotlin serialization: kotlinx.serialization Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10105) Add more metadata fields to FileMetadata Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10020) Java transform executed as Python transform? Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10103) Add WasbIO / WasbFileSystem (Azure Blob Storage) Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9766) Add support for dynamic destinations when writing to Kinesis Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10104) Allow configuring credentials for access to S3FileSystem (Python) Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9728) PubsubIO.Read support for timestamp parsing Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10005) Unable to use ApproximateQuantiles.globally/ApproximateUnique.globally when inputs not windowed by GlobalWindows Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10072) RequiresTimeSortedInput not working for DoFns without state Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10200) Improve memory profiling for users of Portable Beam Python Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9543) BeamSQL Pattern Recognization Functionality Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9571) Add withMongoClientProvider to MongoDbIO Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9653) remove _AvroSource in favor of using _FastAvroSource Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9992) Migrate BeamSQL's SET operators to Sets transforms Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9611) Add a test for Iter/ReIter parameters in ParDos (such as after a GBK). Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9567) GCS needs to be testable Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9967) Add support for BigQuery job labels on ReadFrom/WriteTo(BigQuery) transforms Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10087) Flink 1.10 failing [Java 11] Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9579) ApproximateQuantilesCombineFn uses deprecated '-' operator Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10088) Examples Spark Runner tests failing [Java 11] Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9494) Remove workaround for BQ transform for Dataflow Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9614) Declare versioned capability for identifying the Go SDK. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10042) Add alternate constructor to improve byte encoding performance in SortValues Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9598) _CustomBigQuerySource checks valueprovider when it's not needed Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9563) TFRecordIO inefficient read from sideinput causing pipeline to be slow - fix Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10144) Update pipeline options snippets for best practices Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10090) Java 11 Precommit failing tasks Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10079) Samza tests failing [Java 11] Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9990) FhirIO should support conditional create / update methods Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10319) Support initial splitting in KafkaIO.ReadAll() Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9748) Refactor Reparallelize as an alternative Reshuffle implementation Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10083) Spark Runner Tests failing [Java 11] Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9533) Replace *-gcp/*-aws tox suites with *-cloud suites to run unit tests for both Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10320) Create external transform builder for KafkaIO.ReadAll() Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9977) Build Kafka Read on top of Java SplittableDoFn Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9500) Refactor load tests Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9616) [Go SDK] starcgen improvements Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9570) Update documentation to show how to use SerializableCoder more securely Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9729) Cleanup bundle registration now that SDKs can pull. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10111) Create methods in fileio to read from / write to archive files Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9700) Support ValueProvider for HCatalogIO Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10040) TestPubsubSignal not signalling success w/ Dataflow Runner Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10029) Add Spanner IO Performance Tests for Python SDK Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10016) Flink postcommits failing testFlattenWithDifferentInputAndOutputCoders2 Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9607) SDFBoundedSourceWrapper should expose the same display_data as Read Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10141) HL7v2IO read methods should assign sendTime timestamps Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9623) Add support for configuring TableProviders in Python SqlTransform Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9650) Add consistent slowly changing side inputs support Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9504) Remove streaming test_streaming_pipeline_returns_expected_user_metrics_fnapi_it from batch validates runner Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9626) pymongo should be an optional requirement Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9577) Update artifact staging and retrieval protocols to be dependency aware. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10186) Send error response to runner when split or progress requests are received out of order Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10175) FhirIO execute bundle uses deprecated auth uri param Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9715) annotations_test fails in some environmens Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9479) Provide option to run pylint in local git pre-commit Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9962) CI/CD for Beam Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10401) Create Jenkins plugin for Dataflow pipeline submission Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9987) Add Gradle instruction to Java quick start guide Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10147) Clean /tmp/dataflow-requirements-cache before downloading the requirements from requirements.txt Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9669) Dataflow SpringBoot app fails to run when bundled as a fat uber jar Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10172) BigQuerySource external data source support in non-US regions Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10192) Duplicate PubSub subscriptions with python direct runner in Jupyter/Colab environment Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9528) Buggy/Slow FileIO.write()/sink implementation Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10113) PubSubIO readMessagesWithMessageId() breaks the payload encoding when using DataflowRunner Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10069) Implement a WebSocketIO Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9818) Remove legacy staging protocol. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10150) save_main_session not working in DoFn.setup() in Dataflow with Python Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9655) Stateful Dataflow runner? Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10129) Pattern: Buffered Service Call Pattern Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10148) Data loaded using ReadAllFromText is not projected properly as side input Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9599) Document Beam ZetaSQL timestamp functions Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10021) BigQueryUtils DATETIME conversion requires unix millis Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9933) Support Streaming in Spark Structured Streaming Runner Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9917) BigQueryBatchFileLoads dynamic destination Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10133) AWS - add possibility for multiple region client Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10006) PipelineOptions can pick up definitions from unrelated tests Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9750) Streaming Word Count Example Documents is out of date (Python) Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9871) Continuous performance tests for BigQuery read is not displayed on the dashboard Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9927) [Beam Internship] Example Notebook w/ diary study Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9697) zetaSqlTimestampValueToJodaInstant IllegalStateException Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9849) Caching license files for license pulling Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9489) python typehints: reduce the number of runtime-type-check wrappers Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10032) Consider using RangeEndEstimator in a finite range for better Split/Progress Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9508) Python installation fails if grpc_tools is not installed Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9469) Provide error message access when Pipeline State is failure Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9866) Improve docker-pull-licenses trigger rule Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10151) Document how to run a Java (xlang) pipeline on the Spark portable runner Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9497) Update "Managing Python Pipeline Dependencies" page Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10146) Clean Docker images after tests Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10152) Add a diagram to the portability page Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9878) Update ElementByteSizeObservableIterable Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9959) Mistakes Computing Composite Inputs and Outputs Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9816) JOIN ON inequality results in RexInputRef cannot be cast to RexCall Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9960) Python MongoDBIO fails when response of split vector command is larger than 16mb Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10070) Skipping null fields in Big Query inserts from Dataflow Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10008) Test TIMESTAMP support in Python SqlTransform Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9492) Non-insertion errors in BigQueryIO.Write cause infinite loop Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9882) Go SplittableDoFn testing Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10155) Remove portability from the roadmap and rewrite as documentation Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9491) DatastoreV1.write() Should Optionally Return PCollection<Void> Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9883) Generalize SDF-validating restrictions Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9790) ClassCastException when using BigQueryIO with readTableRowsWithSchema for DirectRunner Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9943) Priotize Python versions for PreCommit/PostCommit tests Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9980) Do not hardcode Python versions in test suites, instead make it configurable. Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10002) Mongo cursor timeout leads to CursorNotFound error Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9829) Restructure test infrastructure for Python SDK Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9934) Resolve differences in beam:metric:element_count:v1 implementations Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9863) AvroUtils is converting incorrectly LogicalType Timestamps from long into Joda DateTimes Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9944) Reduce PreCommit test to the minimum and move rest of them to PostCommit one Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10182) Support custom gcs location for bigquery read Danny McCormick (Jira)
• [jira] [Commented] (BEAM-9859) Support joda time and java time Duration in schema inference Danny McCormick (Jira)
• [jira] [Commented] (BEAM-10053) Timers exception on "Job Drain" while using stateful beam processing in global window Danny McCormick (Jira)

• Earlier messages
• Later messages