[GitHub] beam pull request #2151: [BEAM-1617] Add Gauge metric type to Java SDK

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2151 [BEAM-1617] Add Gauge metric type to Java SDK Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[GitHub] beam pull request #2141: [BEAM-1565] Update Spark runner PostCommit Jenkins ...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2141 [BEAM-1565] Update Spark runner PostCommit Jenkins job. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[GitHub] beam pull request #2133: [BEAM-1337] Infer state coders

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2133 [BEAM-1337] Infer state coders Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like

[GitHub] beam pull request #2111: [BEAM-351] Add DisplayData to KafkaIO

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2111 [BEAM-351] Add DisplayData to KafkaIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like

[GitHub] beam pull request #2109: [BEAM-1551] Allow `PAssert`s to take a message

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2109 [BEAM-1551] Allow `PAssert`s to take a message Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[GitHub] beam pull request #2108: [BEAM-463] [BEAM-464] [BEAM-466] BoundedHeapCoder, ...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2108 [BEAM-463] [BEAM-464] [BEAM-466] BoundedHeapCoder, HolderCoder, QuantileStateCoder -> StandardCoder Be sure to do all of the following to help us incorporate your contribution quickly

[GitHub] beam pull request #2096: [BEAM-1092] Shade commonly used libraries (e.g. Gua...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2096 [BEAM-1092] Shade commonly used libraries (e.g. Guava) to avoid class conflicts Be sure to do all of the following to help us incorporate your contribution quickly and easily

[GitHub] beam pull request #2095: [BEAM-1446] Create with TypeDescriptor

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2095 [BEAM-1446] Create with TypeDescriptor Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like

[GitHub] beam pull request #2083: Remove periods from step name in SparkBeamMetric to...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2083 Remove periods from step name in SparkBeamMetric to avoid inconsistent hierarchies in Graphite metric sink Be sure to do all of the following to help us incorporate your contribution quickly

[GitHub] beam pull request #2082: [BEAM-1397] [BEAM-1398] Introduce IO metrics. Add K...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2082 [BEAM-1397] [BEAM-1398] Introduce IO metrics. Add KafkaIO metrics. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the

[GitHub] beam pull request #2067: [BEAM-1465] No natural place to flush/close resourc...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2067 [BEAM-1465] No natural place to flush/close resources in FileBasedWriter Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure

[GitHub] beam pull request #1983: [BEAM-1466] JSON utils extension

Github user aviemzur closed the pull request at: https://github.com/apache/beam/pull/1983 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] beam pull request #1983: [BEAM-1466] JSON utils extension

GitHub user aviemzur reopened a pull request: https://github.com/apache/beam/pull/1983 [BEAM-1466] JSON utils extension Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is formatted like

[GitHub] beam pull request #2048: [BEAM-1513] Skip slower verifications if '-DskipTes...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2048 [BEAM-1513] Skip slower verifications if '-DskipTests' specified Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make s

[GitHub] beam pull request #2046: [BEAM-1512] Optimize leaf transforms materializatio...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2046 [BEAM-1512] Optimize leaf transforms materialization Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[GitHub] beam pull request #2034: More informative KafkaCheckpointMark toString

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2034 More informative KafkaCheckpointMark toString Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[GitHub] beam pull request #2033: [BEAM-1294] Long running UnboundedSource Readers vi...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/2033 [BEAM-1294] Long running UnboundedSource Readers via Broadcasts Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[GitHub] beam pull request #1986: Fixed javadoc comment in ResumeFromCheckpointStream...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/1986 Fixed javadoc comment in ResumeFromCheckpointStreamingTest. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[GitHub] beam pull request #1983: [BEAM-1466] JSON utils extension

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/1983 [BEAM-1466] JSON utils extension Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like

[GitHub] beam pull request #1962: [BEAM-1437] Spark runner StreamingListeners are not...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/1962 [BEAM-1437] Spark runner StreamingListeners are not recoverable. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[GitHub] beam pull request #1944: [BEAM-1433] Remove coder from TextIO

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/1944 [BEAM-1433] Remove coder from TextIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like

[GitHub] beam pull request #1920: [BEAM-1392] DoFn teardown not called on empty parti...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/1920 [BEAM-1392] DoFn teardown not called on empty partitions Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[GitHub] beam pull request #1906: [BEAM-1379] Shade Guava in beam-sdks-java-io-kafka ...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/1906 [BEAM-1379] Shade Guava in beam-sdks-java-io-kafka module Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[GitHub] beam pull request #1868: [BEAM-797] A PipelineVisitor that creates a Spark-n...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/1868 [BEAM-797] A PipelineVisitor that creates a Spark-native pipeline. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the

[GitHub] beam pull request #1865: [BEAM-1334] Split UsesMetrics category and tests in...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/1865 [BEAM-1334] Split UsesMetrics category and tests into UsesCommittedMetrics and UsesAttemptedMetrics Be sure to do all of the following to help us incorporate your contribution quickly and

[GitHub] beam pull request #1815: [BEAM-648] Persist and restore Aggergator values in...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/1815 [BEAM-648] Persist and restore Aggergator values in case of recovery from failure Be sure to do all of the following to help us incorporate your contribution quickly and easily

[GitHub] beam pull request #1750: [BEAM-774] Implement Metrics support for Spark runn...

GitHub user aviemzur opened a pull request: https://github.com/apache/beam/pull/1750 [BEAM-774] Implement Metrics support for Spark runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

<    1   2