You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Updated] (BEAM-12948) Add .withPipelineTempDirectory() Builder setting for file-based sinks - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-12948) Add .withPipelineTempDirectory() Builder setting for file-based sinks - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13231) Globbing asterisk cannot be escaped in file reads. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11174) [Website revamp] Create guidelines for development - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 3 replies.
- [jira] [Work started] (BEAM-7519) Improve work with SSL/TLS certificates in SDK IO, for Google Dataflow - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13573) Flink runner failing testOnWindowTimestampSkew - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11429) User-friendly stage name for packed combiners - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13572) Flink runner does not support PerKeyOrdering - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8934) Store&Read offset with KafkaIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-7158) Operate the TensorFlow API with Apache Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14323) Improve IDE integration for Spark cross version builds - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13760) Add randomness to default Dataflow job name in Python sdk - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7048) Fetch GCP-Datastore entity by id inside of a Dataflow transform - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 2 replies.
- [jira] [Updated] (BEAM-10557) Move DataStoreV1 Logic to Core Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13231) Globbing asterisk cannot be escaped in file reads. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11281) [Website revamp] Create Beam model design - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 2 replies.
- [jira] [Updated] (BEAM-14067) Beam Core IO: WriteFiles stuck - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14067) Beam Core IO: WriteFiles stuck - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-7159) Add cluster monitoring BI to Apache Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-7818) Create Presto I/O connector - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:54:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-2256) mongodb sdk MongoDbIO.BoundedMongoDbSource.splitKeysToFilters incorrect - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 12:55:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10418) Support type hint annotations on CombineFn add_input() and extract_output() - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 18:16:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10254) Python type hints: support typing.Pattern - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 18:16:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10258) Support type hint annotations on PTransform's expand() - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 18:16:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10623) Add workflow to run Beam python tests on Linux/Windows/Mac platforms - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 18:17:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13585) Python SDK S3 reader 2x - 10x performance opportunity - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 18:17:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13980) S3 Client broken: missing get_object_metadata() - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 18:17:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13794) Update documentation for Java 17 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 18:17:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11208) BigQuery storage streams fail with QUOTA_EXCEEDED errors in split - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 18:17:00 UTC, 2 replies.
- [jira] [Updated] (BEAM-11386) BigQuery streaming inserts should fail if SchemaUpdateOptions specified - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/21 18:17:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12122) Python IO MongoDB: integer and string `_id` keys are not supported. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 02:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11915) Python MondgoDB Connector: TypeError: '>=' not supported between instances of 'str' and 'ObjectId' - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 02:01:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14088) Add ability to type PTransforms with input and output by making it a generic - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 02:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10294) Beam metrics are unreadable in Spark history server - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-8103) Stop job service when pipeline execution finishes - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12762) java.io.InvalidClassException with Spark 3.1.2 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10106) Script the deployment of artifacts to pypi - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8183) Optionally bundle multiple pipelines into a single Flink jar - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-8103) Stop job service when pipeline execution finishes - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8115) Overwrite portable Flink application jar pipeline options at runtime - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-8899) Artifact retrieval failure logs at info level - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14335) Spotless sources for Spark runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14345) Hadoop version tests are failing for Spark 3 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10668) Replace toLowerCase().equals() with equalsIgnoreCase - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-12526) Configure Automatic Updates via Dependabot - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14380) Forward pipeline metric results in Beam package. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12241) Update bytebuddy to version 1.11.0 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12089) Improve documentation of artifacts-dir. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9996) Flink should not shadow FnApiRunnerTest.test_metrics - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12882) pubsublite.SubscriptionPartitionLoaderTest.addedResults flaky - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4228) The FlinkRunner shouldn't require all of the values for a key to fit in memory - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4552) Use Spark AccumulatorsV2 API - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14051) There should be single source of truth for the project version - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12712) Java Portable VR PostCommits failing - ParDoTest TimerTests.testEventTimeTimerLoop - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12526) Configure Automatic Updates via Dependabot - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8296) Containerize the Spark job server - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12875) File systems are not registered when ArtifactRetrievalService is created by Spark runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13504) Remove provided/compileOnly deps not intended for external use - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-10676) Timers use the input timestamp as the timer output timestamp which prevents watermark progress - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12510) POM files with direct reference to maven repositories - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-9213) FlinkRunner ignores --flink_submit_uber_jar when master unset - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8968) portableWordCount test for Spark/Flink failing: jar not found - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14334) Avoid using forkEvery in Spark runner tests - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:51:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9795) Support custom avro DatumWriters when writing to BigQuery - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:52:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6730) Enable configuration of Java transforms (specifically IO) through other SDKs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:52:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10103) Add WasbIO / WasbFileSystem (Azure Blob Storage) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:52:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9410) Make JdbcIO readAll consistent with other Beam readAll methods - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:52:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-10030) Add CSVIO for Java SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:52:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13298) Add "withResults()" for KafkaIO.write - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:52:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9893) Add SnowflakeIO to Java SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:52:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11439) Fix Snowflake streaming docs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:52:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-10103) Add WasbIO / WasbFileSystem (Azure Blob Storage) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 07:52:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10775) Create precomimt job for typescript tests - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 10:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9333) DataCatalogPipelineOptions is not registered - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 10:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10956) PipelineInstrumentTest is flaky - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 10:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10858) beam.io.jdbc not working on Google Cloud Dataflow - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 10:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11025) PCollectionVisualizationTest.test_dynamic_plotting_return_handle failing in precommit - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 10:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10261) [FileIO] Unexpected exception thrown when retrieving a GCS file with a space inside path - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 11:41:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12075) GroupByKey doesn't seem to work with FixedWindows in DirectRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11968) Bump com.google.cloud:libraries-bom to 19.0.0 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9430) Migrate from ProcessContext#updateWatermark to WatermarkEstimators - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-9564) Remove insecure ssl options from MongoDBIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-9564) Remove insecure ssl options from MongoDBIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9647) No MQTT connection possible because clientId is too long - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12674) SqlTransform IllegalArgumentException: key already present: SchemaCoder - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Work stopped] (BEAM-10556) Eliminate rawtype errors from Beam Java - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9310) Make SpannerAccessor in Java package-private to reduce API surface - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-8878) Possible flake in PortableRunnerTest.test_error_traceback_includes_user_code - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13950) PVR_Spark2_Streaming perma-red - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13564) [Playground] Add getting of preparation output for the sent example - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14212) Custom Coders are ignored sometimes - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13970) RunInference V1 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9571) Add withMongoClientProvider to MongoDbIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7237) Run NeedsRunner test category with Spark Runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9187) org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactoryTest.loadBalancesBundles is flaky - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14445) Add automation for managing GitHub issues - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13765) Missing IterableAssert.inOnlyPane and SingletonAssert.inWindow methods - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-12793) beam_PostRelease_NightlySnapshot failed - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14207) Investigate releasing models in inference base class - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9652) BigQueryIO MultiPartitionsWriteTables fails with ClassCastException: java.lang.Object cannot be cast to org.apache.beam.sdk.values.KV - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8879) IOError flake in PortableRunnerTest - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12274) Create and use an extension of JavaTypeFactoryImpl. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:20:00 UTC, 2 replies.
- [jira] [Updated] (BEAM-7321) TestStreamTest breaks on Flink runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:21:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-7319) Multiple NeedsRunner tests break with Flink 'Cannot union streams of different types' - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:21:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6523) Support transcoding for Flatten in Flink Runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:21:00 UTC, 2 replies.
- [jira] [Updated] (BEAM-7323) PartitionTest.testDroppedPartition breaks on Flink runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:21:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-7318) WriteFilesTest.testEmptyWrite breaks on Flink runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 14:21:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12204) Portable Java caches entirety of iterable side inputs. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12400) Improve MongoDBIO for beam - add update capability - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12866) TestStream should only emit bytes - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13727) Beam Dependency Update Request: org.testcontainers:kafka - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8235) Python Post Commit 3.6 issue - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13729) Beam Dependency Update Request: org.testcontainers:postgresql - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13043) Implementation encoding position sdk-go - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6993) Default to cleaning staged artifacts after running portable pipeline - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10894) Implement dataframe IO methods. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11807) SDK Worker with multithreading causes boto3 the KeyError(endpoint_resolver) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9502) SchemaCoder is not update compatible - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13402) Pub/Sub Lite commits can take 10s of hours without completing - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12194) Support user-defined aggregate functions in ZetaSQL. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14051) There should be single source of truth for the project version - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13460) IsmSideInputReaderTest.verifyMap does not make some contains assertions - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-10526) Use grpc test rules for graceful server/channel shutdown in tests - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9451) Optimize translation when Schema information is available in Spark Structured Streaming runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13280) Beam Dependency Update Request: org.immutables:value - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12451) BigQueryIO leaks gRPC channels - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-10664) Enable kinesis read on localstack in python cross-language it test - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13728) Beam Dependency Update Request: org.testcontainers:mysql - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12016) Implement add_suffix, add_prefix for DataFrame and Series - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12380) Go SDK Kafka IO Transform implemented via XLang - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-8637) Beam Dependency Update Request: org.apache.httpcomponents:httpclient - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13762) Get the latest GitHub Actions runners version and update the self-hosted runners - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13421) Python DeferredDataFrame.xs differs from Pandas - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-13271) error-prone UnusedVariable check raises false positives for StateId and TimerId usages - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11151) Add ToString support - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4965) Beam Dependency Update Request: org.apache.httpcomponents:httpclient 4.5.6 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-12133) Tracking: DataFrame API future enhancements - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-12148) Align Spark runner jackson dependency version with Beam's - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-11806) KafkaIO - Partition Recognition in WriteRecords - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13275) Beam Dependency Update Request: selenium - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7668) Add ability to query a pipeline from a gRPC JobService - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7083) Remove non-functional pipeline option for default Java environment URL - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9040) Add Spark Structured Streaming to Nexmark PostCommit run - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13947) Implement Series.str.split() and Series.str.rsplit() for DataFrame API - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-12133) Tracking: DataFrame API future enhancements - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13814) Run errorprone with Java 11 (required in 2.11.0 and newer) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12151) Bump Parquet dependency version to 1.12.0 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13891) Bump spark3 dependencies to 3.2.1 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12060) beam_PostCommit_Go_VR_Flink and beam_PostCommit_Go_VR_Spark failing since Mar 23, 2021 6:00:00 AM - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12314) Run Direct and Dataflow ValidatesRunner tests compiled with JDK8 and run with JDK17 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work stopped] (BEAM-13767) Use gradle configuration avoidance api when declaring tasks - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12238) StateBackedIterable is not Serializable - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-4963) Beam Dependency Update Request: org.apache.httpcomponents - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-11361) Allow dynamic splitting of dataframe IOs. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12009) Implement Calc splitting. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8773) Beam Dependency Update Request: org.apache.httpcomponents:httpcore-nio - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12701) Converting two deferred dataframes to csv in the same pipeline causes a PCollection label collision - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-11950) Support arithmetic operations between DeferredScalars - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12563) Implement swaplevel for Series and DataFrame - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12180) UnbatchPandas (and to_pcollection) do not set type hint for unbatched DataFrames - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 1 replies.
- [jira] [Work stopped] (BEAM-4963) Beam Dependency Update Request: org.apache.httpcomponents - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12627) Spark Structured Streaming runner: Migrate spark Encoders Beam wrappers to spark 3 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-12425) DataFrame API: Consider adding support for sparse data - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12313) Publish Java 17 SDK Harness docker image - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11972) ParquetIO should close all opened channels/readers - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13410) Add integration test for S3FileSystem - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 2 replies.
- [jira] [Updated] (BEAM-9561) Run pandas tests with Beam Dataframe API - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12566) Implement set_axis for DataFrame and Series - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12142) Reduce overhead of MetricsEnvironment - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-14542) TPC-DS: Add user documentation on website - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-12198) Support Dataflow update when schemas are used - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12634) JmsIO autoscaling ability - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-10554) Add builder unit tests for external transforms creation - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8772) Beam Dependency Update Request: org.apache.httpcomponents:httpcore - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12770) Java Quickstart: Gradle/Dataflow runner command is incorrect - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12564) Implement Series.hasnans - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12073) Support overloaded UDF definitions. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12942) Dataflow runner specialization of PubsubIO should validate messages - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12242) An incorrect model pipeline is generated when PubSub is followed by a x-lang transform for streaming - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12884) Support Gradle build for all runners. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14507) Add support for pandas 1.5 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12441) DataFrame API: Add distributed implementation of Series.value_counts(bins) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13280) Beam Dependency Update Request: org.immutables:value - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13936) Beam Dependency Update Request: org.mock-server:mockserver-client-java - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11676) Add an EnumerationType for portable schema definition - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-12478) start-build-env.sh fails - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11712) Run TPC-DS with BeamSQL and Spark runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-11129) Populate display data in Beam protos. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:32:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8324) Pre/Postcommit Dataflow IT tests fail: _create_function() takes from 2 to 6 positional arguments but 7 were given - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-7424) Retry HTTP 429 errors from GCS w/ exponential backoff when reading data - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6984) Python 3.7 Support - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7667) report GCS throttling time to Dataflow autoscaler - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7436) Use Beam coder for Flink's encoded key instead of falling back to Kryo - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11357) Support for annotations for transforms in Go SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6983) Python 3.6 Support - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11318) AttributeError: 'SubscriberClient' object has no attribute 'transport' error while reading from input subscription with ReadFromPubSub - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11519) Adding PYPI_INSTALL_REQ role and SDK container support - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11092) Add support for GCP IO metrics - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11129) Populate display data in Beam protos. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10237) Clean up Experimental usage and come up with a graduation policy - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5663) Add tox suites for various Python 3 versions (3.5, 3.6, 3.7) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 15:33:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13630) Improve documentation for the Dataflow Service options - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/22 22:43:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12166) Beam Sql - Combine Accumulator return Map fails with class cast exception - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10458) Message limit for grpc message is set to default 4 MB - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-544) Add header/footer support to TextIO.Write - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12145) Normalize transform IDs generated by SDKs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12191) python DataflowRunner upload_graph feature doesn't reduce template file size - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7158) Operate the TensorFlow API with Apache Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-1946) Add IO module for restful api - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-610) Enable spark's checkpointing mechanism for driver-failure recovery in streaming - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-12203) Reduce thread context switches in BeamFnControlClient - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-573) TextIO.read() should support sharding - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7159) Add cluster monitoring BI to Apache Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10341) Support drain in SDF - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10334) Message limit for grpc message is set to default 4 MB - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10918) Row.withSchema.withFieldValues(Map) is broken - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11219) [Website revamp] Development of All about Apache Beam component - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11561) Fix issues with reloading Home page on social media component - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11301) [Website Revamp] Add hover interaction to Calendar - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-316) Support file scheme in TextIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12376) Support ReadLater() API in Java SDK Harness - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12141) Print sha256 and size when downloading artifacts via artifact retrieval service - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:35:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-12990) Implement per stream progress reporting - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-2307) BoundedReadFromUnboundedSource should be strongly discouraged - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13194) Call the stored procedure in dataflow pipeline - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10095) Add hyperlinks to the beam-overview page. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13977) [Website] Update Community landing page - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13194) Call the stored procedure in dataflow pipeline - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13683) Implement cross-language SQL in the Go SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13976) [Website] Update Home page - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11422) [Website revamp] UI design for Join Beam Community page - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14324) Exempt fn_test.go from ST1008 check - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13759) Document Python custom metrics in programming guide - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9278) Make HBase client a provided dependency in HBaseIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13631) SQS read IO requires deterministic coder for SQS message to work in batch mode mode. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9782) README on how to keep go katas up-to-date - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13759) Document Python custom metrics in programming guide - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-1783) Add Integration Tests for HBaseIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13978) [Website] Update Community/Join page - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11406) [Website revamp] Copy for the Contact Us page - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-11423) [Website revamp] Development of Twitter feed component - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-12990) Implement per stream progress reporting - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14346) ret2() function checks incorrect index for error case - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11381) [Website revamp] Update Beam programming guide navigation - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11424) [Website revamp] Development of Contribution Guide page - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:36:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-2706) Create JdbcIO.readAll() - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:37:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-14263) beam_PostCommit_Java_DataflowV2, testBigQueryStorageWrite30MProto failing consistently - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10474) Failure / flake in DisplayDataTest > test_value_provider_display_data - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3382) Validate count for trigger AfterCount - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3134) cannot write data to BigQuery with Dataflow - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13835) Support any-column-type to partition JdbcIO table reads - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4081) Review of schema metadata vs schema types - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9482) beam_PerformanceTests_Kafka_IO failing due to " provided port is already allocated" - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12484) JdbcIO date conversion is sensitive to OS - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7133) Spark job server Gradle task should pass along system properties - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13261) JDBC IO: expose max pool connections as a setting - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10586) Sunset Python 2 in Dataflow runner. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3508) Beam does not compile with Eclipse - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10570) Consider making a logical type for generic Python types in Rows. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [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 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14398) apache_beam/transforms/userstate_test.py::StatefulDoFnOnDirectRunnerTest::test_dynamic_timer_clear_then_set_timer is flakey - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13494) KinesisIO.read requires default rater limiter for low throughput shards - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13184) Support autosharding for JdbcIO writers - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 2 replies.
- [jira] [Work started] (BEAM-12790) Projection pushdown in JDBC SchemaIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9509) Subprocess job server treats missing local file as remote URL - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3001) Allow disabling validation on BigtableIO.write() - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10513) Failure / flake: Repeated deadlock in JdbcIOTest > testCustomFluentBackOffConfiguration - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10784) Spark portable streaming: failing window-related tests - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10109) Fix context classloader in Spark portable runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12396) beam_PostCommit_XVR_Direct failed (flaked?) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3031) Go presubmit failed - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-12484) JdbcIO date conversion is sensitive to OS - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7442) Bounded Reads for Flink Runner fails with OOM - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-10006) PipelineOptions can pick up definitions from unrelated tests - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12609) Projection pushdown in SchemaIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-2958) Expose a top level user agent PipelineOption which can be communicated to external services - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10151) Document how to run a Java (xlang) pipeline on the Spark portable runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14432) JdbcIO: WriteWithResult not works as expected when maps ResultSet - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3195) Failure in Java postcommit & nightly - WriteFiles - "When using windowed writes, must specify number of output shards explicitly [WriteFiles]" - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7512) Replace usage of assertEquals with assertEqual in synthetic_pipeline_test.py - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-12515) Python PreCommit flaking in PipelineOptionsTest.test_display_data - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3881) Failure reading backlog in KinesisIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13609) Not all variable length types works properly for Oracle DB - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10006) PipelineOptions can pick up definitions from unrelated tests - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12790) Projection pushdown in JDBC SchemaIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14417) JdbcIO.Write needs exception handling tests - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13480) apache_beam.io.gcp.pubsub_integration_test.PubSubIntegrationTest.test_streaming_data_only is flaky - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3726) Kinesis Reader: java.lang.IllegalArgumentException: Attempting to move backwards - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-2956) DataflowRunner incorrectly reports the user agent for the Dataflow distribution - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12515) Python PreCommit flaking in PipelineOptionsTest.test_display_data - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10591) apache_beam.io.external.xlang_jdbcio_it_test.CrossLanguageJdbcIOTest is flaky - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13116) Support AWS credentials provider for AWS IOs (SDK v1) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3404) Update KinesisIO to use AWS SDK 1.11.255 and KCL 1.8.8 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-2393) BoundedSource is not fault-tolerant in FlinkRunner Streaming mode - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3087) Extend lock scope in Flink UnboundedSourceWrapper - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3819) Add withRequestRecordsLimit option to KinesisIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6992) Implement KinesisIO.Write using AWS SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7589) Kinesis IO.write throws LimitExceededException - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4348) Enforce ErrorProne analysis in the kinesis IO project - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9764) :sdks:java:container:generateThirdPartyLicenses failing - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4305) Enforce ErrorProne analysis in job-management project - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7240) Kinesis IO Watermark Computation Improvements - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7555) Migrate AWS IOs to AWS SDK for Java 2 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9702) Update Java KinesisIO.Read to support AWS SDK v2 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-6353) TFRecordIOTest is failing - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3228) KinesisMockReadTest is flaky - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7080) Remove unused class KinesisUploader from KinesisIO tests - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6608) Flink Runner prepares to-be-staged file too late - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8958) Use default credentials provider with BasicKinesisProvider - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4335) Enforce ErrorProne analysis in the amazon-web-services IO project - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12406) Progressing watermark for not available Kinesis stream - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5143) Stop showing dependencies which are not able to upgraded in the weekly report - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3405) Make maxNumRecords a long and validate if stream exists for KinesisIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3291) Add Kinesis Write transform - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3549) Move KinesisIO into the amazon-web-services module - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-2752) KinesisIO throws ConcurrentModificationException on checkpoint - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3373) Add serviceEndpoint parameter to KinesisIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3438) KinesisReaderIT fails due to a missing PipelineOptions property - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6567) Extend "Data insertion pipeline" with KinesisIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5109) Build nightly snapshot for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7638) Migrate KinesisIO to AWS SDK for Java 2 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9670) CoGroup transform should allow widening nullability in key schemas - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-2752) KinesisIO throws ConcurrentModificationException on checkpoint - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7894) Upgrade "com.amazonaws:amazon-kinesis-producer" to version 0.13.1 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:39:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4921) Beam Dependency Update Request: org.freemarker - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:40:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5242) runMobileGamingJavaDirect Aborted after 100 minutes - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:40:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-5241) runMobileGamingJavaDirect FAILED SocketException: Connection reset - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:40:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14317) Add an example JvmInitializer - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 09:40:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11640) Upgrade Linkage Checker to the latest 1.5.4 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11827) Gradle task :checkJavaLinkage is not working - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11382) [Website revamp] Landing pages for Languages page - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11638) KafkaIO and 3rd Party Libraries like Lenses.io - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14310) [Website] Bug in Playground Section at Home - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14300) Fix Java precommit failure - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14311) [Website] Home Page Improvements - Margins & Width - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11689) 401 on org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14298) Can't resolve org.pentaho:pentaho-aggdesigner-algorithm:5.1.5-jhyde - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13399) [Go SDK] Add automated expansion service start up feature - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:14:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13421) Python DeferredDataFrame.xs differs from Pandas - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10201) Enhance JsonToRow to add Deadletter Support - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10482) Schema-aware CoGroup transform doesn't work for any schema-aware POJO PCollection - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13390) API for specifying Python dependencies to the expansion service - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10377) Avoid expanding windows if not needed when processing elements in portable runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13960) SchemaTranslation.RowToProto does not properly handle all types - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:14:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13764) Adding schema-based payload builder to Java external transform - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/23 21:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13824) Migrate SnsIO.write to async implementation - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 04:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13206) Consolidate multiple levels of retries for AWS IOs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 04:20:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-413) Mean$CountSum tests for floating point equality - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 07:29:00 UTC, 3 replies.
- [jira] [Updated] (BEAM-417) AvroUtils$AvroMetadata exposes mutable syncMarker - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 07:29:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-412) DisplayData is marked Serializable but contains non-serializable field - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 07:29:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-420) Non-transient non-serializable instance field in WatermarkHold - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 07:29:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-763) BigQueryIOTest.testBuildSourceWithTableAndSqlDialect is not a valid RunnableOnService test - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 07:30:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12534) Support the XDG Base Directory Specification - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 07:30:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-617) Allow setting of StateBackend on FlinkPipelineOptions - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 07:30:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-755) beam-runners-core-java NeedsRunner tests not executing - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 07:30:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-628) Sink class org.apache.beam.runners.spark.aggregators.metrics.sink.GraphiteSink cannot be instantiated - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 07:30:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-619) UnboundedSourceWrapper snapshotting fails with IndexOutOfBoundsException - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/24 07:30:00 UTC, 0 replies.
- [jira] [Work stopped] (BEAM-13631) SQS read IO requires deterministic coder for SQS message to work in batch mode mode. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13335) DataFrame sources produce excessively large index - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10300) Test failure: JdbcIOTest.testCustomFluentBackOffConfiguration - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13245) Generalize S3FileSystem to support multiple URI schemes (AWS SDK v2) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13509) SQS reader uses shared client instance without coordinating shutdown (AWS SDK v2) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13466) [Playground] Sort categories and examples in alphabetical order - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13716) Clear before creating a new virtual environment in setupVirtualenv - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13244) Add STS Assume role credentials provider to AwsModule (AWS SDK v2) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12925) JdbcIo readRows does not handle null numerical values properly - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13588) beam_PostCommit_Java_PVR_Samza fails - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13602) Metrics reporting failed bigtable io - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11982) Java Spanner - Implement IO Request Count metrics - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13510) SQS reader retries on invalid (expired) receipt handles (AWS SDK v2) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-10136) Add cross-language wrapper for Java's JdbcIO Write - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13638) SqsMessage class have package private access for getters - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13276) Beam Dependency Update Request: com.fasterxml.jackson.core - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13236) Properly close kinesis producer on teardown - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13597) Java GHA Test (Wordcount on Dataflow) failing with ClassNotFoundException - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13697) Add SchemaFieldNumber annotation - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:37:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13273) Beam Dependency Update Request: google-cloud-recommendations-ai - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-11388) Implement missing ZETA_SQL Functions - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11389) Implement the LOGICAL_AND function for Beam SQL ZetaSQL dialect, as CombineFn. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13237) org.apache.beam.sdk.transforms.CombineTest$WindowingTests.testWindowedCombineGloballyAsSingletonView flaky on Dataflow Runner V2 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13274) Beam Dependency Update Request: pyparsing - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13274) Beam Dependency Update Request: pyparsing - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10074) Hash Functions in BeamSQL - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-12315) Support PARTITIONED BY on Beam's SQL DDL - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11533) PubSub support types: TIMESTAMP, DATE, TIME, DATETIME - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12533) DeferredSeries and DeferredDataFrame should have a useful repr - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11698) Implement BIT_XOR as CombineFn for Zetasql - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11388) Implement missing ZETA_SQL Functions - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12258) SQL postcommit timing out - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 10:38:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6810) [SQL] Plan optimizer eliminates aliasing in trivial projections - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 16:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7269) Remove StateSpec from hashCode of SimpleStateTag - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12662) AttributeError: 'FlinkUberJarJobServer' object has no attribute '_flink_version' - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-419) Non-transient non-serializable instance field in CombineFnUtil$NonSerializableBoundedKeyedCombineFn - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14386) [Flink] Support for scala 2.12 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-421) StateTags$CombiningValueStateTag inherits equals from super class but without incorporating its state - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14438) Beam slowness compared to flink-native - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12704) Fix primitive Read on portable Flink Runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-418) BitSetCoder transient field byteArrayCoder not set after deserialization - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14438) Beam slowness compared to flink-native - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 1 replies.
- [jira] [Work started] (BEAM-7827) MetricsTest$AttemptedMetricTests.testAllAttemptedMetrics is flaky on DirectRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7793) BagState drops Rows when triggered by timer - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12586) Python Direct Runner doesn't support both streaming & non streaming sources - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8092) Switch to java Optional in DirectRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:22:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8370) Project 'beam-runners-flink_2.11-job-server' not found in root project 'beam'. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 17:23:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-267) Enable Chekstyle check in Spark runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:44:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-157) CombineTest.testGlobalCombineWithDefaultsAndTriggers is broken - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:44:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-162) assert fail using session windows - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:44:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-257) fix ConcurrentModificationException in KafkaIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:44:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-182) SourceTestUtils.assertSplitAtFractionExhaustive should do a bounded number of trials - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:44:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-158) Add support for bounded sources in streaming mode - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:44:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-707) Migrate PubsubIO/PubsubUnboundedSource/PubsubUnboundedSink to use AutoValue to reduce boilerplate - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:44:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-236) Implement Windowing in batch execution - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:44:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13924) Coder information lost in Kafka Read - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:45:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12193) WatchKafkaTopicPartitionDoFn reports user counter to indicate which TopicPartition has been emitted to downstream - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:45:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13852) KafkaIO.read.withDynamicRead() doesn't pick up new TopicPartitions - posted by "Anonymous (Jira)" <ji...@apache.org> on 2024/11/28 22:45:00 UTC, 0 replies.