issues
Thread
Date
Later messages
Messages by Thread
[jira] [Commented] (BEAM-7796) Improve health signal for StreamingDataflowWorker
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7796) Improve health signal for StreamingDataflowWorker
Danny McCormick (Jira)
[jira] [Commented] (BEAM-8091) "SELECT COUNT(1) FROM table" doesn't work
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-8091) "SELECT COUNT(1) FROM table" doesn't work
Danny McCormick (Jira)
[jira] [Commented] (BEAM-8112) Support passing stateBackend through pipeline options in python sdks
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-8112) Support passing stateBackend through pipeline options in python sdks
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7976) Documentation for word count example is unclear about inputFile vs pom.xml
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7976) Documentation for word count example is unclear about inputFile vs pom.xml
Danny McCormick (Jira)
[jira] [Commented] (BEAM-8009) Pipeline context manager calls wait_until_finish on streaming pipelines
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-8009) Pipeline context manager calls wait_until_finish on streaming pipelines
Danny McCormick (Jira)
[jira] [Commented] (BEAM-8087) PGBKCVOperation is undocumented
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-8087) PGBKCVOperation is undocumented
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7900) Implementing getTableStatistics for HCatalogTable
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7900) Implementing getTableStatistics for HCatalogTable
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7517) Document dynamic destinations for avro
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-8104) Remove windowStrategy deserialization exception handling
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-8104) Remove windowStrategy deserialization exception handling
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7769) Add ReadAll transform for MongoDBIO
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7769) Add ReadAll transform for MongoDBIO
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7757) Tagging python transform class as experimental breaks tests
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7757) Tagging python transform class as experimental breaks tests
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7971) Pycharm debugger for apache_beam/*_test.py broken
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7971) Pycharm debugger for apache_beam/*_test.py broken
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7930) bundle_processor log spam using python SDK on dataflow runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7930) bundle_processor log spam using python SDK on dataflow runner
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7552) Consider documenting the intended usage of --fix in standard_coders_test or removing that codepath if no longer needed.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7955) Dynamic Writer - combining computed shards' number for late events with window's
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7955) Dynamic Writer - combining computed shards' number for late events with window's
Danny McCormick (Jira)
[jira] [Commented] (BEAM-14210) Example configs for Beam on Flink kubernetes operator
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7089) Update pydocs front page
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7699) Remove duplicated null checks in Row.equals
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7932) GcsFileSystem should validate directories and file names for \n chars
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7932) GcsFileSystem should validate directories and file names for \n chars
Danny McCormick (Jira)
[jira] [Commented] (BEAM-6839) User reports protobuf ClassChangeError running against 2.6.0 or above
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7941) Example of DoFn.setup()
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7941) Example of DoFn.setup()
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7622) Cannot import InteractiveRunner as IPython.display is no longer a valid symbol.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7622) Cannot import InteractiveRunner as IPython.display is no longer a valid symbol.
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7007) Pipeline options documentation has typos and does not show how to use user-defined the options.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7209) Validate HCatalogIO works with Hive version 3.x dependencies
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7655) Multiple Instances of Beam Table During Query Planning
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7655) Multiple Instances of Beam Table During Query Planning
Danny McCormick (Jira)
[jira] [Commented] (BEAM-7521) Add unit tests for InMemoryBagUserStateFactory
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7958) Log message argument missing for stager's .whl extra_package warning
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7104) Document Deployment of a Flink and Spark Clusters with Portable Beam
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7386) Add Utility BiTemporalStreamJoin
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6804) [beam_PostCommit_Java] [PubsubReadIT.testReadPublicData] Timeout waiting on Sub
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7419) Add steps to run the examples in mobile gaming walkthrough
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7390) Colab examples for aggregation transforms (Python)
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7215) Wordcount example page does not tell the user to create the maven project using archetype
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7246) Add Google Spanner IO on Python SDK
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6821) FileBasedSink is not creating file paths according to target filesystem
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7237) Run NeedsRunner test category with Spark Runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6918) Github link requires login and example link is broken
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7084) Support custom environment types when expanding external transforms
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7468) Add Python global window side input pattern
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7471) DirectRunner GameStats fails, ValueError: PCollection of size 2 with more than one element accessed as a singleton view. First two elements encountered are "181.611538462", "9.1". [while running 'CalculateSpammyUsers/ProcessAndFilter']
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7020) Reduce the log severity of profiling agent discovery
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6911) Update CassandraIO to use the cassandra driver 4.x.x
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6855) Side inputs are not supported when using the state API
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7314) ViewTest.testEmptySingletonSideInput breaks on Spark runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7072) SQL Delta JOIN
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6819) Remote sources provide insufficient metadata about relative sizes of splits
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7434) RabbitMqIO uses a deprecated API
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7418) Install google-cloud-storage on py worker container
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7315) GatherAllPanesTest.multiplePanesMultipleReifiedPane breaks on Spark runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7490) TfIdfTest should not be marked ValidatesRunner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7428) ReadAllViaFileBasedSource does not output the timestamps of the read elements
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7389) Colab examples for element-wise transforms (Python)
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6947) TestGCSIO.test_last_updated (gcsio_test.py) fails when the current timezone offset and the timezone offset on 2nd of Jan 1970 differ
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6868) Flink runner supports Bundle Finalization
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7294) Upgrade hadoop-yarn-common
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7293) Upgrade hadoop-yarn-api
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7296) Upgrade jetty-http
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-11021) Portable Flink runner support bundle finalization in Batch
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6892) Use temp_location for BQ FILE_LOADS on DirectRunner, and autocreate it in GCS if not specified by user.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6892) Use temp_location for BQ FILE_LOADS on DirectRunner, and autocreate it in GCS if not specified by user.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7278) Upgrade some Beam dependencies
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7478) Remote cluster submission from Flink Runner broken due to staging issues
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7046) fix http_proxy warnings from grpc in tests
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7322) PubSubIO watermark does not advance for very low volumes
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7033) Document that query results can be read with the BigQuery storage API
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7200) BeamEnumerableConverter.toRowList should support LIMIT
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7006) test_split_crazy_sdf broken in python presubmit. 'DataInputOperation' object has no attribute 'index'
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7303) Move Portable Runner and other of reference runner.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7049) Merge multiple input to one BeamUnionRel
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7233) Spark portable runner: support Bundle Finalization
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7123) COUNT(*) should return 0 when input is empty
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7236) Support transcoding for Flatten in Spark Runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7495) Add support for dynamic worker re-balancing when reading BigQuery data using Cloud Dataflow
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6954) @Default not called if the options json has null value for a property
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7167) Unable to cancel a DoFn Timer
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7256) Add support for allowDiskUse (AggregationOptions) in MongoDbIO
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6874) HCatalogTableProvider supports filter pushdown
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6904) Test all Coder structuralValue implementations
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7438) Distribution and Gauge metrics are not being exported to Flink dashboard neither Prometheus IO
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7435) Add HBaseIO tests with provided HBase 2 client/server
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6963) Bug in RuntimeValueProvider JSON serialization
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7146) Build a general code generator that is accessible from all RelNode
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7247) DoFnSignatures analysis of @ProcessElement with @Element fails when Java SDK is used from Kotlin
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7391) Colab examples for other transforms (Python)
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7204) ReduceFnRunner overhead
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7398) Add getTaggedKeyedPCollection to KeyedPCollectionTuple
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7250) Use annotation based parameters for SDF on Java
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7219) Spark portable runner: support Spark metrics
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6831) python sdk WriteToBigQuery excessive usage of metered API
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7120) Turn `WindowedValue<T>` into `T` for all the interfaces of Data Plane
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6970) Java SDK : How to bounded messages from PubSub ?
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7180) Consider having @Validation.Required check to see if a field is set or not in PipelineOptions
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7379) Flink runner build instructions need updating
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7199) Better optimize Portable pipelines in Java fuser
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7460) Refactor ExecutorServiceFactory out of GcsOptions
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7191) Add quieter debug logging API for beam developers.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7165) FileIOTest.testMatchWatchForNewFiles flakey in java presubmit
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7206) Coder copy overhead
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7244) Convert external transforms to use StringUtf8Coder instead of ByteArrayCoder
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7309) Adding AvroCoder to StandardCoders
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7155) Provide access to <K> within DoFn.OnTimerContext
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6871) apache_beam.io.parquetio_test.TestParquet is very flaky
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6852) Produce a better error message when GCS bucket is not available when writing
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6856) Support dynamic MapState on Dataflow
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7384) Cleanup stale Jenkins jobs on UI
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6798) Reconsider usage of gradle release plugin
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7433) RabbitMQMessage coder can't be registered when using Google Cloud Dataflow
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7285) Speed up merge_accumulators for ApproximateUniqueGlobally
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6802) Re-enable conscrypt SSL as default when possible
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7058) Python SDK: Collect metrics in non-cython environment
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6949) Python Gcp tests stalling on machine without credentials
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7410) Explore possibilities to lower in-use IP address quota footprint.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7482) Update Documentations for issue BEAM-7439
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6980) Jenkins PR jobs tab contains non-beam jobs in "Queue" section
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6830) Direct runner throws error "http 404 not found" when reading Bigquery tables from any other region than "US"
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7222) Spark portable runner: support SDF
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7108) Support for writing to partitioned and clustered BigQuery tables using Python
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7252) "beam:java:boundedsource" not supported with python optimizer
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7358) Developing "GroupByMultiKey"
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7496) python sdk fail to read data from HDFS
Kenneth Knowles (Jira)
[jira] [Work logged] (BEAM-7439) Bigquery Write with schema None: TypeError: 'NoneType' object has no attribute '__getitem__'
ASF GitHub Bot (Jira)
[jira] [Commented] (BEAM-7161) filter.Distinct should accept a KV type
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6833) dataflow_metrics.py should be able to fully query the metrics
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6849) SpannerIO.Write "Part Running" at schemaView, never completes with Wait.on
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6879) Portable runner support for @RequiresStableInput
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6846) Beam Performance Degradation on Dataflow Runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6809) spark.streaming.backpressure not work properly
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6817) NoSuchMethodError when writing to BigTable
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6893) TestDataflowRunner should log explicitly when it is interruped
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6837) Portable Validates Runner Tests for Python Reference Runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6925) Extract common User MonitoringInfo URN parsing logic.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6832) Populate labels and custom metadata on VMs that serves Dataflow
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6910) Beam does not consider BigQuery's processing location when getting query results
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6835) beam-sdks-python-test-suites-tox-py35:sdist FAILED on clean branch
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6884) NoSuchMethodError: descriptors$EnumValueDescriptor when deploying Beam Java SDK 2.10.0 to Dataflow
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6808) Use gav or something equivalent in announcement for dependency uogrades
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6799) Streamline project version usage
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6930) Wrong log severity in Dataflow logs
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6920) Expand aliases in ElasticsearchIO.Read
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6886) Change batch handling in ElasticsearchIO to avoid necessity for GroupIntoBatches
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6885) java.lang.IncompatibleClassChangeError when deploying Beam Java SDK 2.11.0 to Dataflow
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6826) All Python counters should use the same code path
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7025) Python pipelines should not be able to use output tags that are not defined in with_outputs.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7026) Python SDK: Unable to obtain the PCollection for output tags which are not consumed by a downstream step.
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7022) BigQueryIO.write.withExtendedErrorInfo() does not catch missing tables (and maybe datasets)
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7050) Antipattern will break legacy dataflow python pipelines if a new cy_combiner is added and used in the python counter_factory
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7040) Spotless doesn't check build.gradle files
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7047) Direct Runner loses checkpoint marks when committing offsets to Apache Kafka partitions using KafkaIO
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7127) Timer parameter not supported in timer callback
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7160) Run NeedsRunner test category with Flink Runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7172) Support using SDFs as cross-language transforms using ExternalTransform
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7280) Allow for setMaxRetryJobs in BigQueryIO to be configurable
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7323) PartitionTest.testDroppedPartition breaks on Flink runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7255) UNNEST with JOIN: NullPointerException in BeamUnnestRel
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7248) Support "beam:runner:executable_stage:v1" on fn_api_runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7321) TestStreamTest breaks on Flink runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7142) Data Driven testing for BeamSQL
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7300) Writing in batch to BigQuery may lead to data loss
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7318) WriteFilesTest.testEmptyWrite breaks on Flink runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7164) Python precommit failing on Java PRs. dataflow:setupVirtualenv
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7319) Multiple NeedsRunner tests break with Flink 'Cannot union streams of different types'
Kenneth Knowles (Jira)
[jira] [Updated] (BEAM-14556) Honor custom formatters being installed on the root logging handler
Luke Cwik (Jira)
[jira] [Work logged] (BEAM-14556) Honor custom formatters being installed on the root logging handler
ASF GitHub Bot (Jira)
[jira] [Work logged] (BEAM-14556) Honor custom formatters being installed on the root logging handler
ASF GitHub Bot (Jira)
[jira] [Commented] (BEAM-7411) Allow upload gzipped files via apache_beam.io.gcp.gcsio.GcsIO with proper content-encoding
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7400) Authentication for ElasticsearchIO seems to be failing
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7394) Python fileio handles compressed files
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7361) UNION does not work with Double
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7425) Reading BigQuery Table Data into Java Classes(Pojo) Directly
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7353) Filter verbose oauth2client log messages
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7308) Add determinism checker for Python AvroCoder
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7452) Ensure all RunnerHarnesses provide a valid RunnerApi.IsBounded value on all PCollections
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7423) Spark unbounded source advances watermarks prematurely
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7483) Audit mis-uses of GCS client library API
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-6921) Improve SpannerIO output
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7363) Make HCatalogIOIT running on Jenkins
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7395) Check immutability violations in Dataflow Runner (as an option)
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7486) Update GRPC versions of beam-sdks-java-io-google-cloud-platform
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7497) SyntheticSource option forceNumInitialBundles is not optional in all cases
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7498) Inputs SQS with Session based Windowing doesn't work
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7374) Add usage documentation for vet runner
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7489) High CPU and memory usage in the case of SqlTransform with complex triggers
Kenneth Knowles (Jira)
[jira] [Commented] (BEAM-7069) Emit a warning when a pipeline option with a hyphen is encountered by BeamArgumentParser
Kenneth Knowles (Jira)
Later messages