[jira] [Updated] (BEAM-7805) Configure logging level in portable Spark runner

[ https://issues.apache.org/jira/browse/BEAM-7805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7805: --- Priority: Major (was: Minor) > Configure logging level in portable Spark runner >

[jira] [Commented] (BEAM-7219) Spark portable runner: support Spark metrics

[ https://issues.apache.org/jira/browse/BEAM-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052039#comment-17052039 ] Ismaël Mejía commented on BEAM-7219: It seems this is what we addressed with

[jira] [Resolved] (BEAM-6633) Spark's Validates Runner StreamingSourceMetricsTest testUnboundedSourceMetrics takes too long to complete

[ https://issues.apache.org/jira/browse/BEAM-6633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-6633. Fix Version/s: Not applicable Resolution: Fixed > Spark's Validates Runner

[jira] [Assigned] (BEAM-3044) Spark runner documentation missing information and miss reports defaults

[ https://issues.apache.org/jira/browse/BEAM-3044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-3044: -- Assignee: (was: Amit Sela) > Spark runner documentation missing information and miss

[jira] [Assigned] (BEAM-3022) Enable the ability to grow partition count in the underlying Spark RDD

[ https://issues.apache.org/jira/browse/BEAM-3022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-3022: -- Assignee: (was: Amit Sela) > Enable the ability to grow partition count in the underlying

[jira] [Assigned] (BEAM-2847) Stop streaming pipeline when global watermark reaches +INF

[ https://issues.apache.org/jira/browse/BEAM-2847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-2847: -- Assignee: (was: Amit Sela) > Stop streaming pipeline when global watermark reaches +INF >

[jira] [Assigned] (BEAM-2479) get MAX value from PCollection .apply(Combine.globally(Max.ofDoubles()))

[ https://issues.apache.org/jira/browse/BEAM-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-2479: -- Assignee: (was: Amit Sela) > get MAX value from PCollection >

[jira] [Resolved] (BEAM-2479) get MAX value from PCollection .apply(Combine.globally(Max.ofDoubles()))

[ https://issues.apache.org/jira/browse/BEAM-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-2479. Fix Version/s: Not applicable Resolution: Not A Problem > get MAX value from PCollection >

[jira] [Resolved] (BEAM-2598) SparkRunner Fn API based ParDo operator

[ https://issues.apache.org/jira/browse/BEAM-2598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-2598. Fix Version/s: Not applicable Resolution: Invalid > SparkRunner Fn API based ParDo operator

[jira] [Closed] (BEAM-2598) SparkRunner Fn API based ParDo operator

[ https://issues.apache.org/jira/browse/BEAM-2598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía closed BEAM-2598. -- > SparkRunner Fn API based ParDo operator > --- > >

[jira] [Assigned] (BEAM-1444) Flatten of Bounded and Unbounded repeats the union with the RDD for each micro-batch.

[ https://issues.apache.org/jira/browse/BEAM-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1444: -- Assignee: (was: Amit Sela) > Flatten of Bounded and Unbounded repeats the union with the

[jira] [Assigned] (BEAM-1115) Support for new Timer API in Spark runner

[ https://issues.apache.org/jira/browse/BEAM-1115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1115: -- Assignee: (was: Amit Sela) > Support for new Timer API in Spark runner >

[jira] [Assigned] (BEAM-1215) Assert over metrics sent to Graphite

[ https://issues.apache.org/jira/browse/BEAM-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1215: -- Assignee: (was: Stas Levin) > Assert over metrics sent to Graphite >

[jira] [Assigned] (BEAM-1563) Flatten Spark runner libraries.

[ https://issues.apache.org/jira/browse/BEAM-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1563: -- Assignee: (was: Amit Sela) > Flatten Spark runner libraries. >

[jira] [Assigned] (BEAM-1564) Support streaming side-inputs in the Spark runner.

[ https://issues.apache.org/jira/browse/BEAM-1564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1564: -- Assignee: (was: Amit Sela) > Support streaming side-inputs in the Spark runner. >

[jira] [Commented] (BEAM-7890) Rework dependency stack to ensure beam stay lightweight + embeddable

[ https://issues.apache.org/jira/browse/BEAM-7890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052095#comment-17052095 ] Romain Manni-Bucau commented on BEAM-7890: -- side note: still an issue and design "bug" of beam

[jira] [Resolved] (BEAM-7890) Rework dependency stack to ensure beam stay lightweight + embeddable

[ https://issues.apache.org/jira/browse/BEAM-7890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-7890. Fix Version/s: Not applicable Resolution: Won't Fix > Rework dependency stack to ensure beam

[jira] [Updated] (BEAM-7943) Spark Portable Runner flakes on KeysTest.testKeys

[ https://issues.apache.org/jira/browse/BEAM-7943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7943: --- Issue Type: Bug (was: Improvement) > Spark Portable Runner flakes on KeysTest.testKeys >

[jira] [Updated] (BEAM-7943) Spark Portable Runner flakes on KeysTest.testKeys

[ https://issues.apache.org/jira/browse/BEAM-7943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7943: --- Priority: Critical (was: Minor) > Spark Portable Runner flakes on KeysTest.testKeys >

[jira] [Resolved] (BEAM-7943) Spark Portable Runner flakes on KeysTest.testKeys

[ https://issues.apache.org/jira/browse/BEAM-7943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-7943. Fix Version/s: Not applicable Resolution: Cannot Reproduce > Spark Portable Runner flakes on

[jira] [Assigned] (BEAM-5358) Support @RequiresStableInput on Spark runner

[ https://issues.apache.org/jira/browse/BEAM-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-5358: -- Assignee: (was: Amit Sela) > Support @RequiresStableInput on Spark runner >

[jira] [Assigned] (BEAM-5682) Reshuffle causes brittle pipelines on Spark runner

[ https://issues.apache.org/jira/browse/BEAM-5682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-5682: -- Assignee: (was: Amit Sela) > Reshuffle causes brittle pipelines on Spark runner >

[jira] [Assigned] (BEAM-2789) Watermark can become unavailable for executors while it's updated with new values

[ https://issues.apache.org/jira/browse/BEAM-2789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-2789: -- Assignee: (was: Amit Sela) > Watermark can become unavailable for executors while it's

[jira] [Assigned] (BEAM-2778) Serialization stack error using spark stream

[ https://issues.apache.org/jira/browse/BEAM-2778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-2778: -- Assignee: (was: Amit Sela) > Serialization stack error using spark stream >

[jira] [Resolved] (BEAM-2778) Serialization stack error using spark stream

[ https://issues.apache.org/jira/browse/BEAM-2778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-2778. Fix Version/s: Not applicable Resolution: Cannot Reproduce > Serialization stack error

[jira] [Assigned] (BEAM-2811) Complete the removal of aggregators from Spark runner.

[ https://issues.apache.org/jira/browse/BEAM-2811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-2811: -- Assignee: (was: Amit Sela) > Complete the removal of aggregators from Spark runner. >

[jira] [Closed] (BEAM-2409) Spark runner produces exactly twice the number of results in streaming mode when use triggers to re-window results on global window.

[ https://issues.apache.org/jira/browse/BEAM-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía closed BEAM-2409. -- > Spark runner produces exactly twice the number of results in streaming mode > when use triggers to

[jira] [Updated] (BEAM-2409) Spark runner produces exactly twice the number of results in streaming mode when use triggers to re-window results on global window.

[ https://issues.apache.org/jira/browse/BEAM-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-2409: --- Fix Version/s: (was: Not applicable) > Spark runner produces exactly twice the number of results

[jira] [Resolved] (BEAM-2409) Spark runner produces exactly twice the number of results in streaming mode when use triggers to re-window results on global window.

[ https://issues.apache.org/jira/browse/BEAM-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-2409. Fix Version/s: 2.19.0 Not applicable Resolution: Fixed > Spark runner

[jira] [Assigned] (BEAM-2112) Add support for PCollectionView in spark runner in streaming mode

[ https://issues.apache.org/jira/browse/BEAM-2112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-2112: -- Assignee: (was: Amit Sela) > Add support for PCollectionView in spark runner in streaming

[jira] [Assigned] (BEAM-1591) Implement Combine optimizations for GABW in streaming.

[ https://issues.apache.org/jira/browse/BEAM-1591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1591: -- Assignee: (was: Kobi Salant) > Implement Combine optimizations for GABW in streaming. >

[jira] [Updated] (BEAM-1591) Implement Combine optimizations for GABW in streaming

[ https://issues.apache.org/jira/browse/BEAM-1591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-1591: --- Summary: Implement Combine optimizations for GABW in streaming (was: Implement Combine optimizations

[jira] [Assigned] (BEAM-1789) can't use window in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1789: -- Assignee: (was: Amit Sela) > can't use window in spark cluster module >

[jira] [Updated] (BEAM-1789) can't use window in spark cluster module

[ https://issues.apache.org/jira/browse/BEAM-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-1789: --- Summary: can't use window in spark cluster module (was: window can't not use in spark cluster

[jira] [Assigned] (BEAM-1821) SparkRunnerDebugger fails when provided with a spark context in pipeline options

[ https://issues.apache.org/jira/browse/BEAM-1821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1821: -- Assignee: (was: Kobi Salant) > SparkRunnerDebugger fails when provided with a spark

[jira] [Assigned] (BEAM-785) Enable selected ROS tests for streaming.

[ https://issues.apache.org/jira/browse/BEAM-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-785: - Assignee: (was: Amit Sela) > Enable selected ROS tests for streaming. >

[jira] [Resolved] (BEAM-913) Create the skeleton for a Dataset API Spark runner

[ https://issues.apache.org/jira/browse/BEAM-913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-913. --- Fix Version/s: Not applicable Assignee: (was: Amit Sela) Resolution: Invalid >

[jira] [Assigned] (BEAM-866) Support set/delete of timer by ID in Spark runner

[ https://issues.apache.org/jira/browse/BEAM-866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-866: - Assignee: (was: Amit Sela) > Support set/delete of timer by ID in Spark runner >

[jira] [Work logged] (BEAM-9442) Schema Select does not properly handle nested nullable fields

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

[jira] [Work logged] (BEAM-9396) Docker image names in Jenkins jobs don't match generated ones

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

[jira] [Assigned] (BEAM-6484) Spark's pipeline result throws exceptions

[ https://issues.apache.org/jira/browse/BEAM-6484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-6484: -- Assignee: (was: Amit Sela) > Spark's pipeline result throws exceptions >

[jira] [Assigned] (BEAM-5212) Update native spark metrics

[ https://issues.apache.org/jira/browse/BEAM-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-5212: -- Assignee: (was: Amit Sela) > Update native spark metrics > --- > >

[jira] [Commented] (BEAM-5212) Update native spark metrics

[ https://issues.apache.org/jira/browse/BEAM-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052041#comment-17052041 ] Ismaël Mejía commented on BEAM-5212: Is this still valid / worth? > Update native spark metrics >

[jira] [Assigned] (BEAM-4732) Failed to construct instance from factory method SparkRunner#fromOptions

[ https://issues.apache.org/jira/browse/BEAM-4732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-4732: -- Assignee: (was: Amit Sela) > Failed to construct instance from factory method

[jira] [Assigned] (BEAM-2812) Dropped windows counters / log prints no longer working

[ https://issues.apache.org/jira/browse/BEAM-2812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-2812: -- Assignee: (was: Amit Sela) > Dropped windows counters / log prints no longer working >

[jira] [Assigned] (BEAM-2464) Create.of(...) does not work as expected when spark-runner is configured to streaming mode

[ https://issues.apache.org/jira/browse/BEAM-2464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-2464: -- Assignee: (was: Stas Levin) > Create.of(...) does not work as expected when spark-runner

[jira] [Updated] (BEAM-9440) Performance Issue with Spark Runner compared with Native Spark

[ https://issues.apache.org/jira/browse/BEAM-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9440: --- Summary: Performance Issue with Spark Runner compared with Native Spark (was: Performance Issue with

[jira] [Updated] (BEAM-9440) Performance Issue with Spark Runner compared with Native Spark

[ https://issues.apache.org/jira/browse/BEAM-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9440: --- Status: Open (was: Triage Needed) > Performance Issue with Spark Runner compared with Native Spark >

[jira] [Updated] (BEAM-9440) Performance Issue with Spark Runner compared with Native Spark

[ https://issues.apache.org/jira/browse/BEAM-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9440: --- Priority: Major (was: Critical) > Performance Issue with Spark Runner compared with Native Spark >

[jira] [Resolved] (BEAM-982) Document spark configuration update

[ https://issues.apache.org/jira/browse/BEAM-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-982. --- Fix Version/s: Not applicable Resolution: Not A Problem > Document spark configuration update >

[jira] [Assigned] (BEAM-981) Not possible to directly submit a pipeline on spark cluster

[ https://issues.apache.org/jira/browse/BEAM-981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-981: - Assignee: (was: Amit Sela) > Not possible to directly submit a pipeline on spark cluster >

[jira] [Resolved] (BEAM-981) Not possible to directly submit a pipeline on spark cluster

[ https://issues.apache.org/jira/browse/BEAM-981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-981. --- Fix Version/s: Not applicable Resolution: Cannot Reproduce > Not possible to directly submit a

[jira] [Resolved] (BEAM-1557) Separate TestPipeline into 2 versions: one for users, and one for sdk/runner developers

[ https://issues.apache.org/jira/browse/BEAM-1557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-1557. Fix Version/s: Not applicable Resolution: Won't Fix We are converging now towards the

[jira] [Assigned] (BEAM-1557) Separate TestPipeline into 2 versions: one for users, and one for sdk/runner developers

[ https://issues.apache.org/jira/browse/BEAM-1557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-1557: -- Assignee: (was: Stas Levin) > Separate TestPipeline into 2 versions: one for users, and

[jira] [Updated] (BEAM-5530) Migrate to java.time lib instead of joda-time

[ https://issues.apache.org/jira/browse/BEAM-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5530: --- Component/s: sdk-java-core > Migrate to java.time lib instead of joda-time >

[jira] [Commented] (BEAM-5530) Migrate to java.time lib instead of joda-time

[ https://issues.apache.org/jira/browse/BEAM-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052158#comment-17052158 ] Ismaël Mejía commented on BEAM-5530: We can start to provide alternative methods for all of time uses

[jira] [Commented] (BEAM-5526) Make ByteBuddyDoFnInvokerFactory injection strategy configurable + drop the singleton

[ https://issues.apache.org/jira/browse/BEAM-5526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052159#comment-17052159 ] Ismaël Mejía commented on BEAM-5526: Noted above, for reference the umbrella ticket for Java 11 is

[jira] [Resolved] (BEAM-5526) Make ByteBuddyDoFnInvokerFactory injection strategy configurable + drop the singleton

[ https://issues.apache.org/jira/browse/BEAM-5526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5526. Fix Version/s: Not applicable Resolution: Won't Fix There are not plans to allow

[jira] [Resolved] (BEAM-7445) Add search field to Beam website

[ https://issues.apache.org/jira/browse/BEAM-7445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-7445. Fix Version/s: Not applicable Resolution: Fixed > Add search field to Beam website >

[jira] [Resolved] (BEAM-7355) CassandraIOTest failing in presubmit

[ https://issues.apache.org/jira/browse/BEAM-7355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-7355. Fix Version/s: Not applicable Assignee: (was: Jean-Baptiste Onofré) Resolution:

[jira] [Commented] (BEAM-9440) Performance Issue with Spark Runner compared with Native Spark

[ https://issues.apache.org/jira/browse/BEAM-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052177#comment-17052177 ] Soumabrata Chakraborty commented on BEAM-9440: -- [~iemejia] - Its not just a performance issue

[jira] [Resolved] (BEAM-5266) TextIO doen't support http schema anymore

[ https://issues.apache.org/jira/browse/BEAM-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5266. Fix Version/s: Not applicable Resolution: Invalid Beam does not have a Filesystems that

[jira] [Work logged] (BEAM-9448) Misleading log line: says "downloading" when using cache

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

[jira] [Resolved] (BEAM-2647) Improve release guide with verification step

[ https://issues.apache.org/jira/browse/BEAM-2647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-2647. Fix Version/s: Not applicable Assignee: (was: Jean-Baptiste Onofré) Resolution:

[jira] [Comment Edited] (BEAM-5266) TextIO doen't support http schema anymore

[ https://issues.apache.org/jira/browse/BEAM-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052176#comment-17052176 ] Ismaël Mejía edited comment on BEAM-5266 at 3/5/20, 2:25 PM: - Beam does not

[jira] [Assigned] (BEAM-5266) TextIO doen't support http schema anymore

[ https://issues.apache.org/jira/browse/BEAM-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-5266: -- Assignee: (was: Jean-Baptiste Onofré) > TextIO doen't support http schema anymore >

[jira] [Updated] (BEAM-5266) TextIO doen't support http schema anymore

[ https://issues.apache.org/jira/browse/BEAM-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5266: --- Labels: (was: triaged) > TextIO doen't support http schema anymore >

[jira] [Resolved] (BEAM-881) Provide a PTransform in IOs providing a "standard" Avro IndexedRecord

[ https://issues.apache.org/jira/browse/BEAM-881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-881. --- Fix Version/s: Not applicable Assignee: (was: Jean-Baptiste Onofré) Resolution:

[jira] [Work logged] (BEAM-9446) FlinkRunner discards parallelism and execution_mode_for_batch pipeline options

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

[jira] [Resolved] (BEAM-9360) Schema FieldType should not consider metadata for equivalence

[ https://issues.apache.org/jira/browse/BEAM-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jozef Vilcek resolved BEAM-9360. Fix Version/s: 2.21.0 Resolution: Fixed > Schema FieldType should not consider metadata for

[jira] [Work logged] (BEAM-8328) remove :beam-test-infra-metrics:test from build target.

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

[jira] [Closed] (BEAM-9360) Schema FieldType should not consider metadata for equivalence

[ https://issues.apache.org/jira/browse/BEAM-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jozef Vilcek closed BEAM-9360. -- > Schema FieldType should not consider metadata for equivalence >

[jira] [Updated] (BEAM-9450) Update /dist links to point to downloads.apache.org

[ https://issues.apache.org/jira/browse/BEAM-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9450: --- Status: Open (was: Triage Needed) > Update /dist links to point to downloads.apache.org >

[jira] [Created] (BEAM-9450) Update /dist links to point to downloads.apache.org

Ismaël Mejía created BEAM-9450: -- Summary: Update /dist links to point to downloads.apache.org Key: BEAM-9450 URL: https://issues.apache.org/jira/browse/BEAM-9450 Project: Beam Issue Type:

[jira] [Assigned] (BEAM-9450) Update www.apache.org/dist/ links to point to downloads.apache.org

[ https://issues.apache.org/jira/browse/BEAM-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-9450: -- Assignee: Ismaël Mejía > Update www.apache.org/dist/ links to point to downloads.apache.org >

[jira] [Updated] (BEAM-9450) Update www.apache.org/dist/ links to point to downloads.apache.org

[ https://issues.apache.org/jira/browse/BEAM-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9450: --- Summary: Update www.apache.org/dist/ links to point to downloads.apache.org (was: Update /dist links

[jira] [Comment Edited] (BEAM-9445) Preoptimize causes error with environment setup

[ https://issues.apache.org/jira/browse/BEAM-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052021#comment-17052021 ] Ismaël Mejía edited comment on BEAM-9445 at 3/5/20, 11:10 AM: -- Just for the

[jira] [Commented] (BEAM-9445) Preoptimize causes error with environment setup

[ https://issues.apache.org/jira/browse/BEAM-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052021#comment-17052021 ] Ismaël Mejía commented on BEAM-9445: Just for the sake of curiosity what is this pre_optimize setting

[jira] [Work logged] (BEAM-2546) Create InfluxDbIO

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

[jira] [Work logged] (BEAM-2546) Create InfluxDbIO

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

[jira] [Work logged] (BEAM-2546) Create InfluxDbIO

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

[jira] [Work logged] (BEAM-2546) Create InfluxDbIO

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

[jira] [Work logged] (BEAM-2546) Create InfluxDbIO

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

[jira] [Work logged] (BEAM-2546) Create InfluxDbIO

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

[jira] [Updated] (BEAM-9022) Publish spark job server container images in release process

[ https://issues.apache.org/jira/browse/BEAM-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9022: --- Fix Version/s: 2.20.0 > Publish spark job server container images in release process >

[jira] [Updated] (BEAM-9450) Update www.apache.org/dist/ links to point to downloads.apache.org

[ https://issues.apache.org/jira/browse/BEAM-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9450: --- Description: Infra is deprecating /dist for downloads, for ref

[jira] [Work logged] (BEAM-5537) Beam Dependency Update Request: google-cloud-bigquery

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

[jira] [Work logged] (BEAM-5537) Beam Dependency Update Request: google-cloud-bigquery

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

[jira] [Work logged] (BEAM-9305) Support ValueProvider for BigQuerySource query string

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

[jira] [Assigned] (BEAM-2546) Create InfluxDbIO

[ https://issues.apache.org/jira/browse/BEAM-2546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-2546: -- Assignee: Bipin Upadhyaya (was: Jean-Baptiste Onofré) > Create InfluxDbIO > -

[jira] [Updated] (BEAM-2546) Create InfluxDbIO

[ https://issues.apache.org/jira/browse/BEAM-2546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-2546: --- Fix Version/s: 2.21.0 > Create InfluxDbIO > - > > Key: BEAM-2546 >

[jira] [Work logged] (BEAM-9446) FlinkRunner discards parallelism and execution_mode_for_batch pipeline options

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

[jira] [Updated] (BEAM-9450) Update www.apache.org/dist/ links to point to downloads.apache.org

[ https://issues.apache.org/jira/browse/BEAM-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9450: --- Summary: Update www.apache.org/dist/ links to point to downloads.apache.org (was: [website] Update

[jira] [Work logged] (BEAM-9396) Docker image names in Jenkins jobs don't match generated ones

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

[jira] [Commented] (BEAM-9436) Try to avoid elements list materialization in GBK

[ https://issues.apache.org/jira/browse/BEAM-9436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051980#comment-17051980 ] Etienne Chauchot commented on BEAM-9436: Could not avoid materialization because ReduceFnRunner

[jira] [Work logged] (BEAM-9396) Docker image names in Jenkins jobs don't match generated ones

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

[jira] [Work logged] (BEAM-9305) Support ValueProvider for BigQuerySource query string

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

[jira] [Work logged] (BEAM-9450) Update www.apache.org/dist/ links to point to downloads.apache.org

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

[jira] [Resolved] (BEAM-9022) Publish spark job server container images in release process

[ https://issues.apache.org/jira/browse/BEAM-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-9022. Resolution: Fixed > Publish spark job server container images in release process >

[jira] [Updated] (BEAM-9450) Update /dist links to point to downloads.apache.org

[ https://issues.apache.org/jira/browse/BEAM-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-9450: --- Description: Infra is deprecating /dist for downloads, for ref

  1   2   3   4   >