Jenkins build is back to normal : flink-snapshot-deployment #658

See

flink git commit: [hotfix] Always explicitly set hadoop.version in create_binary_release

Repository: flink Updated Branches: refs/heads/release-1.4 13631b961 -> 3b58038d6 [hotfix] Always explicitly set hadoop.version in create_binary_release Before, the "hadoop2" profile would create a binary release for whatever happens to be the default hadoop.version. Project:

flink git commit: [hotfix] Exclude python-source.zip from checkstyle

Repository: flink Updated Branches: refs/heads/master d86c6b6bb -> 54dd91603 [hotfix] Exclude python-source.zip from checkstyle This was causing the snapshot deployment to fail. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-8118] [table] Allow to specify the offsets of KafkaTableSources

[FLINK-8118] [table] Allow to specify the offsets of KafkaTableSources This closes #5056. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2fb24581 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2fb24581 Diff:

[1/2] flink git commit: [FLINK-8118] [table] Improve KafkaTableSource documentation

Repository: flink Updated Branches: refs/heads/release-1.4 828ef09b0 -> 13631b961 [FLINK-8118] [table] Improve KafkaTableSource documentation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/13631b96 Tree:

flink git commit: [FLINK-5465] [streaming] Wait for pending timer threads to finish or to exceed a time limit in exceptional stream task shutdown.

Repository: flink Updated Branches: refs/heads/release-1.4 e100861f8 -> 828ef09b0 [FLINK-5465] [streaming] Wait for pending timer threads to finish or to exceed a time limit in exceptional stream task shutdown. This closes #5058. (cherry picked from commit d86c6b6) Project:

flink git commit: [FLINK-5465] [streaming] Wait for pending timer threads to finish or to exceed a time limit in exceptional stream task shutdown.

Repository: flink Updated Branches: refs/heads/master fda2c9ff6 -> d86c6b6bb [FLINK-5465] [streaming] Wait for pending timer threads to finish or to exceed a time limit in exceptional stream task shutdown. This closes #5058. Project: http://git-wip-us.apache.org/repos/asf/flink/repo

flink git commit: [hotfix][docs] Improve Kafka exactly-once docs

Repository: flink Updated Branches: refs/heads/release-1.4 62bf00189 -> e100861f8 [hotfix][docs] Improve Kafka exactly-once docs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e100861f Tree:

flink git commit: [hotfix][docs] Improve Kafka exactly-once docs

Repository: flink Updated Branches: refs/heads/master 7ff3f373a -> fda2c9ff6 [hotfix][docs] Improve Kafka exactly-once docs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fda2c9ff Tree:

[1/2] flink git commit: [FLINK-8118] [table] Fix documentation mistakes

Repository: flink Updated Branches: refs/heads/master 458c909ca -> 7ff3f373a [FLINK-8118] [table] Fix documentation mistakes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ff3f373 Tree:

[2/2] flink git commit: [FLINK-8118] [table] Allow to specify the offsets of KafkaTableSources

[FLINK-8118] [table] Allow to specify the offsets of KafkaTableSources This closes #5056. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4083c70d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4083c70d Diff:

[2/3] flink git commit: [FLINK-8132][kafka] Re-initialize transactional KafkaProducer on each checkpoint

[FLINK-8132][kafka] Re-initialize transactional KafkaProducer on each checkpoint Previously faulty scenario with producer pool of 2. 1. started transaction 1 with producerA, written record 42 2. checkpoint 1 triggered, pre committing txn1, started txn2 with producerB, written record 43 3.

[1/3] flink git commit: [hotfix][kafka] Throw FlinkKafkaProducer011Exception with error codes instead of generic Exception

Repository: flink Updated Branches: refs/heads/release-1.4 8a052bf09 -> 62bf00189 [hotfix][kafka] Throw FlinkKafkaProducer011Exception with error codes instead of generic Exception Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [hotfix][kafka] Remove unused method in kafka tests

[hotfix][kafka] Remove unused method in kafka tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/62bf0018 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/62bf0018 Diff:

[1/3] flink git commit: [hotfix][kafka] Remove unused method in kafka tests

Repository: flink Updated Branches: refs/heads/master ccf917de2 -> 458c909ca [hotfix][kafka] Remove unused method in kafka tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/458c909c Tree:

[2/3] flink git commit: [FLINK-8132][kafka] Re-initialize transactional KafkaProducer on each checkpoint

[FLINK-8132][kafka] Re-initialize transactional KafkaProducer on each checkpoint Previously faulty scenario with producer pool of 2. 1. started transaction 1 with producerA, written record 42 2. checkpoint 1 triggered, pre committing txn1, started txn2 with producerB, written record 43 3.

[3/3] flink git commit: [hotfix][kafka] Throw FlinkKafkaProducer011Exception with error codes instead of generic Exception

[hotfix][kafka] Throw FlinkKafkaProducer011Exception with error codes instead of generic Exception Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ac32c59 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2ac32c59

flink git commit: [FLINK-6505] Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

Repository: flink Updated Branches: refs/heads/release-1.4 35517f129 -> 8a052bf09 [FLINK-6505] Proactively cleanup local FS for RocksDBKeyedStateBackend on startup Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8a052bf0

flink git commit: [FLIN-6505] Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

Repository: flink Updated Branches: refs/heads/master 200612ee0 -> ccf917de2 [FLIN-6505] Proactively cleanup local FS for RocksDBKeyedStateBackend on startup Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ccf917de Tree:

[2/2] flink-web git commit: Rebuild website

Rebuild website Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/389b00e6 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/389b00e6 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/389b00e6

[1/2] flink-web git commit: Fix small issues in 1.4 to 1.5 blog post

Repository: flink-web Updated Branches: refs/heads/asf-site c2b139f18 -> 389b00e67 Fix small issues in 1.4 to 1.5 blog post Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/3df7f594 Tree: