You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Updated] (BEAM-8371) Sunset Beam Python 2 support in new releases in 2020. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 09:23:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-1251) Python 3 Support - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 09:24:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6673) BigQueryIO.Read should automatically produce schemas - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7194) [SQL] EXCEPT DISTINCT behavior when right set contains a value is incorrect - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6872) Add hook for user-defined JVM initialization in workers - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6695) Latest transform for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7263) Deprecate set/getClientConfiguration in JdbcIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7305) Add first version of Hazelcast Jet Runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7144) Job re-scale fails on Flink >= 1.6 with certain values of maxParallelism - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6620) Do not relocate guava - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7023) WithKeys transform for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6769) BigQuery IO does not support bytes in Python 3 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7286) RedisIO support for INCRBY/DECRBY operations - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7348) Option to expire SDK worker environments - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7019) Reify transform for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7265) Update Spark runner to use spark version 2.4.3 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7442) Bounded Reads for Flink Runner fails with OOM - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7268) Make external sorter Hadoop free - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5148) Implement MongoDB IO for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5865) Auto sharding of streaming sinks in FlinkRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6693) ApproximateUnique transform for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6952) concatenated compressed files bug with python sdk - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-562) DoFn Reuse: Add new DoFn setup and teardown to python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6674) The JdbcIO source should produce schemas - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7043) Add DynamoDBIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56: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 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7021) ToString transform for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:56:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7742) BigQuery File Loads to work well with load job size limits - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7741) Add SetState in Python sdk - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7603) Support for ValueProvider-given GCS Location for WriteToBigQuery w File Loads - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6611) A Python Sink for BigQuery with File Loads in Streaming - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7465) Upgrade Jackson to version 2.9.9 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7907) Support customized container - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5191) Add support for writing to BigQuery clustered tables - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7045) Element counters in the Web UI graph representations for transforms for Python streaming jobs in Google Cloud Dataflow - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7927) Add ability to get the list of submitted jobs from gRPC JobService - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6480) Add AvroIO.sink for IndexedRecord (FileIO compatible) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57: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 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7667) report GCS throttling time to Dataflow autoscaler - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7833) warn user when --region flag is not explicitly set - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3645) Support multi-process execution on the FnApiRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7013) A new count distinct transform based on BigQuery compatible HyperLogLog++ implementation - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7866) Python MongoDB IO performance and correctness issues - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8368) [Python] libprotobuf-generated exception when importing apache_beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7443) BoundedSource->SDF needs a wrapper in Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7728) Support ParquetTable Source in SQL - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7060) Design Py3-compatible typehints annotation support in Beam 3. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7561) HdfsFileSystem is unable to match a directory - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7513) [SQL] Row Estimation for BigQueryTable - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5539) Beam Dependency Update Request: google-cloud-pubsub - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7880) Upgrade Jackson databind to version 2.9.9.3 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8111) SchemaCoder broken on DataflowRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7616) urlopen calls could get stuck without a timeout - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7600) Spark portable runner: reuse SDK harness - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7450) Support unbounded reads with HCatalogIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7761) Support transform_name_mapping option in python sdk - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6675) The JdbcIO sink should accept schemas - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7588) Python BigQuery sink should be able to handle 15TB load job quota - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7820) Add hot key detection to Dataflow Runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6114) SQL join selection should be done in planner, not in expansion to PTransform - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-5539) Beam Dependency Update Request: google-cloud-pubsub - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:57:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7980) External environment with containerized worker pool - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5967) ProtoCoder doesn't support DynamicMessage - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58: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 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7730) Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-8363) Nexmark regression in direct runner in streaming mode - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8394) Add withDataSourceConfiguration() method in JdbcIO.ReadRows class - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8303) Filesystems not properly registered using FileIO.write() on FlinkRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7962) Drop support for Flink 1.5 and 1.6 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8015) Get logs for SDK worker Docker containers - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8609) Add HllCount to Java transform catalog - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5428) Implement cross-bundle state caching. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8100) Add exception handling to Json transforms in Java SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8410) JdbcIO should support setConnectionInitSqls in its DataSource - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8363) Nexmark regression in direct runner in streaming mode - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7967) Execute portable Flink application jar - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8355) Make BooleanCoder a standard coder - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8161) Upgrade to joda time 2.10.3 to get updated TZDB - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58: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 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7986) Increase minimum grpcio required version - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8372) Allow submission of Flink UberJar directly to flink cluster. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8285) Upgrade to ZetaSQL 2019.09.1 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-5895) Beam Dependency Update Request: com.rabbitmq:amqp-client - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8088) PCollection boundedness should be tracked and propagated in python sdk - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8861) Disallow self-signed certificates by default in ElasticsearchIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7990) Add ability to read parquet files into PCollection - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7635) Migrate SnsIO to AWS SDK for Java 2 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6896) Beam Dependency Update Request: PyYAML - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8471) Flink native job submission for portable pipelines - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8312) Flink portable pipeline jars do not need to stage artifacts remotely - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8098) BigQueryIO needs documentation on how data types in BigQuery and in Beam SDK correspond - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7920) AvroTableProvider - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7966) Write portable Beam application jar - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8299) Upgrade Jackson to version 2.9.10 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8351) Support passing in arbitrary KV pairs to sdk worker via external environment config - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8014) Use OffsetRange as restriction for OffsetRestrictionTracker - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8306) improve estimation of data byte size reading from source in ElasticsearchIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7473) Update RestrictionTracker within Python to not be required to be thread safe - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8392) Update pyarrow version bounds - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8396) Default to LOOPBACK mode for local flink (spark, ...) runner. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:58:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7078) Beam Dependency Update Request: com.amazonaws:amazon-kinesis-client - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8352) Reading records in background may lead to OOM errors - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8822) Upgrade Hadoop dependencies to version 2.8 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8802) Timestamp combiner not respected across bundles in streaming mode. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7981) ParDo function wrapper doesn't support Iterable output types - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8989) Backwards incompatible change in ParDo.getSideInputs (caught by failure when running Apache Nemo quickstart) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8468) Add predicate/filter push-down capability to IO APIs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8480) Explicitly set restriction coder for bounded reader wrapper SDF. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8667) Data channel should to avoid unlimited buffering in Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8379) Cache Eviction for Interactive Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8515) Ensure that ValueProvider types have equals/hashCode implemented for comparison reasons - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8016) Render Beam Pipeline as DOT with Interactive Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7636) Migrate SqsIO to AWS SDK for Java 2 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8657) Not doing Combiner lifting for data-driven triggers - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8658) Optionally set artifact staging port in FlinkUberJarJobServer - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4776) Java PortableRunner should support metrics - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8254) (Java SDK) Add workerRegion and workerZone options - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7760) Interactive Beam Caching PCollections bound to user defined vars in notebook - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8814) --no_auth flag is boolean type and is misleading - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7917) Python datastore v1new fails on retry - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8835) Artifact retrieval fails with FlinkUberJarJobServer - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8663) BundleBasedRunner Stacked Bundles don't respect PaneInfo - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8365) Add project push-down capability to IO APIs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8803) Default behaviour for Python BQ Streaming inserts sink should be to retry always - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8146) SchemaCoder/RowCoder have no equals() function - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8343) Add means for IO APIs to support predicate and/or project push-down when running SQL pipelines - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8456) Add pipeline option to control truncate of BigQuery data processed by Beam SQL - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6756) Support lazy iterables in schemas - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8660) Override returned artifact staging endpoint - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8252) (Python SDK) Add worker_region and worker_zone options - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8470) Create a new Spark runner based on Spark Structured streaming framework - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8825) OOM when writing large numbers of 'narrow' rows - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8508) [SQL] Support predicate push-down without project push-down - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8427) [SQL] Add support for MongoDB source - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8513) RabbitMqIO: Allow reads from exchange-bound queue without declaring the exchange - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4777) Python PortableRunner should support metrics - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8579) Strip UTF-8 BOM bytes (if present) in TextSource. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8347) UnboundedRabbitMqReader can fail to advance watermark if no new data comes in - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8540) Fix CSVSink example in FileIO docs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6303) Add .parquet extension to files in ParquetIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 10:59:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9322) Python SDK ignores manually set PCollection tags - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9725) Perfomance regression in reshuffle - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9123) HadoopResourceId returns wrong directory name - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9445) Preoptimize causes error with environment setup - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7310) Confluent Schema Registry support in KafkaIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5192) Support Elasticsearch 7.x - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-9445) Preoptimize causes error with environment setup - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9041) SchemaCoder equals should not rely on from/toRowFunction equality - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8561) Add ThriftIO to Support IO for Thrift Files - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-9579) ApproximateQuantilesCombineFn uses deprecated '-' operator - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9258) [Python] PTransform that connects to Cloud DLP deidentification service - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9144) Beam's own Avro TimeConversion class in beam-sdk-java-core - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8399) Python HDFS implementation should support filenames of the format "hdfs://namenodehost/parent/child" - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9042) AvroUtils.schemaCoder(schema) produces a not serializable SchemaCoder - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00: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 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9305) Support ValueProvider for BigQuerySource query string - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-9322) Python SDK ignores manually set PCollection tags - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6857) Support dynamic timers - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8550) @RequiresTimeSortedInput DoFn annotation - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-7246) Add Google Spanner IO on Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8616) ParquetIO should have Hadoop dependencies as provided - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9579) ApproximateQuantilesCombineFn uses deprecated '-' operator - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8836) ExternalTransform is not providing a unique name - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8882) Allow Dataflow to automatically choose portability or not. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9228) _SDFBoundedSourceWrapper doesn't distribute data to multiple workers - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9248) [Python] PTransform that integrates Cloud Natural Language functionality - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9063) Migrate docker images to apache namespace. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8884) Python MongoDBIO TypeError when splitting - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3453) Allow usage of public Google PubSub topics in Python DirectRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9065) Spark runner accumulates metrics (incorrectly) between runs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9146) [Python] PTransform that integrates Video Intelligence functionality - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9277) Beam 2.19 raises exception in IPython notebook - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9503) SyntaxError in process worker startup - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9247) [Python] PTransform that integrates Cloud Vision functionality - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7246) Add Google Spanner IO on Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-1833) Restructure Python pipeline construction to better follow the Runner API - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9225) Flink uber jar job server hangs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8841) Add ability to perform BigQuery file loads using avro - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-1440) Create a BigQuery source (that implements iobase.BoundedSource) for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:00:03 UTC, 0 replies.
- [jira] [Updated] (BEAM-8946) Report collection size from MongoDBIOIT - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-8717) Beam Dependency Update Request: org.apache.commons:commons-lang3 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9035) BIP-1: Typed options for Row Schema and Fields - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8816) Load balance bundle processing w/ multiple SDK workers - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6008) Improve error reporting in Java/Python PortableRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8716) Beam Dependency Update Request: org.apache.commons:commons-csv - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9055) Unify the config names of Fn Data API across languages - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5495) PipelineResources algorithm is not working in most environments - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8935) Fail fast if sdk harness startup failed - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8949) Add Spanner IO Integration Test for Python - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8837) PCollectionVisualizationTest: possible bug - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8701) Beam Dependency Update Request: commons-io:commons-io - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8746) Allow the local job service to work from inside docker - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8993) [SQL] MongoDb should use predicate push-down - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8801) PubsubMessageToRow should not check useFlatSchema() in processElement - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8999) PGBKCVOperation does not respect timestamp combiners - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8696) Beam Dependency Update Request: com.google.protobuf:protobuf-java - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8749) Beam Dependency Update Request: com.datastax.cassandra:cassandra-driver-mapping - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8953) Extend ParquetIO.Read/ReadFiles.Builder to support Avro GenericData model - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8962) FlinkMetricContainer causes churn in the JobManager and lets the web frontend malfunction - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9218) Template staging broken on Beam 2.18.0 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8577) FileSystems may have not be initialized during ResourceId deserialization - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-8701) Beam Dependency Update Request: commons-io:commons-io - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5546) Beam Dependency Update Request: commons-codec:commons-codec - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8025) Cassandra IO classMethod test is flaky - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9050) Beam pickler doesn't pickle classes that have __module__ set to None. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8978) Report saved data size from HadoopFormatIOIT - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8623) Add additional message field to Provision API response for passing status endpoint - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8995) apache_beam.io.gcp.bigquery_read_it_test failing on Py3.5 PC with: TypeError: the JSON object must be str, not 'bytes' - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-2572) Implement an S3 filesystem for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8624) Implement FnService for status api in Dataflow runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-5546) Beam Dependency Update Request: commons-codec:commons-codec - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-8749) Beam Dependency Update Request: com.datastax.cassandra:cassandra-driver-mapping - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9053) Improve error message when unable to get the correct filesystem for specified path in Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7949) Add time-based cache threshold support in the data service of the Python SDK harness - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8139) Execute portable Spark application jar - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8296) Containerize the Spark job server - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8717) Beam Dependency Update Request: org.apache.commons:commons-lang3 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5690) Issue with GroupByKey in BeamSql using SparkRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8745) More fine-grained controls for the size of a BigQuery Load job - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9019) Improve Spark Encoders (wrappers of beam coders) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8844) [SQL] Create performance tests for BigQueryTable - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9023) Upgrade to ZetaSQL 2019.12.1 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8402) Create a class hierarchy to represent environments - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8582) Python SDK emits duplicate records for Default and AfterWatermark triggers - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8943) SDK harness servers don't shut down properly when SDK harness environment cleanup fails - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:01:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9430) Migrate from ProcessContext#updateWatermark to WatermarkEstimators - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9569) Coder inference should be disabled for Row types - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9916) Update IOs documentation links - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7304) Twister2 Beam runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8019) Support cross-language transforms for DataflowRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8494) Python 3.8 Support - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10220) Add support for implicit nulls in de/serializing JSON - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10135) Add cross-language wrapper for Java's JdbcIO Read - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9634) [Java] PTransform that integrates Cloud Natural Language functionality - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9136) Add LICENSES and NOTICES to docker images - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9279) Make HBase.ReadAll based on Reads instead of HBaseQuery - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9199) Make --region a required flag for DataflowRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9860) Make job_endpoint required for PortableRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9964) Setting workerCacheMb to make its way to the WindmillStateCache Constructor - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9147) [Java] PTransform that integrates Video Intelligence functionality - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10383) Update Snowflake JDBC dependency - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10343) Add dispositions for SnowflakeIO.write - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9044) BIP-1: Convert protobuf options to Schema options - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10136) Add cross-language wrapper for Java's JdbcIO Write - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9722) Add batch SnowflakeIO.Read to Java SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10335) Add STS Assume role credentials provider to AwsModule - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9723) [Java] PTransform that connects to Cloud DLP deidentification service - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9716) Alias zone to worker_zone and warn - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Work stopped] (BEAM-6696) GroupIntoBatches transform for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9468) Add Google Cloud Healthcare API IO Connectors - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9646) [Java] PTransform that integrates Cloud Vision functionality - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8603) Add Python SqlTransform MVP - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9529) Remove googledatastore package - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8596) Add SplunkIO transform to write messages to Splunk - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6696) GroupIntoBatches transform for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Work stopped] (BEAM-9704) BIP-1: Deprecate and remove FieldType metadata - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-1589) Add OnWindowExpiration method to Stateful DoFn - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9443) support direct_num_workers=0 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9704) BIP-1: Deprecate and remove FieldType metadata - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:02:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10885) Add Avro support to Kafka Table Provider - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10864) Update Snowflake JDBC dependency - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10524) Default decoder for ReadFromBigQuery does not support repeatable fields - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9850) Key should be available in @OnTimer methods (Spark Runner) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10644) Mark 2.24.0 as the last release supporting Python 2 in release notes and warnings. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10258) Support type hint annotations on PTransform's expand() - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9898) Add cross-language support to SnowflakeIO.Write - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10124) ContextualTextIO - An IO that is provides metadata about the line. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5757) Elasticsearch IO provide delete function - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4091) Typehint annotations don't work with @ptransform_fn annotation - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10603) Large Source Recording for Interarctive Runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10138) Add cross-language wrapper for Java's KinesisIO Write - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8543) Dataflow streaming timers are not strictly time ordered when set earlier mid-bundle - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03: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 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10549) Improve Runtime Type Checking Performance - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9999) Remove support for EOLed runners (Apex and Gearpump) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10417) Shared - Library to simplify managing shared large memory objects - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10197) Support type hints for frozenset - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10283) BigtableIO doesn't support ValueProvider in withKeyRange and withRowFilter methods - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9747) Deprecate RedisIO.readAll() and add RedisIO.readKeyPatterns() as a replacement - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11113) Default compressor change breaks dataflow python streaming job update compatibility - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10892) Add Proto support to Kafka Table Provider - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-2546) Add InfluxDbIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6928) Make Python SDK custom Sink the default Sink for BigQuery - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10670) Make non-portable Splittable DoFn the only option when executing Java "Read" transforms - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-10417) Shared - Library to simplify managing shared large memory objects - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10601) DICOM API Beam IO connector - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-10670) Make non-portable Splittable DoFn the only option when executing Java "Read" transforms - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-8543) Dataflow streaming timers are not strictly time ordered when set earlier mid-bundle - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10137) Add cross-language wrapper for Java's KinesisIO Read - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9896) Add streaming for SnowflakeIO.Write to Java SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9897) Add cross-language support to SnowflakeIO.Read - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9372) Drop support for Python 3.5 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9839) OnTimerContext should not create a new one when processing each element/timer in FnApiDoFnRunner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:03:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12071) DataFrame IO sinks do not correctly partition by window - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11941) Upgrade Flink runner to Flink version 1.12.2 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11173) Create Bigtable table provider - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11531) pandas 1.2.0 breaks Python precommit - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9278) Make HBase client a provided dependency in HBaseIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11146) Add option to disable copying between Flink runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10893) Add JSON suport to Kafka Table Provider - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11338) Beam schema for thrift data - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11444) MongoDB Python connector shows password in display_data - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11948) Drop support for Flink 1.8 and 1.9 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11373) Add write support to Bigtable Table for BeamSQL - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5504) PubsubAvroTable - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11850) Support DDL in SQL Transform - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11772) GCP BigQuery sink (file loads) uses runner determined sharding for unbounded data - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-9650) Add consistent slowly changing side inputs support - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11913) Add support for Hadoop configuration on ParquetIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-3736) Add SetUp() and TearDown() for CombineFns - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9650) Add consistent slowly changing side inputs support - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3736) Add SetUp() and TearDown() for CombineFns - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11929) DataframeTransfom, BatchRowsAsDataFrame do not preserve field order when schema created with beam.Row - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11628) Implement GroupBy.apply - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10641) Add Combiner Packing to Dataflow - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7093) Support Spark 3 in Spark runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11806) KafkaIO - Partition Recognition in WriteRecords - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11266) Cannot use Python MongoDB connector with Atlas MongoDB - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6103) Allow setting a HTTP write timeout to requests to BigQuery - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11065) Apache Beam Template to ingest from Apache Kafka to Google Pub/Sub - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8569) Support Hadoop 3 on Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7637) Migrate S3FileSystem to AWS SDK for Java 2 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8106) Publish Java 11 SDK Harness docker image - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11719) Enforce deterministic coding for GroupByKey and Stateful DoFns - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:04:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10324) Create ApproximateDistinct using HLL Impl - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12024) Add well-documented DataFrame example pipelines - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11482) Thrift support for KafkaTableProvider - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8344) Refactor ParquetTableProvider - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11533) PubSub support types: TIMESTAMP, DATE, TIME, DATETIME - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11665) Create Beam GCP BOM - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11408) GCP BigQuery sink (streaming inserts) uses runner determined sharding - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12212) Add sdkContainerImage flag to (eventually) replace workerHarnessContainerImage - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11526) Add Beam schema support to ParquetIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11855) ib.collect should accept DeferredDataFrame instances - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11538) Add a Deque Encoder - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11018) Use metric for Python BigQuery streaming insert API latency logging - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-10029) Add Spanner IO Performance Tests for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-11205) Beam Dependency Update Request: com.google.cloud:libraries-bom - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10029) Add Spanner IO Performance Tests for Python SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11329) HDFS not deduplicating identical configuration paths. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-2530) Make Beam compatible with next Java LTS version (Java 11) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10074) Hash Functions in BeamSQL - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11643) SpannerIO does not support using BigDecimal for Numeric fields - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11571) Support Conversion to GenericRecords in Convert.to transform - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11624) Hash functions in ZetaSQL - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11460) Support reading Parquet files with unknown schema - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11457) Enable skip key-value clone for HadoopFormatIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11677) Expose commit_offset_in_finalize and timestamp_policy to ReadFromKafka - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8202) Support ParquetTable Writer - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11697) Upgrade Flink runner to Flink versions 1.12.1 and 1.11.3 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11032) Use metric for Java BigQuery streaming insert API latency logging - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11205) Beam Dependency Update Request: com.google.cloud:libraries-bom - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11277) WriteToBigQuery with batch file loads does not respect schema update options when there are multiple load jobs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11762) Upgrade Beam base image to use Tensorflow 2.4.1 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11799) S3 options does not provided to boto3 client while using FlinkRunner and Beam worker pool container - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11527) Support user configurable Hadoop Configuration flags for ParquetIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:05:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12277) Add flink 1.13 build target - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12514) BigQueryIO - ReadFromBigQuery can not get table reference from RuntimeValueProvider - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-2085) Transforms could give hints to runners on resource requirements - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12281) Drop support for Flink 1.10 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12198) Support Dataflow update when schemas are used - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12216) Remove MqttIO.create() with clientId constructor as it was deprecated since Beam 2.13.0 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12260) Java - Backport FirestoreIO connector's ramp-up to DatastoreIO connector - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7372) Clean up Python 2 codepaths once Beam no longer supports Python 2. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11227) Upgrade beam-vendor-grpc-1_26_0-0.3 to fix CVE-2020-27216 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12028) DataFrame API error messages should be more helpful - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-7819) PubsubMessage message parsing is lacking non-attribute fields - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12362) BigQuery sink swallows HttpErrors when performing streaming inserts preventing retries - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12214) Remove RedisIO.readAll() as it was deprecated since Beam 2.13.0 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12217) MongoDbIO: remove Read.withFilter() and Read.withProjection() - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12339) Support CREATE FUNCTION statement in Calcite dialect. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-2085) Transforms could give hints to runners on resource requirements - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12361) Reshuffle.withNumBuckets creates (N*2)-1 buckets - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9487) GBKs on unbounded pcolls with global windows and no triggers should fail - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12220) ZipFiles.zipDirectory leaks native JVM memory - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12272) Python - Backport FirestoreIO connector's ramp-up to DatastoreIO connector - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:06:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12511) JdbcIO.Write.withResults work without statement - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12479) UnsupportedOperationException when reading from BigQuery tables and converting TableRows to Beam Rows - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12759) ORDER BY column not in SELECT crashes - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-12474) Configure PubsubIO with dead-letter topic - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-10917) Implement a BigQuery bounded source using the BigQuery storage API - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10955) testSavepointRestoreLegacy flake: Could not find Flink job (FlinkJobNotFoundException) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12781) SDFBoundedSourceReader behaves much slower compared with the original behavior of BoundedSource - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12715) SnowflakeWrite fails in batch mode when the number of shards is > 1000 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12628) AvroCoder changed underlying String class for SpecificRecords - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12435) Generalize S3FileSystem - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07: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 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12385) AvroUtils exception when converting JDBC Row to GenericRecord - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6516) Failed to advance source: org.apache.beam.sdk.io.rabbitmq.RabbitMqIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12601) Support append-only indices in ES output - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12609) Projection pushdown in SchemaIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12456) Querying table in parallel in JdbcIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12225) Replace AWS API used to list shards from DescribeStream to ListShards - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-9547) Implement all pandas operations (or raise WontImplementError) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12474) Configure PubsubIO with dead-letter topic - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-10917) Implement a BigQuery bounded source using the BigQuery storage API - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:07:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12070) Make ParquetIO splittable by default - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12047) Create a URN convention for cross-language transforms - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12913) Enable configuring query priority in Python ReadFromBigQuery - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12950) Missing events when using Python WriteToFiles in streaming pipeline - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13149) JdbcIO.readWithPartitions supports only int ranges - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08: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 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13001) DoFn Execution time metrics (msecs) for Go SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13189) Add escapechar to Python TextIO reads - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13099) Upgrade vendored Calcite to 1.28.0 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11087) [Go SDK] Validate Side Input behavior WRT windows - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11275) Support GCS files for extra_requirements argument in Python Beam portable runners - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-12906) Track DataFrame pandas requirement separately - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13233) Replace AWS API used to list Kinesis shards from DescribeStream to ListShards (SDK v2) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12680) Calcite SqlTransform no longer experimental - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13499) beam-sdks-java-io-hcatalog and beam-sdks-java-extensions-sql-hcatalog are vulnerable to CVE-2021-44228 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12946) [Go SDK] SmallestPerKey transform is broken, needs testing - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12522) @InitialRestriction and @SplitRestriction should be able to access sideinputs as @ProcessElement - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12945) DataFrame API fails to import with pandas 1.0.x - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12730) Add custom delimiters to Python TextIO reads - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 1 replies.
- [jira] [Updated] (BEAM-13009) DynamoDBIO misses writing items if `withDeduplicateKeys` is not set - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9379) Upgrade to Calcite 1.26.0 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11097) [Go SDK] Windowed Side Input Caching (Cross Bundle) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13499) beam-sdks-java-io-hcatalog and beam-sdks-java-extensions-sql-hcatalog are vulnerable to CVE-2021-44228 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13434) Bump up Apache log4j2 to 2.16.0 due to the vulnerability - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9918) Cross-language transforms support for Go SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5505) Disable Row flattening in Apache Calcite - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:08:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11703) Support apache-beam python install on ARM64 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13761) Xlang Debezium IO wrapper for Go SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13695) Provide more accurate size estimates for cache objects in Java 17 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13683) Implement cross-language SQL in the Go SDK - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3293) Add lazy map side input form - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-12092) Beam Dependency Update Request: redis.clients:jedis - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13757) Pane observation in user DoFN - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12240) Make Beam compatible with next Java LTS version (Java 17) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13459) Dataflow python runner should cache uploaded artifacts across job runs - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13821) [Go SDK] Add automated expansion service start-up to KafkaIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13421) Python DeferredDataFrame.xs differs from Pandas - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13732) [Cross-Language] Implement Go SDK wrapper for xlang BigQuery IO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12000) Support Python 3.9 in Apache Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13638) SqsMessage class have package private access for getters - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13293) Go SDK JDBC IO XLang Transform - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13695) Provide more accurate size estimates for cache objects in Java 17 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12092) Beam Dependency Update Request: redis.clients:jedis - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-5378) Ensure all Go SDK examples run successfully - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12865) Allow customising batch duration when streaming with WriteToBigQuery - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12931) Timer.setOutputTimestamp doesn't take into account for DoFn#getAllowedTimestampSkew() - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13171) Support for stopReadTime on KafkaIO SDF - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13605) Support pandas 1.4.0 in the DataFrame API - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8123) Support CloudPickle as pickler for Apache Beam. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13980) S3 Client broken: missing get_object_metadata() - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13864) Add Dataflow v1 Python 3.9 tests, once the runner supports it. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:09:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14112) ReadFromBigQuery cannot be used with the interactive runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14143) ExternalPythonTransform API for easily invoking Python transforms from Java - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14139) Drop support for Flink 1.11 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-1857) Add Neo4jIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (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 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14235) parquetio module does not parse PEP-440 compliant Pyarrow version - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11106) [Go SDK] Truncating SDFs during drain - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13563) Generalize AWS client provider to be independent of client type - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13174) Deprecate amazon-web-services & kinesis module (SDK v1) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13860) ParDo.infer_output_type expects DoFn.infer_output_type to return Iterable of element_type - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14003) Add support for Elasticsearch 8.x - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14351) Example 'JsonCoder' object has no attribute 'to_type_hint' - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13445) Fix chunked encoding for S3WritableButeChannel - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10: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 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13948) Implement DataFrame.unstack() and Series.unstack() for DataFrame API - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14128) Quadratic behavior in go pipeline rewriting. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13663) Fix AWS client configuration in AwsModule - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13209) DynamoDBIO silently drops unprocessed items - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13966) Implement DataFrame.pivot() for DataFrame API - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10: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 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14130) Implement Jupyterlab extension for managing Dataproc clusters - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13441) Use quiet mode for batch deletes in AWS S3FileSystem - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13175) Implement missing KinesisIO.Write for aws2 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14283) Reduce number of threads spawned by BigqueryIO StreamingInserts - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14011) AWS SDK2 S3FileSystem MultiPart Copy sets incorrect request parameters - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14071) Enabling Flink on Dataproc for Interactive Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13739) [Go SDK] Remove deprecated shallow copy functions - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Work stopped] (BEAM-13174) Deprecate amazon-web-services & kinesis module (SDK v1) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-12976) Projection pushdown in Beam Java - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4032) Support staging binary distributions of dependency packages. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14104) Shard aware Kinesis record aggregation (AWS Sdk v2) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13657) Sunset Python 3.6 support in Beam - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14133) Fix potential NPE in BigQueryServicesImpl.getErrorInfo - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14348) Upgrade to ZetaSQL 2022.04.1 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14314) Add last_updated field in filesystem.FileMetaData - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13587) Use AwsRegionProvider to load region in AwsOptions if available - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13246) Add support for S3 Bucket Key at the object level (AWS SDK v2) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14014) Support impersonation credentials in Dataflow runner. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13106) Add support for Flink 1.14 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14405) Java Spanner IO NPE when ProjectID not specified in template executions - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14386) [Flink] Support for scala 2.12 - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14160) Java expansion service does not recognize filesToStage argument - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11104) [Go SDK] DoFn Self Checkpointing - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14160) Java expansion service does not recognize filesToStage argument - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14489) Make all TextIO SDF. - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14347) [Go SDK] Allow users to optimize DoFns with a single generic registration function - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14000) Elastic search IO doesnot work when both username/password and keystore are used - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-11167) Beam Dependency Update Request: dill - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11: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 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13829) Expose status api from Go SDK Harness - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-4783) Add bundleSize parameter to control splitting of Spark sources (useful for Dynamic Allocation) - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-8218) Implement Apache PulsarIO - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11167) Beam Dependency Update Request: dill - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14000) Elastic search IO doesnot work when both username/password and keystore are used - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:11:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-19) Hadoop Runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:13:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-14373) Support using FlinkRunner with the beam_sql magic - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:13:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-14373) Support using FlinkRunner with the beam_sql magic - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:13:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-9) Storm Runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:13:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-9) Storm Runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:13:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-3304) Go triggering support - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-79) Gearpump runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-11076) Go Direct Runner Improvements - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:14:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-11076) Go Direct Runner Improvements - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6372) Direct Runner should marshal data in a similar way to Dataflow runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:14:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-6372) Direct Runner should marshal data in a similar way to Dataflow runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13130) [Go SDK] Side Input Memory Leak - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13075) [Go SDK] Update side input handling in the direct runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:14:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13075) [Go SDK] Update side input handling in the direct runner - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:14:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-6553) A BigQuery sink thta is SDK-implemented and supports file loads in Python - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:15:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-2888) Runner Comparison / Capability Matrix revamp - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:18:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-2706) Create JdbcIO.readAll() - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:18:00 UTC, 0 replies.
- [jira] [Updated] (BEAM-13669) Install Python wheel and dependencies to local venv in SDK harness - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:19:00 UTC, 0 replies.
- [jira] [Work started] (BEAM-13669) Install Python wheel and dependencies to local venv in SDK harness - posted by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:19:00 UTC, 0 replies.