See 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/1627/display/redirect?page=changes>

Changes:

[geet.kumar75] BEAM-4038: Support Kafka Headers in KafkaIO

[geet.kumar75] BEAM-4038: Update license information

[geet.kumar75] Update code formatting

[geet.kumar75] Remove custom implementations of KafkaHeader, KafkaHeaders, etc.

[geet.kumar75] Changes based on review comments

[daniel.o.programmer] [BEAM-3513] Removing PrimitiveCombineGroupedValues 
override w/ FnAPI.

[echauchot] Introduce MetricsPusher in runner core to regularly push aggregated

[echauchot] Instanciate MetricsPusher in runner-specific code because we need

[echauchot] Improve MetricsPusher: do not aggregate metrics when not needed, 
improve

[echauchot] Create JsonMetricsSerializer

[echauchot] Stop MetricsPusher thread by observing pipeline state and improve 
the

[echauchot] Make metrics sink configurable through PipelineOptions, pass

[echauchot] Add MetricsPusher tests specific to Spark (because Spark streaming 
tests

[echauchot] Add a MetricksPusher test to runner-core (batch and streaming are 
done

[echauchot] Push metrics at the end of a batch pipeline in flink runner

[echauchot] improve MetricsPusher lifecycle and thread safety

[echauchot] Make MetricsPusher merge a list a MetricsContainerStepMaps because 
there

[echauchot] Fix thread synchronisation and replace usages of instance variable 
by

[echauchot] Clear dummyMetricsSink before test

[echauchot] Push metrics at the end of a batch pipeline in spark runner

[echauchot] Improve MetricsPusher teardown to enable multiple pipelines in a 
single

[echauchot] Manually generate json and remove jackson

[echauchot] Replace use of http client by use of java.net.HttpUrlConnection and 
deal

[echauchot] Remove DEFAULT_PERIOD constant in favor of already existing

[echauchot] Remove unneeded null check, format

[echauchot] convert MetricsSink to an interface with a single writeMetrics 
method

[echauchot] Remove MetricsSerializer base class and inline serialization in

[echauchot] Dynamically create the sinks by reflection

[echauchot] Split DummyMetricsSink into NoOpMetricsSink (default sink) and

[echauchot] Reduce overhead when no metricsSink is provided, do not start 
polling

[echauchot] Make MetricsPusher a regular object instead of a singleton to allow

[echauchot] Explicitely start MetricsPusher from the runners

[echauchot] Separate MetricsHttpSink POC to a new runners-extensions artifact 
and

[echauchot] Fix cycle bug between teardown() and pushmetrics()

[echauchot] Update MetricsPusher and TestMetricsSink to new serializable

[echauchot] Use regular jackson object mapper to serialize metrics now that 
they are

[echauchot] Give MetricsPusher a bit of time to push before assert in test

[echauchot] Make MetricsPusher thread a daemon

[echauchot] Fix build and clean: dependencies, rat, checkstyle, findbugs, remove

[geet.kumar75] Support kafka versions 0.10.1.0 and above

[echauchot] Move build to gradle

[echauchot] MetricsSink no more needs to be generic

[echauchot] SparkRunnerDebugger does not need to export metrics as it does not 
run

[tgroh] Use Existing Matchers in WatermarkManagerTest

[echauchot] Move MetricsHttpSink and related classes to a new sub-module

[kirpichov] Consistently handle EmptyMatchTreatment

[rangadi] Add 10 millis sleep when there are no elements left in a partition.

------------------------------------------
[...truncated 69.74 KB...]
2018-04-24 00:17:50,212 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:18:15,592 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:18:19,180 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r7575b9ff5d12d2be_00000162f503e5e3_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r7575b9ff5d12d2be_00000162f503e5e3_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r7575b9ff5d12d2be_00000162f503e5e3_1 ... (0s) Current status: DONE   
2018-04-24 00:18:19,180 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:18:49,107 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:18:52,674 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r2462e8db5cfb9f42_00000162f5046913_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r2462e8db5cfb9f42_00000162f5046913_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r2462e8db5cfb9f42_00000162f5046913_1 ... (0s) Current status: DONE   
2018-04-24 00:18:52,674 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:19:18,851 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:19:22,276 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r4d6c79f6698db4b0_00000162f504dcef_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r4d6c79f6698db4b0_00000162f504dcef_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r4d6c79f6698db4b0_00000162f504dcef_1 ... (0s) Current status: DONE   
2018-04-24 00:19:22,276 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:19:50,254 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:19:53,601 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_ra1a446f62d7b944_00000162f5055704_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_ra1a446f62d7b944_00000162f5055704_1 
... (0s) Current status: RUNNING                                                
                                     Waiting on 
bqjob_ra1a446f62d7b944_00000162f5055704_1 ... (0s) Current status: DONE   
2018-04-24 00:19:53,602 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:20:10,105 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:20:13,643 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r7ee5e43f767728cb_00000162f505a48c_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r7ee5e43f767728cb_00000162f505a48c_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r7ee5e43f767728cb_00000162f505a48c_1 ... (0s) Current status: DONE   
2018-04-24 00:20:13,643 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:20:33,119 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:20:36,500 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r7c1b35fee44eba92_00000162f505fe74_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r7c1b35fee44eba92_00000162f505fe74_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r7c1b35fee44eba92_00000162f505fe74_1 ... (0s) Current status: DONE   
2018-04-24 00:20:36,500 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:20:55,367 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:20:58,634 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r1a86aab6d73a6ce0_00000162f506555e_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r1a86aab6d73a6ce0_00000162f506555e_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r1a86aab6d73a6ce0_00000162f506555e_1 ... (0s) Current status: DONE   
2018-04-24 00:20:58,634 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:21:28,190 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:21:31,369 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r6cd4cf55ec8d6489_00000162f506d596_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r6cd4cf55ec8d6489_00000162f506d596_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r6cd4cf55ec8d6489_00000162f506d596_1 ... (0s) Current status: DONE   
2018-04-24 00:21:31,369 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:21:49,441 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:21:52,587 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r3e1be144413c55fd_00000162f507288e_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r3e1be144413c55fd_00000162f507288e_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r3e1be144413c55fd_00000162f507288e_1 ... (0s) Current status: DONE   
2018-04-24 00:21:52,588 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:22:19,210 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:22:22,388 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r2760f7dd0cf8244c_00000162f5079cdf_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r2760f7dd0cf8244c_00000162f5079cdf_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r2760f7dd0cf8244c_00000162f5079cdf_1 ... (0s) Current status: DONE   
2018-04-24 00:22:22,388 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:22:51,215 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:22:54,552 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r51f025f830665beb_00000162f50819e1_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r51f025f830665beb_00000162f50819e1_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r51f025f830665beb_00000162f50819e1_1 ... (0s) Current status: DONE   
2018-04-24 00:22:54,553 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:23:12,083 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:23:15,421 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_re7f569f1edb96d8_00000162f5086b65_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_re7f569f1edb96d8_00000162f5086b65_1 
... (0s) Current status: RUNNING                                                
                                     Waiting on 
bqjob_re7f569f1edb96d8_00000162f5086b65_1 ... (0s) Current status: DONE   
2018-04-24 00:23:15,422 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:23:31,275 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:23:34,616 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r821c30cd3399c5d_00000162f508b669_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r821c30cd3399c5d_00000162f508b669_1 
... (0s) Current status: RUNNING                                                
                                     Waiting on 
bqjob_r821c30cd3399c5d_00000162f508b669_1 ... (0s) Current status: DONE   
2018-04-24 00:23:34,617 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:23:55,779 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:23:59,644 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r2b3c3413c5ee0c6a_00000162f5091896_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r2b3c3413c5ee0c6a_00000162f5091896_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r2b3c3413c5ee0c6a_00000162f5091896_1 ... (0s) Current status: DONE   
2018-04-24 00:23:59,644 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:24:22,261 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:24:26,689 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r44b92973b7bfc5be_00000162f5097d88_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r44b92973b7bfc5be_00000162f5097d88_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r44b92973b7bfc5be_00000162f5097d88_1 ... (1s) Current status: RUNNING     
                                                                                
 Waiting on bqjob_r44b92973b7bfc5be_00000162f5097d88_1 ... (1s) Current status: 
DONE   
2018-04-24 00:24:26,690 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:24:45,124 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:24:48,684 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r12ffea5c1b990291_00000162f509d7d0_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r12ffea5c1b990291_00000162f509d7d0_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r12ffea5c1b990291_00000162f509d7d0_1 ... (0s) Current status: DONE   
2018-04-24 00:24:48,684 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:25:06,412 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:25:10,032 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r8dc29e00a9680c3_00000162f50a2afa_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r8dc29e00a9680c3_00000162f50a2afa_1 
... (0s) Current status: RUNNING                                                
                                     Waiting on 
bqjob_r8dc29e00a9680c3_00000162f50a2afa_1 ... (0s) Current status: DONE   
2018-04-24 00:25:10,032 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:25:31,297 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:25:34,781 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r6035179c65cd6349_00000162f50a8b30_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r6035179c65cd6349_00000162f50a8b30_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r6035179c65cd6349_00000162f50a8b30_1 ... (0s) Current status: DONE   
2018-04-24 00:25:34,781 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:25:50,719 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:25:54,588 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r1f0cbec8f7564956_00000162f50ad893_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r1f0cbec8f7564956_00000162f50ad893_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r1f0cbec8f7564956_00000162f50ad893_1 ... (0s) Current status: DONE   
2018-04-24 00:25:54,588 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:26:15,275 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:26:18,906 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r753f85abf1bae1f2_00000162f50b37ed_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r753f85abf1bae1f2_00000162f50b37ed_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r753f85abf1bae1f2_00000162f50b37ed_1 ... (0s) Current status: DONE   
2018-04-24 00:26:18,906 50988614 MainThread INFO     Retrying exception running 
IssueRetryableCommand: Command returned a non-zero exit code.

2018-04-24 00:26:37,982 50988614 MainThread INFO     Running: bq load 
--autodetect --source_format=NEWLINE_DELIMITED_JSON 
beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json>
2018-04-24 00:26:41,602 50988614 MainThread INFO     Ran: {bq load --autodetect 
--source_format=NEWLINE_DELIMITED_JSON beam_performance.pkb_results 
<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/runs/50988614/perfkit-bq-pubhyk_ye.json}>
  ReturnCode:1
STDOUT: 

BigQuery error in load operation: Error processing job
'apache-beam-testing:bqjob_r14e1b3a4a5eaa9e4_00000162f50b909c_1': Invalid schema
update. Field timestamp has changed type from TIMESTAMP to FLOAT

STDERR: Upload complete.Waiting on bqjob_r14e1b3a4a5eaa9e4_00000162f50b909c_1 
... (0s) Current status: RUNNING                                                
                                      Waiting on 
bqjob_r14e1b3a4a5eaa9e4_00000162f50b909c_1 ... (0s) Current status: DONE   
Traceback (most recent call last):
  File "PerfKitBenchmarker/pkb.py", line 21, in <module>
    sys.exit(Main())
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
 line 977, in Main
    return RunBenchmarks()
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/PerfKitBenchmarker/perfkitbenchmarker/pkb.py";,>
 line 904, in RunBenchmarks
    collector.PublishSamples()
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/PerfKitBenchmarker/perfkitbenchmarker/publisher.py";,>
 line 927, in PublishSamples
    publisher.PublishSamples(self.samples)
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/PerfKitBenchmarker/perfkitbenchmarker/publisher.py";,>
 line 538, in PublishSamples
    vm_util.IssueRetryableCommand(load_cmd)
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/PerfKitBenchmarker/perfkitbenchmarker/vm_util.py";,>
 line 249, in WrappedFunction
    return f(*args, **kwargs)
  File 
"<https://builds.apache.org/job/beam_PerformanceTests_Spark/ws/PerfKitBenchmarker/perfkitbenchmarker/vm_util.py";,>
 line 387, in IssueRetryableCommand
    'Command returned a non-zero exit code.\n')
perfkitbenchmarker.errors.CalledProcessException: Command returned a non-zero 
exit code.

Build step 'Execute shell' marked build as failure

Reply via email to