issues  

Messages by Thread

• [jira] [Work started] (BEAM-8388) Update Avro to 1.9.1 from 1.8.2 Anonymous (Jira)
• [jira] [Updated] (BEAM-162) assert fail using session windows Anonymous (Jira)
• [jira] [Updated] (BEAM-12193) WatchKafkaTopicPartitionDoFn reports user counter to indicate which TopicPartition has been emitted to downstream Anonymous (Jira)
• [jira] [Updated] (BEAM-13852) KafkaIO.read.withDynamicRead() doesn't pick up new TopicPartitions Anonymous (Jira)
• [jira] [Updated] (BEAM-158) Add support for bounded sources in streaming mode Anonymous (Jira)
• [jira] [Updated] (BEAM-13924) Coder information lost in Kafka Read Anonymous (Jira)
• [jira] [Updated] (BEAM-157) CombineTest.testGlobalCombineWithDefaultsAndTriggers is broken Anonymous (Jira)
• [jira] [Updated] (BEAM-707) Migrate PubsubIO/PubsubUnboundedSource/PubsubUnboundedSink to use AutoValue to reduce boilerplate Anonymous (Jira)
• [jira] [Updated] (BEAM-236) Implement Windowing in batch execution Anonymous (Jira)
• [jira] [Updated] (BEAM-182) SourceTestUtils.assertSplitAtFractionExhaustive should do a bounded number of trials Anonymous (Jira)
• [jira] [Updated] (BEAM-257) fix ConcurrentModificationException in KafkaIO Anonymous (Jira)
• [jira] [Updated] (BEAM-267) Enable Chekstyle check in Spark runner Anonymous (Jira)
• [jira] [Updated] (BEAM-8370) Project 'beam-runners-flink_2.11-job-server' not found in root project 'beam'. Anonymous (Jira)
• [jira] [Updated] (BEAM-7269) Remove StateSpec from hashCode of SimpleStateTag Anonymous (Jira)
• [jira] [Updated] (BEAM-7793) BagState drops Rows when triggered by timer Anonymous (Jira)
• [jira] [Updated] (BEAM-12662) AttributeError: 'FlinkUberJarJobServer' object has no attribute '_flink_version' Anonymous (Jira)
• [jira] [Work started] (BEAM-14438) Beam slowness compared to flink-native Anonymous (Jira)
• [jira] [Updated] (BEAM-12586) Python Direct Runner doesn't support both streaming & non streaming sources Anonymous (Jira)
• [jira] [Updated] (BEAM-421) StateTags$CombiningValueStateTag inherits equals from super class but without incorporating its state Anonymous (Jira)
• [jira] [Updated] (BEAM-12704) Fix primitive Read on portable Flink Runner Anonymous (Jira)
• [jira] [Updated] (BEAM-8092) Switch to java Optional in DirectRunner Anonymous (Jira)
• [jira] [Updated] (BEAM-14438) Beam slowness compared to flink-native Anonymous (Jira)
  • [jira] [Updated] (BEAM-14438) Beam slowness compared to flink-native Anonymous (Jira)
• [jira] [Updated] (BEAM-418) BitSetCoder transient field byteArrayCoder not set after deserialization Anonymous (Jira)
• [jira] [Work started] (BEAM-7827) MetricsTest$AttemptedMetricTests.testAllAttemptedMetrics is flaky on DirectRunner Anonymous (Jira)
• [jira] [Updated] (BEAM-419) Non-transient non-serializable instance field in CombineFnUtil$NonSerializableBoundedKeyedCombineFn Anonymous (Jira)
• [jira] [Updated] (BEAM-6810) [SQL] Plan optimizer eliminates aliasing in trivial projections Anonymous (Jira)
• [jira] [Updated] (BEAM-12533) DeferredSeries and DeferredDataFrame should have a useful repr Anonymous (Jira)
• [jira] [Updated] (BEAM-13274) Beam Dependency Update Request: pyparsing Anonymous (Jira)
• [jira] [Updated] (BEAM-12258) SQL postcommit timing out Anonymous (Jira)
• [jira] [Updated] (BEAM-13237) org.apache.beam.sdk.transforms.CombineTest$WindowingTests.testWindowedCombineGloballyAsSingletonView flaky on Dataflow Runner V2 Anonymous (Jira)
• [jira] [Updated] (BEAM-13273) Beam Dependency Update Request: google-cloud-recommendations-ai Anonymous (Jira)
• [jira] [Work started] (BEAM-13274) Beam Dependency Update Request: pyparsing Anonymous (Jira)
• [jira] [Updated] (BEAM-11389) Implement the LOGICAL_AND function for Beam SQL ZetaSQL dialect, as CombineFn. Anonymous (Jira)
• [jira] [Updated] (BEAM-11388) Implement missing ZETA_SQL Functions Anonymous (Jira)
• [jira] [Work started] (BEAM-11388) Implement missing ZETA_SQL Functions Anonymous (Jira)
• [jira] [Updated] (BEAM-11698) Implement BIT_XOR as CombineFn for Zetasql Anonymous (Jira)
• [jira] [Updated] (BEAM-12315) Support PARTITIONED BY on Beam's SQL DDL Anonymous (Jira)
• [jira] [Updated] (BEAM-13588) beam_PostCommit_Java_PVR_Samza fails Anonymous (Jira)
• [jira] [Updated] (BEAM-13236) Properly close kinesis producer on teardown Anonymous (Jira)
• [jira] [Updated] (BEAM-13276) Beam Dependency Update Request: com.fasterxml.jackson.core Anonymous (Jira)
• [jira] [Updated] (BEAM-13602) Metrics reporting failed bigtable io Anonymous (Jira)
• [jira] [Updated] (BEAM-13597) Java GHA Test (Wordcount on Dataflow) failing with ClassNotFoundException Anonymous (Jira)
• [jira] [Updated] (BEAM-13244) Add STS Assume role credentials provider to AwsModule (AWS SDK v2) Anonymous (Jira)
• [jira] [Updated] (BEAM-13335) DataFrame sources produce excessively large index Anonymous (Jira)
• [jira] [Updated] (BEAM-13509) SQS reader uses shared client instance without coordinating shutdown (AWS SDK v2) Anonymous (Jira)
• [jira] [Updated] (BEAM-13697) Add SchemaFieldNumber annotation Anonymous (Jira)
• [jira] [Updated] (BEAM-13716) Clear before creating a new virtual environment in setupVirtualenv Anonymous (Jira)
• [jira] [Updated] (BEAM-10300) Test failure: JdbcIOTest.testCustomFluentBackOffConfiguration Anonymous (Jira)
• [jira] [Updated] (BEAM-11982) Java Spanner - Implement IO Request Count metrics Anonymous (Jira)
• [jira] [Updated] (BEAM-13466) [Playground] Sort categories and examples in alphabetical order Anonymous (Jira)
• [jira] [Work stopped] (BEAM-13631) SQS read IO requires deterministic coder for SQS message to work in batch mode mode. Anonymous (Jira)
• [jira] [Updated] (BEAM-628) Sink class org.apache.beam.runners.spark.aggregators.metrics.sink.GraphiteSink cannot be instantiated Anonymous (Jira)
• [jira] [Updated] (BEAM-420) Non-transient non-serializable instance field in WatermarkHold Anonymous (Jira)
  • [jira] [Updated] (BEAM-420) Non-transient non-serializable instance field in WatermarkHold Anonymous (Jira)
• [jira] [Updated] (BEAM-755) beam-runners-core-java NeedsRunner tests not executing Anonymous (Jira)
• [jira] [Updated] (BEAM-617) Allow setting of StateBackend on FlinkPipelineOptions Anonymous (Jira)
• [jira] [Updated] (BEAM-619) UnboundedSourceWrapper snapshotting fails with IndexOutOfBoundsException Anonymous (Jira)
• [jira] [Updated] (BEAM-763) BigQueryIOTest.testBuildSourceWithTableAndSqlDialect is not a valid RunnableOnService test Anonymous (Jira)
• [jira] [Updated] (BEAM-412) DisplayData is marked Serializable but contains non-serializable field Anonymous (Jira)
• [jira] [Updated] (BEAM-13824) Migrate SnsIO.write to async implementation Anonymous (Jira)
• [jira] [Updated] (BEAM-13206) Consolidate multiple levels of retries for AWS IOs Anonymous (Jira)
• [jira] [Work started] (BEAM-13764) Adding schema-based payload builder to Java external transform Anonymous (Jira)
• [jira] [Updated] (BEAM-13960) SchemaTranslation.RowToProto does not properly handle all types Anonymous (Jira)
• [jira] [Updated] (BEAM-10377) Avoid expanding windows if not needed when processing elements in portable runner Anonymous (Jira)
• [jira] [Work started] (BEAM-13421) Python DeferredDataFrame.xs differs from Pandas Anonymous (Jira)
• [jira] [Updated] (BEAM-10201) Enhance JsonToRow to add Deadletter Support Anonymous (Jira)
• [jira] [Updated] (BEAM-10482) Schema-aware CoGroup transform doesn't work for any schema-aware POJO PCollection Anonymous (Jira)
• [jira] [Updated] (BEAM-14310) [Website] Bug in Playground Section at Home Anonymous (Jira)
• [jira] [Updated] (BEAM-14300) Fix Java precommit failure Anonymous (Jira)
• [jira] [Updated] (BEAM-14311) [Website] Home Page Improvements - Margins & Width Anonymous (Jira)
• [jira] [Updated] (BEAM-14298) Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde Anonymous (Jira)
• [jira] [Updated] (BEAM-11689) 401 on org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde Anonymous (Jira)
• [jira] [Updated] (BEAM-11640) Upgrade Linkage Checker to the latest 1.5.4 Anonymous (Jira)
• [jira] [Updated] (BEAM-11638) KafkaIO and 3rd Party Libraries like Lenses.io Anonymous (Jira)
• [jira] [Updated] (BEAM-11382) [Website revamp] Landing pages for Languages page Anonymous (Jira)
• [jira] [Updated] (BEAM-11827) Gradle task :checkJavaLinkage is not working Anonymous (Jira)
• [jira] [Updated] (BEAM-14263) beam_PostCommit_Java_DataflowV2, testBigQueryStorageWrite30MProto failing consistently Anonymous (Jira)
• [jira] [Updated] (BEAM-12145) Normalize transform IDs generated by SDKs Anonymous (Jira)
• [jira] [Updated] (BEAM-13116) Support AWS credentials provider for AWS IOs (SDK v1) Anonymous (Jira)
• [jira] [Updated] (BEAM-9764) :sdks:java:container:generateThirdPartyLicenses failing Anonymous (Jira)
• [jira] [Updated] (BEAM-5143) Stop showing dependencies which are not able to upgraded in the weekly report Anonymous (Jira)
• [jira] [Updated] (BEAM-3438) KinesisReaderIT fails due to a missing PipelineOptions property Anonymous (Jira)
• [jira] [Updated] (BEAM-3087) Extend lock scope in Flink UnboundedSourceWrapper Anonymous (Jira)
• [jira] [Updated] (BEAM-11406) [Website revamp] Copy for the Contact Us page Anonymous (Jira)
  • [jira] [Updated] (BEAM-11406) [Website revamp] Copy for the Contact Us page Anonymous (Jira)
• [jira] [Updated] (BEAM-2958) Expose a top level user agent PipelineOption which can be communicated to external services Anonymous (Jira)
• [jira] [Work started] (BEAM-2307) BoundedReadFromUnboundedSource should be strongly discouraged Anonymous (Jira)
• [jira] [Updated] (BEAM-12990) Implement per stream progress reporting Anonymous (Jira)
• [jira] [Work started] (BEAM-13835) Support any-column-type to partition JdbcIO table reads Anonymous (Jira)
• [jira] [Updated] (BEAM-13976) [Website] Update Home page Anonymous (Jira)
• [jira] [Updated] (BEAM-573) TextIO.read() should support sharding Anonymous (Jira)
• [jira] [Updated] (BEAM-5242) runMobileGamingJavaDirect Aborted after 100 minutes Anonymous (Jira)
• [jira] [Updated] (BEAM-6608) Flink Runner prepares to-be-staged file too late Anonymous (Jira)
• [jira] [Updated] (BEAM-6992) Implement KinesisIO.Write using AWS SDK Anonymous (Jira)
• [jira] [Updated] (BEAM-7638) Migrate KinesisIO to AWS SDK for Java 2 Anonymous (Jira)
• [jira] [Updated] (BEAM-12406) Progressing watermark for not available Kinesis stream Anonymous (Jira)
• [jira] [Work started] (BEAM-14317) Add an example JvmInitializer Anonymous (Jira)
• [jira] [Updated] (BEAM-4921) Beam Dependency Update Request: org.freemarker Anonymous (Jira)
• [jira] [Updated] (BEAM-4335) Enforce ErrorProne analysis in the amazon-web-services IO project Anonymous (Jira)
• [jira] [Updated] (BEAM-6353) TFRecordIOTest is failing Anonymous (Jira)
• [jira] [Updated] (BEAM-9670) CoGroup transform should allow widening nullability in key schemas Anonymous (Jira)
• [jira] [Work started] (BEAM-2752) KinesisIO throws ConcurrentModificationException on checkpoint Anonymous (Jira)
• [jira] [Updated] (BEAM-5109) Build nightly snapshot for Python SDK Anonymous (Jira)
• [jira] [Updated] (BEAM-3373) Add serviceEndpoint parameter to KinesisIO Anonymous (Jira)
• [jira] [Updated] (BEAM-2393) BoundedSource is not fault-tolerant in FlinkRunner Streaming mode Anonymous (Jira)
• [jira] [Updated] (BEAM-3549) Move KinesisIO into the amazon-web-services module Anonymous (Jira)
• [jira] [Updated] (BEAM-7240) Kinesis IO Watermark Computation Improvements Anonymous (Jira)
• [jira] [Updated] (BEAM-3291) Add Kinesis Write transform Anonymous (Jira)
• [jira] [Updated] (BEAM-2752) KinesisIO throws ConcurrentModificationException on checkpoint Anonymous (Jira)
• [jira] [Updated] (BEAM-6567) Extend "Data insertion pipeline" with KinesisIO Anonymous (Jira)
• [jira] [Updated] (BEAM-3405) Make maxNumRecords a long and validate if stream exists for KinesisIO Anonymous (Jira)
• [jira] [Work started] (BEAM-5241) runMobileGamingJavaDirect FAILED SocketException: Connection reset Anonymous (Jira)
• [jira] [Updated] (BEAM-4305) Enforce ErrorProne analysis in job-management project Anonymous (Jira)
• [jira] [Updated] (BEAM-4348) Enforce ErrorProne analysis in the kinesis IO project Anonymous (Jira)
• [jira] [Updated] (BEAM-7589) Kinesis IO.write throws LimitExceededException Anonymous (Jira)
• [jira] [Updated] (BEAM-7555) Migrate AWS IOs to AWS SDK for Java 2 Anonymous (Jira)
• [jira] [Updated] (BEAM-3228) KinesisMockReadTest is flaky Anonymous (Jira)
• [jira] [Updated] (BEAM-3404) Update KinesisIO to use AWS SDK 1.11.255 and KCL 1.8.8 Anonymous (Jira)
• [jira] [Updated] (BEAM-8958) Use default credentials provider with BasicKinesisProvider Anonymous (Jira)
• [jira] [Updated] (BEAM-7080) Remove unused class KinesisUploader from KinesisIO tests Anonymous (Jira)
• [jira] [Updated] (BEAM-3819) Add withRequestRecordsLimit option to KinesisIO Anonymous (Jira)
• [jira] [Updated] (BEAM-7512) Replace usage of assertEquals with assertEqual in synthetic_pipeline_test.py Anonymous (Jira)
• [jira] [Updated] (BEAM-3382) Validate count for trigger AfterCount Anonymous (Jira)
• [jira] [Updated] (BEAM-13480) apache_beam.io.gcp.pubsub_integration_test.PubSubIntegrationTest.test_streaming_data_only is flaky Anonymous (Jira)
• [jira] [Updated] (BEAM-7133) Spark job server Gradle task should pass along system properties Anonymous (Jira)
• [jira] [Updated] (BEAM-10513) Failure / flake: Repeated deadlock in JdbcIOTest > testCustomFluentBackOffConfiguration Anonymous (Jira)
• [jira] [Updated] (BEAM-3031) Go presubmit failed Anonymous (Jira)
• [jira] [Updated] (BEAM-9509) Subprocess job server treats missing local file as remote URL Anonymous (Jira)
• [jira] [Updated] (BEAM-10109) Fix context classloader in Spark portable runner Anonymous (Jira)
• [jira] [Updated] (BEAM-2956) DataflowRunner incorrectly reports the user agent for the Dataflow distribution Anonymous (Jira)
• [jira] [Updated] (BEAM-10151) Document how to run a Java (xlang) pipeline on the Spark portable runner Anonymous (Jira)
• [jira] [Updated] (BEAM-4081) Review of schema metadata vs schema types Anonymous (Jira)
• [jira] [Updated] (BEAM-13494) KinesisIO.read requires default rater limiter for low throughput shards Anonymous (Jira)
• [jira] [Updated] (BEAM-10006) PipelineOptions can pick up definitions from unrelated tests Anonymous (Jira)
• [jira] [Updated] (BEAM-10784) Spark portable streaming: failing window-related tests Anonymous (Jira)
• [jira] [Updated] (BEAM-3881) Failure reading backlog in KinesisIO Anonymous (Jira)
• [jira] [Work started] (BEAM-12790) Projection pushdown in JDBC SchemaIO Anonymous (Jira)
• [jira] [Updated] (BEAM-14398) apache_beam/transforms/userstate_test.py::StatefulDoFnOnDirectRunnerTest::test_dynamic_timer_clear_then_set_timer is flakey Anonymous (Jira)
• [jira] [Updated] (BEAM-12515) Python PreCommit flaking in PipelineOptionsTest.test_display_data Anonymous (Jira)
• [jira] [Updated] (BEAM-10586) Sunset Python 2 in Dataflow runner. Anonymous (Jira)
• [jira] [Updated] (BEAM-13609) Not all variable length types works properly for Oracle DB Anonymous (Jira)
• [jira] [Updated] (BEAM-10591) apache_beam.io.external.xlang_jdbcio_it_test.CrossLanguageJdbcIOTest is flaky Anonymous (Jira)
• [jira] [Updated] (BEAM-3001) Allow disabling validation on BigtableIO.write() Anonymous (Jira)
• [jira] [Updated] (BEAM-9482) beam_PerformanceTests_Kafka_IO failing due to " provided port is already allocated" Anonymous (Jira)
• [jira] [Updated] (BEAM-10474) Failure / flake in DisplayDataTest > test_value_provider_display_data Anonymous (Jira)
• [jira] [Work started] (BEAM-14432) JdbcIO: WriteWithResult not works as expected when maps ResultSet Anonymous (Jira)
• [jira] [Work started] (BEAM-12515) Python PreCommit flaking in PipelineOptionsTest.test_display_data Anonymous (Jira)
• [jira] [Updated] (BEAM-12484) JdbcIO date conversion is sensitive to OS Anonymous (Jira)
• [jira] [Work started] (BEAM-12484) JdbcIO date conversion is sensitive to OS Anonymous (Jira)
• [jira] [Updated] (BEAM-3195) Failure in Java postcommit & nightly - WriteFiles - "When using windowed writes, must specify number of output shards explicitly [WriteFiles]" Anonymous (Jira)
• [jira] [Work started] (BEAM-10006) PipelineOptions can pick up definitions from unrelated tests Anonymous (Jira)
• [jira] [Updated] (BEAM-12790) Projection pushdown in JDBC SchemaIO Anonymous (Jira)
• [jira] [Updated] (BEAM-12396) beam_PostCommit_XVR_Direct failed (flaked?) Anonymous (Jira)
• [jira] [Updated] (BEAM-3134) cannot write data to BigQuery with Dataflow Anonymous (Jira)
• [jira] [Updated] (BEAM-10570) Consider making a logical type for generic Python types in Rows. Anonymous (Jira)
• [jira] [Updated] (BEAM-3508) Beam does not compile with Eclipse Anonymous (Jira)
• [jira] [Updated] (BEAM-13184) Support autosharding for JdbcIO writers Anonymous (Jira)
  • [jira] [Updated] (BEAM-13184) Support autosharding for JdbcIO writers Anonymous (Jira)
  • [jira] [Updated] (BEAM-13184) Support autosharding for JdbcIO writers Anonymous (Jira)
• [jira] [Work started] (BEAM-14417) JdbcIO.Write needs exception handling tests Anonymous (Jira)
• [jira] [Updated] (BEAM-13194) Call the stored procedure in dataflow pipeline Anonymous (Jira)
• [jira] [Work started] (BEAM-13631) SQS read IO requires deterministic coder for SQS message to work in batch mode mode. Anonymous (Jira)
• [jira] [Updated] (BEAM-11301) [Website Revamp] Add hover interaction to Calendar Anonymous (Jira)
• [jira] [Updated] (BEAM-10918) Row.withSchema.withFieldValues(Map) is broken Anonymous (Jira)
• [jira] [Updated] (BEAM-11219) [Website revamp] Development of All about Apache Beam component Anonymous (Jira)
• [jira] [Updated] (BEAM-1946) Add IO module for restful api Anonymous (Jira)
• [jira] [Work started] (BEAM-12990) Implement per stream progress reporting Anonymous (Jira)
• [jira] [Updated] (BEAM-12191) python DataflowRunner upload_graph feature doesn't reduce template file size Anonymous (Jira)
• [jira] [Updated] (BEAM-13978) [Website] Update Community/Join page Anonymous (Jira)
• [jira] [Updated] (BEAM-11381) [Website revamp] Update Beam programming guide navigation Anonymous (Jira)
• [jira] [Updated] (BEAM-9782) README on how to keep go katas up-to-date Anonymous (Jira)
• [jira] [Updated] (BEAM-13977) [Website] Update Community landing page Anonymous (Jira)
• [jira] [Updated] (BEAM-14324) Exempt fn_test.go from ST1008 check Anonymous (Jira)
• [jira] [Updated] (BEAM-11422) [Website revamp] UI design for Join Beam Community page Anonymous (Jira)
• [jira] [Updated] (BEAM-13759) Document Python custom metrics in programming guide Anonymous (Jira)
• [jira] [Updated] (BEAM-11424) [Website revamp] Development of Contribution Guide page Anonymous (Jira)
• [jira] [Work started] (BEAM-13194) Call the stored procedure in dataflow pipeline Anonymous (Jira)
• [jira] [Updated] (BEAM-7158) Operate the TensorFlow API with Apache Beam Anonymous (Jira)
• [jira] [Updated] (BEAM-14346) ret2() function checks incorrect index for error case Anonymous (Jira)
• [jira] [Updated] (BEAM-12166) Beam Sql - Combine Accumulator return Map fails with class cast exception Anonymous (Jira)
• [jira] [Updated] (BEAM-610) Enable spark's checkpointing mechanism for driver-failure recovery in streaming Anonymous (Jira)
  • [jira] [Updated] (BEAM-610) Enable spark's checkpointing mechanism for driver-failure recovery in streaming Anonymous (Jira)
• [jira] [Updated] (BEAM-11561) Fix issues with reloading Home page on social media component Anonymous (Jira)
• [jira] [Updated] (BEAM-1783) Add Integration Tests for HBaseIO Anonymous (Jira)
• [jira] [Updated] (BEAM-10095) Add hyperlinks to the beam-overview page. Anonymous (Jira)
• [jira] [Updated] (BEAM-11423) [Website revamp] Development of Twitter feed component Anonymous (Jira)
  • [jira] [Updated] (BEAM-11423) [Website revamp] Development of Twitter feed component Anonymous (Jira)
• [jira] [Updated] (BEAM-10334) Message limit for grpc message is set to default 4 MB Anonymous (Jira)
• [jira] [Updated] (BEAM-12203) Reduce thread context switches in BeamFnControlClient Anonymous (Jira)
• [jira] [Updated] (BEAM-12141) Print sha256 and size when downloading artifacts via artifact retrieval service Anonymous (Jira)
• [jira] [Updated] (BEAM-544) Add header/footer support to TextIO.Write Anonymous (Jira)
• [jira] [Updated] (BEAM-7159) Add cluster monitoring BI to Apache Beam Anonymous (Jira)
• [jira] [Updated] (BEAM-12376) Support ReadLater() API in Java SDK Harness Anonymous (Jira)
• [jira] [Updated] (BEAM-316) Support file scheme in TextIO Anonymous (Jira)
• [jira] [Updated] (BEAM-13630) Improve documentation for the Dataflow Service options Anonymous (Jira)
• [jira] [Updated] (BEAM-12400) Improve MongoDBIO for beam - add update capability Anonymous (Jira)
• [jira] [Updated] (BEAM-9561) Run pandas tests with Beam Dataframe API Anonymous (Jira)
• [jira] [Work started] (BEAM-13460) IsmSideInputReaderTest.verifyMap does not make some contains assertions Anonymous (Jira)
• [jira] [Updated] (BEAM-11807) SDK Worker with multithreading causes boto3 the KeyError(endpoint_resolver) Anonymous (Jira)

• Earlier messages