[9/9] flink git commit: [FLINK-4959] [docs] Add documentation for ProcessFunction

[FLINK-4959] [docs] Add documentation for ProcessFunction Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a339a65 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7a339a65 Diff: http://git-wip-us.apache.org/repos/asf/f

[1/9] flink git commit: [FLINK-5438] [streaming api] Typo in JobGraph generator Exception

Repository: flink Updated Branches: refs/heads/master ef8cdfe59 -> 7a339a65f [FLINK-5438] [streaming api] Typo in JobGraph generator Exception This closes #3098 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c2f28c01 Tre

[2/9] flink git commit: [FLINK-5448] [checkpoints] Fix typo in StateAssignmentOperation Exception

[FLINK-5448] [checkpoints] Fix typo in StateAssignmentOperation Exception This closes #3097 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fa67ef40 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fa67ef40 Diff: http:

[1/7] flink git commit: [FLINK-5448] [checkpoints] Fix typo in StateAssignmentOperation Exception

Repository: flink Updated Branches: refs/heads/release-1.2 f4869a66d -> 2eb926f2b [FLINK-5448] [checkpoints] Fix typo in StateAssignmentOperation Exception This closes #3097 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit

[2/7] flink git commit: [FLINK-5438] [streaming api] Typo in JobGraph generator Exception

[FLINK-5438] [streaming api] Typo in JobGraph generator Exception This closes #3098 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/30b467f2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/30b467f2 Diff: http://git-wi

[6/7] flink git commit: [FLINK-3617] [scala apis] Added null value check.

[FLINK-3617] [scala apis] Added null value check. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/27c11e1b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/27c11e1b Diff: http://git-wip-us.apache.org/repos/asf/flink/dif

[4/7] flink git commit: [FLINK-5345] [core] Add a utility to delete directories without failing in the presence of concurrent deletes

[FLINK-5345] [core] Add a utility to delete directories without failing in the presence of concurrent deletes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b1be3f5c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b1

[5/7] flink git commit: [FLINK-5345] [core] Migrate various cleanup calls to concurrency-safe directory deletion

[FLINK-5345] [core] Migrate various cleanup calls to concurrency-safe directory deletion Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d1b86aab Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d1b86aab Diff: http://g

[7/7] flink git commit: [FLINK-4959] [docs] Add documentation for ProcessFunction

[FLINK-4959] [docs] Add documentation for ProcessFunction Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2eb926f2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2eb926f2 Diff: http://git-wip-us.apache.org/repos/asf/f

[3/7] flink git commit: [FLINK-5485] [webfrontend] Mark compiled web frontend files as binary when processed by git diff

[FLINK-5485] [webfrontend] Mark compiled web frontend files as binary when processed by git diff Particularly beneficial now that javascript is minified, we can mark compiled web frontend files as binary when processed by git diff. https://linux.die.net/man/5/gitattributes This does not affect

[2/2] flink git commit: [FLINK-5531] [docs] Fix SSL code-block/list formatting

[FLINK-5531] [docs] Fix SSL code-block/list formatting This closes #3140 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d0bcd9d6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d0bcd9d6 Diff: http://git-wip-us.apache

[1/2] flink git commit: [FLINK-5521] [runtime] remove unused KvStateRequestSerializer#serializeList

Repository: flink Updated Branches: refs/heads/release-1.2 a988e6cc9 -> d3a16d298 [FLINK-5521] [runtime] remove unused KvStateRequestSerializer#serializeList Also make sure that the serialization via the state backends' list states matches the deserialization of the KvStateRequestSerializer#de

[1/4] flink git commit: [FLINK-5531] [docs] Fix SSL code-block/list formatting

Repository: flink Updated Branches: refs/heads/master e1b2cd01c -> a18657dcc [FLINK-5531] [docs] Fix SSL code-block/list formatting This closes #3140 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ac815d78 Tree: http://g

[3/4] flink git commit: [FLINK-5521] [runtime] remove unused KvStateRequestSerializer#serializeList

[FLINK-5521] [runtime] remove unused KvStateRequestSerializer#serializeList Also make sure that the serialization via the state backends' list states matches the deserialization of the KvStateRequestSerializer#deserializeList method. So far, it was used this way but not made sure via tests. This

[2/4] flink git commit: [FLINK-5543] [client] Add a comment to the code about adding a customCommandLine to the CLI

[FLINK-5543] [client] Add a comment to the code about adding a customCommandLine to the CLI This closes #3144 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cda40a7f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c

[4/4] flink git commit: [FLINK-5519] [build] scala-maven-plugin version all change to 3.2.2

[FLINK-5519] [build] scala-maven-plugin version all change to 3.2.2 This closes #3132 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a18657dc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a18657dc Diff: http://git-

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

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-5585] [jobmanager] Fix NullPointerException in JobManager.updateAccumulators

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: [FLINK-5459] [docs] Add troubleshooting guide for classloading issues

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://

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

[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

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

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

flink git commit: [FLINK-5454] [docs] Add documentation how to tune streaming applications for large state

Repository: flink Updated Branches: refs/heads/master 21742b2d7 -> 392b2e9a0 [FLINK-5454] [docs] Add documentation how to tune streaming applications for large state Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/392b2e9

flink git commit: [FLINK-5454] [docs] Add documentation how to tune streaming applications for large state

Repository: flink Updated Branches: refs/heads/release-1.2 7a0e3d610 -> 099cdd010 [FLINK-5454] [docs] Add documentation how to tune streaming applications for large state Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/09

[3/9] flink git commit: [hotfix] Cleanups of the AbstractKeyedStateBackend

[hotfix] Cleanups of the AbstractKeyedStateBackend Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/51c02eee Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/51c02eee Diff: http://git-wip-us.apache.org/repos/asf/flink/di

[1/9] flink git commit: [hotfix] [streaming api] Non-merging triggers throw UnsupportedOperationException instead of RuntimeException

Repository: flink Updated Branches: refs/heads/master 392b2e9a0 -> 09380e492 [hotfix] [streaming api] Non-merging triggers throw UnsupportedOperationException instead of RuntimeException Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf

[5/9] flink git commit: [FLINK-5590] [runtime] Add proper internal state hierarchy

http://git-wip-us.apache.org/repos/asf/flink/blob/3b97128f/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java -- diff --git a/flink-streaming-java/src/main/java/org/apache

[9/9] flink git commit: [FLINK-5582] [streaming] Add 'AggregateFunction' and 'AggregatingState'.

[FLINK-5582] [streaming] Add 'AggregateFunction' and 'AggregatingState'. The AggregateFunction implements a very flexible interface for distributive aggregations. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/09380e49 Tree

[7/9] flink git commit: [FLINK-5590] [runtime] Add proper internal state hierarchy

[FLINK-5590] [runtime] Add proper internal state hierarchy This introduces an internal state hierarchy that mirrors the external state hierarchy, but gives the runtime access to methods that should not be part of the user facing API, such as: - setting namespaces - accessing raw values - m

[2/9] flink git commit: [hotfix] Remove no longer used Generic State classes

[hotfix] Remove no longer used Generic State classes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/254a7007 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/254a7007 Diff: http://git-wip-us.apache.org/repos/asf/flink/

[6/9] flink git commit: [FLINK-5590] [runtime] Add proper internal state hierarchy

http://git-wip-us.apache.org/repos/asf/flink/blob/3b97128f/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapListState.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapList

[8/9] flink git commit: [hotfix] Remove sysout logging in SavepointMigrationTestBase and fix several warnings.

[hotfix] Remove sysout logging in SavepointMigrationTestBase and fix several warnings. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b3fd395 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2b3fd395 Diff: http://git

[4/9] flink git commit: [hotfix] [runtime] Various code cleanups and reductions of warnings in heap state restoring code

[hotfix] [runtime] Various code cleanups and reductions of warnings in heap state restoring code Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8a784e9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b8a784e9 Diff:

[3/6] flink git commit: [FLINK-5532] [streaming api] Make marker window assigners for aligned window ops non-extendable

[FLINK-5532] [streaming api] Make marker window assigners for aligned window ops non-extendable Makes the TumblingAlignedProcessingTimeWindows and the SlidingAlignedProcessingTimeWindows final so that users cannot extend them. This closes #3180 Project: http://git-wip-us.apache.org/repos/asf/f

[5/6] flink git commit: [FLINK-5562] [gelly] Driver fixes: Improve parametrization and output formatting.

[FLINK-5562] [gelly] Driver fixes: Improve parametrization and output formatting. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c943e68 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3c943e68 Diff: http://git-wip-

[1/6] flink git commit: [FLINK-5118] [metrics] Fix inconsistent numBytesIn/Out metrics for network channels

Repository: flink Updated Branches: refs/heads/release-1.2 1d6b8bbce -> 940b4900d [FLINK-5118] [metrics] Fix inconsistent numBytesIn/Out metrics for network channels Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/940b490

[4/6] flink git commit: [FLINK-5532] [streaming api] Improve JavaDocs for assigners for Fast Aligned Windows to clarify role

[FLINK-5532] [streaming api] Improve JavaDocs for assigners for Fast Aligned Windows to clarify role Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/feeb9d7b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/feeb9d7b Di

[6/6] flink git commit: [hotfix] [gelly] Fix TriangleListing EdgeOrder

[hotfix] [gelly] Fix TriangleListing EdgeOrder The edge bitmask was swapped in ed09dba. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7d3bfa2f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7d3bfa2f Diff: http://gi

[2/6] flink git commit: [hotfix] [build] Include flink-gelly-examples in opt/

[hotfix] [build] Include flink-gelly-examples in opt/ Adds the flink-gelly-examples jar to the opt/ directory of the binary release artifacts. The examples jar is referenced in the online documentation. Corrects the file paths in the Gelly quickstart documentation. Project: http://git-wip-us.ap

[1/6] flink git commit: [FLINK-5118] [metrics] Fix inconsistent numBytesIn/Out metrics for network channels

Repository: flink Updated Branches: refs/heads/master 33780ef4f -> 3a258f7ea [FLINK-5118] [metrics] Fix inconsistent numBytesIn/Out metrics for network channels This closes #3106 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/

[4/6] flink git commit: [FLINK-5532] [streaming api] Improve JavaDocs for assigners for Fast Aligned Windows to clarify role

[FLINK-5532] [streaming api] Improve JavaDocs for assigners for Fast Aligned Windows to clarify role Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b4fb1ce5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b4fb1ce5 Di

[5/6] flink git commit: [FLINK-5562] [gelly] Driver fixes: Improve parametrization and output formatting.

[FLINK-5562] [gelly] Driver fixes: Improve parametrization and output formatting. This closes #3187 This closes #3188 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a246ec2a Tree: http://git-wip-us.apache.org/repos/asf/flin

[2/6] flink git commit: [hotfix] [build] Include flink-gelly-examples in opt/

[hotfix] [build] Include flink-gelly-examples in opt/ Adds the flink-gelly-examples jar to the opt/ directory of the binary release artifacts. The examples jar is referenced in the online documentation. Corrects the file paths in the Gelly quickstart documentation. Project: http://git-wip-us.ap

[6/6] flink git commit: [hotfix] [gelly] Fix TriangleListing EdgeOrder

[hotfix] [gelly] Fix TriangleListing EdgeOrder The edge bitmask was swapped in ed09dba. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/185a5f20 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/185a5f20 Diff: http://gi

[3/6] flink git commit: [FLINK-5532] [streaming api] Make marker window assigners for aligned window ops non-extendable

[FLINK-5532] [streaming api] Make marker window assigners for aligned window ops non-extendable Makes the TumblingAlignedProcessingTimeWindows and the SlidingAlignedProcessingTimeWindows final so that users cannot extend them. This closes #3180 Project: http://git-wip-us.apache.org/repos/asf/f

[2/4] flink git commit: [hotfix] [streaming api] Minor cleanup in WindowedStream and AllWindowedStream

[hotfix] [streaming api] Minor cleanup in WindowedStream and AllWindowedStream Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/159f51b2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/159f51b2 Diff: http://git-wip-us.a

[1/4] flink git commit: [FLINK-5247] [streaming api] Fix checks for allowed lateness in windowed streams

Repository: flink Updated Branches: refs/heads/release-1.2 28dd4a57a -> 1dfb3e0e2 [FLINK-5247] [streaming api] Fix checks for allowed lateness in windowed streams Also, fix outdated documentation. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org

[4/4] flink git commit: [hotfix] [streaming api] Improve JavaDocs of the user-facing checkpointing and state interfaces

[hotfix] [streaming api] Improve JavaDocs of the user-facing checkpointing and state interfaces Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1dfb3e0e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1dfb3e0e Diff: h

[3/4] flink git commit: [FLINK-4917] [streaming api] Deprecate "CheckpointedAsynchronously" interface

[FLINK-4917] [streaming api] Deprecate "CheckpointedAsynchronously" interface This closes #3087 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/083152c6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/083152c6 Diff: h

[3/6] flink git commit: [FLINK-4905] [kafka 08 consumer] Suppress offset committing failures when fetcher is shutting down

[FLINK-4905] [kafka 08 consumer] Suppress offset committing failures when fetcher is shutting down This closes #3035 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e7cda75b Tree: http://git-wip-us.apache.org/repos/asf/flink

[5/6] flink git commit: [hotfix] [streaming api] Improve JavaDocs of the user-fcing checkpointing and state interfaces

[hotfix] [streaming api] Improve JavaDocs of the user-fcing checkpointing and state interfaces Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c69f366c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c69f366c Diff: ht

[6/6] flink git commit: [FLINK-5577] [yarn] Fix application id growth by reusing Yarn Client

[FLINK-5577] [yarn] Fix application id growth by reusing Yarn Client This closes #3173 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/84064c96 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/84064c96 Diff: http://git

[1/6] flink git commit: [FLINK-4917] [streaming api] Deprecate "CheckpointedAsynchronously" interface

Repository: flink Updated Branches: refs/heads/master acfeeaf5e -> 84064c969 [FLINK-4917] [streaming api] Deprecate "CheckpointedAsynchronously" interface This closes #3087 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/

[2/6] flink git commit: [FLINK-5247] [streaming api] Fix checks for allowed lateness in windowed streams

[FLINK-5247] [streaming api] Fix checks for allowed lateness in windowed streams Also, fix outdated documentation. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/87af8419 Tree: http://git-wip-us.apache.org/repos/asf/flink/tr

[4/6] flink git commit: [hotfix] [streaming api] Minor cleanup in WindowedStream and AllWindowedStream

[hotfix] [streaming api] Minor cleanup in WindowedStream and AllWindowedStream Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6342d6db Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6342d6db Diff: http://git-wip-us.a

flink git commit: [FLINK-5639] [rabbitmq connector] Add a note about MPL 1.1 license of Maven dependency

Repository: flink Updated Branches: refs/heads/master 171b11095 -> 8004999fc [FLINK-5639] [rabbitmq connector] Add a note about MPL 1.1 license of Maven dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8004999f

flink git commit: [FLINK-5639] [rabbitmq connector] Add a note about MPL 1.1 license of Maven dependency

Repository: flink Updated Branches: refs/heads/release-1.2 47cf3a3c7 -> 3efd3115c [FLINK-5639] [rabbitmq connector] Add a note about MPL 1.1 license of Maven dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3efd

flink git commit: [FLINK-5639] [rabbitmq connector] Add a note about MPL 1.1 license of Maven dependency

Repository: flink Updated Branches: refs/heads/release-1.1 6566b63aa -> 743aaf6f8 [FLINK-5639] [rabbitmq connector] Add a note about MPL 1.1 license of Maven dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/743a

flink git commit: [FLINK-5639] [rabbitmq connector] Fix incorrect location of README.md for backported notice

Repository: flink Updated Branches: refs/heads/release-1.1 743aaf6f8 -> 0c99e48c0 [FLINK-5639] [rabbitmq connector] Fix incorrect location of README.md for backported notice 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: [license] Update license with 'angular-drag-and-drop-lists' dependency

Repository: flink Updated Branches: refs/heads/release-1.2 3efd3115c -> d4b92bcf7 [license] Update license with 'angular-drag-and-drop-lists' dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d4b92bcf Tree: http:/

flink git commit: [license] Update license with 'angular-drag-and-drop-lists' dependency

Repository: flink Updated Branches: refs/heads/master 8004999fc -> 34e106f63 [license] Update license with 'angular-drag-and-drop-lists' dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/34e106f6 Tree: http://git-

[2/4] flink git commit: [FLINK-5630] [streaming api] Followups to the AggregateFunction

http://git-wip-us.apache.org/repos/asf/flink/blob/1542260d/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowTranslationTest.scala -- diff --git a/flink-streaming-scala/src/test/scala/org/apache/flink

[4/4] flink git commit: [hotfix] Fix testing setup of StreamingOperatorsITCase via ScalaStreamingMultipleProgramsTestBase

[hotfix] Fix testing setup of StreamingOperatorsITCase via ScalaStreamingMultipleProgramsTestBase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/082f892a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/082f892a Diff:

[3/4] flink git commit: [FLINK-5630] [streaming api] Followups to the AggregateFunction

[FLINK-5630] [streaming api] Followups to the AggregateFunction - Add a RichAggregateFunction - Document generic type parameters - Allowing different input/output types for the cases where an additional window apply function is specified - Adding the aggregate() methods to the Scala API

[1/4] flink git commit: [FLINK-5632] [streaming api] Fix typo in StreamGraph variable name

Repository: flink Updated Branches: refs/heads/master 54d3e2668 -> 082f892ad [FLINK-5632] [streaming api] Fix typo in StreamGraph variable name This closes #3203 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6f5c7d8a Tr

[2/2] flink git commit: [FLINK-5612] [code] Make GlobPathFilter serializable

[FLINK-5612] [code] Make GlobPathFilter serializable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ef96054d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ef96054d Diff: http://git-wip-us.apache.org/repos/asf/flink/

flink git commit: [FLINK-5612] [code] Make GlobPathFilter serializable

Repository: flink Updated Branches: refs/heads/release-1.2 2df0e4781 -> bb9a95a51 [FLINK-5612] [code] Make GlobPathFilter serializable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bb9a95a5 Tree: http://git-wip-us.apache

[1/2] flink git commit: [hotfix] [tests] Speed up StreamCheckpointNotifierITCase

Repository: flink Updated Branches: refs/heads/master 4fbc6316f -> ef96054d1 [hotfix] [tests] Speed up StreamCheckpointNotifierITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fc597f6f Tree: http://git-wip-us.apache.

[flink] 03/04: [FLINK-24255][tests] Test environments respect configuration when being instantiated.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 57253c5fc880fff880526a8954446c8189ac7c72 Author: Stephan Ewen AuthorDate: Fri Aug 27 02:27:10 2021 +0200 [FLINK

[flink] branch master updated (ad16e2c -> 7a10982)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from ad16e2c [FLINK-24889][table] Support casting MULTISET to STRING new c2f510f [hotfix][coordination] Improve hint

[flink] 01/04: [hotfix][coordination] Improve hint to build akka RPC system.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit c2f510f670cc26ba85d183d822ef8c41ff6bd068 Author: Stephan Ewen AuthorDate: Thu Nov 18 15:31:29 2021 +0100 [hotfix

[flink] 04/04: [FLINK-23842][coordination] Add logging statements in SourceCoordinators for reader registration and split requests.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 7a109823a21150c7bea9ba41fc22203cbaf7094f Author: Stephan Ewen AuthorDate: Tue Aug 17 18:31:54 2021 +0200 [FLINK

[flink] 02/04: [FLINK-24366][runtime] Don't log error for failed task restore if the task is already canceled.

This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e6798c3e40bffeccfc35c84021e63aae41a3ac48 Author: Stephan Ewen AuthorDate: Thu Sep 23 17:47:13 2021 +0200 [FLINK

[flink] branch release-1.14 updated (9d114b0 -> dfa47af)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from 9d114b0 [FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods add

[flink] branch release-1.13 updated (b9c729e -> a3a776d)

This is an automated email from the ASF dual-hosted git repository. sewen pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from b9c729e [FLINK-24631][k8s] Use a stable subset of labels to select jobManager and taskManager pods add

flink git commit: [FLINK-4229] [metrics] Only start JMX server when port is specified

Repository: flink Updated Branches: refs/heads/master 5dd85e286 -> 73836f7ac [FLINK-4229] [metrics] Only start JMX server when port is specified This closes #2279 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/73836f7a T

[5/8] flink git commit: [hotfix] [build] Update LICENSE file with new URL of simplejmx dependency

[hotfix] [build] Update LICENSE file with new URL of simplejmx dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4456453b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4456453b Diff: http://git-wip-us.apache

[6/8] flink git commit: [hotfix] Remove various '.hidden' files that seem to have been accidentally committed

[hotfix] Remove various '.hidden' files that seem to have been accidentally committed Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cb98256c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cb98256c Diff: http://git-

[1/8] flink git commit: [FLINK-4251] [Rabbit MQ] Allow users to override queue setup in order to customize queue config

Repository: flink Updated Branches: refs/heads/master 7ea9c0195 -> 873d6cd18 [FLINK-4251] [Rabbit MQ] Allow users to override queue setup in order to customize queue config This closes #2281 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repo

[8/8] flink git commit: [FLINK-4290] [Cassandra Connector] Skip CassandraConnectorTest on Java 7 builds

[FLINK-4290] [Cassandra Connector] Skip CassandraConnectorTest on Java 7 builds Cassandra needs Java 8 to run reliably. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/873d6cd1 Tree: http://git-wip-us.apache.org/repos/asf/fli

[4/8] flink git commit: [hotfix] [docs] Remove obsolete file 'plotPoints.py'

[hotfix] [docs] Remove obsolete file 'plotPoints.py' Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8847955f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8847955f Diff: http://git-wip-us.apache.org/repos/asf/flink/

[3/8] flink git commit: [FLINK-4285] [docs] Update the setup quickstart guide with the new SocketWindowWordCount example

[FLINK-4285] [docs] Update the setup quickstart guide with the new SocketWindowWordCount example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ba12a751 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ba12a751 Diff:

[2/8] flink git commit: [FLINK-4292] [batch connectors] Fix setup of HCatalog project by adding Scala SDK dependency

[FLINK-4292] [batch connectors] Fix setup of HCatalog project by adding Scala SDK dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/923c6a7e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/923c6a7e Diff: http

[7/8] flink git commit: [FLINK-4298] [storm compatibility] Clean up unnecessary dependencies in 'flink-storm'

[FLINK-4298] [storm compatibility] Clean up unnecessary dependencies in 'flink-storm' Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ea2596e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0ea2596e Diff: http://git-

[3/7] flink git commit: [FLINK-4292] [batch connectors] Fix setup of HCatalog project by adding Scala SDK dependency

[FLINK-4292] [batch connectors] Fix setup of HCatalog project by adding Scala SDK dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/70a0479c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/70a0479c Diff: http

[6/7] flink git commit: [hotfix] [build] Update LICENSE file with new URL of simplejmx dependency

[hotfix] [build] Update LICENSE file with new URL of simplejmx dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4d6a7afd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4d6a7afd Diff: http://git-wip-us.apache

[2/7] flink git commit: [FLINK-4285] [docs] Update the setup quickstart guide with the new SocketWindowWordCount example

[FLINK-4285] [docs] Update the setup quickstart guide with the new SocketWindowWordCount example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7b6ed59a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7b6ed59a Diff:

[7/7] flink git commit: [FLINK-4290] [Cassandra Connector] Skip CassandraConnectorTest on Java 7 builds

[FLINK-4290] [Cassandra Connector] Skip CassandraConnectorTest on Java 7 builds Cassandra needs Java 8 to run reliably. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ae41a92 Tree: http://git-wip-us.apache.org/repos/asf/fli

[5/7] flink git commit: [hotfix] Remove various '.hidden' files that seem to have been accidentally committed

[hotfix] Remove various '.hidden' files that seem to have been accidentally committed Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/633d92dc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/633d92dc Diff: http://git-

[4/7] flink git commit: [FLINK-4251] [Rabbit MQ] Allow users to override queue setup in order to customize queue config

[FLINK-4251] [Rabbit MQ] Allow users to override queue setup in order to customize queue config This closes #2281 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bf1bbb15 Tree: http://git-wip-us.apache.org/repos/asf/flink/tr

[1/7] flink git commit: [hotfix] [docs] Remove obsolete file 'plotPoints.py'

Repository: flink Updated Branches: refs/heads/release-1.1 4d988a925 -> 8ae41a926 [hotfix] [docs] Remove obsolete file 'plotPoints.py' Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b0a9987c Tree: http://git-wip-us.apache

flink git commit: [FLINK-4298] [storm compatibility] Add proper repository for Closure dependencies.

Repository: flink Updated Branches: refs/heads/master 4b8f28825 -> 45df1b25b [FLINK-4298] [storm compatibility] Add proper repository for Closure dependencies. Adds further dependency exlcusions for unneeded (and potentially conflicting) storm dependencies. Project: http://git-wip-us.apach

flink git commit: [FLINK-4307] [streaming API] Restore ListState behavior for user-facing ListStates

Repository: flink Updated Branches: refs/heads/release-1.1 8ae41a926 -> b1f827f57 [FLINK-4307] [streaming API] Restore ListState behavior for user-facing ListStates Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b1f827f5

[2/2] flink git commit: [hotfix] [tests] Fix minor test instability in ConnectionUtilsTest

[hotfix] [tests] Fix minor test instability in ConnectionUtilsTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/36c09b09 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/36c09b09 Diff: http://git-wip-us.apache.org/re

[1/2] flink git commit: [FLINK-4306] [storm compatibility] Fix dependencies in flink-storm and flink-storm-examples

Repository: flink Updated Branches: refs/heads/master 5d2c465af -> 36c09b099 [FLINK-4306] [storm compatibility] Fix dependencies in flink-storm and flink-storm-examples - Flink dependencies are now 'provided' - flink-storm-examples has no direct storm-core dependency, but only depends th

flink git commit: [FLINK-4307] [streaming API] Restore ListState behavior for user-facing ListStates

Repository: flink Updated Branches: refs/heads/master 31837a757 -> d5a06b4d6 [FLINK-4307] [streaming API] Restore ListState behavior for user-facing ListStates Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d5a06b4d Tree

[3/3] flink git commit: [FLINK-4161] [build] Add Quickstart exclusion for flink-dist dependencies

[FLINK-4161] [build] Add Quickstart exclusion for flink-dist dependencies This closes #2309 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/745b393f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/745b393f Diff: http:

[1/3] flink git commit: [build] Bump version to 1.2-SNAPSHOT

Repository: flink Updated Branches: refs/heads/master d5a06b4d6 -> 745b393f8 [build] Bump version to 1.2-SNAPSHOT This closes #2324 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/036f4d01 Tree: http://git-wip-us.apache.o

[2/3] flink git commit: [build] Bump docs and tools to version 1.2-SNAPSHOT

[build] Bump docs and tools to version 1.2-SNAPSHOT Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6025157b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6025157b Diff: http://git-wip-us.apache.org/repos/asf/flink/d

flink-web git commit: [faq] Add FAQ entry about YARN container kills due to exceeding allowed memory

Repository: flink-web Updated Branches: refs/heads/asf-site f7fd98e87 -> 75ddc959f [faq] Add FAQ entry about YARN container kills due to exceeding allowed memory Also improve answer about lost TaskManager. Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-

flink git commit: [build] Move GitHub specific files to '.github', update release script

Repository: flink Updated Branches: refs/heads/master 745b393f8 -> 245f02bd6 [build] Move GitHub specific files to '.github', update release script Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/245f02bd Tree: http://git-

<    1   2   3   4   5   6   7   8   9   10   >