[jira] [Assigned] (BEAM-4042) Get rid of deprecated gradle API

[ https://issues.apache.org/jira/browse/BEAM-4042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-4042: -- Assignee: Romain Manni-Bucau (was: Davor Bonaci) > Get rid of deprecated gradle

[jira] [Commented] (BEAM-3852) Migrate existing users to new channel ASF slack channel

[ https://issues.apache.org/jira/browse/BEAM-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405503#comment-16405503 ] Davor Bonaci commented on BEAM-3852: It's fine to leave it assigned until the formal move has happened

[jira] [Assigned] (BEAM-3852) Migrate existing users to new channel ASF slack channel

[ https://issues.apache.org/jira/browse/BEAM-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-3852: -- Assignee: Romain Manni-Bucau (was: Davor Bonaci) > Migrate existing users to new channel

[jira] [Assigned] (BEAM-2339) Jenkins cross JDK version test on Windows

[ https://issues.apache.org/jira/browse/BEAM-2339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2339: -- Assignee: (was: Davor Bonaci) > Jenkins cross JDK version test on Wind

[jira] [Assigned] (BEAM-3852) Migrate existing users to new channel ASF slack channel

[ https://issues.apache.org/jira/browse/BEAM-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-3852: -- Assignee: Romain Manni-Bucau (was: Davor Bonaci) > Migrate existing users to new channel

[jira] [Assigned] (BEAM-3845) Avoid calling Class#newInstance

[ https://issues.apache.org/jira/browse/BEAM-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-3845: -- Assignee: Ted Yu (was: Davor Bonaci) > Avoid calling Class#newInsta

[jira] [Updated] (BEAM-3845) Avoid calling Class#newInstance

[ https://issues.apache.org/jira/browse/BEAM-3845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-3845: --- Component/s: (was: project-management) sdk-java-core > Avoid calling Cl

[jira] [Commented] (BEAM-1754) Will Dataflow ever support Node.js with an SDK similar to Java or Python?

[ https://issues.apache.org/jira/browse/BEAM-1754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16379755#comment-16379755 ] Davor Bonaci commented on BEAM-1754: You are more than welcome to do so! I'd suggest using dev

[jira] [Assigned] (BEAM-3697) Add errorprone to maven and gradle builds

[ https://issues.apache.org/jira/browse/BEAM-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-3697: -- Assignee: (was: Davor Bonaci) > Add errorprone to maven and gradle bui

[jira] [Assigned] (BEAM-3266) MergeBot bug when regenerating website

[ https://issues.apache.org/jira/browse/BEAM-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-3266: -- Assignee: Jason Kuster (was: Davor Bonaci) > MergeBot bug when regenerating webs

[jira] [Commented] (BEAM-998) Consider asking Apache to register Apache Beam trademark

[ https://issues.apache.org/jira/browse/BEAM-998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16255499#comment-16255499 ] Davor Bonaci commented on BEAM-998: --- US application submitted. > Consider asking Apache to regis

[jira] [Assigned] (BEAM-3185) Build blocks on parsing long as int from github status json

[ https://issues.apache.org/jira/browse/BEAM-3185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-3185: -- Assignee: Jason Kuster (was: Davor Bonaci) > Build blocks on parsing long as int from git

[jira] [Assigned] (BEAM-3164) Capture stderr logs during gen proto

[ https://issues.apache.org/jira/browse/BEAM-3164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-3164: -- Assignee: Holden Karau (was: Davor Bonaci) > Capture stderr logs during gen pr

[jira] [Assigned] (BEAM-3106) Consider not pinning all python dependencies, or moving them to requirements.txt

[ https://issues.apache.org/jira/browse/BEAM-3106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-3106: -- Assignee: Ahmet Altay (was: Davor Bonaci) > Consider not pinning all python dependenc

[jira] [Updated] (BEAM-3086) build failed

[ https://issues.apache.org/jira/browse/BEAM-3086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-3086: --- Component/s: (was: build-system) sdk-py-core > build fai

[jira] [Assigned] (BEAM-3086) build failed

[ https://issues.apache.org/jira/browse/BEAM-3086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-3086: -- Assignee: Ahmet Altay (was: Davor Bonaci) > build fai

[jira] [Commented] (BEAM-2802) TextIO should allow specifying a custom delimiter

[ https://issues.apache.org/jira/browse/BEAM-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183062#comment-16183062 ] Davor Bonaci commented on BEAM-2802: [~ryanskraba] and [~echauchot] -- thank you both for making

[jira] [Commented] (BEAM-998) Consider asking Apache to register Apache Beam trademark

[ https://issues.apache.org/jira/browse/BEAM-998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16140717#comment-16140717 ] Davor Bonaci commented on BEAM-998: --- Re-pinged. > Consider asking Apache to register Apache B

[jira] [Assigned] (BEAM-1457) Enable rat plugin and findbugs plugin in default build

[ https://issues.apache.org/jira/browse/BEAM-1457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1457: -- Assignee: (was: Davor Bonaci) > Enable rat plugin and findbugs plugin in default bu

[jira] [Assigned] (BEAM-1189) Add guide for release verifiers in the release guide

[ https://issues.apache.org/jira/browse/BEAM-1189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1189: -- Assignee: (was: Davor Bonaci) > Add guide for release verifiers in the release gu

[jira] [Assigned] (BEAM-1975) Documentation around logging in different runners

[ https://issues.apache.org/jira/browse/BEAM-1975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1975: -- Assignee: (was: Davor Bonaci) > Documentation around logging in different runn

[jira] [Assigned] (BEAM-1961) Standard IO metrics documentation

[ https://issues.apache.org/jira/browse/BEAM-1961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1961: -- Assignee: (was: Davor Bonaci) > Standard IO metrics documentat

[jira] [Assigned] (BEAM-2082) I/O Authoring overview - emphasize reading the PTransform style guide

[ https://issues.apache.org/jira/browse/BEAM-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2082: -- Assignee: Chamikara Jayalath (was: Davor Bonaci) > I/O Authoring overview - emphasize read

[jira] [Assigned] (BEAM-1957) Missing DoFn annotations documentation

[ https://issues.apache.org/jira/browse/BEAM-1957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1957: -- Assignee: Kenneth Knowles (was: Davor Bonaci) > Missing DoFn annotations documentat

[jira] [Assigned] (BEAM-2634) Add better documentation on testing unbounded I/O scenarios

[ https://issues.apache.org/jira/browse/BEAM-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2634: -- Assignee: (was: Davor Bonaci) > Add better documentation on testing unbounded I/O scenar

[jira] [Assigned] (BEAM-2358) "/test-your-pipeline" example code results in an exception

[ https://issues.apache.org/jira/browse/BEAM-2358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2358: -- Assignee: Jason Kuster (was: Davor Bonaci) > "/test-your-pipeline" example

[jira] [Assigned] (BEAM-601) Enable Kinesis integration tests

[ https://issues.apache.org/jira/browse/BEAM-601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-601: - Assignee: Chamikara Jayalath (was: Davor Bonaci) > Enable Kinesis integration te

[jira] [Assigned] (BEAM-1605) Add support for Apex cluster metrics to PerfKit Benchmarker

[ https://issues.apache.org/jira/browse/BEAM-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1605: -- Assignee: Jason Kuster (was: Davor Bonaci) > Add support for Apex cluster metrics to Perf

[jira] [Assigned] (BEAM-910) Always explicitly specify --output for ITs

[ https://issues.apache.org/jira/browse/BEAM-910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-910: - Assignee: (was: Davor Bonaci) > Always explicitly specify --output for

[jira] [Assigned] (BEAM-2650) migrate beam_it_args -> beam_it_options

[ https://issues.apache.org/jira/browse/BEAM-2650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2650: -- Assignee: Chamikara Jayalath > migrate beam_it_args -> beam_it_o

[jira] [Assigned] (BEAM-1654) Tests that UnboundedSources are executed correctly

[ https://issues.apache.org/jira/browse/BEAM-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1654: -- Assignee: (was: Davor Bonaci) > Tests that UnboundedSources are executed correc

[jira] [Assigned] (BEAM-2650) migrate beam_it_args -> beam_it_options

[ https://issues.apache.org/jira/browse/BEAM-2650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2650: -- Assignee: (was: Davor Bonaci) > migrate beam_it_args -> beam_it_o

[jira] [Assigned] (BEAM-2121) Tests on MacOS

[ https://issues.apache.org/jira/browse/BEAM-2121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2121: -- Assignee: (was: Davor Bonaci) > Tests on MacOS > -- > >

[jira] [Assigned] (BEAM-2220) Move org.apache.beam.sdk.util within google-cloud-platform-core to org.apache.beam.runners.dataflow

[ https://issues.apache.org/jira/browse/BEAM-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2220: -- Assignee: Luke Cwik (was: Davor Bonaci) > Move org.apache.beam.sdk.util within google-cl

[jira] [Assigned] (BEAM-1609) Add support for Beam Metrics API to PKB

[ https://issues.apache.org/jira/browse/BEAM-1609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1609: -- Assignee: Jason Kuster (was: Davor Bonaci) > Add support for Beam Metrics API to

[jira] [Assigned] (BEAM-1271) Develop Apache Accumulo IO

[ https://issues.apache.org/jira/browse/BEAM-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1271: -- Assignee: Reuven Lax (was: Davor Bonaci) > Develop Apache Accumulo

[jira] [Assigned] (BEAM-1271) Develop Apache Accumulo IO

[ https://issues.apache.org/jira/browse/BEAM-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1271: -- Assignee: Wyatt Frelot (was: Reuven Lax) > Develop Apache Accumulo

[jira] [Assigned] (BEAM-1305) Support additional configuration in BigQueryServices.insertAll()

[ https://issues.apache.org/jira/browse/BEAM-1305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1305: -- Assignee: (was: Davor Bonaci) > Support additional configurat

[jira] [Assigned] (BEAM-2752) Job fails to checkpoint with kinesis stream as an input for Flink job

[ https://issues.apache.org/jira/browse/BEAM-2752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2752: -- Assignee: Chamikara Jayalath (was: Davor Bonaci) > Job fails to checkpoint with kinesis str

[jira] [Assigned] (BEAM-1664) Support Kafka0.8.x client in KafkaIO

[ https://issues.apache.org/jira/browse/BEAM-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1664: -- Assignee: Raghu Angadi (was: Davor Bonaci) > Support Kafka0.8.x client in Kafk

[jira] [Assigned] (BEAM-2639) Unbounded Source for MongoDB

[ https://issues.apache.org/jira/browse/BEAM-2639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2639: -- Assignee: Jean-Baptiste Onofré (was: Davor Bonaci) > Unbounded Source for Mong

[jira] [Assigned] (BEAM-1879) PTransform style guide should discuss display data

[ https://issues.apache.org/jira/browse/BEAM-1879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1879: -- Assignee: Eugene Kirpichov (was: Davor Bonaci) > PTransform style guide should discuss disp

[jira] [Assigned] (BEAM-2582) KinesisIO incorrectly handles closed shards

[ https://issues.apache.org/jira/browse/BEAM-2582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2582: -- Assignee: Chamikara Jayalath (was: Davor Bonaci) > KinesisIO incorrectly handles closed sha

[jira] [Assigned] (BEAM-2703) KafkaIO: watermark outside the bounds of BoundedWindow

[ https://issues.apache.org/jira/browse/BEAM-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2703: -- Assignee: Raghu Angadi (was: Davor Bonaci) > KafkaIO: watermark outside the bou

[jira] [Assigned] (BEAM-2704) KafkaIO: NPE without key serializer set

[ https://issues.apache.org/jira/browse/BEAM-2704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2704: -- Assignee: Raghu Angadi (was: Davor Bonaci) > KafkaIO: NPE without key serializer

[jira] [Assigned] (BEAM-2605) Exception raised when using MongoDBIO.Write in streaming mode

[ https://issues.apache.org/jira/browse/BEAM-2605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2605: -- Assignee: Jean-Baptiste Onofré (was: Davor Bonaci) > Exception raised when us

[jira] [Assigned] (BEAM-2738) Setup shield and certificates in Elasticseach ITests backend server

[ https://issues.apache.org/jira/browse/BEAM-2738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2738: -- Assignee: Etienne Chauchot (was: Davor Bonaci) > Setup shield and certificates in Elasticse

[jira] [Updated] (BEAM-2721) Augment BeamRecordType to do slicing and concatenation.

[ https://issues.apache.org/jira/browse/BEAM-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-2721: --- Component/s: (was: sdk-java-extensions) dsl-sql > Augment BeamRecordType to

[jira] [Assigned] (BEAM-2577) IO tests should exercise Runtime Values where supported

[ https://issues.apache.org/jira/browse/BEAM-2577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2577: -- Assignee: (was: Davor Bonaci) > IO tests should exercise Runtime Values where suppor

[jira] [Assigned] (BEAM-2721) Augment BeamRecordType to do slicing and concatenation.

[ https://issues.apache.org/jira/browse/BEAM-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2721: -- Assignee: Xu Mingmin (was: Davor Bonaci) > Augment BeamRecordType to do slic

[jira] [Assigned] (BEAM-448) Print Properties on validation failures in PipelineOptionsValidator

[ https://issues.apache.org/jira/browse/BEAM-448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-448: - Assignee: (was: Davor Bonaci) > Print Properties on validation failu

[jira] [Assigned] (BEAM-449) Support PCollectionList in PAssert

[ https://issues.apache.org/jira/browse/BEAM-449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-449: - Assignee: (was: Davor Bonaci) > Support PCollectionList in PAss

[jira] [Assigned] (BEAM-1408) outputWithTimestamp() accepts timestamps that will fail preconditions

[ https://issues.apache.org/jira/browse/BEAM-1408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1408: -- Assignee: (was: Davor Bonaci) > outputWithTimestamp() accepts timestamps that will f

[jira] [Assigned] (BEAM-1639) Catch bad FractionConsumed values in the beam SDK.

[ https://issues.apache.org/jira/browse/BEAM-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1639: -- Assignee: (was: Davor Bonaci) > Catch bad FractionConsumed values in the beam

[jira] [Assigned] (BEAM-728) Javadoc should clearly separate facts from runner requirements

[ https://issues.apache.org/jira/browse/BEAM-728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-728: - Assignee: (was: Davor Bonaci) > Javadoc should clearly separate facts from runner requireme

[jira] [Assigned] (BEAM-1662) Re. BEAM-974 - PubSub.read/write() .withCoder requirement should raise a more informative error in Dataflow

[ https://issues.apache.org/jira/browse/BEAM-1662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1662: -- Assignee: (was: Davor Bonaci) > Re. BEAM-974 - PubSub.read/write() .withCoder requirem

[jira] [Commented] (BEAM-1461) duplication with StartBundle and prepareForProcessing in DoFn

[ https://issues.apache.org/jira/browse/BEAM-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16140695#comment-16140695 ] Davor Bonaci commented on BEAM-1461: Seems complete; I'd resolve. Please reactivate if there's more

[jira] [Resolved] (BEAM-1461) duplication with StartBundle and prepareForProcessing in DoFn

[ https://issues.apache.org/jira/browse/BEAM-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-1461. Resolution: Fixed Fix Version/s: Not applicable > duplication with StartBun

[jira] [Resolved] (BEAM-1691) Dynamic properties supported in PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-1691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-1691. Resolution: Not A Problem Fix Version/s: Not applicable > Dynamic properties suppor

[jira] [Commented] (BEAM-1691) Dynamic properties supported in PipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-1691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16140693#comment-16140693 ] Davor Bonaci commented on BEAM-1691: I'd resolve for now; if we want to change the behavior here

[jira] [Assigned] (BEAM-1448) Coder encode/decode context documentation is lacking

[ https://issues.apache.org/jira/browse/BEAM-1448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1448: -- Assignee: (was: Davor Bonaci) > Coder encode/decode context documentation is lack

[jira] [Assigned] (BEAM-1898) Need a SerializableThrowable for PAssert to capture the point of an assertion

[ https://issues.apache.org/jira/browse/BEAM-1898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1898: -- Assignee: (was: Davor Bonaci) > Need a SerializableThrowable for PAssert to capt

[jira] [Assigned] (BEAM-2303) Add SpecificData to AvroCoder

[ https://issues.apache.org/jira/browse/BEAM-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2303: -- Assignee: (was: Davor Bonaci) > Add SpecificData to AvroCo

[jira] [Assigned] (BEAM-2069) Remove ResourceId.getCurrentDirectory()?

[ https://issues.apache.org/jira/browse/BEAM-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2069: -- Assignee: (was: Davor Bonaci) > Remove ResourceId.getCurrentDirect

[jira] [Assigned] (BEAM-2302) WriteFiles with runner-determined sharding and large numbers of windows causes OOM errors

[ https://issues.apache.org/jira/browse/BEAM-2302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2302: -- Assignee: Reuven Lax (was: Davor Bonaci) > WriteFiles with runner-determined shard

[jira] [Assigned] (BEAM-2615) Add ViewTests with SlidingWindows

[ https://issues.apache.org/jira/browse/BEAM-2615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2615: -- Assignee: Thomas Groh (was: Davor Bonaci) > Add ViewTests with SlidingWind

[jira] [Commented] (BEAM-2302) WriteFiles with runner-determined sharding and large numbers of windows causes OOM errors

[ https://issues.apache.org/jira/browse/BEAM-2302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16140689#comment-16140689 ] Davor Bonaci commented on BEAM-2302: Fixed? > WriteFiles with runner-determined sharding and la

[jira] [Commented] (BEAM-2601) FileBasedSink produces incorrect shards when writing to multiple destinations

[ https://issues.apache.org/jira/browse/BEAM-2601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16140688#comment-16140688 ] Davor Bonaci commented on BEAM-2601: Fixed? > FileBasedSink produces incorrect shards when writ

[jira] [Assigned] (BEAM-2601) FileBasedSink produces incorrect shards when writing to multiple destinations

[ https://issues.apache.org/jira/browse/BEAM-2601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2601: -- Assignee: Reuven Lax (was: Davor Bonaci) > FileBasedSink produces incorrect shards w

[jira] [Assigned] (BEAM-2624) File-based sinks should produce a PCollection of written filenames

[ https://issues.apache.org/jira/browse/BEAM-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2624: -- Assignee: Reuven Lax (was: Davor Bonaci) > File-based sinks should produce a PCollect

[jira] [Assigned] (BEAM-2701) use a custom implementation of java.io.ObjectInputStream

[ https://issues.apache.org/jira/browse/BEAM-2701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2701: -- Assignee: Luke Cwik (was: Davor Bonaci) > use a custom implementat

[jira] [Assigned] (BEAM-2705) DoFnTester supports for StateParameter

[ https://issues.apache.org/jira/browse/BEAM-2705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2705: -- Assignee: Kenneth Knowles (was: Davor Bonaci) > DoFnTester supports for StateParame

[jira] [Commented] (BEAM-2646) Problem to join in slack channel

[ https://issues.apache.org/jira/browse/BEAM-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16140680#comment-16140680 ] Davor Bonaci commented on BEAM-2646: Same thing -- in addition to emailing dev-subscr

[jira] [Resolved] (BEAM-2646) Problem to join in slack channel

[ https://issues.apache.org/jira/browse/BEAM-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-2646. Resolution: Information Provided Fix Version/s: Not applicable > Problem to join in sl

[jira] [Assigned] (BEAM-1449) Maven should be able to build and run tests across multiple languages

[ https://issues.apache.org/jira/browse/BEAM-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-1449: -- Assignee: Ahmet Altay (was: Davor Bonaci) > Maven should be able to build and run tests acr

[jira] [Resolved] (BEAM-1809) Fix one error in TravisCI build

[ https://issues.apache.org/jira/browse/BEAM-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci resolved BEAM-1809. Resolution: Won't Fix Fix Version/s: Not applicable Travis-CI has been fully replaced

[jira] [Assigned] (BEAM-2793) Include all versions in top-level pom

[ https://issues.apache.org/jira/browse/BEAM-2793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2793: -- Assignee: Jason Kuster (was: Davor Bonaci) > Include all versions in top-level

[jira] [Assigned] (BEAM-2581) KinesisClientProvider interface needs to be public

[ https://issues.apache.org/jira/browse/BEAM-2581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2581: -- Assignee: Chamikara Jayalath (was: Davor Bonaci) > KinesisClientProvider interface ne

[jira] [Assigned] (BEAM-2750) Read whole files as one PCollection element each

[ https://issues.apache.org/jira/browse/BEAM-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2750: -- Assignee: Christopher Hebert (was: Davor Bonaci) > Read whole files as one PCollection elem

[jira] [Assigned] (BEAM-2757) Link to Jenkins view is dead

[ https://issues.apache.org/jira/browse/BEAM-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2757: -- Assignee: Jason Kuster (was: Davor Bonaci) > Link to Jenkins view is d

[jira] [Commented] (BEAM-2709) Add TezRunner

[ https://issues.apache.org/jira/browse/BEAM-2709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16113370#comment-16113370 ] Davor Bonaci commented on BEAM-2709: Welcome [~bdscheller], and thanks for your contribution

[jira] [Assigned] (BEAM-2709) Add TezRunner

[ https://issues.apache.org/jira/browse/BEAM-2709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2709: -- Assignee: Brandon Scheller (was: Davor Bonaci) > Add TezRun

[jira] [Assigned] (BEAM-2341) Make our Python pom files virtualenv-compatible.

[ https://issues.apache.org/jira/browse/BEAM-2341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2341: -- Assignee: Ahmet Altay (was: Davor Bonaci) > Make our Python pom files virtualenv-compati

[jira] [Assigned] (BEAM-2547) FireBase IO

[ https://issues.apache.org/jira/browse/BEAM-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2547: -- Assignee: Chamikara Jayalath (was: Davor Bonaci) > FireBase

[jira] [Assigned] (BEAM-2608) Unclosed BoundedReader in TextIO#ReadTextFn#process()

[ https://issues.apache.org/jira/browse/BEAM-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2608: -- Assignee: Eugene Kirpichov (was: Davor Bonaci) > Unclosed BoundedReader in TextIO#ReadTex

[jira] [Assigned] (BEAM-2554) failIfNoTests: causes issues when trying to run integration tests

[ https://issues.apache.org/jira/browse/BEAM-2554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2554: -- Assignee: (was: Davor Bonaci) > failIfNoTests: causes issues when trying to run integrat

[jira] [Assigned] (BEAM-2544) AvroIOTest is flaky

[ https://issues.apache.org/jira/browse/BEAM-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2544: -- Assignee: Eugene Kirpichov (was: Davor Bonaci) > AvroIOTest is fl

[jira] [Assigned] (BEAM-2506) Consider bundling multiple ValidatesRunner tests into one pipeline

[ https://issues.apache.org/jira/browse/BEAM-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2506: -- Assignee: (was: Davor Bonaci) > Consider bundling multiple ValidatesRunner tests into

[jira] [Assigned] (BEAM-2493) TestStream.Builder.addElements() should return the same builder

[ https://issues.apache.org/jira/browse/BEAM-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2493: -- Assignee: Thomas Groh (was: Davor Bonaci) > TestStream.Builder.addElements() should ret

[jira] [Assigned] (BEAM-2467) KinesisIO watermark based on approximateArrivalTimestamp

[ https://issues.apache.org/jira/browse/BEAM-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2467: -- Assignee: Paweł Kaczmarczyk > KinesisIO watermark based on approximateArrivalTimest

[jira] [Assigned] (BEAM-2468) Reading Kinesis records in the background

[ https://issues.apache.org/jira/browse/BEAM-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2468: -- Assignee: Paweł Kaczmarczyk > Reading Kinesis records in the backgro

[jira] [Assigned] (BEAM-2469) Handling Kinesis shards splits and merges

[ https://issues.apache.org/jira/browse/BEAM-2469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2469: -- Assignee: Paweł Kaczmarczyk > Handling Kinesis shards splits and mer

[jira] [Assigned] (BEAM-2469) Handling Kinesis shards splits and merges

[ https://issues.apache.org/jira/browse/BEAM-2469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2469: -- Assignee: (was: Davor Bonaci) > Handling Kinesis shards splits and mer

[jira] [Assigned] (BEAM-2467) KinesisIO watermark based on approximateArrivalTimestamp

[ https://issues.apache.org/jira/browse/BEAM-2467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2467: -- Assignee: (was: Davor Bonaci) > KinesisIO watermark based on approximateArrivalTimest

[jira] [Commented] (BEAM-2468) Reading Kinesis records in the background

[ https://issues.apache.org/jira/browse/BEAM-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16055114#comment-16055114 ] Davor Bonaci commented on BEAM-2468: [~pawel.kaczmarczyk], can you perhaps contribute a fix

[jira] [Assigned] (BEAM-2468) Reading Kinesis records in the background

[ https://issues.apache.org/jira/browse/BEAM-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2468: -- Assignee: (was: Davor Bonaci) > Reading Kinesis records in the backgro

[jira] [Commented] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16055111#comment-16055111 ] Davor Bonaci commented on BEAM-2466: Totally! > Add Kafka Streams run

[jira] [Assigned] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2466: -- Assignee: (was: Davor Bonaci) > Add Kafka Streams run

[jira] [Assigned] (BEAM-2455) Backlog size retrieval for Kinesis source

[ https://issues.apache.org/jira/browse/BEAM-2455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci reassigned BEAM-2455: -- Assignee: Paweł Kaczmarczyk > Backlog size retrieval for Kinesis sou

[jira] [Commented] (BEAM-2455) Backlog size retrieval for Kinesis source

[ https://issues.apache.org/jira/browse/BEAM-2455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16052952#comment-16052952 ] Davor Bonaci commented on BEAM-2455: You are welcome to do so! I'd just ask you to do it in separate

  1   2   3   4   5   6   7   8   9   10   >