clear query| facets| time Search criteria: .   Results from 1 to 10 from 16263 (0.0s).
Loading phrases to help you
refine your search...
[BEAM-9295] Add Flink 1.10 build target and Make FlinkRunner compatible with Flink 1.10 - Beam - [issue]
...Apache Flink 1.10 has completed the final release vote, see [1]. So, I would like to add Flink 1.10 build target and make Flink Runner compatible with Flink 1.10.And I appreciate it ...
http://issues.apache.org/jira/browse/BEAM-9295    Author: sunjincheng , 2020-02-26, 05:41
[BEAM-7336] KafkaIO should support inferring schemas when reading Avro - Beam - [issue]
...PubSubIO already supports this.It would also be nice to be able to look up Avro schemas in the Kafka schema registry....
http://issues.apache.org/jira/browse/BEAM-7336    Author: Reuven Lax , 2020-02-26, 05:24
[BEAM-9329] Support request of schemas by version on KafkaIO + Confluent Schema Registry - Beam - [issue]
...BEAM-7310 introduced support to get Avro Schemas from Confluent Schema Registry as part of KafkaIO. By default it always takes the latest (most recent) version of the Schema. It would be nic...
http://issues.apache.org/jira/browse/BEAM-9329    Author: Ismaël Mejía , 2020-02-26, 05:01
[BEAM-8989] Backwards incompatible change in ParDo.getSideInputs (caught by failure when running Apache Nemo quickstart) - Beam - [issue]
...PR/9275 changed ParDo.getSideInputs from List<PCollectionView> to Map<String, PCollectionView> which is backwards incompatible change and was released as part of Beam 2.16.0 erro...
http://issues.apache.org/jira/browse/BEAM-8989    Author: Luke Cwik , 2020-02-26, 04:33
[BEAM-9252] Problem shading Beam pipeline with Beam 2.20.0-SNAPSHOT - Beam - [issue]
...I was checking today a pipeline against the latest 2.20.0-SNAPSHOT and I found that it works perfectly with version 2.19.0, but it is failing with a  shade related exception that refers to g...
http://issues.apache.org/jira/browse/BEAM-9252    Author: Ismaël Mejía , 2020-02-26, 04:32
[BEAM-8335] Add streaming support to Interactive Beam - Beam - [issue]
...This issue tracks the work items to introduce streaming support to the Interactive Beam experience. This will allow users to: Write and run a streaming job in IPython Automatically cache rec...
http://issues.apache.org/jira/browse/BEAM-8335    Author: Sam Rohde , 2020-02-26, 04:22
[BEAM-8971] BigQueryIO.Write sometimes throws errors - Beam - [issue]
...The following error happens from time to time. After that beam retries an entire batch and that gets processed fine. There are 2 concerns: that may produce duplicates (however, I am not sure...
http://issues.apache.org/jira/browse/BEAM-8971    Author: Pavlo Pohrrebnyi , 2020-02-26, 03:47
[BEAM-2822] Add support for progress reporting in fn API - Beam - [issue]
...https://s.apache.org/beam-fn-api-progress-reportingNote that the ULR reference implementation, when ready, should be useful for every runner....
http://issues.apache.org/jira/browse/BEAM-2822    Author: Vikas Kedigehalli , 2020-02-26, 03:40
[BEAM-9322] Python SDK ignores manually set PCollection tags - Beam - [issue]
...The Python SDK currently ignores any tags set on PCollections manually when applying PTransforms when adding the PCollection to the PTransform outputs. In the add_output method, the tag is s...
http://issues.apache.org/jira/browse/BEAM-9322    Author: Sam Rohde , 2020-02-26, 03:22
[BEAM-7304] Twister2 Beam runner - Beam - [issue]
...Twister2 is a big data framework which supports both batch and stream processing [1] [2]. The goal is to develop an beam runner for Twister2. [1] https://github.com/D...
http://issues.apache.org/jira/browse/BEAM-7304    Author: Pulasthi Wickramasinghe , 2020-02-26, 03:15