buildbot success in on flink-docs-release-0.10

2017-01-20 Thread buildbot
The Buildbot has detected a restored build on builder flink-docs-release-0.10 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-0.10/builds/459 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The

[1/2] flink git commit: [FLINK-5459] [docs] Add troubleshooting guide for classloading issues

2017-01-20 Thread sewen
Repository: flink Updated Branches: refs/heads/master 6dffe282b -> 3b6267555 [FLINK-5459] [docs] Add troubleshooting guide for classloading issues Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3b626755 Tree: http://git-w

[2/2] flink git commit: [FLINK-5585] [jobmanager] Fix NullPointerException in JobManager.updateAccumulators

2017-01-20 Thread sewen
[FLINK-5585] [jobmanager] Fix NullPointerException in JobManager.updateAccumulators Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/24ff9eba Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/24ff9eba Diff: http://git-wi

flink git commit: [FLINK-5459] [docs] Add troubleshooting guide for classloading issues

2017-01-20 Thread sewen
Repository: flink Updated Branches: refs/heads/release-1.2 8c5edb2fc -> 289932cdb [FLINK-5459] [docs] Add troubleshooting guide for classloading issues Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/289932cd Tree: http://

flink git commit: [FLINK-2662] [optimizer] Fix translation of broadcasted unions.

2017-01-20 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-1.1 f6f1c244c -> 6566b63aa [FLINK-2662] [optimizer] Fix translation of broadcasted unions. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6566b63a Tree: http://git-wi

flink git commit: [FLINK-2662] [optimizer] Fix translation of broadcasted unions.

2017-01-20 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-1.2 03a1f25fa -> 8c5edb2fc [FLINK-2662] [optimizer] Fix translation of broadcasted unions. This closes #3083. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8c5edb2f

flink git commit: [FLINK-2662] [optimizer] Fix translation of broadcasted unions.

2017-01-20 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 8d6426320 -> 6dffe282b [FLINK-2662] [optimizer] Fix translation of broadcasted unions. This closes #3083. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6dffe282 Tree

flink git commit: [FLINK-5528] [tests] Reduce query retry delay in QueryableStateITCase

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.2 694927634 -> 03a1f25fa [FLINK-5528] [tests] Reduce query retry delay in QueryableStateITCase Using 100ms instead of the 1s previously used does not impose too much additional query load and reduces the test suite's duration from 16-20s

flink git commit: [FLINK-5528] [tests] Reduce query retry delay in QueryableStateITCase

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/master f266e8255 -> 8d6426320 [FLINK-5528] [tests] Reduce query retry delay in QueryableStateITCase Using 100ms instead of the 1s previously used does not impose too much additional query load and reduces the test suite's duration from 16-20s to 1

flink git commit: [FLINK-5368] [kafka] Log msg if kafka topic doesn't have any partitions

2017-01-20 Thread tzulitai
Repository: flink Updated Branches: refs/heads/release-1.2 5cbaf796d -> 694927634 [FLINK-5368] [kafka] Log msg if kafka topic doesn't have any partitions This closes #3036. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/

flink git commit: [FLINK-5580] [security] Fix path setting of shipped Kerberos keytabs in YARN mode

2017-01-20 Thread tzulitai
Repository: flink Updated Branches: refs/heads/release-1.2 3b5882afa -> 5cbaf796d [FLINK-5580] [security] Fix path setting of shipped Kerberos keytabs in YARN mode This closes #3177. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/fl

flink git commit: [FLINK-5355] [kinesis] Handle AmazonKinesisException gracefully in Kinesis Streaming Connector

2017-01-20 Thread tzulitai
Repository: flink Updated Branches: refs/heads/release-1.2 be09143cd -> 3b5882afa [FLINK-5355] [kinesis] Handle AmazonKinesisException gracefully in Kinesis Streaming Connector This closes #3078. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org

flink git commit: [FLINK-5386] [table] Refactor window clause.

2017-01-20 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-1.2 0a24611a8 -> be09143cd [FLINK-5386] [table] Refactor window clause. - move window() before groupBy() - make window alias mandatory - groupBy() must include window alias Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commi

[2/3] flink git commit: [FLINK-5580] [security] Fix path setting of shipped Kerberos keytabs in YARN mode

2017-01-20 Thread tzulitai
[FLINK-5580] [security] Fix path setting of shipped Kerberos keytabs in YARN mode This closes #3177. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/640a149e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/640a149e D

[1/3] flink git commit: [FLINK-5355] [kinesis] Handle AmazonKinesisException gracefully in Kinesis Streaming Connector

2017-01-20 Thread tzulitai
Repository: flink Updated Branches: refs/heads/master 988729ec1 -> f266e8255 [FLINK-5355] [kinesis] Handle AmazonKinesisException gracefully in Kinesis Streaming Connector This closes #3078. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repo

[3/3] flink git commit: [FLINK-5368] [kafka] Log msg if kafka topic doesn't have any partitions

2017-01-20 Thread tzulitai
[FLINK-5368] [kafka] Log msg if kafka topic doesn't have any partitions This closes #3036. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f266e825 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f266e825 Diff: http:/

flink git commit: [FLINK-5468] [savepoints] Improve error message for migrating semi async RocksDB snapshot

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/master 6c4644de1 -> 988729ec1 [FLINK-5468] [savepoints] Improve error message for migrating semi async RocksDB snapshot This closes #3119. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf

flink git commit: [FLINK-5549] [core] TypeExtractor fails with RuntimeException, but should use GenericTypeInfo

2017-01-20 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 6bf556e60 -> 2703d339a [FLINK-5549] [core] TypeExtractor fails with RuntimeException, but should use GenericTypeInfo This closes #3154. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos

flink git commit: [FLINK-5549] [core] TypeExtractor fails with RuntimeException, but should use GenericTypeInfo

2017-01-20 Thread twalthr
Repository: flink Updated Branches: refs/heads/release-1.2 d4313731c -> 0a24611a8 [FLINK-5549] [core] TypeExtractor fails with RuntimeException, but should use GenericTypeInfo This closes #3154. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/

flink git commit: [FLINK-5468] [savepoints] Improve error message for migrating semi async RocksDB snapshot

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.2 108865db2 -> d4313731c [FLINK-5468] [savepoints] Improve error message for migrating semi async RocksDB snapshot This closes #3119. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repo

flink git commit: [FLINK-5561] [runtime] Fix DataInputDeserializer#available()

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.2 e2a4f3232 -> 108865db2 [FLINK-5561] [runtime] Fix DataInputDeserializer#available() This closes #3171. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/108865db Tr

flink git commit: [FLINK-5561] [runtime] Fix DataInputDeserializer#available()

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/master 2703d339a -> 6c4644de1 [FLINK-5561] [runtime] Fix DataInputDeserializer#available() This closes #3171. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6c4644de Tree: h

flink git commit: [FLINK-5386] [table] Refactor window clause.

2017-01-20 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 8ccedd103 -> 6bf556e60 [FLINK-5386] [table] Refactor window clause. - move window() before groupBy() - make window alias mandatory - groupBy() must include window alias This closes #3046. Project: http://git-wip-us.apache.org/repos/asf/f

flink git commit: [FLINK-5585] [jobmanager] Fix NullPointerException in JobManager.updateAccumulators

2017-01-20 Thread sewen
Repository: flink Updated Branches: refs/heads/release-1.2 6e85106b1 -> e2a4f3232 [FLINK-5585] [jobmanager] Fix NullPointerException in JobManager.updateAccumulators Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e2a4f32

flink git commit: [hotfix] [table] Update documentation about limitations

2017-01-20 Thread twalthr
Repository: flink Updated Branches: refs/heads/master 1fc34502e -> 8ccedd103 [hotfix] [table] Update documentation about limitations Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ccedd10 Tree: http://git-wip-us.apache.o

flink git commit: [FLINK-4693] [table] Add session group-windows for batch tables

2017-01-20 Thread twalthr
Repository: flink Updated Branches: refs/heads/master ddd7c36ec -> 1fc34502e [FLINK-4693] [table] Add session group-windows for batch tables This closes #3150. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1fc34502 Tree

flink git commit: [FLINK-5585] [jobmanager] Fix NullPointerException in JobManager.updateAccumulators

2017-01-20 Thread sewen
Repository: flink Updated Branches: refs/heads/release-1.1 931929bf8 -> f6f1c244c [FLINK-5585] [jobmanager] Fix NullPointerException in JobManager.updateAccumulators Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f6f1c24

flink git commit: [FLINK-5515] [queryable state] Remove unused getSerializedValue call

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.2 1c8a48f8f -> 6e85106b1 [FLINK-5515] [queryable state] Remove unused getSerializedValue call This closes #3131. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6e8

flink git commit: [FLINK-5515] [queryable state] Remove unused getSerializedValue call

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/master 63a6af3be -> ddd7c36ec [FLINK-5515] [queryable state] Remove unused getSerializedValue call This closes #3131. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ddd7c36e

flink git commit: [FLINK-5507] [queryable state] Remove list variant of asQueryableState

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.2 1db810218 -> 1c8a48f8f [FLINK-5507] [queryable state] Remove list variant of asQueryableState The queryable state "sink" using ListState stores all incoming data forever and is never cleaned. Eventually, it will pile up too much memory

flink git commit: [FLINK-5507] [queryable state] Remove list variant of asQueryableState

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/master 7ff7f431d -> 63a6af3be [FLINK-5507] [queryable state] Remove list variant of asQueryableState The queryable state "sink" using ListState stores all incoming data forever and is never cleaned. Eventually, it will pile up too much memory and

[2/2] flink git commit: [FLINK-5482] [queryable state] Re-issue location lookup upon failure

2017-01-20 Thread uce
[FLINK-5482] [queryable state] Re-issue location lookup upon failure Any failing lookup, e.g. in case the job has not been started yet, previously remained in the lookup cache and thus future queries did not retry the lookup and failed. This commit changes the lookup caching code so that completed

[1/2] flink git commit: [FLINK-5482] [tests] Dedup code in QueryableStateITCase

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/release-1.2 9073c53f9 -> 1db810218 [FLINK-5482] [tests] Dedup code in QueryableStateITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da10a2e9 Tree: http://git-wip-us.apa

[1/2] flink git commit: [FLINK-5482] [tests] Dedup code in QueryableStateITCase

2017-01-20 Thread uce
Repository: flink Updated Branches: refs/heads/master 883fc5a77 -> 7ff7f431d [FLINK-5482] [tests] Dedup code in QueryableStateITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/661b3f90 Tree: http://git-wip-us.apache.o

[2/2] flink git commit: [FLINK-5482] [queryable state] Re-issue location lookup upon failure

2017-01-20 Thread uce
[FLINK-5482] [queryable state] Re-issue location lookup upon failure Any failing lookup, e.g. in case the job has not been started yet, previously remained in the lookup cache and thus future queries did not retry the lookup and failed. This commit changes the lookup caching code so that completed