Build failed in Jenkins: flink-snapshot-deployment #406

2017-03-16 Thread Apache Jenkins Server
See -- [...truncated 169.78 KB...] [ERROR] protected final int nextStringEndPos(byte[] bytes, int startPos, int limit, byte[] delimiter) { [ERROR] ^ [ERROR]

[4/4] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend

2017-03-16 Thread srichter
[FLINK-5715] Asynchronous snapshots for heap-based keyed state backend Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ab014ef9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ab014ef9 Diff:

[3/4] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend

2017-03-16 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/ab014ef9/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTable.java -- diff --git

[2/4] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend

2017-03-16 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/ab014ef9/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapMapState.java -- diff --git

[1/4] flink git commit: [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend

2017-03-16 Thread srichter
Repository: flink Updated Branches: refs/heads/master 30bb958a7 -> ab014ef94 http://git-wip-us.apache.org/repos/asf/flink/blob/ab014ef9/flink-runtime/src/test/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTableTest.java

[2/2] flink git commit: [FLINK-5650] [py] Continuously check PyProcess health while waiting for incoming connection

2017-03-16 Thread chesnay
[FLINK-5650] [py] Continuously check PyProcess health while waiting for incoming connection Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c2bb5de6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c2bb5de6 Diff:

[1/2] flink git commit: [refactor] [py] General code clean-up

2017-03-16 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 03889ae1f -> 30bb958a7 [refactor] [py] General code clean-up - added missing serialVersionUID - PythonPlan* classes no longer implement serializable - marked several fields as transient - replaced some fields by local variables -

[1/3] flink git commit: [FLINK-6041] [streaming api] Move StreamingFunctionUtils to 'org.apache.flink.streaming.util'

2017-03-16 Thread sewen
Repository: flink Updated Branches: refs/heads/master 24408e190 -> 03889ae1f [FLINK-6041] [streaming api] Move StreamingFunctionUtils to 'org.apache.flink.streaming.util' This close #3532 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [FLINK-5134] [runtime] Aggregate ResourceSpec for chained operators when generating job graph

2017-03-16 Thread sewen
[FLINK-5134] [runtime] Aggregate ResourceSpec for chained operators when generating job graph This closes #3455 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/980d072f Tree:

[2/3] flink git commit: [FLINK-6009] [java api] Deprecate DataSetUtils#checksumHashCode

2017-03-16 Thread sewen
[FLINK-6009] [java api] Deprecate DataSetUtils#checksumHashCode This is likely only used by Gelly and we have a more featureful implementation allowing for multiple outputs and setting the job name. Deprecation will allow this to be removed in Flink 2.0. This closes #3516 Project:

[7/8] flink git commit: [FLINK-4754] [checkpoints] Make number of retained checkpoints user configurable

2017-03-16 Thread sewen
[FLINK-4754] [checkpoints] Make number of retained checkpoints user configurable This closes #3374 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b46f5e05 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b46f5e05

[3/8] flink git commit: [FLINK-5692] [core] Add an Option to Deactivate Kryo Fallback for Serializers

2017-03-16 Thread sewen
[FLINK-5692] [core] Add an Option to Deactivate Kryo Fallback for Serializers This closes #3373 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0f99aae1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0f99aae1 Diff:

[8/8] flink git commit: [FLINK-4754] [checkpoints] Small followups to the configuration of number of retained checkpoints.

2017-03-16 Thread sewen
[FLINK-4754] [checkpoints] Small followups to the configuration of number of retained checkpoints. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/24408e19 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/24408e19

[6/8] flink git commit: [FLINK-4422] [clients] Convert time interval measurements to System.nanoTime() in 'flink-clients'

2017-03-16 Thread sewen
[FLINK-4422] [clients] Convert time interval measurements to System.nanoTime() in 'flink-clients' This closes #3384 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6b5e1f68 Tree:

[1/8] flink git commit: [FLINK-5962] [checkpoints] Remove scheduled cancel-task from timer queue to prevent memory leaks

2017-03-16 Thread sewen
Repository: flink Updated Branches: refs/heads/master d160b5e56 -> 24408e190 [FLINK-5962] [checkpoints] Remove scheduled cancel-task from timer queue to prevent memory leaks This closes #3548 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[4/8] flink git commit: [hotfix] [core] Fix/cleanup serialization test for ExecutionConfig

2017-03-16 Thread sewen
[hotfix] [core] Fix/cleanup serialization test for ExecutionConfig Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/afd36f98 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/afd36f98 Diff:

[2/8] flink git commit: [FLINK-5692] [core] (followups) Add an Option to Deactivate Kryo Fallback for Serializers

2017-03-16 Thread sewen
[FLINK-5692] [core] (followups) Add an Option to Deactivate Kryo Fallback for Serializers Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d498cbed Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d498cbed Diff:

[5/8] flink git commit: [FLINK-5756] [rocksdb] Add mini benchmarks to reproduce 'merge' performance problems

2017-03-16 Thread sewen
[FLINK-5756] [rocksdb] Add mini benchmarks to reproduce 'merge' performance problems Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/677b508a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/677b508a Diff:

[flink] Git Push Summary

2017-03-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/table-retraction [created] d160b5e56

flink git commit: [hotfix] Remove auto-boxing in ContinuousEventTimeTrigger

2017-03-16 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master e5057b72c -> d160b5e56 [hotfix] Remove auto-boxing in ContinuousEventTimeTrigger Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d160b5e5 Tree:

flink git commit: [FLINK-6032] [cep] Clean-up operator state when not needed.

2017-03-16 Thread kkloudas
Repository: flink Updated Branches: refs/heads/master 97f178894 -> e5057b72c [FLINK-6032] [cep] Clean-up operator state when not needed. The CEP operator now cleans the registered state for a key. This happens: 1) for the priority queue, when the queue is empty. 2) for the NFA, when its

flink git commit: [FLINK-6064][flip6] fix BlobServer connection in TaskExecutor

2017-03-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 264f6df8e -> 97f178894 [FLINK-6064][flip6] fix BlobServer connection in TaskExecutor The hostname used for the BlobServer was set to the akka address which is invalid for this use. Instead, this adds the hostname to the RpcGateway /