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

2017-03-13 Thread Apache Jenkins Server
See -- [...truncated 170.33 KB...] [ERROR] public static void rethrowIOException(Throwable t) throws IOException { [ERROR] ^ [ERROR]

flink git commit: [FLINK-6007] Allow key removal from within the watermark callback.

2017-03-13 Thread kkloudas
Repository: flink Updated Branches: refs/heads/master 5f08e5359 -> 14c1941d8 [FLINK-6007] Allow key removal from within the watermark callback. When deleting a key from the InternalWatermarkCallbackService, the deleted key is put into a separate set, and the actual deletion happens after the

flink git commit: [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization

2017-03-13 Thread tzulitai
Repository: flink Updated Branches: refs/heads/release-1.2 1ea252a41 -> b7d288fe2 [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization This commit adds a reimplemented JavaSerializer to be registered with Kryo. This is due to a know issue with Kryo's JavaSerializer that

flink git commit: [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization

2017-03-13 Thread tzulitai
Repository: flink Updated Branches: refs/heads/release-1.1 01703e60e -> e50bf6506 [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization This commit adds a reimplemented JavaSerializer to be registered with Kryo. This is due to a know issue with Kryo's JavaSerializer that

[1/2] flink git commit: [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization

2017-03-13 Thread tzulitai
Repository: flink Updated Branches: refs/heads/master fcd264a70 -> 5f08e5359 [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization This commit adds a reimplemented JavaSerializer to be registered with Kryo. This is due to a know issue with Kryo's JavaSerializer that may

[2/2] flink git commit: [FLINK-3123] [kafka] Allow custom specific start offsets for FlinkKafkaConsumer

2017-03-13 Thread tzulitai
[FLINK-3123] [kafka] Allow custom specific start offsets for FlinkKafkaConsumer This closes #2687. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5f08e535 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5f08e535

flink git commit: [FLINK-5971] [flip-6] Add timeout for registered jobs on the ResourceManager

2017-03-13 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 04aee61d8 -> fcd264a70 [FLINK-5971] [flip-6] Add timeout for registered jobs on the ResourceManager This PR introduces a timeout for inactive jobs on the ResourceManager. A job is inactive if there is no active leader known for this job.

flink git commit: [FLINK-5882] [table] TableFunction (UDTF) should support variable types and variable arguments

2017-03-13 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 9b179beae -> 04aee61d8 [FLINK-5882] [table] TableFunction (UDTF) should support variable types and variable arguments This closes #3407. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-5881] [table] ScalarFunction(UDF) should support variable types and variable arguments

2017-03-13 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 354a13edf -> 9b179beae [FLINK-5881] [table] ScalarFunction(UDF) should support variable types and variable arguments This closes #3389. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: