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

See -- [...truncated 169.78 KB...] [ERROR] protected final int nextStringEndPos(byte[] bytes, int startPos, int limit, byte[] delimiter) { [ERROR] ^ [ERROR]

[2/3] flink git commit: [FLINK-5808] Move max keygroup constants to ExecutionConfig

[FLINK-5808] Move max keygroup constants to ExecutionConfig We need to have them there if we want to properly test the arguments of setMaxParallelism() in the ExecutionConfig itself. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/c

[3/3] flink git commit: [FLINK-5808] Move default parallelism to StreamingJobGraphGenerator

[FLINK-5808] Move default parallelism to StreamingJobGraphGenerator Before, it was set on the ExecutionConfig for some stream execution environments and later for others. Now, we don't set the default parallelism on the ExecutionConfig but instead set it at the latest possible point, in the Stream

[1/3] flink git commit: [FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism()

Repository: flink Updated Branches: refs/heads/master 20fff32a5 -> f31a55e08 [FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism() Before, there where some checks in StreamExecutionEnvironment.set(Max)Parallelism() but a user would circumvent these if using the ExecutionConfig

flink git commit: Commit for release 1.1.5

Repository: flink Updated Branches: refs/heads/release-1.1.5-rc1 [created] ed18e976c Commit for release 1.1.5 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ed18e976 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree

flink git commit: [FLINK-5985] Report no task states for stateless tasks on checkpointing

Repository: flink Updated Branches: refs/heads/master 97ccc1473 -> 20fff32a5 [FLINK-5985] Report no task states for stateless tasks on checkpointing Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20fff32a Tree: http://git

svn commit: r18782 - /release/flink/KEYS

Author: rmetzger Date: Fri Mar 17 16:09:15 2017 New Revision: 18782 Log: [flink] Add missing newline in PGP key Modified: release/flink/KEYS Modified: release/flink/KEYS == --- release/flink/KEYS (original) +++ relea

[2/2] flink git commit: [FLINK-4364] Introduce HeartbeatServices for the HeartbeatManager instantiation

[FLINK-4364] Introduce HeartbeatServices for the HeartbeatManager instantiation The HeartbeatServices are used to create all services relevant for heartbeating. This includes at the moment the creation of HeartbeatManager implementations which actively send heartbeats and those which only respon

[1/2] flink git commit: [FLINK-4364] [heartbeats] Implement TaskManager side of heartbeat from JobManager

Repository: flink Updated Branches: refs/heads/master 521a53d9a -> 97ccc1473 [FLINK-4364] [heartbeats] Implement TaskManager side of heartbeat from JobManager This closes #3151. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/c

[1/2] flink git commit: [FLINK-5932] initializeState() before legacy state restoring in operator

Repository: flink Updated Branches: refs/heads/master 8765f3241 -> 521a53d9a [FLINK-5932] initializeState() before legacy state restoring in operator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d998ff91 Tree: http://gi

[2/2] flink git commit: [FLINK-5846] [cep] Make the CEP operators backwards compatible with Flink 1.1

[FLINK-5846] [cep] Make the CEP operators backwards compatible with Flink 1.1 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/521a53d9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/521a53d9 Diff: http://git-wip-us.ap

svn commit: r18781 - /release/flink/KEYS

Author: rmetzger Date: Fri Mar 17 14:56:11 2017 New Revision: 18781 Log: Remove incubator from flink url Modified: release/flink/KEYS Modified: release/flink/KEYS == --- release/flink/KEYS (original) +++ release/flin

svn commit: r18780 - /release/flink/KEYS

Author: rmetzger Date: Fri Mar 17 14:54:48 2017 New Revision: 18780 Log: Add key for Gordon Modified: release/flink/KEYS Modified: release/flink/KEYS == --- release/flink/KEYS (original) +++ release/flink/KEYS Fri Ma

flink git commit: [FLINK-6076] Refactor HeartbeatManager to extend HeartbeatTarget

Repository: flink Updated Branches: refs/heads/master 713c092b2 -> 8765f3241 [FLINK-6076] Refactor HeartbeatManager to extend HeartbeatTarget Remove start method from HeartbeatManager This closes #3555. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apa

flink git commit: [hotfix] Added missing documentation in StateTransformationFunction

Repository: flink Updated Branches: refs/heads/master e0614f655 -> 713c092b2 [hotfix] Added missing documentation in StateTransformationFunction Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/713c092b Tree: http://git-wip

flink git commit: [FLINK-5981] [security] Make SSL pick up configured protocols and cipher suites

Repository: flink Updated Branches: refs/heads/master 78f22aaec -> e0614f655 [FLINK-5981] [security] Make SSL pick up configured protocols and cipher suites This closes #3486 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commi

[3/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (2)

http://git-wip-us.apache.org/repos/asf/flink/blob/78f22aae/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/ProjectableTableSource.scala -- diff --git a/flink-libraries/flink-table/src/main/scala/org/apach

[4/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (2)

[FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (2) This closes #3520. fix compilation failure fix compilation failure again. 1. Deep copy TableSource when we copy TableSourceScan 2. unify push project into scan rule for both batch and stream address comments

[1/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (1)

Repository: flink Updated Branches: refs/heads/master ab014ef94 -> 78f22aaec http://git-wip-us.apache.org/repos/asf/flink/blob/9f6cd2e7/flink-libraries/flink-table/src/test/scala/org/apache/flink/table/plan/util/RexProgramExpressionExtractorTest.scala ---

[2/4] flink git commit: [FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (1)

[FLINK-3849] [table] Add FilterableTableSource interface and rules for pushing it (1) fix filterable test rebase and trying fix rexnode parsing create wrapper and update rules Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commi

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

Repository: flink Updated Branches: refs/heads/release-1.2 9d59e008d -> edd1065c7 [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