Skip to content

Conversation

@mxm
Copy link
Contributor

@mxm mxm commented Mar 18, 2016

No description provided.

@davorbonaci
Copy link
Member

LGTM for merging at your convenience.

Jenkins shows some flakiness in the Spark runner:

Results :

Tests in error: 
  AvroPipelineTest.testGeneric:75 » Runtime java.io.IOException: Could not creat...
  NumShardsTest.testText:77 » Runtime java.io.IOException: Could not create File...
  HadoopFileFormatPipelineTest.testSequenceFile:83 » Runtime java.io.IOException...
  TransformTranslatorTest.testTextIOReadAndWriteTransforms:76->runPipeline:96 » Runtime
  KafkaStreamingTest.testRun:121 » Runtime java.io.IOException: failure to login...

Tests run: 27, Failures: 0, Errors: 5, Skipped: 0

[ERROR] There are test failures.

I've filed BEAM-133 for the test flakiness.

@asfgit asfgit merged commit 447c8af into apache:master Mar 20, 2016
asfgit pushed a commit that referenced this pull request Mar 20, 2016
@mxm mxm deleted the BEAM-116 branch March 20, 2016 18:52
@mxm
Copy link
Contributor Author

mxm commented Mar 20, 2016

Woho, my first ever merge commit :)

@davorbonaci
Copy link
Member

First time for everything ;) I had so many firsts in the last month or so.

iemejia referenced this pull request in iemejia/beam Jan 12, 2018
iemejia referenced this pull request in iemejia/beam Apr 27, 2018
Temporary fix for SDK harness container build.
mareksimunek pushed a commit to mareksimunek/beam that referenced this pull request May 9, 2018
apache#14 [euphoria-flink] Don't send timestamp along with each element.
hengfengli referenced this pull request in hengfengli/beam Mar 21, 2022
* fix: set the watermark based on partitions running

Sets the watermark of the DetectNewPartitions SDF based on the min of
the watermark of the partitions running.

* fix: catch not found error on bundle finalizer

Catches not found errors when updating the watermark of partitions in
the bundle finalizer.

* fix: do not set watermark when null

Skip setting the watermark in the DetectNewPartitions SDF when there are
no partitions left.

* refactor: move info logs to debug level

* refactor: make metrics methods non-static

This way we can have state in the metrics class.

* feat: add the option to disable metrics on demand

* fix: make change stream metrics class serializable

* feat: print the metadata table name when job start
xinyuiscool added a commit to xinyuiscool/beam that referenced this pull request Jan 14, 2023
Co-authored-by: Xinyu Liu <xiliu@xiliu-mn1.linkedin.biz>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants