issues  

Messages by Date

• 2024/12/17 [jira] [Work started] (BEAM-8388) Update Avro to 1.9.1 from 1.8.2 Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-162) assert fail using session windows Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-12193) WatchKafkaTopicPartitionDoFn reports user counter to indicate which TopicPartition has been emitted to downstream Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13852) KafkaIO.read.withDynamicRead() doesn't pick up new TopicPartitions Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-158) Add support for bounded sources in streaming mode Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13924) Coder information lost in Kafka Read Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-157) CombineTest.testGlobalCombineWithDefaultsAndTriggers is broken Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-707) Migrate PubsubIO/PubsubUnboundedSource/PubsubUnboundedSink to use AutoValue to reduce boilerplate Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-236) Implement Windowing in batch execution Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-182) SourceTestUtils.assertSplitAtFractionExhaustive should do a bounded number of trials Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-257) fix ConcurrentModificationException in KafkaIO Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-267) Enable Chekstyle check in Spark runner Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-8370) Project 'beam-runners-flink_2.11-job-server' not found in root project 'beam'. Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-7269) Remove StateSpec from hashCode of SimpleStateTag Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-7793) BagState drops Rows when triggered by timer Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-12662) AttributeError: 'FlinkUberJarJobServer' object has no attribute '_flink_version' Anonymous (Jira)
• 2024/11/28 [jira] [Work started] (BEAM-14438) Beam slowness compared to flink-native Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-12586) Python Direct Runner doesn't support both streaming & non streaming sources Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-14438) Beam slowness compared to flink-native Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-413) Mean$CountSum tests for floating point equality Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-421) StateTags$CombiningValueStateTag inherits equals from super class but without incorporating its state Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-417) AvroUtils$AvroMetadata exposes mutable syncMarker Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-12704) Fix primitive Read on portable Flink Runner Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-8092) Switch to java Optional in DirectRunner Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-6523) Support transcoding for Flatten in Flink Runner Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-14438) Beam slowness compared to flink-native Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-6523) Support transcoding for Flatten in Flink Runner Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-14386) [Flink] Support for scala 2.12 Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-418) BitSetCoder transient field byteArrayCoder not set after deserialization Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-413) Mean$CountSum tests for floating point equality Anonymous (Jira)
• 2024/11/28 [jira] [Work started] (BEAM-7827) MetricsTest$AttemptedMetricTests.testAllAttemptedMetrics is flaky on DirectRunner Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-419) Non-transient non-serializable instance field in CombineFnUtil$NonSerializableBoundedKeyedCombineFn Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-420) Non-transient non-serializable instance field in WatermarkHold Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-6810) [SQL] Plan optimizer eliminates aliasing in trivial projections Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13245) Generalize S3FileSystem to support multiple URI schemes (AWS SDK v2) Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-12533) DeferredSeries and DeferredDataFrame should have a useful repr Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13274) Beam Dependency Update Request: pyparsing Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-9410) Make JdbcIO readAll consistent with other Beam readAll methods Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-12258) SQL postcommit timing out Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13237) org.apache.beam.sdk.transforms.CombineTest$WindowingTests.testWindowedCombineGloballyAsSingletonView flaky on Dataflow Runner V2 Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-10074) Hash Functions in BeamSQL Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13273) Beam Dependency Update Request: google-cloud-recommendations-ai Anonymous (Jira)
• 2024/11/28 [jira] [Work started] (BEAM-13274) Beam Dependency Update Request: pyparsing Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-11389) Implement the LOGICAL_AND function for Beam SQL ZetaSQL dialect, as CombineFn. Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-11388) Implement missing ZETA_SQL Functions Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-10074) Hash Functions in BeamSQL Anonymous (Jira)
• 2024/11/28 [jira] [Work started] (BEAM-11388) Implement missing ZETA_SQL Functions Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-11533) PubSub support types: TIMESTAMP, DATE, TIME, DATETIME Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-11698) Implement BIT_XOR as CombineFn for Zetasql Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-12315) Support PARTITIONED BY on Beam's SQL DDL Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-12274) Create and use an extension of JavaTypeFactoryImpl. Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-12274) Create and use an extension of JavaTypeFactoryImpl. Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13588) beam_PostCommit_Java_PVR_Samza fails Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-10136) Add cross-language wrapper for Java's JdbcIO Write Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13236) Properly close kinesis producer on teardown Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13510) SQS reader retries on invalid (expired) receipt handles (AWS SDK v2) Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13276) Beam Dependency Update Request: com.fasterxml.jackson.core Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13510) SQS reader retries on invalid (expired) receipt handles (AWS SDK v2) Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13184) Support autosharding for JdbcIO writers Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13602) Metrics reporting failed bigtable io Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13597) Java GHA Test (Wordcount on Dataflow) failing with ClassNotFoundException Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13244) Add STS Assume role credentials provider to AwsModule (AWS SDK v2) Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13335) DataFrame sources produce excessively large index Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13509) SQS reader uses shared client instance without coordinating shutdown (AWS SDK v2) Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13697) Add SchemaFieldNumber annotation Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-12925) JdbcIo readRows does not handle null numerical values properly Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13716) Clear before creating a new virtual environment in setupVirtualenv Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-10300) Test failure: JdbcIOTest.testCustomFluentBackOffConfiguration Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13184) Support autosharding for JdbcIO writers Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-11982) Java Spanner - Implement IO Request Count metrics Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13638) SqsMessage class have package private access for getters Anonymous (Jira)
• 2024/11/28 [jira] [Updated] (BEAM-13466) [Playground] Sort categories and examples in alphabetical order Anonymous (Jira)
• 2024/11/28 [jira] [Work stopped] (BEAM-13631) SQS read IO requires deterministic coder for SQS message to work in batch mode mode. Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-628) Sink class org.apache.beam.runners.spark.aggregators.metrics.sink.GraphiteSink cannot be instantiated Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-420) Non-transient non-serializable instance field in WatermarkHold Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-755) beam-runners-core-java NeedsRunner tests not executing Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-610) Enable spark's checkpointing mechanism for driver-failure recovery in streaming Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-12534) Support the XDG Base Directory Specification Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-617) Allow setting of StateBackend on FlinkPipelineOptions Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-12534) Support the XDG Base Directory Specification Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-417) AvroUtils$AvroMetadata exposes mutable syncMarker Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-619) UnboundedSourceWrapper snapshotting fails with IndexOutOfBoundsException Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-413) Mean$CountSum tests for floating point equality Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-763) BigQueryIOTest.testBuildSourceWithTableAndSqlDialect is not a valid RunnableOnService test Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-413) Mean$CountSum tests for floating point equality Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-412) DisplayData is marked Serializable but contains non-serializable field Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13824) Migrate SnsIO.write to async implementation Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13206) Consolidate multiple levels of retries for AWS IOs Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-13764) Adding schema-based payload builder to Java external transform Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13410) Add integration test for S3FileSystem Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13960) SchemaTranslation.RowToProto does not properly handle all types Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13399) [Go SDK] Add automated expansion service start up feature Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13765) Missing IterableAssert.inOnlyPane and SingletonAssert.inWindow methods Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10377) Avoid expanding windows if not needed when processing elements in portable runner Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-13421) Python DeferredDataFrame.xs differs from Pandas Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13410) Add integration test for S3FileSystem Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13390) API for specifying Python dependencies to the expansion service Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10201) Enhance JsonToRow to add Deadletter Support Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10482) Schema-aware CoGroup transform doesn't work for any schema-aware POJO PCollection Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-14310) [Website] Bug in Playground Section at Home Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-14300) Fix Java precommit failure Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-14311) [Website] Home Page Improvements - Margins & Width Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-14298) Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-11689) 401 on org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-11640) Upgrade Linkage Checker to the latest 1.5.4 Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-11638) KafkaIO and 3rd Party Libraries like Lenses.io Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-11406) [Website revamp] Copy for the Contact Us page Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-11382) [Website revamp] Landing pages for Languages page Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-11827) Gradle task :checkJavaLinkage is not working Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-11423) [Website revamp] Development of Twitter feed component Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-11208) BigQuery storage streams fail with QUOTA_EXCEEDED errors in split Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7894) Upgrade "com.amazonaws:amazon-kinesis-producer" to version 0.13.1 Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-14263) beam_PostCommit_Java_DataflowV2, testBigQueryStorageWrite30MProto failing consistently Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-12145) Normalize transform IDs generated by SDKs Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13116) Support AWS credentials provider for AWS IOs (SDK v1) Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-9764) :sdks:java:container:generateThirdPartyLicenses failing Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-5143) Stop showing dependencies which are not able to upgraded in the weekly report Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3438) KinesisReaderIT fails due to a missing PipelineOptions property Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3087) Extend lock scope in Flink UnboundedSourceWrapper Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-12142) Reduce overhead of MetricsEnvironment Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-11406) [Website revamp] Copy for the Contact Us page Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7048) Fetch GCP-Datastore entity by id inside of a Dataflow transform Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-2958) Expose a top level user agent PipelineOption which can be communicated to external services Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-2307) BoundedReadFromUnboundedSource should be strongly discouraged Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-12990) Implement per stream progress reporting Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-13835) Support any-column-type to partition JdbcIO table reads Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13976) [Website] Update Home page Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13683) Implement cross-language SQL in the Go SDK Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-2706) Create JdbcIO.readAll() Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-573) TextIO.read() should support sharding Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7048) Fetch GCP-Datastore entity by id inside of a Dataflow transform Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-5242) runMobileGamingJavaDirect Aborted after 100 minutes Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-6608) Flink Runner prepares to-be-staged file too late Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-6992) Implement KinesisIO.Write using AWS SDK Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7638) Migrate KinesisIO to AWS SDK for Java 2 Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-12406) Progressing watermark for not available Kinesis stream Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-9702) Update Java KinesisIO.Read to support AWS SDK v2 Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-14317) Add an example JvmInitializer Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-4921) Beam Dependency Update Request: org.freemarker Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-4335) Enforce ErrorProne analysis in the amazon-web-services IO project Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-6353) TFRecordIOTest is failing Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-9670) CoGroup transform should allow widening nullability in key schemas Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-2752) KinesisIO throws ConcurrentModificationException on checkpoint Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-5109) Build nightly snapshot for Python SDK Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3373) Add serviceEndpoint parameter to KinesisIO Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-9702) Update Java KinesisIO.Read to support AWS SDK v2 Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-2393) BoundedSource is not fault-tolerant in FlinkRunner Streaming mode Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3549) Move KinesisIO into the amazon-web-services module Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7240) Kinesis IO Watermark Computation Improvements Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3291) Add Kinesis Write transform Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-2752) KinesisIO throws ConcurrentModificationException on checkpoint Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-6567) Extend "Data insertion pipeline" with KinesisIO Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3405) Make maxNumRecords a long and validate if stream exists for KinesisIO Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-5241) runMobileGamingJavaDirect FAILED SocketException: Connection reset Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-4965) Beam Dependency Update Request: org.apache.httpcomponents:httpclient 4.5.6 Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-4305) Enforce ErrorProne analysis in job-management project Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-4348) Enforce ErrorProne analysis in the kinesis IO project Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7589) Kinesis IO.write throws LimitExceededException Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7555) Migrate AWS IOs to AWS SDK for Java 2 Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3228) KinesisMockReadTest is flaky Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3404) Update KinesisIO to use AWS SDK 1.11.255 and KCL 1.8.8 Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-8958) Use default credentials provider with BasicKinesisProvider Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7080) Remove unused class KinesisUploader from KinesisIO tests Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3819) Add withRequestRecordsLimit option to KinesisIO Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7512) Replace usage of assertEquals with assertEqual in synthetic_pipeline_test.py Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3382) Validate count for trigger AfterCount Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-12609) Projection pushdown in SchemaIO Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13480) apache_beam.io.gcp.pubsub_integration_test.PubSubIntegrationTest.test_streaming_data_only is flaky Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7133) Spark job server Gradle task should pass along system properties Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10513) Failure / flake: Repeated deadlock in JdbcIOTest > testCustomFluentBackOffConfiguration Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3031) Go presubmit failed Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-9509) Subprocess job server treats missing local file as remote URL Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10109) Fix context classloader in Spark portable runner Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-2956) DataflowRunner incorrectly reports the user agent for the Dataflow distribution Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13261) JDBC IO: expose max pool connections as a setting Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10151) Document how to run a Java (xlang) pipeline on the Spark portable runner Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-14173) beam_LoadTests_Go_CoGBK_Flink_batch, beam_LoadTests_Go_Combine_Flink_batch, etc: Encountered unsupported logical type URN: int org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.UncheckedExecutionException Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-4081) Review of schema metadata vs schema types Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-7442) Bounded Reads for Flink Runner fails with OOM Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13494) KinesisIO.read requires default rater limiter for low throughput shards Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10006) PipelineOptions can pick up definitions from unrelated tests Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10784) Spark portable streaming: failing window-related tests Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3881) Failure reading backlog in KinesisIO Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-12790) Projection pushdown in JDBC SchemaIO Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-14398) apache_beam/transforms/userstate_test.py::StatefulDoFnOnDirectRunnerTest::test_dynamic_timer_clear_then_set_timer is flakey Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-12515) Python PreCommit flaking in PipelineOptionsTest.test_display_data Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10586) Sunset Python 2 in Dataflow runner. Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-13609) Not all variable length types works properly for Oracle DB Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10591) apache_beam.io.external.xlang_jdbcio_it_test.CrossLanguageJdbcIOTest is flaky Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3001) Allow disabling validation on BigtableIO.write() Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-9482) beam_PerformanceTests_Kafka_IO failing due to " provided port is already allocated" Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-10474) Failure / flake in DisplayDataTest > test_value_provider_display_data Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-14432) JdbcIO: WriteWithResult not works as expected when maps ResultSet Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-12515) Python PreCommit flaking in PipelineOptionsTest.test_display_data Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-12484) JdbcIO date conversion is sensitive to OS Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-12484) JdbcIO date conversion is sensitive to OS Anonymous (Jira)
• 2024/11/23 [jira] [Updated] (BEAM-3195) Failure in Java postcommit & nightly - WriteFiles - "When using windowed writes, must specify number of output shards explicitly [WriteFiles]" Anonymous (Jira)
• 2024/11/23 [jira] [Work started] (BEAM-10006) PipelineOptions can pick up definitions from unrelated tests Anonymous (Jira)

• Earlier messages