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

2017-04-18 Thread Apache Jenkins Server
See -- [...truncated 2.78 MB...] [INFO] Including org.apache.zookeeper:zookeeper:jar:3.4.6 in the shaded jar. [INFO] Including com.twitter:chill_2.11:jar:0.7.4 in the shaded

[3/3] flink git commit: [FLINK-6149] [table] Add additional flink logical relation nodes and separate current optimization to logical and physical optimize

2017-04-18 Thread kurt
[FLINK-6149] [table] Add additional flink logical relation nodes and separate current optimization to logical and physical optimize This closes #3594. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6a0ada81 Tree:

[2/3] flink git commit: [FLINK-6149] [table] Add additional flink logical relation nodes and separate current optimization to logical and physical optimize

2017-04-18 Thread kurt
http://git-wip-us.apache.org/repos/asf/flink/blob/6a0ada81/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalOverWindow.scala -- diff --git

[1/3] flink git commit: [FLINK-6149] [table] Add additional flink logical relation nodes and separate current optimization to logical and physical optimize

2017-04-18 Thread kurt
Repository: flink Updated Branches: refs/heads/master 2ef4900aa -> 6a0ada81e http://git-wip-us.apache.org/repos/asf/flink/blob/6a0ada81/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/dataSet/PushFilterIntoBatchTableSourceScanRule.scala

[1/2] flink git commit: [FLINK-6324] [DataStream] Refine OperatorStateStore interface

2017-04-18 Thread tzulitai
Repository: flink Updated Branches: refs/heads/master 0182141d4 -> 2ef4900aa [FLINK-6324] [DataStream] Refine OperatorStateStore interface This commit refines the OperatorStateStore interface by, - deprecating Java serialization shortcuts - rename getOperatorState to getListState The Java

[2/2] flink git commit: [FLINK-5991] [DataStream] Expose Union ListState for operator state

2017-04-18 Thread tzulitai
[FLINK-5991] [DataStream] Expose Union ListState for operator state This commit exposes the union list state scheme for managed operator state. The actual functionality was already previously added to the `DefaultOperatorStateBackend`, so this change simply exposes the feature through the

[4/4] flink git commit: Revert "[FLINK-5808] Move max keygroup constants to ExecutionConfig"

2017-04-18 Thread aljoscha
Revert "[FLINK-5808] Move max keygroup constants to ExecutionConfig" This reverts commit e4fbae36207c563363eed39886c24eea51d7db01. The fixes around FLINK-5808 introduced follow-up issues. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/4] flink git commit: Revert "[FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism()"

2017-04-18 Thread aljoscha
Revert "[FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism()" This reverts commit f31a55e08ddb7b4bc9e47577a187bac31ad42f4b. The fixes around FLINK-5808 introduced follow-up issues. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

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

2017-04-18 Thread aljoscha
Revert "[FLINK-5808] Move default parallelism to StreamingJobGraphGenerator" This reverts commit 9cfae899358e0694c3ecedae1fad20e428a1d359. The fixes around FLINK-5808 introduced follow-up issues. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/4] flink git commit: [FLINK-6294] Add close without input test for BucketingSink

2017-04-18 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 9d3f127e4 -> 0182141d4 [FLINK-6294] Add close without input test for BucketingSink And earlier version of the code was throwing an NPE if the sink was closed without ever seeing any input. Project:

flink git commit: [FLINK-6300] Use 'exec' in start-foreground calls

2017-04-18 Thread greg
Repository: flink Updated Branches: refs/heads/release-1.2 58d09d565 -> 4a1aa4ce8 [FLINK-6300] Use 'exec' in start-foreground calls To avoid signal-handling issues in Docker, applications need to run as a single executable or use a process manager that forwards signals correctly, in either

[1/3] flink git commit: [FLINK-6195] [build] Move gelly-examples jar from opt to examples

2017-04-18 Thread greg
Repository: flink Updated Branches: refs/heads/master 3042b182c -> 9d3f127e4 [FLINK-6195] [build] Move gelly-examples jar from opt to examples The opt directory should be reserved for Flink JARs which users may optionally move to lib to be loaded by the runtime. flink-gelly-examples is a user

[3/3] flink git commit: [FLINK-6300] Use 'exec' in start-foreground calls

2017-04-18 Thread greg
[FLINK-6300] Use 'exec' in start-foreground calls To avoid signal-handling issues in Docker, applications need to run as a single executable or use a process manager that forwards signals correctly, in either case running as PID 1. Since Flink uses a number of chained scripts before the ultimate

[2/3] flink git commit: [hotfix] [gelly] Don't print Null edge values

2017-04-18 Thread greg
[hotfix] [gelly] Don't print Null edge values Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/22475023 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/22475023 Diff:

flink git commit: [FLINK-6286] [scripts] Print error for 'hbase not found'

2017-04-18 Thread greg
Repository: flink Updated Branches: refs/heads/master 5e6ffbc19 -> 3042b182c [FLINK-6286] [scripts] Print error for 'hbase not found' Previously if HBASE_CONF_DIR was set then `hbase classpath` was run and appended to INTERNAL_HADOOP_CLASSPATHS. Now when HBASE_CONF_DIR is set HBASE_HOME or

flink git commit: [FLINK-6104] Fix resource leak in ListViaRangeSpeedMiniBenchmark

2017-04-18 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 33abc25f0 -> 5e6ffbc19 [FLINK-6104] Fix resource leak in ListViaRangeSpeedMiniBenchmark This closes #3725. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5e6ffbc1

flink git commit: [FLINK-6313] [runtime] Fix typos; log exception in QSClient for ActorSystem shutdown failure

2017-04-18 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 82a258bf6 -> 33abc25f0 [FLINK-6313] [runtime] Fix typos; log exception in QSClient for ActorSystem shutdown failure This closes #3728. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-6317] Fix wrong default directory for history server

2017-04-18 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 9be5cc42c -> 82a258bf6 [FLINK-6317] Fix wrong default directory for history server This closes #3731. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82a258bf Tree:

flink git commit: [FLINK-6292] fix transfer.sh upload by using https

2017-04-18 Thread chesnay
Repository: flink Updated Branches: refs/heads/release-1.2 5061e7e28 -> 58d09d565 [FLINK-6292] fix transfer.sh upload by using https Seems the upload via http is not supported anymore. This closes #3708. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: