See
<https://builds.apache.org/job/beam_PreCommit_Go_Cron/103/display/redirect?page=changes>
Changes:
[ankurgoenka] Warn on docker image pull fail
[s.lebedev] [BEAM-1251] Replace NameError-driven dispatch with ``past``
[altay] Install fastavro only in linux
[Pablo] [BEAM-4718]Run gradle build before publish
[Pablo] Add CODEOWNERS file (#5909)
[Pablo] Full tracking of Batch side inputs. Performance tests show no regression
------------------------------------------
[...truncated 309.21 KB...]
--- PASS:
TestGauge_Set/set_set1.load["A"]_to_1_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set1.load["A"]_to_1_at_1970-01-01_00:00:00_+0000_UTC#01
(0.00s)
--- PASS:
TestGauge_Set/set_set1.speed["A"]_to_1_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set1.speed["A"]_to_2_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set1.load["B"]_to_1_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set1.load["B"]_to_1_at_1970-01-01_00:00:00_+0000_UTC#01
(0.00s)
--- PASS:
TestGauge_Set/set_set1.speed["B"]_to_1_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set1.speed["B"]_to_2_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set2.load["A"]_to_1_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set2.load["A"]_to_1_at_1970-01-01_00:00:00_+0000_UTC#01
(0.00s)
--- PASS:
TestGauge_Set/set_set2.speed["A"]_to_1_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set2.speed["A"]_to_2_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set2.load["B"]_to_1_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set2.load["B"]_to_1_at_1970-01-01_00:00:00_+0000_UTC#01
(0.00s)
--- PASS:
TestGauge_Set/set_set2.speed["B"]_to_1_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
--- PASS:
TestGauge_Set/set_set2.speed["B"]_to_2_at_1970-01-01_00:00:00_+0000_UTC (0.00s)
=== RUN TestNameCollisions
=== RUN TestNameCollisions/Counter_name_collides_with_Counter
=== RUN TestNameCollisions/Counter_name_collides_with_Distribution
=== RUN TestNameCollisions/Counter_name_collides_with_Gauge
=== RUN TestNameCollisions/Distribution_name_collides_with_Counter
=== RUN TestNameCollisions/Distribution_name_collides_with_Distribution
=== RUN TestNameCollisions/Distribution_name_collides_with_Gauge
=== RUN TestNameCollisions/Gauge_name_collides_with_Counter
=== RUN TestNameCollisions/Gauge_name_collides_with_Distribution
=== RUN TestNameCollisions/Gauge_name_collides_with_Gauge
--- PASS: TestNameCollisions (0.00s)
--- PASS: TestNameCollisions/Counter_name_collides_with_Counter (0.00s)
metrics_test.go:291: reusing names is fine when the metrics the same
type: Counter Counter
--- PASS: TestNameCollisions/Counter_name_collides_with_Distribution (0.00s)
metrics_test.go:286: panic caught re-using a name between a Counter,
and a Distribution
--- PASS: TestNameCollisions/Counter_name_collides_with_Gauge (0.00s)
metrics_test.go:286: panic caught re-using a name between a Counter,
and a Gauge
--- PASS: TestNameCollisions/Distribution_name_collides_with_Counter (0.00s)
metrics_test.go:286: panic caught re-using a name between a
Distribution, and a Counter
--- PASS: TestNameCollisions/Distribution_name_collides_with_Distribution
(0.00s)
metrics_test.go:291: reusing names is fine when the metrics the same
type: Distribution Distribution
--- PASS: TestNameCollisions/Distribution_name_collides_with_Gauge (0.00s)
metrics_test.go:286: panic caught re-using a name between a
Distribution, and a Gauge
--- PASS: TestNameCollisions/Gauge_name_collides_with_Counter (0.00s)
metrics_test.go:286: panic caught re-using a name between a Gauge, and
a Counter
--- PASS: TestNameCollisions/Gauge_name_collides_with_Distribution (0.00s)
metrics_test.go:286: panic caught re-using a name between a Gauge, and
a Distribution
--- PASS: TestNameCollisions/Gauge_name_collides_with_Gauge (0.00s)
metrics_test.go:291: reusing names is fine when the metrics the same
type: Gauge Gauge
=== RUN TestClearBundleData
--- PASS: TestClearBundleData (0.00s)
PASS
coverage: 70.5% of statements
ok github.com/apache/beam/sdks/go/pkg/beam/core/metrics 0.008s
coverage: 70.5% of statements
> Task :beam-sdks-go:test
Test for github.com/apache/beam/sdks/go/pkg/beam/core/graph/coder finished, 5
completed, 0 failed
Result of package github.com/apache/beam/sdks/go/pkg/beam/core/metrics:
Test for github.com/apache/beam/sdks/go/pkg/beam/core/metrics finished, 6
completed, 0 failed
Result of package github.com/apache/beam/sdks/go/pkg/beam/core/runtime/exec:
=== RUN TestCombine
=== RUN TestCombine/#00
=== RUN TestCombine/#01
=== RUN TestCombine/#02
=== RUN TestCombine/#03
--- PASS: TestCombine (0.00s)
--- PASS: TestCombine/#00 (0.00s)
--- PASS: TestCombine/#01 (0.00s)
--- PASS: TestCombine/#02 (0.00s)
--- PASS: TestCombine/#03 (0.00s)
=== RUN TestLiftedCombine
=== RUN TestLiftedCombine/#00
=== RUN TestLiftedCombine/#01
=== RUN TestLiftedCombine/#02
=== RUN TestLiftedCombine/#03
--- PASS: TestLiftedCombine (0.00s)
--- PASS: TestLiftedCombine/#00 (0.00s)
--- PASS: TestLiftedCombine/#01 (0.00s)
--- PASS: TestLiftedCombine/#02 (0.00s)
--- PASS: TestLiftedCombine/#03 (0.00s)
=== RUN TestFlatten
--- PASS: TestFlatten (0.00s)
=== RUN TestInvoke
--- PASS: TestInvoke (0.00s)
=== RUN TestMultiplex
--- PASS: TestMultiplex (0.00s)
=== RUN TestParDo
--- PASS: TestParDo (0.00s)
=== RUN TestAssignWindow
--- PASS: TestAssignWindow (0.00s)
PASS
coverage: 34.1% of statements
ok github.com/apache/beam/sdks/go/pkg/beam/core/runtime/exec 0.010s
coverage: 34.1% of statements
=== RUN TestBind
--- PASS: TestBind (0.00s)
=== RUN TestBindWithTypedefs
--- PASS: TestBindWithTypedefs (0.00s)
=== RUN TestBuildValid
--- PASS: TestBuildValid (0.00s)
=== RUN TestBuildNoCoder
--- PASS: TestBuildNoCoder (0.00s)
=== RUN TestBuildUnconnectedNode
--- PASS: TestBuildUnconnectedNode (0.00s)
=== RUN TestBuildNodeNotInGraph
--- PASS: TestBuildNodeNotInGraph (0.00s)
PASS
coverage: 33.7% of statements
ok github.com/apache/beam/sdks/go/pkg/beam/core/graph 0.003s
coverage: 33.7% of statements
=== RUN TestDirectParDoAfterGBK
2018/07/13 00:03:25 Pipeline:
2018/07/13 00:03:25 Nodes: {1: []uint8/bytes GLO}
{2: int/int[varintz] GLO}
{3: KV<int,int>/KV<int[varintz],int[varintz]> GLO}
{4: CoGBK<int,int>/CoGBK<int[varintz],int[varintz]> GLO}
{5: int/int[varintz] GLO}
{6: KV<int,int>/KV<int[varintz],int[varintz]> GLO}
{7: int/int[varintz] GLO}
{8: []uint8/bytes GLO}
{9: int/int[varintz] GLO}
{10: []uint8/bytes GLO}
{11: int/int[varintz] GLO}
{12: int/int[varintz] GLO}
{13: int/int[varintz] GLO}
Edges: 1: Impulse [] -> [Out: []uint8 -> {1: []uint8/bytes GLO}]
2: ParDo [In(Main): []uint8 <- {1: []uint8/bytes GLO}] -> [Out: T -> {2:
int/int[varintz] GLO}]
3: ParDo [In(Main): T <- {2: int/int[varintz] GLO}] -> [Out: KV<int,T> -> {3:
KV<int,int>/KV<int[varintz],int[varintz]> GLO}]
4: CoGBK [In(Main): KV<int,int> <- {3:
KV<int,int>/KV<int[varintz],int[varintz]> GLO}] -> [Out: CoGBK<int,int> -> {4:
CoGBK<int,int>/CoGBK<int[varintz],int[varintz]> GLO}]
5: ParDo [In(Main): CoGBK<int,int> <- {4:
CoGBK<int,int>/CoGBK<int[varintz],int[varintz]> GLO}] -> [Out: int -> {5:
int/int[varintz] GLO}]
6: ParDo [In(Main): T <- {5: int/int[varintz] GLO}] -> [Out: KV<int,T> -> {6:
KV<int,int>/KV<int[varintz],int[varintz]> GLO}]
7: ParDo [In(Main): KV<X,Y> <- {6: KV<int,int>/KV<int[varintz],int[varintz]>
GLO}] -> [Out: Y -> {7: int/int[varintz] GLO}]
8: Impulse [] -> [Out: []uint8 -> {8: []uint8/bytes GLO}]
9: ParDo [In(Main): []uint8 <- {8: []uint8/bytes GLO}] -> [Out: T -> {9:
int/int[varintz] GLO}]
10: Impulse [] -> [Out: []uint8 -> {10: []uint8/bytes GLO}]
11: ParDo [In(Main): []uint8 <- {10: []uint8/bytes GLO} In(Iter): T <- {7:
int/int[varintz] GLO} In(Iter): T <- {9: int/int[varintz] GLO}] -> [Out: T ->
{11: int/int[varintz] GLO} Out: T -> {12: int/int[varintz] GLO} Out: T -> {13:
int/int[varintz] GLO}]
12: ParDo [In(Main): X <- {11: int/int[varintz] GLO}] -> []
13: ParDo [In(Main): X <- {13: int/int[varintz] GLO}] -> []
2018/07/13 00:03:25 Plan[plan]:
15: Impulse[0]
17: Impulse[0]
18: Impulse[0]
1: ParDo[passert.failFn] Out:[]
2: Discard
3: ParDo[passert.failFn] Out:[]
4: ParDo[passert.diffFn] Out:[1 2 3]
5: wait[2] Out:4
6: buffer[6]. wait:5 Out:4
7: buffer[7]. wait:5 Out:4
8: ParDo[beam.dropKeyFn] Out:[6]
9: ParDo[beam.addFixedKeyFn] Out:[8]
10: ParDo[regression.directCountFn] Out:[9]
11: CoGBK. Out:10
12: Inject[0]. Out:11
13: ParDo[beam.addFixedKeyFn] Out:[12]
14: ParDo[beam.createFn] Out:[13]
16: ParDo[beam.createFn] Out:[7]
2018/07/13 00:03:25 wait[5] unblocked w/ 1 [false]
2018/07/13 00:03:25 wait[5] done
--- PASS: TestDirectParDoAfterGBK (0.00s)
=== RUN TestEmitParDoAfterGBK
2018/07/13 00:03:25 Pipeline:
2018/07/13 00:03:25 Nodes: {1: []uint8/bytes GLO}
{2: int/int[varintz] GLO}
{3: KV<int,int>/KV<int[varintz],int[varintz]> GLO}
{4: CoGBK<int,int>/CoGBK<int[varintz],int[varintz]> GLO}
{5: int/int[varintz] GLO}
{6: KV<int,int>/KV<int[varintz],int[varintz]> GLO}
{7: int/int[varintz] GLO}
{8: []uint8/bytes GLO}
{9: int/int[varintz] GLO}
{10: []uint8/bytes GLO}
{11: int/int[varintz] GLO}
{12: int/int[varintz] GLO}
{13: int/int[varintz] GLO}
Edges: 1: Impulse [] -> [Out: []uint8 -> {1: []uint8/bytes GLO}]
2: ParDo [In(Main): []uint8 <- {1: []uint8/bytes GLO}] -> [Out: T -> {2:
int/int[varintz] GLO}]
3: ParDo [In(Main): T <- {2: int/int[varintz] GLO}] -> [Out: KV<int,T> -> {3:
KV<int,int>/KV<int[varintz],int[varintz]> GLO}]
4: CoGBK [In(Main): KV<int,int> <- {3:
KV<int,int>/KV<int[varintz],int[varintz]> GLO}] -> [Out: CoGBK<int,int> -> {4:
CoGBK<int,int>/CoGBK<int[varintz],int[varintz]> GLO}]
5: ParDo [In(Main): CoGBK<int,int> <- {4:
CoGBK<int,int>/CoGBK<int[varintz],int[varintz]> GLO}] -> [Out: int -> {5:
int/int[varintz] GLO}]
6: ParDo [In(Main): T <- {5: int/int[varintz] GLO}] -> [Out: KV<int,T> -> {6:
KV<int,int>/KV<int[varintz],int[varintz]> GLO}]
7: ParDo [In(Main): KV<X,Y> <- {6: KV<int,int>/KV<int[varintz],int[varintz]>
GLO}] -> [Out: Y -> {7: int/int[varintz] GLO}]
8: Impulse [] -> [Out: []uint8 -> {8: []uint8/bytes GLO}]
9: ParDo [In(Main): []uint8 <- {8: []uint8/bytes GLO}] -> [Out: T -> {9:
int/int[varintz] GLO}]
10: Impulse [] -> [Out: []uint8 -> {10: []uint8/bytes GLO}]
11: ParDo [In(Main): []uint8 <- {10: []uint8/bytes GLO} In(Iter): T <- {7:
int/int[varintz] GLO} In(Iter): T <- {9: int/int[varintz] GLO}] -> [Out: T ->
{11: int/int[varintz] GLO} Out: T -> {12: int/int[varintz] GLO} Out: T -> {13:
int/int[varintz] GLO}]
12: ParDo [In(Main): X <- {11: int/int[varintz] GLO}] -> []
13: ParDo [In(Main): X <- {13: int/int[varintz] GLO}] -> []
2018/07/13 00:03:25 Plan[plan]:
15: Impulse[0]
17: Impulse[0]
18: Impulse[0]
1: ParDo[passert.failFn] Out:[]
2: Discard
3: ParDo[passert.failFn] Out:[]
4: ParDo[passert.diffFn] Out:[1 2 3]
5: wait[2] Out:4
6: buffer[6]. wait:5 Out:4
7: buffer[7]. wait:5 Out:4
8: ParDo[beam.dropKeyFn] Out:[6]
9: ParDo[beam.addFixedKeyFn] Out:[8]
10: ParDo[regression.emitCountFn] Out:[9]
11: CoGBK. Out:10
12: Inject[0]. Out:11
13: ParDo[beam.addFixedKeyFn] Out:[12]
14: ParDo[beam.createFn] Out:[13]
16: ParDo[beam.createFn] Out:[7]
2018/07/13 00:03:25 wait[5] unblocked w/ 1 [false]
2018/07/13 00:03:25 wait[5] done
--- PASS: TestEmitParDoAfterGBK (0.00s)
PASS
coverage: 100.0% of statements
ok github.com/apache/beam/sdks/go/test/regression 0.007s coverage:
100.0% of statements
> Task :beam-sdks-go:test
Test for github.com/apache/beam/sdks/go/pkg/beam/core/runtime/exec finished, 7
completed, 0 failed
Result of package github.com/apache/beam/sdks/go/pkg/beam/core/graph:
Test for github.com/apache/beam/sdks/go/pkg/beam/core/graph finished, 6
completed, 0 failed
Result of package github.com/apache/beam/sdks/go/test/regression:
Test for github.com/apache/beam/sdks/go/test/regression finished, 2 completed,
0 failed
Generating HTML test report...
Finished generating test html results (0.076 secs) into:
<https://builds.apache.org/job/beam_PreCommit_Go_Cron/ws/src/sdks/go/.gogradle/reports/test>
:beam-sdks-go:test (Thread[Daemon worker,5,main]) completed. Took 20.244 secs.
:beam-sdks-go-examples:buildLinuxAmd64 (Thread[Task worker for ':' Thread
13,5,main]) completed. Took 33.747 secs.
:beam-sdks-go-examples:build (Thread[Task worker for ':' Thread 13,5,main])
started.
> Task :beam-sdks-go-examples:build
Caching disabled for task ':beam-sdks-go-examples:build': Caching has not been
enabled for the task
Task ':beam-sdks-go-examples:build' is not up-to-date because:
Task has not declared any outputs despite executing actions.
:beam-sdks-go-examples:build (Thread[Task worker for ':' Thread 13,5,main])
completed. Took 0.001 secs.
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':rat'.
> Found 1 files with unapproved/unknown licenses. See
> <https://builds.apache.org/job/beam_PreCommit_Go_Cron/ws/src/build/reports/rat/rat-report.txt>
* Try:
Run with --stacktrace option to get the stack trace. Run with --debug option to
get more log output. Run with --scan to get full insights.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 5.0.
See
https://docs.gradle.org/4.8/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 3m 20s
43 actionable tasks: 43 executed
Publishing build scan...
https://gradle.com/s/6pqbeovpmpekk
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
