[1/4] flink git commit: [FLINK-2991] Adjust RocksDB Folding State to latest RocksDBStateBackend

Repository: flink Updated Branches: refs/heads/master b6bfcf008 -> e927ec0be [FLINK-2991] Adjust RocksDB Folding State to latest RocksDBStateBackend Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e927ec0b Tree: http://git

[3/4] flink git commit: [FLINK-2991] Add Folding State and use in WindowOperator

[FLINK-2991] Add Folding State and use in WindowOperator This enables efficient incremental aggregation of fold window. This also adds: - WindowedStream.apply(initVal, foldFunction, windowFunction) - AllWindowedStream.apply(initVal, foldFunction, windowFunction) This closes #1605 Project: http

flink git commit: [FLINK-3392] [kafka] Fix unsynchronized access in ClosableBlockingQueue

Repository: flink Updated Branches: refs/heads/master e927ec0be -> c47cb7af1 [FLINK-3392] [kafka] Fix unsynchronized access in ClosableBlockingQueue Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c47cb7af Tree: http://git

[4/5] flink git commit: [FLINK-3413] [streaming] Remove implicit Seq -> DataStream conversion

[FLINK-3413] [streaming] Remove implicit Seq -> DataStream conversion Because the implicit conversion creates a new ExecutionEnvironment, it leads to strange errors when used withing programs with more than one source. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git

[5/5] flink git commit: [hotfix] [rocksdb] Update predefined RocksDB option profiles.

[hotfix] [rocksdb] Update predefined RocksDB option profiles. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/75dcfc02 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/75dcfc02 Diff: http://git-wip-us.apache.org/repos/a

[1/5] flink git commit: [hotfix] [streaming] Add check in StreamRecord for reserved timestamp values

Repository: flink Updated Branches: refs/heads/master 932a49d7b -> a66458eac [hotfix] [streaming] Add check in StreamRecord for reserved timestamp values Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a66458ea Tree: http:

[2/5] flink git commit: [hotfix] [streaming] Remove some unused internal classes

[hotfix] [streaming] Remove some unused internal classes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5b1231dd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5b1231dd Diff: http://git-wip-us.apache.org/repos/asf/fl

[3/5] flink git commit: [hotfix] [streaming] Remove unused code fragment from DataStream.union() function.

[hotfix] [streaming] Remove unused code fragment from DataStream.union() function. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/489e6535 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/489e6535 Diff: http://git-wip

flink git commit: [FLINK-3420] [api-breaking] Remove utility functions 'readTextFileWithValue' and 'readFileOfPrimitives' from StreamExecutionEnvironment

Repository: flink Updated Branches: refs/heads/master 401837bdf -> ebab47077 [FLINK-3420] [api-breaking] Remove utility functions 'readTextFileWithValue' and 'readFileOfPrimitives' from StreamExecutionEnvironment These methods are highly specific for very niche cases of bounded data stream p

[1/3] flink git commit: [FLINK-3379] [FLINK-3415] [streaming] Refactor TimestampExtractor into two separate classes

Repository: flink Updated Branches: refs/heads/master c1412dde3 -> e08d7a6f3 http://git-wip-us.apache.org/repos/asf/flink/blob/74c2b80b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowFoldITCase.java ---

[3/3] flink git commit: [FLINK-3401] [streaming] [api breaking] AscendingTimestampExtractor only logs violations of ascending timestamp order.

[FLINK-3401] [streaming] [api breaking] AscendingTimestampExtractor only logs violations of ascending timestamp order. The user can also explicitly set an 'IgnoringHandler' or a 'FailingHandler', which do nothing on violations, respectively fail hard. Project: http://git-wip-us.apache.org/repo

[2/3] flink git commit: [FLINK-3379] [FLINK-3415] [streaming] Refactor TimestampExtractor into two separate classes

[FLINK-3379] [FLINK-3415] [streaming] Refactor TimestampExtractor into two separate classes - one class handled periodic watermarks - the other class handled watermarks triggered by elements This also makes sure that any timestamp assigner / watermark generators cannot generate negative water

[5/6] flink git commit: [FLINK-3419] [streaming] Drop 'partitionByHash' function, subsumed by 'keyBy()'

[FLINK-3419] [streaming] Drop 'partitionByHash' function, subsumed by 'keyBy()' Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/06a42bf6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/06a42bf6 Diff: http://git-wip-us.

[3/6] flink git commit: [FLINK-3421] [streaming scala] Remove unneeded ClassTag context bounds

[FLINK-3421] [streaming scala] Remove unneeded ClassTag context bounds Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a8afec3b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a8afec3b Diff: http://git-wip-us.apache.or

[4/6] flink git commit: [hotfix] Properly declare ComplexIntegrationTest as an Integration Test Case

[hotfix] Properly declare ComplexIntegrationTest as an Integration Test Case Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bd137aec Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bd137aec Diff: http://git-wip-us.apa

[2/6] flink git commit: [hotfix] Auto-select actor system port in TestingCluster to prevent port collisions

[hotfix] Auto-select actor system port in TestingCluster to prevent port collisions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a4e8fcbe Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a4e8fcbe Diff: http://git-wi

[1/6] flink git commit: [hotfix] Fixes to flink-annotations JavaDocs

Repository: flink Updated Branches: refs/heads/master 50a166df3 -> a4e8fcbe9 [hotfix] Fixes to flink-annotations JavaDocs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/97d1f4a1 Tree: http://git-wip-us.apache.org/repos/as

[6/6] flink git commit: [FLINK-3413] [streaming] Make implicit conversions from Java DataStream to Scala DataStream explicit

[FLINK-3413] [streaming] Make implicit conversions from Java DataStream to Scala DataStream explicit This also clean up a lot of JavaDocs in various Scala DataStream API classes. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/comm

flink git commit: [FLINK-3430] Remove "no POJO" warning in TypeAnalyzer

Repository: flink Updated Branches: refs/heads/master a4e8fcbe9 -> cee135a85 [FLINK-3430] Remove "no POJO" warning in TypeAnalyzer This closes #1655 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cee135a8 Tree: http://gi

[1/3] flink git commit: [hotfix] [tests] Increase timeouts in WebFrontendITCase for stability on CI infrastructure

Repository: flink Updated Branches: refs/heads/master 41b826bda -> 138334a6d [hotfix] [tests] Increase timeouts in WebFrontendITCase for stability on CI infrastructure Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/13833

[2/3] flink git commit: [FLINK-3424] [tests] Close InputStream in FileStateBackendTest#validateBytesInStream

[FLINK-3424] [tests] Close InputStream in FileStateBackendTest#validateBytesInStream This closes #1653 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7278e875 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7278e875

[3/3] flink git commit: [FLINK-3423] [tests] Fixed ExternalProcessRunnerTest on Windows

[FLINK-3423] [tests] Fixed ExternalProcessRunnerTest on Windows This closes #1650 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/06e3dd13 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/06e3dd13 Diff: http://git-wip-

flink git commit: [FLINK-3520] [streaming] Periodic watermark operator emits current watermark in close()

Repository: flink Updated Branches: refs/heads/master 725f7467e -> de9a878e9 [FLINK-3520] [streaming] Periodic watermark operator emits current watermark in close() This makes sure that for bounded data sets with watermarks, the final elements get properly reflected in window results. Proj

[01/13] flink git commit: [FLINK-3522] [storm compat] PrintSampleStream prints a proper message when involked without arguments

Repository: flink Updated Branches: refs/heads/master c2a43c95d -> 4f12dee04 [FLINK-3522] [storm compat] PrintSampleStream prints a proper message when involked without arguments Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/c

[11/13] flink git commit: [hotfix] Remove remaining unused files from the old standalone web client

http://git-wip-us.apache.org/repos/asf/flink/blob/7a5dde76/flink-clients/src/main/resources/web-docs/css/bootstrap.css -- diff --git a/flink-clients/src/main/resources/web-docs/css/bootstrap.css b/flink-clients/src/main/resources/

[12/13] flink git commit: [hotfix] Remove remaining unused files from the old standalone web client

[hotfix] Remove remaining unused files from the old standalone web client Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7a5dde76 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7a5dde76 Diff: http://git-wip-us.apache

[09/13] flink git commit: [hotfix] Remove remaining unused files from the old standalone web client

http://git-wip-us.apache.org/repos/asf/flink/blob/7a5dde76/flink-clients/src/main/resources/web-docs/js/d3.js -- diff --git a/flink-clients/src/main/resources/web-docs/js/d3.js b/flink-clients/src/main/resources/web-docs/js/d3.js

[05/13] flink git commit: [hotfix] Remove remaining unused files from the old standalone web client

http://git-wip-us.apache.org/repos/asf/flink/blob/7a5dde76/flink-clients/src/main/resources/web-docs/js/jquery.tools.min.js -- diff --git a/flink-clients/src/main/resources/web-docs/js/jquery.tools.min.js b/flink-clients/src/main/

[10/13] flink git commit: [hotfix] Remove remaining unused files from the old standalone web client

http://git-wip-us.apache.org/repos/asf/flink/blob/7a5dde76/flink-clients/src/main/resources/web-docs/css/graph.css -- diff --git a/flink-clients/src/main/resources/web-docs/css/graph.css b/flink-clients/src/main/resources/web-docs

[03/13] flink git commit: [FLINK-3525] [runtime] Fix call to super.close() in TimestampsAndPeriodicWatermarksOperator

[FLINK-3525] [runtime] Fix call to super.close() in TimestampsAndPeriodicWatermarksOperator Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5e769b38 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5e769b38 Diff: http:

[02/13] flink git commit: [hotfix] Make DataStream property methods properly Scalaesk

[hotfix] Make DataStream property methods properly Scalaesk This also includes some minor cleanups This closes #1689 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4eabd4db Tree: http://git-wip-us.apache.org/repos/asf/flink

[04/13] flink git commit: [hotfix] Remove remaining unused files from the old standalone web client

http://git-wip-us.apache.org/repos/asf/flink/blob/7a5dde76/flink-clients/src/main/resources/web-docs/js/program.js -- diff --git a/flink-clients/src/main/resources/web-docs/js/program.js b/flink-clients/src/main/resources/web-docs

[06/13] flink git commit: [hotfix] Remove remaining unused files from the old standalone web client

http://git-wip-us.apache.org/repos/asf/flink/blob/7a5dde76/flink-clients/src/main/resources/web-docs/js/jquery-2.1.0.js -- diff --git a/flink-clients/src/main/resources/web-docs/js/jquery-2.1.0.js b/flink-clients/src/main/resource

[13/13] flink git commit: [license] Update LICENSE file for the latest version

[license] Update LICENSE file for the latest version Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4f12dee0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4f12dee0 Diff: http://git-wip-us.apache.org/repos/asf/flink/

[07/13] flink git commit: [hotfix] Remove remaining unused files from the old standalone web client

http://git-wip-us.apache.org/repos/asf/flink/blob/7a5dde76/flink-clients/src/main/resources/web-docs/js/graphCreator.js -- diff --git a/flink-clients/src/main/resources/web-docs/js/graphCreator.js b/flink-clients/src/main/resource

[08/13] flink git commit: [hotfix] Remove remaining unused files from the old standalone web client

http://git-wip-us.apache.org/repos/asf/flink/blob/7a5dde76/flink-clients/src/main/resources/web-docs/js/dagre-d3.js -- diff --git a/flink-clients/src/main/resources/web-docs/js/dagre-d3.js b/flink-clients/src/main/resources/web-do

flink git commit: [FLINK-3526] [streaming] Fix Processing Time Window Assigner and Trigger

Repository: flink Updated Branches: refs/heads/master 69eeefabf -> 64519e1c1 [FLINK-3526] [streaming] Fix Processing Time Window Assigner and Trigger This closes #1727 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/64519

flink git commit: [FLINK-3526] [streaming] Fix Processing Time Window Assigner and Trigger

Repository: flink Updated Branches: refs/heads/release-1.0 c0ce1b6d9 -> 603f351e2 [FLINK-3526] [streaming] Fix Processing Time Window Assigner and Trigger This closes #1727 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: [hotfix] Properly copy stream record in ReducingWindowBuffer and FoldingWindowBuffer

Repository: flink Updated Branches: refs/heads/master f881e7079 -> 405d22236 [hotfix] Properly copy stream record in ReducingWindowBuffer and FoldingWindowBuffer Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/405d2223 Tr

flink git commit: [docs] Update readme with current feature list and streaming example

Repository: flink Updated Branches: refs/heads/master 405d22236 -> 5f0af06fe [docs] Update readme with current feature list and streaming example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5f0af06f Tree: http://git-wi

flink git commit: [docs] Update readme with current feature list and streaming example

Repository: flink Updated Branches: refs/heads/release-1.0 5b5136e95 -> 702627116 [docs] Update readme with current feature list and streaming example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/70262711 Tree: http://g

flink git commit: [docs] fix readme typos; use the same scala style in the examples

Repository: flink Updated Branches: refs/heads/release-1.0 30486905b -> 8e30f8665 [docs] fix readme typos; use the same scala style in the examples This closes #1743 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8e30f86

[3/3] flink git commit: [FLINK-2788] [apis] Add TypeHint class to allow type-safe generic type parsing

[FLINK-2788] [apis] Add TypeHint class to allow type-safe generic type parsing This closes #1744 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8d67aa55 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8d67aa55 Diff:

[2/3] flink git commit: [FLINK-3554] [streaming] Emit a MAX Watermark after finite sources finished

[FLINK-3554] [streaming] Emit a MAX Watermark after finite sources finished This closes #1750 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ff80dc04 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ff80dc04 Diff: htt

[1/3] flink git commit: [hotfix] Removed deprecated and commented code in SourceFunctionTest

Repository: flink Updated Branches: refs/heads/master 93733cc00 -> 8d67aa55f [hotfix] Removed deprecated and commented code in SourceFunctionTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8a50524c Tree: http://git-wi

flink git commit: [FLINK-3554] [streaming] Emit a MAX Watermark after finite sources finished

Repository: flink Updated Branches: refs/heads/release-1.0 8949ccf66 -> 43e5975d5 [FLINK-3554] [streaming] Emit a MAX Watermark after finite sources finished This closes #1750 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/comm

flink git commit: [FLINK-2788] [apis] Add TypeHint class to allow type-safe generic type parsing

Repository: flink Updated Branches: refs/heads/release-1.0 43e5975d5 -> 23dc2a4ac [FLINK-2788] [apis] Add TypeHint class to allow type-safe generic type parsing This closes #1744 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/c

flink git commit: [hotfix] Fix JavaDocs for SourceFunction

Repository: flink Updated Branches: refs/heads/master 072da7def -> 7fbfab64f [hotfix] Fix JavaDocs for SourceFunction Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7fbfab64 Tree: http://git-wip-us.apache.org/repos/asf/fl

flink git commit: [hotfix] Fix JavaDocs for SourceFunction

Repository: flink Updated Branches: refs/heads/release-1.0 a79521fba -> 7e6c2ec62 [hotfix] Fix JavaDocs for SourceFunction Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7e6c2ec6 Tree: http://git-wip-us.apache.org/repos/a

flink git commit: [FLINK-3569] [build] Adjust test cases due to shading plugin base directory changes

Repository: flink Updated Branches: refs/heads/release-1.0 b2893116a -> fd0830ead [FLINK-3569] [build] Adjust test cases due to shading plugin base directory changes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd0830e

flink git commit: [FLINK-3569] [build] Adjust test cases due to shading plugin base directory changes

Repository: flink Updated Branches: refs/heads/master dbe9e596e -> bb62ab082 [FLINK-3569] [build] Adjust test cases due to shading plugin base directory changes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bb62ab08 Tre

[5/6] flink git commit: [FLINK-3495] [tests] Disable RocksDB tests on Windows

[FLINK-3495] [tests] Disable RocksDB tests on Windows This closes #1711 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2cde19b1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2cde19b1 Diff: http://git-wip-us.apache.

[6/6] flink git commit: [docs] Add documentation about Event Time, Timestamp Assigners, Watermark Generation

[docs] Add documentation about Event Time, Timestamp Assigners, Watermark Generation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0e61ffc5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0e61ffc5 Diff: http://git-w

[4/6] flink git commit: [FLINK-3575] [docs] Update 'Working With State' section in docs

[FLINK-3575] [docs] Update 'Working With State' section in docs This closes #1760 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c3c7345 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c3c7345 Diff: http://git-wip-

[3/6] flink git commit: [FLINK-3578] [streaming scala] Support RichFunctions for Scala WindowFunction and AllWindowFunction

[FLINK-3578] [streaming scala] Support RichFunctions for Scala WindowFunction and AllWindowFunction This also consolidates the various wrapper classes for fold() and reduce() functions. This closes #1765 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apac

[1/6] flink git commit: [FLINK-3566] [FLINK-3563] [core] TypeExtraction input type validation fixes

Repository: flink Updated Branches: refs/heads/release-1.0 fd0830ead -> b3765408b [FLINK-3566] [FLINK-3563] [core] TypeExtraction input type validation fixes This closes #1759 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/comm

[2/6] flink git commit: [FLINK-3491] [tests] Prevent URIException in HDFSCopyTest and disable HDFSCopyUtilitiesTest on Windows

[FLINK-3491] [tests] Prevent URIException in HDFSCopyTest and disable HDFSCopyUtilitiesTest on Windows This closes #1703 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5a63cbfd Tree: http://git-wip-us.apache.org/repos/asf/f

[08/10] flink git commit: [FLINK-3491] [tests] Prevent URIException in HDFSCopyTest and disable HDFSCopyUtilitiesTest on Windows

[FLINK-3491] [tests] Prevent URIException in HDFSCopyTest and disable HDFSCopyUtilitiesTest on Windows This closes #1703 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c9863576 Tree: http://git-wip-us.apache.org/repos/asf/f

[03/10] flink git commit: [docs] Fix javascript exception caused by disqus and fix typos in cluster execution.

[docs] Fix javascript exception caused by disqus and fix typos in cluster execution. This closes #1756 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b10bd927 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b10bd927

[09/10] flink git commit: [FLINK-3550] [examples] Rework WindowJoin to properly demonstrate continuous window joins (Java + Scala)

[FLINK-3550] [examples] Rework WindowJoin to properly demonstrate continuous window joins (Java + Scala) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/271071ad Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/271071a

[01/10] flink git commit: [docs] Add documentation about Event Time, Timestamp Assigners, Watermark Generation

Repository: flink Updated Branches: refs/heads/master bb62ab082 -> 986d5368f [docs] Add documentation about Event Time, Timestamp Assigners, Watermark Generation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e3835a88 Tr

[05/10] flink git commit: [docs] Active tab caption is now displaying blue

[docs] Active tab caption is now displaying blue This closes #1763 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/628bafa8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/628bafa8 Diff: http://git-wip-us.apache.org/r

[06/10] flink git commit: [FLINK-3566] [FLINK-3563] [core] TypeExtraction input type validation fixes

[FLINK-3566] [FLINK-3563] [core] TypeExtraction input type validation fixes This closes #1759 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/434e88fd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/434e88fd Diff: htt

[10/10] flink git commit: [FLINK-3552] [examples] Add a properly windowed word count reading from a socket (Java + Scala)

[FLINK-3552] [examples] Add a properly windowed word count reading from a socket (Java + Scala) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/986d5368 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/986d5368 Diff: h

[04/10] flink git commit: [FLINK-3578] [streaming scala] Support RichFunctions for Scala WindowFunction and AllWindowFunction

[FLINK-3578] [streaming scala] Support RichFunctions for Scala WindowFunction and AllWindowFunction This also consolidates the various wrapper classes for fold() and reduce() functions. This closes #1765 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apac

[07/10] flink git commit: [FLINK-3495] [tests] Disable RocksDB tests on Windows

[FLINK-3495] [tests] Disable RocksDB tests on Windows This closes #1711 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b0befc4c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b0befc4c Diff: http://git-wip-us.apache.

[02/10] flink git commit: [FLINK-3575] [docs] Update 'Working With State' section in docs

[FLINK-3575] [docs] Update 'Working With State' section in docs This closes #1760 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e650d132 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e650d132 Diff: http://git-wip-

flink git commit: [docs] Add description and illustration about Watermarks in streams

Repository: flink Updated Branches: refs/heads/master cdc8f0a9b -> e0947cc3e [docs] Add description and illustration about Watermarks in streams Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e0947cc3 Tree: http://git-wip

flink git commit: [docs] Add description and illustration about Watermarks in streams

Repository: flink Updated Branches: refs/heads/release-1.0 2831b7d84 -> 95cd07c02 [docs] Add description and illustration about Watermarks in streams Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/95cd07c0 Tree: http://gi

flink git commit: [FLINK-3577] [docs] Display anchor links when hovering over headers.

Repository: flink Updated Branches: refs/heads/master f6e6924eb -> 5fbedff01 [FLINK-3577] [docs] Display anchor links when hovering over headers. This closes #1762 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5fbedff0

flink git commit: [FLINK-3594] [runtime] Make sure exceptions during checkpoints are handled properly

Repository: flink Updated Branches: refs/heads/master 5aca6f4a7 -> 34110fefc [FLINK-3594] [runtime] Make sure exceptions during checkpoints are handled properly - For the asynchronous trigger, exceptions are suppressed if the task is no longer running - The task cannot go to "not running

flink git commit: [FLINK-2671] [tests] Fix test instability in StreamCheckpointNotifierITCase

Repository: flink Updated Branches: refs/heads/master c9e0761de -> 3bbe59c0e [FLINK-2671] [tests] Fix test instability in StreamCheckpointNotifierITCase Also add more logging, to help future test debugging Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.a

[3/4] flink git commit: [FLINK-3467] [runtime] Remove superfluous objects from DataSourceTask.invoke

[FLINK-3467] [runtime] Remove superfluous objects from DataSourceTask.invoke This closes #1691 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4870fd62 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4870fd62 Diff: ht

[2/4] flink git commit: [FLINK-3590] [jdbc] Hide derby log in JDBC tests

[FLINK-3590] [jdbc] Hide derby log in JDBC tests This closes #1773 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2e78a36f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2e78a36f Diff: http://git-wip-us.apache.org/r

[4/4] flink git commit: [FLINK-3472] [jdbc] Give a better exception if jdbc column has a null value

[FLINK-3472] [jdbc] Give a better exception if jdbc column has a null value This closes #1772 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e719eddb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e719eddb Diff: htt

[1/4] flink git commit: [tests] Fix unstable test WebFrontendITCase

Repository: flink Updated Branches: refs/heads/master 0f8d76c6f -> 4870fd62f [tests] Fix unstable test WebFrontendITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/acb051d8 Tree: http://git-wip-us.apache.org/repos/asf

[2/3] flink git commit: [FLINK-2671] [tests] Fix test instability in StreamCheckpointNotifierITCase

[FLINK-2671] [tests] Fix test instability in StreamCheckpointNotifierITCase Also add more logging, to help future test debugging Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/43e95f2c Tree: http://git-wip-us.apache.org/repo

[1/3] flink git commit: [FLINK-3594] [runtime] Make sure exceptions during checkpoints are handled properly

Repository: flink Updated Branches: refs/heads/release-1.0 a405b55b0 -> 3d8c7c1ea [FLINK-3594] [runtime] Make sure exceptions during checkpoints are handled properly - For the asynchronous trigger, exceptions are suppressed if the task is no longer running - The task cannot go to "not ru

[3/3] flink git commit: [FLINK-3472] [jdbc] Give a better exception if jdbc column has a null value

[FLINK-3472] [jdbc] Give a better exception if jdbc column has a null value This closes #1772 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3d8c7c1e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3d8c7c1e Diff: htt

[5/9] flink git commit: [docs] Add "concepts" documentation page

http://git-wip-us.apache.org/repos/asf/flink/blob/9aa207c0/docs/concepts/fig/program_dataflow.svg -- diff --git a/docs/concepts/fig/program_dataflow.svg b/docs/concepts/fig/program_dataflow.svg new file mode 100644 index 000..

[8/9] flink git commit: [docs] Add "concepts" documentation page

http://git-wip-us.apache.org/repos/asf/flink/blob/9aa207c0/docs/concepts/fig/event_ingestion_processing_time.svg -- diff --git a/docs/concepts/fig/event_ingestion_processing_time.svg b/docs/concepts/fig/event_ingestion_processing_

[6/9] flink git commit: [docs] Add "concepts" documentation page

http://git-wip-us.apache.org/repos/asf/flink/blob/9aa207c0/docs/concepts/fig/processes.svg -- diff --git a/docs/concepts/fig/processes.svg b/docs/concepts/fig/processes.svg new file mode 100644 index 000..fe83a9d --- /dev/null

[2/9] flink git commit: [docs] Add "concepts" documentation page

http://git-wip-us.apache.org/repos/asf/flink/blob/9aa207c0/docs/concepts/fig/tasks_chains.svg -- diff --git a/docs/concepts/fig/tasks_chains.svg b/docs/concepts/fig/tasks_chains.svg new file mode 100644 index 000..581112a ---

[3/9] flink git commit: [docs] Add "concepts" documentation page

http://git-wip-us.apache.org/repos/asf/flink/blob/9aa207c0/docs/concepts/fig/state_partitioning.svg -- diff --git a/docs/concepts/fig/state_partitioning.svg b/docs/concepts/fig/state_partitioning.svg new file mode 100644 index 000

[9/9] flink git commit: [docs] Add "concepts" documentation page

[docs] Add "concepts" documentation page Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9aa207c0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9aa207c0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9aa207c

[7/9] flink git commit: [docs] Add "concepts" documentation page

http://git-wip-us.apache.org/repos/asf/flink/blob/9aa207c0/docs/concepts/fig/parallel_dataflow.svg -- diff --git a/docs/concepts/fig/parallel_dataflow.svg b/docs/concepts/fig/parallel_dataflow.svg new file mode 100644 index 00

[1/9] flink git commit: [docs] Add "concepts" documentation page

Repository: flink Updated Branches: refs/heads/master 0331882af -> 9aa207c07 http://git-wip-us.apache.org/repos/asf/flink/blob/9aa207c0/docs/concepts/fig/tasks_slots.svg -- diff --git a/docs/concepts/fig/tasks_slots.svg b/docs

[4/9] flink git commit: [docs] Add "concepts" documentation page

http://git-wip-us.apache.org/repos/asf/flink/blob/9aa207c0/docs/concepts/fig/slot_sharing.svg -- diff --git a/docs/concepts/fig/slot_sharing.svg b/docs/concepts/fig/slot_sharing.svg new file mode 100644 index 000..a3be133 ---

flink git commit: [FLINK-3635] [connectors] Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap

Repository: flink Updated Branches: refs/heads/master a6a53a494 -> 81fa9adcd [FLINK-3635] [connectors] Potential null deference in TwitterExample#SelectEnglishAndTokenizeFlatMap#flatMap This closes #1845 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.ap

[2/4] flink git commit: [hotfix] Updates the AssignerWithPunctuatedWatermarks and the AssignerWithPeriodicWatermarks javadocs

[hotfix] Updates the AssignerWithPunctuatedWatermarks and the AssignerWithPeriodicWatermarks javadocs This closes #1811 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6593e482 Tree: http://git-wip-us.apache.org/repos/asf/fl

[3/4] flink git commit: [FLINK-1159] [Scala API] Add API extension to support case-style anonymous functions

http://git-wip-us.apache.org/repos/asf/flink/blob/5cb84f18/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/extensions/impl/acceptPartialFunctions/OnDataStream.scala -- diff --git a/flink-streaming-scala/s

[4/4] flink git commit: [FLINK-1159] [Scala API] Add API extension to support case-style anonymous functions

[FLINK-1159] [Scala API] Add API extension to support case-style anonymous functions This closes #1704 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5cb84f18 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5cb84f18

[1/4] flink git commit: [FLINK-3623] [runtime] Adjust MurmurHash Algorithm

Repository: flink Updated Branches: refs/heads/master 3465580e7 -> 641a0d436 [FLINK-3623] [runtime] Adjust MurmurHash Algorithm Fix "hash *= n" to be "hash = hash * m + n". This closes #1806 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repo

flink git commit: [hotfix] Updates the AssignerWithPunctuatedWatermarks and the AssignerWithPeriodicWatermarks javadocs

Repository: flink Updated Branches: refs/heads/release-1.0 e0dc5c137 -> a76cefc28 [hotfix] Updates the AssignerWithPunctuatedWatermarks and the AssignerWithPeriodicWatermarks javadocs This closes #1811 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apac

flink git commit: [hotfix] [core] Improve error messages of the Java Closure Cleaner

Repository: flink Updated Branches: refs/heads/master 641a0d436 -> b1e508645 [hotfix] [core] Improve error messages of the Java Closure Cleaner Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b1e50864 Tree: http://git-wip-

[11/14] flink git commit: [FLINK-3375] [kafka connector] Rework/simplify Kafka Connector and have a WatermarkExtractor object per partition

[FLINK-3375] [kafka connector] Rework/simplify Kafka Connector and have a WatermarkExtractor object per partition Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c93103d Tree: http://git-wip-us.apache.org/repos/asf/flink/tre

[09/14] flink git commit: [FLINK-3375] [kafka connector] Rework/simplify Kafka Connector and have a WatermarkExtractor object per partition

http://git-wip-us.apache.org/repos/asf/flink/blob/3c93103d/flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java -- diff --git a/flink-streaming

[12/14] flink git commit: [FLINK-3126] [core] Remove accumulator type from "value" in web frontend

[FLINK-3126] [core] Remove accumulator type from "value" in web frontend This closes #1868 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db85f385 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/db85f385 Diff: http:/

[02/14] flink git commit: [hotfix] [kafka consumer] Increase Kafka test stability by validating written data before consuming

[hotfix] [kafka consumer] Increase Kafka test stability by validating written data before consuming Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d20eda1b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d20eda1b Dif

[14/14] flink git commit: [FLINK-3737] [tests] Adding comment about SOCKS proxy server for WikipediaEditsSourceTest

[FLINK-3737] [tests] Adding comment about SOCKS proxy server for WikipediaEditsSourceTest This closes #1872 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/342db48b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/342

<    5   6   7   8   9   10   11   12   13   14   >