issues  

Messages by Thread

• [jira] [Updated] (BEAM-316) Support file scheme in TextIO Anonymous (Jira)
• [jira] [Updated] (BEAM-13630) Improve documentation for the Dataflow Service options Anonymous (Jira)
• [jira] [Updated] (BEAM-12400) Improve MongoDBIO for beam - add update capability Anonymous (Jira)
• [jira] [Updated] (BEAM-9561) Run pandas tests with Beam Dataframe API Anonymous (Jira)
• [jira] [Work started] (BEAM-13460) IsmSideInputReaderTest.verifyMap does not make some contains assertions Anonymous (Jira)
• [jira] [Updated] (BEAM-11807) SDK Worker with multithreading causes boto3 the KeyError(endpoint_resolver) Anonymous (Jira)
• [jira] [Updated] (BEAM-12451) BigQueryIO leaks gRPC channels Anonymous (Jira)
• [jira] [Updated] (BEAM-9040) Add Spark Structured Streaming to Nexmark PostCommit run Anonymous (Jira)
• [jira] [Updated] (BEAM-7083) Remove non-functional pipeline option for default Java environment URL Anonymous (Jira)
• [jira] [Work stopped] (BEAM-4963) Beam Dependency Update Request: org.apache.httpcomponents Anonymous (Jira)
• [jira] [Updated] (BEAM-6984) Python 3.7 Support Anonymous (Jira)
• [jira] [Work started] (BEAM-11361) Allow dynamic splitting of dataframe IOs. Anonymous (Jira)
• [jira] [Updated] (BEAM-11318) AttributeError: 'SubscriberClient' object has no attribute 'transport' error while reading from input subscription with ReadFromPubSub Anonymous (Jira)
• [jira] [Updated] (BEAM-11129) Populate display data in Beam protos. Anonymous (Jira)
• [jira] [Updated] (BEAM-12142) Reduce overhead of MetricsEnvironment Anonymous (Jira)
  • [jira] [Updated] (BEAM-12142) Reduce overhead of MetricsEnvironment Anonymous (Jira)
• [jira] [Updated] (BEAM-12313) Publish Java 17 SDK Harness docker image Anonymous (Jira)
• [jira] [Updated] (BEAM-12194) Support user-defined aggregate functions in ZetaSQL. Anonymous (Jira)
• [jira] [Updated] (BEAM-12884) Support Gradle build for all runners. Anonymous (Jira)
• [jira] [Updated] (BEAM-13271) error-prone UnusedVariable check raises false positives for StateId and TimerId usages Anonymous (Jira)
• [jira] [Updated] (BEAM-13762) Get the latest GitHub Actions runners version and update the self-hosted runners Anonymous (Jira)
• [jira] [Work started] (BEAM-13891) Bump spark3 dependencies to 3.2.1 Anonymous (Jira)
• [jira] [Work started] (BEAM-13814) Run errorprone with Java 11 (required in 2.11.0 and newer) Anonymous (Jira)
• [jira] [Updated] (BEAM-6983) Python 3.6 Support Anonymous (Jira)
• [jira] [Updated] (BEAM-11357) Support for annotations for transforms in Go SDK Anonymous (Jira)
• [jira] [Updated] (BEAM-11519) Adding PYPI_INSTALL_REQ role and SDK container support Anonymous (Jira)
• [jira] [Updated] (BEAM-7436) Use Beam coder for Flink's encoded key instead of falling back to Kryo Anonymous (Jira)
• [jira] [Updated] (BEAM-10237) Clean up Experimental usage and come up with a graduation policy Anonymous (Jira)
• [jira] [Updated] (BEAM-5663) Add tox suites for various Python 3 versions (3.5, 3.6, 3.7) Anonymous (Jira)
• [jira] [Updated] (BEAM-11092) Add support for GCP IO metrics Anonymous (Jira)
• [jira] [Updated] (BEAM-7424) Retry HTTP 429 errors from GCS w/ exponential backoff when reading data Anonymous (Jira)
• [jira] [Updated] (BEAM-13936) Beam Dependency Update Request: org.mock-server:mockserver-client-java Anonymous (Jira)
• [jira] [Updated] (BEAM-14051) There should be single source of truth for the project version Anonymous (Jira)
• [jira] [Updated] (BEAM-12627) Spark Structured Streaming runner: Migrate spark Encoders Beam wrappers to spark 3 Anonymous (Jira)
• [jira] [Updated] (BEAM-4965) Beam Dependency Update Request: org.apache.httpcomponents:httpclient 4.5.6 Anonymous (Jira)
  • [jira] [Updated] (BEAM-4965) Beam Dependency Update Request: org.apache.httpcomponents:httpclient 4.5.6 Anonymous (Jira)
• [jira] [Updated] (BEAM-13043) Implementation encoding position sdk-go Anonymous (Jira)
• [jira] [Updated] (BEAM-12770) Java Quickstart: Gradle/Dataflow runner command is incorrect Anonymous (Jira)
• [jira] [Updated] (BEAM-13727) Beam Dependency Update Request: org.testcontainers:kafka Anonymous (Jira)
• [jira] [Updated] (BEAM-11950) Support arithmetic operations between DeferredScalars Anonymous (Jira)
• [jira] [Updated] (BEAM-13402) Pub/Sub Lite commits can take 10s of hours without completing Anonymous (Jira)
• [jira] [Updated] (BEAM-11676) Add an EnumerationType for portable schema definition Anonymous (Jira)
• [jira] [Updated] (BEAM-12866) TestStream should only emit bytes Anonymous (Jira)
• [jira] [Updated] (BEAM-13729) Beam Dependency Update Request: org.testcontainers:postgresql Anonymous (Jira)
• [jira] [Updated] (BEAM-12060) beam_PostCommit_Go_VR_Flink and beam_PostCommit_Go_VR_Spark failing since Mar 23, 2021 6:00:00 AM Anonymous (Jira)
• [jira] [Updated] (BEAM-13275) Beam Dependency Update Request: selenium Anonymous (Jira)
• [jira] [Updated] (BEAM-12242) An incorrect model pipeline is generated when PubSub is followed by a x-lang transform for streaming Anonymous (Jira)
• [jira] [Updated] (BEAM-12238) StateBackedIterable is not Serializable Anonymous (Jira)
• [jira] [Work started] (BEAM-14507) Add support for pandas 1.5 Anonymous (Jira)
• [jira] [Updated] (BEAM-12441) DataFrame API: Add distributed implementation of Series.value_counts(bins) Anonymous (Jira)
• [jira] [Work started] (BEAM-4963) Beam Dependency Update Request: org.apache.httpcomponents Anonymous (Jira)
• [jira] [Updated] (BEAM-12566) Implement set_axis for DataFrame and Series Anonymous (Jira)
• [jira] [Updated] (BEAM-13728) Beam Dependency Update Request: org.testcontainers:mysql Anonymous (Jira)
• [jira] [Updated] (BEAM-6993) Default to cleaning staged artifacts after running portable pipeline Anonymous (Jira)
• [jira] [Updated] (BEAM-13947) Implement Series.str.split() and Series.str.rsplit() for DataFrame API Anonymous (Jira)
• [jira] [Updated] (BEAM-7668) Add ability to query a pipeline from a gRPC JobService Anonymous (Jira)
• [jira] [Updated] (BEAM-8773) Beam Dependency Update Request: org.apache.httpcomponents:httpcore-nio Anonymous (Jira)
• [jira] [Updated] (BEAM-13280) Beam Dependency Update Request: org.immutables:value Anonymous (Jira)
• [jira] [Work started] (BEAM-12478) start-build-env.sh fails Anonymous (Jira)
• [jira] [Work started] (BEAM-13280) Beam Dependency Update Request: org.immutables:value Anonymous (Jira)
• [jira] [Work started] (BEAM-10526) Use grpc test rules for graceful server/channel shutdown in tests Anonymous (Jira)
• [jira] [Updated] (BEAM-11712) Run TPC-DS with BeamSQL and Spark runner Anonymous (Jira)
• [jira] [Updated] (BEAM-8772) Beam Dependency Update Request: org.apache.httpcomponents:httpcore Anonymous (Jira)
• [jira] [Updated] (BEAM-11151) Add ToString support Anonymous (Jira)
• [jira] [Work started] (BEAM-12425) DataFrame API: Consider adding support for sparse data Anonymous (Jira)
• [jira] [Updated] (BEAM-14542) TPC-DS: Add user documentation on website Anonymous (Jira)
  • [jira] [Updated] (BEAM-14542) TPC-DS: Add user documentation on website Anonymous (Jira)
• [jira] [Updated] (BEAM-12314) Run Direct and Dataflow ValidatesRunner tests compiled with JDK8 and run with JDK17 Anonymous (Jira)
• [jira] [Updated] (BEAM-8235) Python Post Commit 3.6 issue Anonymous (Jira)
• [jira] [Work started] (BEAM-11129) Populate display data in Beam protos. Anonymous (Jira)
• [jira] [Work started] (BEAM-10554) Add builder unit tests for external transforms creation Anonymous (Jira)
• [jira] [Updated] (BEAM-10894) Implement dataframe IO methods. Anonymous (Jira)
• [jira] [Updated] (BEAM-12151) Bump Parquet dependency version to 1.12.0 Anonymous (Jira)
• [jira] [Updated] (BEAM-12073) Support overloaded UDF definitions. Anonymous (Jira)
• [jira] [Updated] (BEAM-12133) Tracking: DataFrame API future enhancements Anonymous (Jira)
  • [jira] [Updated] (BEAM-12133) Tracking: DataFrame API future enhancements Anonymous (Jira)
• [jira] [Work stopped] (BEAM-13767) Use gradle configuration avoidance api when declaring tasks Anonymous (Jira)
• [jira] [Work started] (BEAM-10664) Enable kinesis read on localstack in python cross-language it test Anonymous (Jira)
• [jira] [Work started] (BEAM-8637) Beam Dependency Update Request: org.apache.httpcomponents:httpclient Anonymous (Jira)
• [jira] [Updated] (BEAM-12564) Implement Series.hasnans Anonymous (Jira)
• [jira] [Updated] (BEAM-12204) Portable Java caches entirety of iterable side inputs. Anonymous (Jira)
• [jira] [Updated] (BEAM-9502) SchemaCoder is not update compatible Anonymous (Jira)
• [jira] [Updated] (BEAM-12942) Dataflow runner specialization of PubsubIO should validate messages Anonymous (Jira)
• [jira] [Updated] (BEAM-12634) JmsIO autoscaling ability Anonymous (Jira)
• [jira] [Updated] (BEAM-12563) Implement swaplevel for Series and DataFrame Anonymous (Jira)
• [jira] [Updated] (BEAM-12380) Go SDK Kafka IO Transform implemented via XLang Anonymous (Jira)
• [jira] [Updated] (BEAM-12016) Implement add_suffix, add_prefix for DataFrame and Series Anonymous (Jira)
• [jira] [Updated] (BEAM-12009) Implement Calc splitting. Anonymous (Jira)
• [jira] [Updated] (BEAM-12180) UnbatchPandas (and to_pcollection) do not set type hint for unbatched DataFrames Anonymous (Jira)
  • [jira] [Updated] (BEAM-12180) UnbatchPandas (and to_pcollection) do not set type hint for unbatched DataFrames Anonymous (Jira)
• [jira] [Updated] (BEAM-11972) ParquetIO should close all opened channels/readers Anonymous (Jira)
• [jira] [Work started] (BEAM-12133) Tracking: DataFrame API future enhancements Anonymous (Jira)
• [jira] [Updated] (BEAM-13410) Add integration test for S3FileSystem Anonymous (Jira)
  • [jira] [Updated] (BEAM-13410) Add integration test for S3FileSystem Anonymous (Jira)
  • [jira] [Updated] (BEAM-13410) Add integration test for S3FileSystem Anonymous (Jira)
• [jira] [Work started] (BEAM-7318) WriteFilesTest.testEmptyWrite breaks on Flink runner Anonymous (Jira)
• [jira] [Updated] (BEAM-7321) TestStreamTest breaks on Flink runner Anonymous (Jira)
• [jira] [Updated] (BEAM-12793) beam_PostRelease_NightlySnapshot failed Anonymous (Jira)
• [jira] [Updated] (BEAM-14207) Investigate releasing models in inference base class Anonymous (Jira)
• [jira] [Updated] (BEAM-13765) Missing IterableAssert.inOnlyPane and SingletonAssert.inWindow methods Anonymous (Jira)
  • [jira] [Updated] (BEAM-13765) Missing IterableAssert.inOnlyPane and SingletonAssert.inWindow methods Anonymous (Jira)
• [jira] [Updated] (BEAM-7323) PartitionTest.testDroppedPartition breaks on Flink runner Anonymous (Jira)
• [jira] [Work started] (BEAM-7319) Multiple NeedsRunner tests break with Flink 'Cannot union streams of different types' Anonymous (Jira)
• [jira] [Work started] (BEAM-9564) Remove insecure ssl options from MongoDBIO Anonymous (Jira)
• [jira] [Updated] (BEAM-8879) IOError flake in PortableRunnerTest Anonymous (Jira)
• [jira] [Updated] (BEAM-9564) Remove insecure ssl options from MongoDBIO Anonymous (Jira)
• [jira] [Updated] (BEAM-9647) No MQTT connection possible because clientId is too long Anonymous (Jira)
• [jira] [Updated] (BEAM-7237) Run NeedsRunner test category with Spark Runner Anonymous (Jira)
• [jira] [Updated] (BEAM-6523) Support transcoding for Flatten in Flink Runner Anonymous (Jira)
  • [jira] [Updated] (BEAM-6523) Support transcoding for Flatten in Flink Runner Anonymous (Jira)
  • [jira] [Updated] (BEAM-6523) Support transcoding for Flatten in Flink Runner Anonymous (Jira)
• [jira] [Updated] (BEAM-9652) BigQueryIO MultiPartitionsWriteTables fails with ClassCastException: java.lang.Object cannot be cast to org.apache.beam.sdk.values.KV Anonymous (Jira)
• [jira] [Work stopped] (BEAM-10556) Eliminate rawtype errors from Beam Java Anonymous (Jira)
• [jira] [Updated] (BEAM-8878) Possible flake in PortableRunnerTest.test_error_traceback_includes_user_code Anonymous (Jira)
• [jira] [Updated] (BEAM-12075) GroupByKey doesn't seem to work with FixedWindows in DirectRunner Anonymous (Jira)
• [jira] [Updated] (BEAM-14445) Add automation for managing GitHub issues Anonymous (Jira)
• [jira] [Updated] (BEAM-14212) Custom Coders are ignored sometimes Anonymous (Jira)
• [jira] [Updated] (BEAM-8819) AvroCoder for SpecificRecords is not serialized correctly since 2.13.0 Anonymous (Jira)
• [jira] [Updated] (BEAM-12674) SqlTransform IllegalArgumentException: key already present: SchemaCoder Anonymous (Jira)
• [jira] [Updated] (BEAM-13564) [Playground] Add getting of preparation output for the sent example Anonymous (Jira)
• [jira] [Updated] (BEAM-11968) Bump com.google.cloud:libraries-bom to 19.0.0 Anonymous (Jira)
• [jira] [Updated] (BEAM-12274) Create and use an extension of JavaTypeFactoryImpl. Anonymous (Jira)
  • [jira] [Updated] (BEAM-12274) Create and use an extension of JavaTypeFactoryImpl. Anonymous (Jira)
  • [jira] [Updated] (BEAM-12274) Create and use an extension of JavaTypeFactoryImpl. Anonymous (Jira)
• [jira] [Work started] (BEAM-13970) RunInference V1 Anonymous (Jira)
• [jira] [Updated] (BEAM-9187) org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactoryTest.loadBalancesBundles is flaky Anonymous (Jira)
• [jira] [Updated] (BEAM-9571) Add withMongoClientProvider to MongoDbIO Anonymous (Jira)
• [jira] [Updated] (BEAM-10858) beam.io.jdbc not working on Google Cloud Dataflow Anonymous (Jira)
• [jira] [Updated] (BEAM-11039) Resolve conflicts between TFMA and Facets imports Anonymous (Jira)
• [jira] [Updated] (BEAM-10956) PipelineInstrumentTest is flaky Anonymous (Jira)
• [jira] [Updated] (BEAM-11025) PCollectionVisualizationTest.test_dynamic_plotting_return_handle failing in precommit Anonymous (Jira)
• [jira] [Updated] (BEAM-10775) Create precomimt job for typescript tests Anonymous (Jira)
• [jira] [Updated] (BEAM-9333) DataCatalogPipelineOptions is not registered Anonymous (Jira)
• [jira] [Updated] (BEAM-10103) Add WasbIO / WasbFileSystem (Azure Blob Storage) Anonymous (Jira)
• [jira] [Work started] (BEAM-13298) Add "withResults()" for KafkaIO.write Anonymous (Jira)
• [jira] [Work started] (BEAM-10103) Add WasbIO / WasbFileSystem (Azure Blob Storage) Anonymous (Jira)
• [jira] [Updated] (BEAM-11439) Fix Snowflake streaming docs Anonymous (Jira)
• [jira] [Updated] (BEAM-9893) Add SnowflakeIO to Java SDK Anonymous (Jira)
• [jira] [Updated] (BEAM-9795) Support custom avro DatumWriters when writing to BigQuery Anonymous (Jira)
• [jira] [Updated] (BEAM-10030) Add CSVIO for Java SDK Anonymous (Jira)
• [jira] [Updated] (BEAM-9410) Make JdbcIO readAll consistent with other Beam readAll methods Anonymous (Jira)
  • [jira] [Updated] (BEAM-9410) Make JdbcIO readAll consistent with other Beam readAll methods Anonymous (Jira)
• [jira] [Updated] (BEAM-14345) Hadoop version tests are failing for Spark 3 Anonymous (Jira)
• [jira] [Updated] (BEAM-4228) The FlinkRunner shouldn't require all of the values for a key to fit in memory Anonymous (Jira)
• [jira] [Updated] (BEAM-12241) Update bytebuddy to version 1.11.0 Anonymous (Jira)
• [jira] [Updated] (BEAM-12875) File systems are not registered when ArtifactRetrievalService is created by Spark runner Anonymous (Jira)
• [jira] [Work started] (BEAM-8103) Stop job service when pipeline execution finishes Anonymous (Jira)
• [jira] [Updated] (BEAM-14334) Avoid using forkEvery in Spark runner tests Anonymous (Jira)
• [jira] [Updated] (BEAM-14380) Forward pipeline metric results in Beam package. Anonymous (Jira)
• [jira] [Updated] (BEAM-14335) Spotless sources for Spark runner Anonymous (Jira)
• [jira] [Updated] (BEAM-13504) Remove provided/compileOnly deps not intended for external use Anonymous (Jira)
  • [jira] [Updated] (BEAM-13504) Remove provided/compileOnly deps not intended for external use Anonymous (Jira)
• [jira] [Work started] (BEAM-12526) Configure Automatic Updates via Dependabot Anonymous (Jira)
• [jira] [Updated] (BEAM-4552) Use Spark AccumulatorsV2 API Anonymous (Jira)
• [jira] [Updated] (BEAM-9996) Flink should not shadow FnApiRunnerTest.test_metrics Anonymous (Jira)
• [jira] [Updated] (BEAM-12526) Configure Automatic Updates via Dependabot Anonymous (Jira)
• [jira] [Updated] (BEAM-10106) Script the deployment of artifacts to pypi Anonymous (Jira)
• [jira] [Updated] (BEAM-12712) Java Portable VR PostCommits failing - ParDoTest TimerTests.testEventTimeTimerLoop Anonymous (Jira)
• [jira] [Updated] (BEAM-8115) Overwrite portable Flink application jar pipeline options at runtime Anonymous (Jira)
• [jira] [Updated] (BEAM-10294) Beam metrics are unreadable in Spark history server Anonymous (Jira)
  • [jira] [Updated] (BEAM-10294) Beam metrics are unreadable in Spark history server Anonymous (Jira)
• [jira] [Updated] (BEAM-10668) Replace toLowerCase().equals() with equalsIgnoreCase Anonymous (Jira)
• [jira] [Updated] (BEAM-10676) Timers use the input timestamp as the timer output timestamp which prevents watermark progress Anonymous (Jira)
• [jira] [Updated] (BEAM-12510) POM files with direct reference to maven repositories Anonymous (Jira)
  • [jira] [Updated] (BEAM-12510) POM files with direct reference to maven repositories Anonymous (Jira)
• [jira] [Updated] (BEAM-12882) pubsublite.SubscriptionPartitionLoaderTest.addedResults flaky Anonymous (Jira)
• [jira] [Updated] (BEAM-8968) portableWordCount test for Spark/Flink failing: jar not found Anonymous (Jira)
• [jira] [Work started] (BEAM-14051) There should be single source of truth for the project version Anonymous (Jira)
• [jira] [Work started] (BEAM-8899) Artifact retrieval failure logs at info level Anonymous (Jira)
• [jira] [Updated] (BEAM-12762) java.io.InvalidClassException with Spark 3.1.2 Anonymous (Jira)
• [jira] [Updated] (BEAM-9213) FlinkRunner ignores --flink_submit_uber_jar when master unset Anonymous (Jira)
• [jira] [Updated] (BEAM-11915) Python MondgoDB Connector: TypeError: '>=' not supported between instances of 'str' and 'ObjectId' Anonymous (Jira)
• [jira] [Work started] (BEAM-14088) Add ability to type PTransforms with input and output by making it a generic Anonymous (Jira)
• [jira] [Updated] (BEAM-12122) Python IO MongoDB: integer and string `_id` keys are not supported. Anonymous (Jira)
• [jira] [Updated] (BEAM-13794) Update documentation for Java 17 Anonymous (Jira)
• [jira] [Updated] (BEAM-11386) BigQuery streaming inserts should fail if SchemaUpdateOptions specified Anonymous (Jira)
• [jira] [Updated] (BEAM-13585) Python SDK S3 reader 2x - 10x performance opportunity Anonymous (Jira)
• [jira] [Updated] (BEAM-11208) BigQuery storage streams fail with QUOTA_EXCEEDED errors in split Anonymous (Jira)
  • [jira] [Updated] (BEAM-11208) BigQuery storage streams fail with QUOTA_EXCEEDED errors in split Anonymous (Jira)
  • [jira] [Updated] (BEAM-11208) BigQuery storage streams fail with QUOTA_EXCEEDED errors in split Anonymous (Jira)
• [jira] [Updated] (BEAM-10623) Add workflow to run Beam python tests on Linux/Windows/Mac platforms Anonymous (Jira)
• [jira] [Updated] (BEAM-10418) Support type hint annotations on CombineFn add_input() and extract_output() Anonymous (Jira)
• [jira] [Updated] (BEAM-10254) Python type hints: support typing.Pattern Anonymous (Jira)
• [jira] [Updated] (BEAM-13231) Globbing asterisk cannot be escaped in file reads. Anonymous (Jira)
• [jira] [Work started] (BEAM-14067) Beam Core IO: WriteFiles stuck Anonymous (Jira)
• [jira] [Updated] (BEAM-2256) mongodb sdk MongoDbIO.BoundedMongoDbSource.splitKeysToFilters incorrect Anonymous (Jira)
• [jira] [Updated] (BEAM-13573) Flink runner failing testOnWindowTimestampSkew Anonymous (Jira)
• [jira] [Updated] (BEAM-14323) Improve IDE integration for Spark cross version builds Anonymous (Jira)
• [jira] [Updated] (BEAM-12948) Add .withPipelineTempDirectory() Builder setting for file-based sinks Anonymous (Jira)
• [jira] [Updated] (BEAM-11429) User-friendly stage name for packed combiners Anonymous (Jira)
• [jira] [Updated] (BEAM-13760) Add randomness to default Dataflow job name in Python sdk Anonymous (Jira)
• [jira] [Updated] (BEAM-13572) Flink runner does not support PerKeyOrdering Anonymous (Jira)
• [jira] [Work started] (BEAM-7818) Create Presto I/O connector Anonymous (Jira)
• [jira] [Updated] (BEAM-11281) [Website revamp] Create Beam model design Anonymous (Jira)
  • [jira] [Updated] (BEAM-11281) [Website revamp] Create Beam model design Anonymous (Jira)
  • [jira] [Updated] (BEAM-11281) [Website revamp] Create Beam model design Anonymous (Jira)
• [jira] [Work started] (BEAM-7519) Improve work with SSL/TLS certificates in SDK IO, for Google Dataflow Anonymous (Jira)
• [jira] [Work started] (BEAM-7158) Operate the TensorFlow API with Apache Beam Anonymous (Jira)
• [jira] [Work started] (BEAM-7159) Add cluster monitoring BI to Apache Beam Anonymous (Jira)
• [jira] [Updated] (BEAM-11174) [Website revamp] Create guidelines for development Anonymous (Jira)

• Earlier messages
• Later messages