[BEAM-258] Configure RunnableOnService tests for Flink runner#291

Closed

kennknowles wants to merge 23 commits intoapache:masterfrom

kennknowles:flink-integration

Commits on May 13, 2016

Add Window.Bound translator to Flink batch
kennknowles
committed
Add TestFlinkPipelineRunner to FlinkRunnerRegistrar
kennknowles
committed
Configure RunnableOnService tests for Flink in batch mode
kennknowles
committed
Fix Dangling Flink DataSets

aljoscha
authored and
kennknowles
committed
Add hamcrest dep to Flink Runner

aljoscha
authored and
kennknowles
committed
Fix Flink Create and GroupByNullKeyTest, Remove Special VoidSerializer

aljoscha
authored and
kennknowles
committed
Fix faulty Flink Flatten with empty PCollectionList

aljoscha
authored and
kennknowles
committed
Fix Flink Batch Partial Combine/Combine

aljoscha
authored and
kennknowles
committed
Disable MaybeEmptyTestITCase

aljoscha
authored and
kennknowles
committed
Add RequiresFixedWindows test category
kennknowles
committed
Exclude RequiresFixedWindows test category from Flink batch tests
kennknowles
committed
Remove unused threadCount from integration tests
kennknowles
committed
Disable Flink streaming integration tests for now
kennknowles
committed
Special casing job exec AssertionError in TestFlinkPipelineRunner
kennknowles
committed
Use Int instead of Void in Combine.globally default insertion

aljoscha
authored and
kennknowles
committed
Fix accumulator update in Flink Reduce Function

aljoscha
authored and
kennknowles
committed
Use Int instead of Void in Sample

aljoscha
authored and
kennknowles
committed
Use Int instead of Void in FlattenTest

aljoscha
authored and
kennknowles
committed
Add RequiresTimestampControl category and tag some tests
kennknowles
committed
Exclude groups from Flink batch integration tests
kennknowles
committed
Fix checkstyle of FlattenTest
kennknowles
committed
Add RequiresTimestampControl to WithTimestampsTest
kennknowles
committed
Temporarily disable failing Spark streaming tests
kennknowles
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[BEAM-258] Configure RunnableOnService tests for Flink runner#291

[BEAM-258] Configure RunnableOnService tests for Flink runner#291
kennknowles wants to merge 23 commits intoapache:masterfrom
kennknowles:flink-integration

Commits on May 13, 2016

Add Window.Bound translator to Flink batch

Add TestFlinkPipelineRunner to FlinkRunnerRegistrar

Configure RunnableOnService tests for Flink in batch mode

Fix Dangling Flink DataSets

Add hamcrest dep to Flink Runner

Fix Flink Create and GroupByNullKeyTest, Remove Special VoidSerializer

Fix faulty Flink Flatten with empty PCollectionList

Fix Flink Batch Partial Combine/Combine

Disable MaybeEmptyTestITCase

Add RequiresFixedWindows test category

Exclude RequiresFixedWindows test category from Flink batch tests

Remove unused threadCount from integration tests

Disable Flink streaming integration tests for now

Special casing job exec AssertionError in TestFlinkPipelineRunner

Use Int instead of Void in Combine.globally default insertion

Fix accumulator update in Flink Reduce Function

Use Int instead of Void in Sample

Use Int instead of Void in FlattenTest

Add RequiresTimestampControl category and tag some tests

Exclude groups from Flink batch integration tests

Fix checkstyle of FlattenTest

Add RequiresTimestampControl to WithTimestampsTest

Temporarily disable failing Spark streaming tests