flink git commit: [FLINK-6311] [kinesis] NPE in FlinkKinesisConsumer if source was closed before run

Repository: flink Updated Branches: refs/heads/release-1.2 4a1aa4ce8 -> 80dc704fc [FLINK-6311] [kinesis] NPE in FlinkKinesisConsumer if source was closed before run This closes #3738. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-6311] [kinesis] NPE in FlinkKinesisConsumer if source was closed before run

Repository: flink Updated Branches: refs/heads/master 42328bd9b -> a0249d993 [FLINK-6311] [kinesis] NPE in FlinkKinesisConsumer if source was closed before run This closes #3738. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

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

See -- [...truncated 2.75 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

[1/6] flink git commit: [hotfix] [checkpoints] Rename JobSnapshottingSettings to JobCheckpointingSettings

Repository: flink Updated Branches: refs/heads/master c607b9a22 -> 42328bd9b [hotfix] [checkpoints] Rename JobSnapshottingSettings to JobCheckpointingSettings Cleanup to consistently use - checkpoint for the overall fault tolerance mechanism and procedure - snapshot for an operators

[3/6] flink git commit: [hotfix] [misc] Minor code cleanups

[hotfix] [misc] Minor code cleanups Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4d8627cc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4d8627cc Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4d8627cc

[6/6] flink git commit: [FLINK-6338] [core] Rename SimpleStringUtils to StringValueUtils

[FLINK-6338] [core] Rename SimpleStringUtils to StringValueUtils This more intuitivce name clarifies the role of the class. This also marks the class as PublicEvolving, as it is not actually used as an internal class. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/6] flink git commit: [hotfix] [streaming] Propagate 'CancelTaskException' in during checkpoint-on-barrier

[hotfix] [streaming] Propagate 'CancelTaskException' in during checkpoint-on-barrier Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1ed0727e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1ed0727e Diff:

[4/6] flink git commit: [hotfix] [streaming api] Make it clear that StreamingJobGraphGenerator is single use.

[hotfix] [streaming api] Make it clear that StreamingJobGraphGenerator is single use. This reduces the public API of the StreamingJobGraphGenerator to a static createJobGraph() method, which internally instantiates a generator, creates the job, and drops the generator. Project:

[5/6] flink git commit: [FLINK-6339] [streaming api] Delete unused (and useless) class ConnectorSource

[FLINK-6339] [streaming api] Delete unused (and useless) class ConnectorSource Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/81abe73e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/81abe73e Diff:

[5/5] flink git commit: [hotfix] [tests] Stabilize AsyncCallsTest by ensuring delayed messages are not executed before their time

[hotfix] [tests] Stabilize AsyncCallsTest by ensuring delayed messages are not executed before their time Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0391e414 Tree:

[1/5] flink git commit: [FLINK-5481] [core] Followups to the typeinfo/Types utility - Move new 'Types' class to 'common' scope, not 'java api'. - Make the method names the same in Scala and Java

Repository: flink Updated Branches: refs/heads/master 52f8b33e5 -> c607b9a22 [FLINK-5481] [core] Followups to the typeinfo/Types utility - Move new 'Types' class to 'common' scope, not 'java api'. - Make the method names the same in Scala and Java Project:

[2/5] flink git commit: [FLINK-5646] [docs] Document JAR upload with the REST API

[FLINK-5646] [docs] Document JAR upload with the REST API This closes #3722 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/97ca03a0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/97ca03a0 Diff:

[4/5] flink git commit: [FLINK-5481] [core] Add utility method to easily generate RowTypeInfos

[FLINK-5481] [core] Add utility method to easily generate RowTypeInfos This closes #3127 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/eb4db536 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/eb4db536 Diff:

[3/5] flink git commit: [hotfix] [tests] Stabilize SystemProcessingTimeServiceTest

[hotfix] [tests] Stabilize SystemProcessingTimeServiceTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c962c45e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c962c45e Diff: