[jira] [Commented] (BEAM-74) Testing harness for Unbounded Sources

[ https://issues.apache.org/jira/browse/BEAM-74?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132183#comment-17132183 ] Beam JIRA Bot commented on BEAM-74: --- This issue is P2 but has been unassigned without any comment for 60

[jira] [Commented] (BEAM-9913) Cross-language ValidatesRunner tests are failing due to failure of ':sdks:java:container:pullLicenses'

[ https://issues.apache.org/jira/browse/BEAM-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132196#comment-17132196 ] Beam JIRA Bot commented on BEAM-9913: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-3568) Overlapping sessions with zero allowed lateness due to window expiry rules

[ https://issues.apache.org/jira/browse/BEAM-3568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3568: Labels: stale-assigned (was: ) > Overlapping sessions with zero allowed lateness due to win

[jira] [Updated] (BEAM-3935) FileChannel instance should be closed in ArtifactServiceStager#StagingCallable#get

[ https://issues.apache.org/jira/browse/BEAM-3935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3935: Labels: stale-assigned (was: ) > FileChannel instance should be closed in > ArtifactService

[jira] [Updated] (BEAM-783) Revisit View.AsSingleton custom transform in Apex runner

[ https://issues.apache.org/jira/browse/BEAM-783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-783: --- Labels: stale-assigned (was: ) > Revisit View.AsSingleton custom transform in Apex run

[jira] [Updated] (BEAM-91) Retractions

[ https://issues.apache.org/jira/browse/BEAM-91?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-91: -- Labels: stale-P2 (was: ) > Retractions > --- > >

[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=17132390#comment-17132390 ] Beam JIRA Bot commented on BEAM-2466: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-2457) Error: "Unable to find registrar for hdfs" - need to prevent/improve error message

[ https://issues.apache.org/jira/browse/BEAM-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132391#comment-17132391 ] Beam JIRA Bot commented on BEAM-2457: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-9886) ReadFromBigQuery should auto-infer which project to bill for BQ exports

[ https://issues.apache.org/jira/browse/BEAM-9886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9886: Labels: stale-assigned (was: ) > ReadFromBigQuery should auto-infer which project to bill for

[jira] [Updated] (BEAM-4275) Pubsub: add DirectRunner support for id_label and timestamp_attribute in Python SDK

[ https://issues.apache.org/jira/browse/BEAM-4275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4275: Labels: stale-assigned (was: ) > Pubsub: add DirectRunner support for id_la

[jira] [Commented] (BEAM-10) Create OSGi/Karaf runner

[ https://issues.apache.org/jira/browse/BEAM-10?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132528#comment-17132528 ] Beam JIRA Bot commented on BEAM-10: --- This issue is assigned but has not received an update in 30 days so

[jira] [Updated] (BEAM-765) TriggerStateMachine does not need to be separate from OnceTriggerStateMachine

[ https://issues.apache.org/jira/browse/BEAM-765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-765: --- Labels: stale-assigned (was: ) > TriggerStateMachine does not need to be separate f

[jira] [Updated] (BEAM-1181) Investigate: does BigQueryIO honor write disposition in all cases?

[ https://issues.apache.org/jira/browse/BEAM-1181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1181: Labels: stale-assigned triaged (was: triaged) > Investigate: does BigQueryIO honor wr

[jira] [Commented] (BEAM-699) Add JpaIO

[ https://issues.apache.org/jira/browse/BEAM-699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132507#comment-17132507 ] Beam JIRA Bot commented on BEAM-699: This issue is assigned but has not received an update in 30 days

[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=17132441#comment-17132441 ] Beam JIRA Bot commented on BEAM-1754: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-3971) Pipeline translation utilities should not use SDK construction classes

[ https://issues.apache.org/jira/browse/BEAM-3971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3971: Labels: stale-assigned (was: ) > Pipeline translation utilities should not use SDK construct

[jira] [Commented] (BEAM-1376) Move website job definitions to main Beam repo

[ https://issues.apache.org/jira/browse/BEAM-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132465#comment-17132465 ] Beam JIRA Bot commented on BEAM-1376: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-2315) Add ValidatesRunner test for non-blocking job submission

[ https://issues.apache.org/jira/browse/BEAM-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2315: Labels: stale-assigned (was: ) > Add ValidatesRunner test for non-blocking job submiss

[jira] [Updated] (BEAM-31) When triggers are changed via pipeline update, stale finished triggers data applied

[ https://issues.apache.org/jira/browse/BEAM-31?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-31: -- Labels: Triggers Update stale-P2 (was: Triggers Update) > When triggers are changed via pipeline upd

[jira] [Commented] (BEAM-361) Batch Pub/Sub sink does not set idLabel

[ https://issues.apache.org/jira/browse/BEAM-361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132524#comment-17132524 ] Beam JIRA Bot commented on BEAM-361: This issue is assigned but has not received an update in 30 days

[jira] [Updated] (BEAM-2402) Support AfterPane.elementGapAtMost() trigger and its combination with elementCountAtLeast()

[ https://issues.apache.org/jira/browse/BEAM-2402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2402: Labels: stale-assigned (was: ) > Support AfterPane.elementGapAtMost() trigger and its combinat

[jira] [Commented] (BEAM-1140) Apex ParDoBoundTranslatorTest.testMultiOutputParDoWithSideInputs is flaky

[ https://issues.apache.org/jira/browse/BEAM-1140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132485#comment-17132485 ] Beam JIRA Bot commented on BEAM-1140: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-1534) Create a dockerized developer environment for Beam

[ https://issues.apache.org/jira/browse/BEAM-1534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1534: Labels: stale-assigned (was: ) > Create a dockerized developer environment for B

[jira] [Updated] (BEAM-2414) Add TwitterIO

[ https://issues.apache.org/jira/browse/BEAM-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2414: Labels: stale-assigned (was: ) > Add TwitterIO > - > > Ke

[jira] [Updated] (BEAM-2668) JStormPipelineTranslator: use urnEqualTo instead of classEqualTo to support other languages (Python).

[ https://issues.apache.org/jira/browse/BEAM-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2668: Labels: stale-assigned (was: ) > JStormPipelineTranslator: use urnEqualTo instead of classEqua

[jira] [Updated] (BEAM-1344) Uniform metrics step name semantics

[ https://issues.apache.org/jira/browse/BEAM-1344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1344: Labels: stale-assigned (was: ) > Uniform metrics step name semant

[jira] [Commented] (BEAM-2632) TextIOReadTest creates pipelines with non-unique application names

[ https://issues.apache.org/jira/browse/BEAM-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132379#comment-17132379 ] Beam JIRA Bot commented on BEAM-2632: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-9665) BeamSqlUnparseContext SqlBasicCall cast to SqlIdentifier

[ https://issues.apache.org/jira/browse/BEAM-9665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9665: Labels: stale-assigned zetasql-compliance (was: zetasql-compliance) > BeamSqlUnparseCont

[jira] [Commented] (BEAM-2037) PTransform identifier(name) documentation in Java SDK.

[ https://issues.apache.org/jira/browse/BEAM-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132422#comment-17132422 ] Beam JIRA Bot commented on BEAM-2037: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-1974) Metrics documentation

[ https://issues.apache.org/jira/browse/BEAM-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132429#comment-17132429 ] Beam JIRA Bot commented on BEAM-1974: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-1306) Support additional configuration in BigQueryServices.insertAll()

[ https://issues.apache.org/jira/browse/BEAM-1306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1306: Labels: stale-assigned (was: ) > Support additional configuration in BigQueryServices.insert

[jira] [Commented] (BEAM-4195) Support Pubsub emulator in Junit

[ https://issues.apache.org/jira/browse/BEAM-4195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132230#comment-17132230 ] Beam JIRA Bot commented on BEAM-4195: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-1065) FileBasedSource: replace SeekableByteChannel with open(spec, startingPosition)

[ https://issues.apache.org/jira/browse/BEAM-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132488#comment-17132488 ] Beam JIRA Bot commented on BEAM-1065: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-4065) Performance Tests Results Analysis and Regression Detection

[ https://issues.apache.org/jira/browse/BEAM-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4065: Labels: stale-assigned (was: ) > Performance Tests Results Analysis and Regression Detect

[jira] [Commented] (BEAM-165) Add Hadoop MapReduce runner

[ https://issues.apache.org/jira/browse/BEAM-165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132525#comment-17132525 ] Beam JIRA Bot commented on BEAM-165: This issue is assigned but has not received an update in 30 days

[jira] [Updated] (BEAM-2231) ApiSurface should be lazy

[ https://issues.apache.org/jira/browse/BEAM-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2231: Labels: stale-assigned (was: ) > ApiSurface should be l

[jira] [Updated] (BEAM-3996) Invalid test util ResourceIdTester#ValidateFailureResolvingIds

[ https://issues.apache.org/jira/browse/BEAM-3996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3996: Labels: stale-assigned triaged (was: triaged) > Invalid test util ResourceIdTes

[jira] [Updated] (BEAM-719) Run WindowedWordCount Integration Test in Spark Streaming

[ https://issues.apache.org/jira/browse/BEAM-719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-719: --- Labels: stale-assigned (was: ) > Run WindowedWordCount Integration Test in Spark Stream

[jira] [Updated] (BEAM-2629) Adding timestamp and id attributes to pubsub messages with no other attributes causes an exception.

[ https://issues.apache.org/jira/browse/BEAM-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2629: Labels: stale-assigned (was: ) > Adding timestamp and id attributes to pubsub messa

[jira] [Updated] (BEAM-3429) TextIO.Write not handling URI properly

[ https://issues.apache.org/jira/browse/BEAM-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3429: Labels: stale-assigned (was: ) > TextIO.Write not handling URI prope

[jira] [Commented] (BEAM-3167) Update BigQueryIO to support schema auto detection when executing load jobs

[ https://issues.apache.org/jira/browse/BEAM-3167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132322#comment-17132322 ] Beam JIRA Bot commented on BEAM-3167: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-2146) Continuously run ValidatesRunner suite on Dataflow forcing streaming mode

[ https://issues.apache.org/jira/browse/BEAM-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2146: Labels: stale-assigned (was: ) > Continuously run ValidatesRunner suite on Dataflow forc

[jira] [Updated] (BEAM-9910) Add byte counters to SpannerIO.write

[ https://issues.apache.org/jira/browse/BEAM-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-9910: Labels: stale-assigned (was: ) > Add byte counters to SpannerIO.wr

[jira] [Updated] (BEAM-1263) Add Jenkins Suites for Performance Tests

[ https://issues.apache.org/jira/browse/BEAM-1263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1263: Labels: stale-assigned (was: ) > Add Jenkins Suites for Performance Te

[jira] [Updated] (BEAM-2535) Allow explicit output time independent of firing specification for all timers

[ https://issues.apache.org/jira/browse/BEAM-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2535: Labels: stale-assigned (was: ) > Allow explicit output time independent of firing specificat

[jira] [Commented] (BEAM-2688) All IOs should log messages

[ https://issues.apache.org/jira/browse/BEAM-2688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132366#comment-17132366 ] Beam JIRA Bot commented on BEAM-2688: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-3280) There are no examples or tests about how to use typehints with TaggedOutput

[ https://issues.apache.org/jira/browse/BEAM-3280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132310#comment-17132310 ] Beam JIRA Bot commented on BEAM-3280: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-21) Add SocketStream IO

[ https://issues.apache.org/jira/browse/BEAM-21?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-21: -- Labels: stale-P2 (was: ) > Add SocketStream IO > --- > >

[jira] [Commented] (BEAM-21) Add SocketStream IO

[ https://issues.apache.org/jira/browse/BEAM-21?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132192#comment-17132192 ] Beam JIRA Bot commented on BEAM-21: --- This issue is P2 but has been unassigned without any comment for 60

[jira] [Commented] (BEAM-3220) Design for runner comparison with narrative intro for each runner

[ https://issues.apache.org/jira/browse/BEAM-3220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132319#comment-17132319 ] Beam JIRA Bot commented on BEAM-3220: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-4263) BigQuery connector reads the table size value from a deprecated field

[ https://issues.apache.org/jira/browse/BEAM-4263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4263: Labels: stale-assigned (was: ) > BigQuery connector reads the table size value from a depreca

[jira] [Commented] (BEAM-2832) Python wordcount example snippets do not match real example code

[ https://issues.apache.org/jira/browse/BEAM-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132343#comment-17132343 ] Beam JIRA Bot commented on BEAM-2832: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-3421) Have the pipeline supply beam-sdks-java-harness instead of embedding it within the beam-sdks-java-container

[ https://issues.apache.org/jira/browse/BEAM-3421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3421: Labels: portability stale-assigned (was: portability) > Have the pipeline supply beam-sdks-j

[jira] [Updated] (BEAM-75) Running tests of dynamic work rebalancing

[ https://issues.apache.org/jira/browse/BEAM-75?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-75: -- Labels: stale-P2 (was: ) > Running tests of dynamic work rebalanc

[jira] [Commented] (BEAM-4093) Support Python ValidatesRunner test against TestDataflowRunner in streaming

[ https://issues.apache.org/jira/browse/BEAM-4093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132244#comment-17132244 ] Beam JIRA Bot commented on BEAM-4093: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-2167) Add appropriate display data to BigQueryIO and tests.

[ https://issues.apache.org/jira/browse/BEAM-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132414#comment-17132414 ] Beam JIRA Bot commented on BEAM-2167: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-2666) JStorm runner: add runner users guide under documentation/runners

[ https://issues.apache.org/jira/browse/BEAM-2666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132373#comment-17132373 ] Beam JIRA Bot commented on BEAM-2666: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-2980) BagState.isEmpty needs a tighter spec

[ https://issues.apache.org/jira/browse/BEAM-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2980: Labels: stale-assigned (was: ) > BagState.isEmpty needs a tighter s

[jira] [Commented] (BEAM-2668) JStormPipelineTranslator: use urnEqualTo instead of classEqualTo to support other languages (Python).

[ https://issues.apache.org/jira/browse/BEAM-2668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132370#comment-17132370 ] Beam JIRA Bot commented on BEAM-2668: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-719) Run WindowedWordCount Integration Test in Spark Streaming

[ https://issues.apache.org/jira/browse/BEAM-719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132506#comment-17132506 ] Beam JIRA Bot commented on BEAM-719: This issue is assigned but has not received an update in 30 days

[jira] [Commented] (BEAM-3320) DataflowRunner for python streaming uses portable containers

[ https://issues.apache.org/jira/browse/BEAM-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132308#comment-17132308 ] Beam JIRA Bot commented on BEAM-3320: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-9894) Add batch SnowflakeIO.Write to Java SDK

[ https://issues.apache.org/jira/browse/BEAM-9894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132205#comment-17132205 ] Beam JIRA Bot commented on BEAM-9894: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-3353) Prohibit stacked GBKs with accumulating mode

[ https://issues.apache.org/jira/browse/BEAM-3353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132306#comment-17132306 ] Beam JIRA Bot commented on BEAM-3353: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-2773) Add Apache RocketMQ IO plugin

[ https://issues.apache.org/jira/browse/BEAM-2773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132352#comment-17132352 ] Beam JIRA Bot commented on BEAM-2773: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-1589) Add OnWindowExpiration method to Stateful DoFn

[ https://issues.apache.org/jira/browse/BEAM-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1589: Labels: stale-assigned (was: ) > Add OnWindowExpiration method to Stateful D

[jira] [Updated] (BEAM-3685) It should be an error to run a Pipeline without ever specifying options

[ https://issues.apache.org/jira/browse/BEAM-3685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3685: Labels: beginner newbie stale-assigned starter (was: beginner newbie starter) > It sho

[jira] [Commented] (BEAM-3772) BigQueryIO - Can't use DynamicDestination with CREATE_IF_NEEDED for unbounded PCollection and FILE_LOADS

[ https://issues.apache.org/jira/browse/BEAM-3772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132277#comment-17132277 ] Beam JIRA Bot commented on BEAM-3772: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-1391) Provide nonce via Context to Sources

[ https://issues.apache.org/jira/browse/BEAM-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132464#comment-17132464 ] Beam JIRA Bot commented on BEAM-1391: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-1209) GcsUtil can try to execute empty batches in some cases.

[ https://issues.apache.org/jira/browse/BEAM-1209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1209: Labels: stale-assigned (was: ) > GcsUtil can try to execute empty batches in some ca

[jira] [Commented] (BEAM-3549) Move KinesisIO into the amazon-web-services module

[ https://issues.apache.org/jira/browse/BEAM-3549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132297#comment-17132297 ] Beam JIRA Bot commented on BEAM-3549: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-2888) Runner Comparison / Capability Matrix revamp

[ https://issues.apache.org/jira/browse/BEAM-2888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2888: Labels: gsod gsod2019 stale-assigned (was: gsod gsod2019) > Runner Comparison / Capability Mat

[jira] [Work logged] (BEAM-10209) Add without_defaults to Mean

[ https://issues.apache.org/jira/browse/BEAM-10209?focusedWorklogId=443868=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-443868 ] ASF GitHub Bot logged work on BEAM-10209: - Author: ASF GitHub Bot

[jira] [Updated] (BEAM-2167) Add appropriate display data to BigQueryIO and tests.

[ https://issues.apache.org/jira/browse/BEAM-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2167: Labels: stale-assigned (was: ) > Add appropriate display data to BigQueryIO and te

[jira] [Updated] (BEAM-4433) Nexmark Configuration should be an immutable object and clean from repeated options

[ https://issues.apache.org/jira/browse/BEAM-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4433: Labels: stale-assigned (was: ) > Nexmark Configuration should be an immutable object and cl

[jira] [Commented] (BEAM-1894) Race conditions in python direct runner eager mode

[ https://issues.apache.org/jira/browse/BEAM-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132434#comment-17132434 ] Beam JIRA Bot commented on BEAM-1894: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-2675) Consolidate ValidatesRunner Groovy Definitions

[ https://issues.apache.org/jira/browse/BEAM-2675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2675: Labels: stale-assigned (was: ) > Consolidate ValidatesRunner Groovy Definiti

[jira] [Updated] (BEAM-4047) TransformExecutorServices should use Executor, not ExecutorService

[ https://issues.apache.org/jira/browse/BEAM-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4047: Labels: stale-assigned (was: ) > TransformExecutorServices should use Execu

[jira] [Updated] (BEAM-1289) TextIO (and others) should provide more informative messages when encountering RVP

[ https://issues.apache.org/jira/browse/BEAM-1289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-1289: Labels: stale-assigned starter (was: starter) > TextIO (and others) should provide m

[jira] [Commented] (BEAM-2633) Update contribution guide to include information on running wordcount with modified sdk from head

[ https://issues.apache.org/jira/browse/BEAM-2633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132378#comment-17132378 ] Beam JIRA Bot commented on BEAM-2633: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-1604) Enable Self-Hosted Beam Execution Engine in PKB

[ https://issues.apache.org/jira/browse/BEAM-1604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132451#comment-17132451 ] Beam JIRA Bot commented on BEAM-1604: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-2631) ParDo processing timer need more tests.

[ https://issues.apache.org/jira/browse/BEAM-2631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132380#comment-17132380 ] Beam JIRA Bot commented on BEAM-2631: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-4043) Remove 'manual' teardown from SolrIO tests

[ https://issues.apache.org/jira/browse/BEAM-4043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132250#comment-17132250 ] Beam JIRA Bot commented on BEAM-4043: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-4192) Pubsub benchmarks in Nexmark

[ https://issues.apache.org/jira/browse/BEAM-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4192: Labels: stale-assigned triaged (was: triaged) > Pubsub benchmarks in Nexm

[jira] [Updated] (BEAM-4441) Incorrect coder inference for List and Tuple typehints.

[ https://issues.apache.org/jira/browse/BEAM-4441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-4441: Labels: stale-assigned (was: ) > Incorrect coder inference for List and Tuple typehi

[jira] [Commented] (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:comment-tabpanel=17132447#comment-17132447 ] Beam JIRA Bot commented on BEAM-1609: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-4115) Go SDK - Vanity Import Path

[ https://issues.apache.org/jira/browse/BEAM-4115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132237#comment-17132237 ] Beam JIRA Bot commented on BEAM-4115: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-221) ProtoIO

[ https://issues.apache.org/jira/browse/BEAM-221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-221: --- Labels: newbie stale-assigned starter (was: newbie starter) > Prot

[jira] [Updated] (BEAM-861) PTranform name uniqueness javadoc

[ https://issues.apache.org/jira/browse/BEAM-861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-861: --- Labels: stale-assigned (was: ) > PTranform name uniqueness java

[jira] [Updated] (BEAM-3269) Occasional ClassCastException in ParDoTranslatorTest.testAssertionFailure

[ https://issues.apache.org/jira/browse/BEAM-3269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3269: Labels: stale-assigned (was: ) > Occasional ClassCastExcept

[jira] [Updated] (BEAM-2385) IO authoring overview - improve steps for beginners

[ https://issues.apache.org/jira/browse/BEAM-2385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2385: Labels: stale-P2 (was: ) > IO authoring overview - improve steps for beginn

[jira] [Updated] (BEAM-2519) Record type of state in Python InMemoryUnmergedState

[ https://issues.apache.org/jira/browse/BEAM-2519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-2519: Labels: stale-P2 (was: ) > Record type of state in Python InMemoryUnmergedSt

[jira] [Updated] (BEAM-3653) Port BatchViewOverridesTest off DoFnTester

[ https://issues.apache.org/jira/browse/BEAM-3653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3653: Labels: beginner newbie stale-assigned starter (was: beginner newbie starter) > P

[jira] [Updated] (BEAM-3192) Be able to specify the Spark Partitioner via the pipeline options

[ https://issues.apache.org/jira/browse/BEAM-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3192: Labels: stale-assigned (was: ) > Be able to specify the Spark Partitioner via the pipeline opti

[jira] [Commented] (BEAM-4215) Resolve dependency warnings during Python SDK installation

[ https://issues.apache.org/jira/browse/BEAM-4215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132231#comment-17132231 ] Beam JIRA Bot commented on BEAM-4215: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-2266) WordCount on ApexRunner writes one word count per file

[ https://issues.apache.org/jira/browse/BEAM-2266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132410#comment-17132410 ] Beam JIRA Bot commented on BEAM-2266: - This issue is assigned but has not received an update in 30

[jira] [Commented] (BEAM-3429) TextIO.Write not handling URI properly

[ https://issues.apache.org/jira/browse/BEAM-3429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132302#comment-17132302 ] Beam JIRA Bot commented on BEAM-3429: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-3810) Add new matcher to check output file content for WordCountIT and WindowedWordCountIT

[ https://issues.apache.org/jira/browse/BEAM-3810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3810: Labels: stale-assigned (was: ) > Add new matcher to check output file content for WordCoun

[jira] [Commented] (BEAM-1888) Support Splittable DoFn in Apex Runner

[ https://issues.apache.org/jira/browse/BEAM-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132435#comment-17132435 ] Beam JIRA Bot commented on BEAM-1888: - This issue is assigned but has not received an update in 30

[jira] [Updated] (BEAM-3152) AfterProcessingTime trigger doesn't create any file panes

[ https://issues.apache.org/jira/browse/BEAM-3152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3152: Labels: stale-assigned (was: ) > AfterProcessingTime trigger doesn't create any file pa

[jira] [Updated] (BEAM-3352) Look into adding README in beam/examples so Python examples are more discoverable

[ https://issues.apache.org/jira/browse/BEAM-3352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-3352: Labels: stale-assigned (was: ) > Look into adding README in beam/examples so Python examp

<    1   2   3   4   5   6   7   8   9   10   >