[flink] branch master updated: [FLINK-10765][test] Include s3p schema in S3 test

2018-11-08 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c5e227b [FLINK-10765][test] Include s3p

[flink] branch release-1.6 updated: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider deep duplication of element serializer

2018-11-08 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 201549d [FLINK-10816][cep] Fix

[flink] branch release-1.7 updated: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider deep duplication of element serializer

2018-11-08 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.7 by this push: new b975ea9 [FLINK-10816][cep] Fix

[flink] branch master updated: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider deep duplication of element serializer

2018-11-08 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 997fa55 [FLINK-10816][cep] Fix

[flink] branch release-1.6 updated: [hotfix] Fix build problem in KafkaTestBase

2018-11-08 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 9e3e04b [hotfix] Fix build problem

[flink] 01/02: [FLINK-10353][kafka] Support change of transactional semantics in Kafka Producer with existing state

2018-11-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git commit b609ede4b4060bcc94b7e936726369983f3b6bfe Author: Stefan Richter AuthorDate: Fri Nov 2 11:48:46 2018 +0100

[flink] branch release-1.6 updated (c0c9cf2 -> 255deb2)

2018-11-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git. from c0c9cf2 [FLINK-10655][rpc] fix RemoteRpcInvocation not overwriting ObjectInputStream&#

[flink] 02/02: [hotfix][tests] Deduplicate the default timeout constants in FlinkKafkaProducerITCase

2018-11-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git commit 255deb2b7da6b30b482b2b4e7f102121d5a0ec70 Author: Stefan Richter AuthorDate: Tue Nov 6 13:24:50 2018 +0100

[flink] 02/02: [hotfix][tests] Deduplicate the default timeout constants in FlinkKafkaProducerITCase

2018-11-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git commit 4609341d0d774d6afb5559dbfa41a093fd405ae6 Author: Stefan Richter AuthorDate: Tue Nov 6 13:24:50 2018 +0100

[flink] branch release-1.7 updated (d4f3d4a -> 4609341)

2018-11-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git. from d4f3d4a [hotfix] [e2e] Categorize nightly tests new 090119a [FLINK-10353][kafka] Support change of

[flink] 01/02: [FLINK-10353][kafka] Support change of transactional semantics in Kafka Producer with existing state

2018-11-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git commit 090119ac96f7c62e592f020edf583b032f823add Author: Stefan Richter AuthorDate: Fri Nov 2 11:48:46 2018 +0100

[flink] 01/02: [FLINK-10353][kafka] Support change of transactional semantics in Kafka Producer with existing state

2018-11-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 85f895b0836c19e4c0e56246aa9af10df8dee09b Author: Stefan Richter AuthorDate: Fri Nov 2 11:48:46 2018 +0100 [FLINK

[flink] 02/02: [hotfix][tests] Deduplicate the default timeout constants in FlinkKafkaProducerITCase

2018-11-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit bf0454b1262d8ef51aa945d8b4cb1015f8429ed1 Author: Stefan Richter AuthorDate: Tue Nov 6 13:24:50 2018 +0100 [hotfix

[flink] branch master updated (53ee80e -> bf0454b)

2018-11-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 53ee80e [FLINK-10800][network][test] Abstract StreamPartitionerTest for common codes new 85f895b [FLINK

[flink] branch release-1.7 updated: [FLINK-10720][tests] Add deployment end-to-end stress test with many inflated task deployment desciptors

2018-11-06 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.7 by this push: new 380df05 [FLINK-10720][tests] Add

[flink] branch master updated: [FLINK-10720][tests] Add deployment end-to-end stress test with many inflated task deployment desciptors

2018-11-06 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 660bb68 [FLINK-10720][tests] Add deployment

[flink] branch release-1.6 updated: [FLINK-10793][ttl] Change visibility of TtlValue and TtlSerializer to public for external tools

2018-11-05 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 9cde8e2 [FLINK-10793][ttl] Change

[flink] branch release-1.7 updated: [FLINK-10793][ttl] Change visibility of TtlValue and TtlSerializer to public for external tools

2018-11-05 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.7 by this push: new 18c1579 [FLINK-10793][ttl] Change

[flink] branch master updated: [FLINK-10793][ttl] Change visibility of TtlValue and TtlSerializer to public for external tools

2018-11-05 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new e1d975d [FLINK-10793][ttl] Change visibility

[flink] branch release-1.7 updated: [FLINK-10364][tests] Fix instability in NonHAQueryableStateFsBackendITCase#testMapState

2018-11-05 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.7 by this push: new 4556c8f [FLINK-10364][tests] Fix

[flink] branch release-1.6 updated: [FLINK-10364][tests] Fix instability in NonHAQueryableStateFsBackendITCase#testMapState

2018-11-05 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 4f3e125 [FLINK-10364][tests] Fix

[flink] branch master updated: [FLINK-10364][tests] Fix instability in NonHAQueryableStateFsBackendITCase#testMapState

2018-11-05 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new b9351fc [FLINK-10364][tests] Fix instability

[flink] branch release-1.7 updated: [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Serializer

2018-11-05 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.7 by this push: new b9a866e [FLINK-10490][tests

[flink] branch master updated: [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Serializer

2018-11-05 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new d5296dc [FLINK-10490][tests

[flink] branch master updated: [FLINK-9635][scheduling] Avoid task spread-out in scheduling with local recovery

2018-10-30 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c8a6471 [FLINK-9635][scheduling] Avoid task

[flink] branch master updated: [FLINK-8995][tests] Add keyed state that uses custom stateful serializer to allround test job

2018-10-30 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 0e9a249 [FLINK-8995][tests] Add keyed state

[flink] branch release-1.6 updated: [FLINK-10567][state] Fix TtlStateSerializer doe not propagate all field serializer during duplicate()

2018-10-18 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new c218097 [FLINK-10567][state] Fix

[flink] branch master updated: [FLINK-10567][state] Fix TtlStateSerializer doe not propagate all field serializer during duplicate()

2018-10-18 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 4be1afa [FLINK-10567][state] Fix

[flink] branch master updated: [FLINK-4052] Use non-local unreachable ip:port in testReturnLocalHostAddressUsingHeuristics

2018-10-16 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new f195a6e [FLINK-4052] Use non-local

[flink] branch master updated: [FLINK-10565][tests] Refactor SchedulerTestBase to remove legacy code paths

2018-10-16 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 05a4789 [FLINK-10565][tests] Refactor

[flink] branch master updated: [hotfix] Use semantically correct timeout in ExecutionGraph::scheduleEager.

2018-10-12 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 7000290 [hotfix] Use semantically correct

[flink] branch master updated: [hotfix] Fix typo in WindowedStream.

2018-10-11 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new feb01b5 [hotfix] Fix typo in WindowedStream

[flink] branch master updated: [FLINK-10289] Classify Exceptions into different categories to apply different failover strategies

2018-10-09 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 20b9326 [FLINK-10289] Classify Exceptions

[flink] branch release-1.6 updated: [hotfix][docs] Improve documentation of savepoints

2018-10-01 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 057394c [hotfix][docs] Improve

[flink] branch master updated: [hotfix][docs] Improve documentation of savepoints

2018-10-01 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 6ba2a0b [hotfix][docs] Improve documentation

[flink] branch release-1.6 updated: [FLINK-10157][State TTL] Allow `null` user values in map state with TTL

2018-09-21 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 3558d15 [FLINK-10157][State TTL

[flink] branch master updated: [FLINK-10157][State TTL] Allow `null` user values in map state with TTL

2018-09-21 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new f343204 [FLINK-10157][State TTL] Allow `null

[flink] branch master updated: [hotfix][runtime] Remove unused exception class

2018-09-11 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new a97e2f7 [hotfix][runtime] Remove unused

[flink] branch master updated: [hotfix][kubernetes] Correct exception typo

2018-09-11 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 3dee499 [hotfix][kubernetes] Correct

[flink] branch release-1.5 updated: [FLINK-10267][state] Fix arbitrary iterator access on RocksDBMapIterator

2018-09-11 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.5 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.5 by this push: new d8e7741 [FLINK-10267][state] Fix

[flink] branch release-1.6 updated: [FLINK-10267][state] Fix arbitrary iterator access on RocksDBMapIterator

2018-09-11 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new a19e1ee [FLINK-10267][state] Fix

[flink] branch master updated: [FLINK-10267][state] Fix arbitrary iterator access on RocksDBMapIterator

2018-09-11 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 16dc597 [FLINK-10267][state] Fix arbitrary

[flink] branch master updated: [FLINK-9735][tests] Potential leak in RocksDBResource

2018-09-10 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 1a94c20 [FLINK-9735][tests] Potential leak in

[flink] 01/02: [FLINK-10175][state] Fix concurrent access to shared buffer between RocksDBMapState and querable state

2018-08-22 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 2b6beedc1cfc7327cd8817a36064364e09e427cb Author: Stefan Richter AuthorDate: Sun Aug 19 14:39:34 2018 +0200 [FLINK

[flink] branch master updated (09eb13a -> 3fd6587)

2018-08-22 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 09eb13a [hotfix] [REST] Add logging to RouterHandler new 2b6beed [FLINK-10175][state] Fix concurrent access

[flink] 02/02: [FLINK-10176][state] Replace ByteArrayData[Input|Output]View with (enhanced) Data[Output|InputDe]Serializer

2018-08-22 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 3fd6587208a16940eab327ed37fa4e23d0b7eb62 Author: Stefan Richter AuthorDate: Wed Aug 22 13:31:49 2018 +0200 [FLINK

[flink] 02/02: [FLINK-10042][state] (part 2) Refactoring of snapshot algorithms for better abstraction and cleaner resource management

2018-08-21 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit f803280bb933d968976e79b9efb5953bed308d96 Author: Stefan Richter AuthorDate: Thu Aug 9 22:23:42 2018 +0200 [FLINK

[flink] branch master updated (07bb90d -> f803280)

2018-08-21 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 07bb90d [FLINK-10181][rest][docs] Add anchor links to rest requests new aba02eb [FLINK-10042][state] (part 1

[flink] 01/02: [FLINK-10042][state] (part 1) Extract snapshot algorithms from inner classes of RocksDBKeyedStateBackend into full classes

2018-08-21 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit aba02eb3fcc4472c3d5f5a0f527960d79c659c31 Author: Stefan Richter AuthorDate: Tue Aug 7 15:57:27 2018 +0200 [FLINK

[flink] 01/02: [FLINK-10068][docs] Add documentation for RocksDB-based timers and stopping timers

2018-08-20 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git commit d6122d6c88acf44b07e1fad9eebe088fe5a83dc3 Author: Stefan Richter AuthorDate: Mon Aug 6 14:54:04 2018 +0200

[flink] branch release-1.6 updated (50c0fb8 -> ac1a802)

2018-08-20 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git. from 50c0fb8 [FLINK-10169] [table] Fix error in RowtimeValidator when getting custom TimestampExtractor new

[flink] 02/02: [hotfix] Minor JavaDoc correction in StateTable

2018-08-20 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git commit ac1a8029992c39eb9e3c0482e672aab226d8a3e1 Author: Stefan Richter AuthorDate: Mon Aug 20 15:05:50 2018 +0200

[flink] branch master updated (9fe70f2 -> 24e0fbe)

2018-08-20 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 9fe70f2 [FLINK-10169] [table] Fix error in RowtimeValidator when getting custom TimestampExtractor new

[flink] 02/02: [hotfix] Minor JavaDoc correction in StateTable

2018-08-20 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 24e0fbe0d10ee0638190cb84d41d0edb5c1cce3c Author: Stefan Richter AuthorDate: Mon Aug 20 15:05:50 2018 +0200

[flink] 01/02: [FLINK-10068][docs] Add documentation for RocksDB-based timers and stopping timers

2018-08-20 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit b456cca8c92adf62e7e58a495f9692b2c9c2cb96 Author: Stefan Richter AuthorDate: Mon Aug 6 14:54:04 2018 +0200 [FLINK

[flink] branch release-1.6 updated: [FLINK-10154][connectors] Make sure we always read at least one record in KinesisConnector.

2018-08-16 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 02152e7 [FLINK-10154][connectors

[flink] branch master updated: [FLINK-10154][connectors] Make sure we always read at least one record in KinesisConnector.

2018-08-16 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new b34ee94 [FLINK-10154][connectors] Make sure

[flink] branch release-1.6 updated: [hotfix][state] Improve memory-friendliness of state assignment by allocating collections with correct sizes or improved size estimates where possible

2018-08-16 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 92815e7 [hotfix][state] Improve

[flink] branch master updated: [hotfix][state] Improve memory-friendliness of state assignment by allocating collections with correct sizes or improved size estimates where possible

2018-08-16 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 15e137e [hotfix][state] Improve memory

[flink] branch release-1.6 updated: [FLINK-10151][state] Fix false recursion call for state TTL in TransformingStateTableKeyGroupPartitioner.tryAddToSource

2018-08-16 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 00a2e81 [FLINK-10151][state] Fix

[flink] branch master updated: [FLINK-10151][state] Fix false recursion call for state TTL in TransformingStateTableKeyGroupPartitioner.tryAddToSource

2018-08-16 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new c73747b [FLINK-10151][state] Fix false

[flink] branch release-1.5 updated: [FLINK-10066] Keep only archived version of previous executions

2018-08-13 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.5 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.5 by this push: new 2217c09 [FLINK-10066] Keep only

[flink] branch release-1.6 updated: [FLINK-10066] Keep only archived version of previous executions

2018-08-13 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 74323d5 [FLINK-10066] Keep only

[flink] branch master updated: [FLINK-10066] Keep only archived version of previous executions

2018-08-13 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 160dc56 [FLINK-10066] Keep only archived

[flink] 02/02: [FLINK-10124][state] Use ByteArrayDataInput/OutputView instead of stream + wrapper

2018-08-10 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 18ff4ab8e55d76522f835cc683f57252b3f742bc Author: Stefan Richter AuthorDate: Fri Aug 10 20:06:58 2018 +0200 [FLINK

[flink] 01/02: [FLINK-10041][state] Extract iterators from RocksDBKeyedStateBackend (inner or static inner classes) into full classes

2018-08-10 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 9d67afbb84736ee8c28ec1bd69eef8ddff4754f0 Author: Stefan Richter AuthorDate: Mon Aug 6 11:21:58 2018 +0200 [FLINK

[flink] branch master updated (396bdd1 -> 18ff4ab)

2018-08-10 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 396bdd1 [hotfix] [docs] Fix ProcessWindowFunction code snippets. new 9d67afb [FLINK-10041][state] Extract

[flink] branch release-1.6 updated: [FLINK-10095][state] Swap serialization order in TTL value: first timestamp then user value

2018-08-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new f45f04b [FLINK-10095][state] Swap

[flink] branch master updated: [FLINK-10095][state] Swap serialization order in TTL value: first timestamp then user value

2018-08-07 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new b535fab [FLINK-10095][state] Swap

[flink] branch master updated: [FLINK-9504][logging] Change the log-level of checkpoint duration to debug

2018-08-06 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new b2a9131 [FLINK-9504][logging] Change the log

[flink] branch release-1.6 updated: [FLINK-9938][state] Clean up full snapshot from expired state with TTL

2018-08-03 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 93bb127 [FLINK-9938][state] Clean

[flink] branch master updated: [FLINK-9938][state] Clean up full snapshot from expired state with TTL

2018-08-03 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new ce96c40 [FLINK-9938][state] Clean up full

[flink] branch release-1.6 updated (01a8471 -> 3fb283e)

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git. from 01a8471 [hotfix] [e2e] Remove explicit Maven plugin version new eca1efa [FLINK-9887][state] Integrate

[flink] 02/02: [hotfix] Minor cleanups in LongSerializer

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git commit 3fb283e4f05d52a7dcb0b6a90baa1b1438863794 Author: Stefan Richter AuthorDate: Mon Jul 30 19:06:48 2018 +0200

[flink] 01/02: [FLINK-9887][state] Integrate priority queue state with existing serializer upgrade mechanism

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git commit eca1efa1f38737509a1348a46629105c45fd8414 Author: Stefan Richter AuthorDate: Fri Jul 27 14:49:27 2018 +0200

[flink] 01/02: [FLINK-9887][state] Integrate priority queue state with existing serializer upgrade mechanism

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 9d273a3fcda4033e1a385c0ff0c4a2b7ad640721 Author: Stefan Richter AuthorDate: Fri Jul 27 14:49:27 2018 +0200 [FLINK

[flink] branch master updated (1fe5e4b -> 6aaf5ed)

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 1fe5e4b [hotfix] [e2e] Remove explicit Maven plugin version new 9d273a3 [FLINK-9887][state] Integrate

[flink] 02/02: [hotfix] Minor cleanups in LongSerializer

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 6aaf5ed897d6b14241957b1fdc98009e5bec05d7 Author: Stefan Richter AuthorDate: Mon Jul 30 19:06:48 2018 +0200

[flink] branch release-1.6 updated: [hotfix] Correct compilation error from rebase

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.6 by this push: new 6006f93 [hotfix] Correct

[flink] 02/02: [FLINK-10028][core] Introduce reusable ByteArrayData[Input/Output]View as adapter between Data[Input/Output]View and byte-arrays

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git commit 7aaa0c43f7591996dc8d693b3ed8ab9c037c55e2 Author: Stefan Richter AuthorDate: Thu Aug 2 11:47:44 2018 +0200

[flink] branch release-1.6 updated (c1f7cc7 -> 7aaa0c4)

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git. from c1f7cc7 [hotfix][build] Fix project version in ES6 test module new 271475c [FLINK-9981][state] Testing

[flink] 02/02: [FLINK-10028][core] Introduce reusable ByteArrayData[Input/Output]View as adapter between Data[Input/Output]View and byte-arrays

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit fffd2e8c5c1eeaaae90eaef56cd577c631f2091b Author: Stefan Richter AuthorDate: Thu Aug 2 11:47:44 2018 +0200 [FLINK

[flink] branch master updated (db00cb4 -> fffd2e8)

2018-08-02 Thread srichter
This is an automated email from the ASF dual-hosted git repository. srichter pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from db00cb4 [FLINK-10021][tests] Update operator name when querying metrics new a20fd1d [FLINK-9981][state

flink git commit: [hotfix] Fix loop in FailingSource

2018-07-20 Thread srichter
Repository: flink Updated Branches: refs/heads/release-1.6 1ee705afa -> 8b1cc1674 [hotfix] Fix loop in FailingSource Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8b1cc167 Tree: http://git-wip-us.apache.org/repos/asf/fli

flink git commit: [hotfix] Fix loop in FailingSource

2018-07-20 Thread srichter
Repository: flink Updated Branches: refs/heads/master 0b4947b61 -> f60aa6e72 [hotfix] Fix loop in FailingSource Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f60aa6e7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tr

flink git commit: [FLINK-9902][tests] Improve and refactor window checkpointing IT cases

2018-07-20 Thread srichter
Repository: flink Updated Branches: refs/heads/release-1.6 6a36afd3a -> f19337a7d [FLINK-9902][tests] Improve and refactor window checkpointing IT cases This closes #6376. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f

flink git commit: [FLINK-9902][tests] Improve and refactor window checkpointing IT cases

2018-07-20 Thread srichter
Repository: flink Updated Branches: refs/heads/master 01cf808ee -> d309e61e2 [FLINK-9902][tests] Improve and refactor window checkpointing IT cases This closes #6376. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d309e6

flink git commit: [FLINK-9858][tests] State TTL End-to-End Test

2018-07-20 Thread srichter
Repository: flink Updated Branches: refs/heads/release-1.6 36ae5cd3c -> 6a36afd3a [FLINK-9858][tests] State TTL End-to-End Test This closes #6361. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6a36afd3 Tree: http://git-

flink git commit: [FLINK-9858][tests] State TTL End-to-End Test

2018-07-20 Thread srichter
Repository: flink Updated Branches: refs/heads/master 46334e2f3 -> 01cf808ee [FLINK-9858][tests] State TTL End-to-End Test This closes #6361. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/01cf808e Tree: http://git-wip-u

[2/3] flink git commit: [FLINK-9701] Introduce TTL configuration in state descriptors

2018-07-12 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/f45b7f7f/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlListStateTest.java -- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlList

[1/3] flink git commit: [FLINK-9701] Introduce TTL configuration in state descriptors

2018-07-12 Thread srichter
Repository: flink Updated Branches: refs/heads/master b407ba792 -> f45b7f7ff http://git-wip-us.apache.org/repos/asf/flink/blob/f45b7f7f/flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBTtlStateTest.java ---

[3/3] flink git commit: [FLINK-9701] Introduce TTL configuration in state descriptors

2018-07-12 Thread srichter
[FLINK-9701] Introduce TTL configuration in state descriptors This closes #6313. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f45b7f7f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f45b7f7f Diff: http://git-wip-u

[2/2] flink git commit: [FLINK-9799][state] Generalize and unify state meta infos

2018-07-12 Thread srichter
[FLINK-9799][state] Generalize and unify state meta infos This closes #6308. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f1ac0f27 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f1ac0f27 Diff: http://git-wip-us.ap

[1/2] flink git commit: [FLINK-9799][state] Generalize and unify state meta infos

2018-07-12 Thread srichter
Repository: flink Updated Branches: refs/heads/master 5363595d5 -> f1ac0f279 http://git-wip-us.apache.org/repos/asf/flink/blob/f1ac0f27/flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/LegacyStateMetaInfoReaders.java ---

flink git commit: [FLINK-9511] Implement state TTL configuration

2018-07-11 Thread srichter
Repository: flink Updated Branches: refs/heads/master 5c43d2b8a -> dc7d81c9c [FLINK-9511] Implement state TTL configuration This closes #6277. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dc7d81c9 Tree: http://git-wip-

[1/2] flink git commit: [FLINK-9486][state] Introduce InternalPriorityQueue as state in keyed state backends

2018-07-09 Thread srichter
Repository: flink Updated Branches: refs/heads/master b12acea2a -> 79b38f8f9 http://git-wip-us.apache.org/repos/asf/flink/blob/79b38f8f/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java -

[2/2] flink git commit: [FLINK-9486][state] Introduce InternalPriorityQueue as state in keyed state backends

2018-07-09 Thread srichter
[FLINK-9486][state] Introduce InternalPriorityQueue as state in keyed state backends This commit does not include the integration with checkpointing. This closes #6276. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/79b38f

[1/2] flink git commit: [FLINK-9513][state] Implement TTL state wrappers factory and serializer for value with TTL

2018-07-04 Thread srichter
Repository: flink Updated Branches: refs/heads/master 382dd0644 -> afdbf5471 http://git-wip-us.apache.org/repos/asf/flink/blob/afdbf547/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/mock/MockInternalValueState.java ---

[2/2] flink git commit: [FLINK-9513][state] Implement TTL state wrappers factory and serializer for value with TTL

2018-07-04 Thread srichter
[FLINK-9513][state] Implement TTL state wrappers factory and serializer for value with TTL This closes #6196. This closes #5799. (forgotten) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/afdbf547 Tree: http://git-wip-us.ap

[2/4] flink git commit: [FLINK-9491][state] Generalization of timer queue (decoupled from timers) and second implementation based on RocksDB

2018-07-03 Thread srichter
http://git-wip-us.apache.org/repos/asf/flink/blob/c6ad421e/flink-runtime/src/test/java/org/apache/flink/runtime/state/heap/OrderedSetCacheTestBase.java -- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/state/hea

<    1   2   3   4   5   6   7   8   >