[2/8] flink git commit: [FLINK-2901] Move PythonAPI to flink-libraries

http://git-wip-us.apache.org/repos/asf/flink/blob/824074aa/flink-staging/flink-language-binding/flink-python/src/main/python/org/apache/flink/languagebinding/api/python/flink/plan/DataSet.py -- diff --git

[4/8] flink git commit: [FLINK-2901] Move PythonAPI to flink-libraries

http://git-wip-us.apache.org/repos/asf/flink/blob/824074aa/flink-staging/flink-language-binding/flink-language-binding-generic/src/main/java/org/apache/flink/languagebinding/api/java/common/streaming/Streamer.java -- diff --git

[5/8] flink git commit: [FLINK-2901] Move PythonAPI to flink-libraries

http://git-wip-us.apache.org/repos/asf/flink/blob/824074aa/flink-libraries/flink-python/src/test/python/org/apache/flink/python/api/test_main.py -- diff --git

flink git commit: [FLINK-2937] Fix Typo in Scala Quickstart Guide (SBT)

Repository: flink Updated Branches: refs/heads/master 7beb0110a -> 2ea458833 [FLINK-2937] Fix Typo in Scala Quickstart Guide (SBT) This closes #1373 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ea45883 Tree:

flink git commit: [FLINK-2233] Update InputF nextRecord javadocs

Repository: flink Updated Branches: refs/heads/master 1f45c8734 -> 7beb0110a [FLINK-2233] Update InputF nextRecord javadocs This closes #2233. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7beb0110 Tree:

[2/2] flink git commit: [FLINK-2692] Untangle CsvInputFormat

[FLINK-2692] Untangle CsvInputFormat This closes #1266 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bd61f2db Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bd61f2db Diff:

flink git commit: [FLINK-2432] Custom serializer support

Repository: flink Updated Branches: refs/heads/master 946e8f648 -> 30647a2e6 [FLINK-2432] Custom serializer support This closes #962 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/30647a2e Tree:

flink git commit: [FLINK-2440][py] Expand Environment feature coverage

Repository: flink Updated Branches: refs/heads/master 0ccbd2779 -> 0ccab95e7 [FLINK-2440][py] Expand Environment feature coverage This closes #1383 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ccab95e Tree:

flink git commit: [FLINK-2686] Show exchange mode in JSON plan

Repository: flink Updated Branches: refs/heads/master ebba20dfa -> 49f5a0179 [FLINK-2686] Show exchange mode in JSON plan This closes #1378 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/49f5a017 Tree:

flink git commit: [FLINK-2318] Union can be used as BroadcastVariable

Repository: flink Updated Branches: refs/heads/master 49f5a0179 -> 25ef3240c [FLINK-2318] Union can be used as BroadcastVariable This closes #1390 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/25ef3240 Tree:

flink git commit: [FLINK-2441] Introduce Python OperationInfo

Repository: flink Updated Branches: refs/heads/master 99d52cc69 -> 5d37fe146 [FLINK-2441] Introduce Python OperationInfo This closes #1352. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5d37fe14 Tree:

flink git commit: [FLINK-1945][py] Python Tests less verbose

Repository: flink Updated Branches: refs/heads/test_1945_pytest [created] c1dd9604d [FLINK-1945][py] Python Tests less verbose This closes #1376 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c1dd9604 Tree:

flink git commit: [FLINK-1945][py] Python Tests less verbose

Repository: flink Updated Branches: refs/heads/master 40cb4e0d7 -> c1dd9604d [FLINK-1945][py] Python Tests less verbose This closes #1376 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c1dd9604 Tree:

flink git commit: [FLINK-4049] Mark (open/close)IF() @PublicEvolving

Repository: flink Updated Branches: refs/heads/master 76dcbd458 -> 393bceb58 [FLINK-4049] Mark (open/close)IF() @PublicEvolving Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/393bceb5 Tree:

[1/2] flink git commit: [hotfix] [py] Fix PythonPlanBinder not copying additional files

Repository: flink Updated Branches: refs/heads/master 8696e799f -> 76dcbd458 [hotfix] [py] Fix PythonPlanBinder not copying additional files Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e90ea9cf Tree:

[3/3] flink git commit: [FLINK-4032] Replace all usage of Guava Preconditions

[FLINK-4032] Replace all usage of Guava Preconditions This closes #2084 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c4bbed9e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c4bbed9e Diff:

[2/3] flink git commit: [FLINK-4032] Replace all usage of Guava Preconditions

http://git-wip-us.apache.org/repos/asf/flink/blob/c4bbed9e/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java -- diff --git

flink git commit: [FLINK-3969] Log Exceptions by Invokable

Repository: flink Updated Branches: refs/heads/master c8fed99e3 -> 279777f2f [FLINK-3969] Log Exceptions by Invokable This closes #2091 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/279777f2 Tree:

flink git commit: [FLINK-3993] [py] Add Environment.generateSequence()

Repository: flink Updated Branches: refs/heads/master bce068c49 -> b201f8664 [FLINK-3993] [py] Add Environment.generateSequence() This closes #2055 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b201f866 Tree:

flink git commit: [FLINK-4091] Fix Guava shading in Cassandra connector

Repository: flink Updated Branches: refs/heads/master bce3a68d9 -> 7e206f490 [FLINK-4091] Fix Guava shading in Cassandra connector This closes #2133 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7e206f49 Tree:

flink git commit: [FLINK-4097] Fix NullPointerException on CassandraSinkBase and CassandraTupleWriteAheadSink's close()

Repository: flink Updated Branches: refs/heads/master e7dfa2894 -> a973d84b2 [FLINK-4097] Fix NullPointerException on CassandraSinkBase and CassandraTupleWriteAheadSink's close() This closes #2144 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-4092] [py] Fix Stringify function's implicit string type conversion problem

Repository: flink Updated Branches: refs/heads/master 7e206f490 -> e04239dd7 [FLINK-4092] [py] Fix Stringify function's implicit string type conversion problem This closes #2130 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3626] [py] Add zipWithIndex()

Repository: flink Updated Branches: refs/heads/master e04239dd7 -> 93c61c097 [FLINK-3626] [py] Add zipWithIndex() This closes #2136 Create a task_id message in PythonStreamer that is passed through to the underlying process and included in the RuntimeContext, where it is accessible to the

flink git commit: [FLINK-4076] BoltWrapper calls super.dispose()

Repository: flink Updated Branches: refs/heads/master 93c61c097 -> e7dfa2894 [FLINK-4076] BoltWrapper calls super.dispose() This closes #2111 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e7dfa289 Tree:

[2/2] flink git commit: [FLINK-3949] Collect Metrics in Runtime Operators

[FLINK-3949] Collect Metrics in Runtime Operators currentLowWatermark lastCheckpointSize numBytes(In/Out)(Local/Remote) numRecords(In/Out) numSplitsProcessed (Batch only) This closes #2090 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: [FLINK-3949] Collect Metrics in Runtime Operators

Repository: flink Updated Branches: refs/heads/master 104958523 -> c78b3c49e http://git-wip-us.apache.org/repos/asf/flink/blob/c78b3c49/flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedFlatMapDriver.java

flink git commit: [FLINK-3275] [py] Support for DataSet.setParallelism()

Repository: flink Updated Branches: refs/heads/master 440137cc3 -> 40422d505 [FLINK-3275] [py] Support for DataSet.setParallelism() -parallelism is stored Value object within the OperationInfo, so it can be passed as a reference to multiple operations (in cases where a set is internally

[2/3] flink git commit: [FLINK-3057] Bidrectional plan connection

[FLINK-3057] Bidrectional plan connection Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fc4d9469 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fc4d9469 Diff:

[1/3] flink git commit: [FLINK-3057] Bidrectional plan connection

Repository: flink Updated Branches: refs/heads/master 0ac5d4020 -> c7ada8d78 http://git-wip-us.apache.org/repos/asf/flink/blob/fc4d9469/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/streaming/data/PythonStreamer.java

[3/3] flink git commit: [FLINK-3014] Replace InStr.read() calls with DataInStr.readFully()

[FLINK-3014] Replace InStr.read() calls with DataInStr.readFully() This closes #1432 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c7ada8d7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c7ada8d7 Diff:

[flink] Git Push Summary

Repository: flink Updated Branches: refs/heads/2686_json_exchange [deleted] 49f5a0179

flink git commit: [FLINK-3063][py] Remove combiner

Repository: flink Updated Branches: refs/heads/master c7ada8d78 -> 54b52c9be [FLINK-3063][py] Remove combiner Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/54b52c9b Tree:

[2/3] flink git commit: [FLINK-2501] [py] Remove the need to specify types for transformations

http://git-wip-us.apache.org/repos/asf/flink/blob/ab847071/flink-libraries/flink-python/src/main/java/org/apache/flink/python/api/streaming/util/SerializationUtils.java -- diff --git

[1/3] flink git commit: [FLINK-2501] [py] Remove the need to specify types for transformations

Repository: flink Updated Branches: refs/heads/master 54b52c9be -> ab8470714 http://git-wip-us.apache.org/repos/asf/flink/blob/ab847071/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/Environment.py

flink git commit: [FLINK-3165] [py] Windows OS support

Repository: flink Updated Branches: refs/heads/master 018f1fee9 -> 0ac5d4020 [FLINK-3165] [py] Windows OS support This closes #1454 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ac5d402 Tree:

flink git commit: [FLINK-3290] [py] Generalize OperationInfo transfer

Repository: flink Updated Branches: refs/heads/masteer [created] 499b60fed [FLINK-3290] [py] Generalize OperationInfo transfer -identifier saved in java OpInfo -changed default values to prevent null exceptions -all operations use the same routine to transfer parameters -PyPlRcv can handle

[flink] Git Push Summary

Repository: flink Updated Branches: refs/heads/masteer [deleted] 499b60fed

flink git commit: [FLINK-3290] [py] Generalize OperationInfo transfer

Repository: flink Updated Branches: refs/heads/master f681d9b83 -> 499b60fed [FLINK-3290] [py] Generalize OperationInfo transfer -identifier saved in java OpInfo -changed default values to prevent null exceptions -all operations use the same routine to transfer parameters -PyPlRcv can handle

flink git commit: [FLINK-3308] [py] Remove debug mode

Repository: flink Updated Branches: refs/heads/master a66458eac -> 401837bdf [FLINK-3308] [py] Remove debug mode Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/401837bd Tree:

[1/2] flink git commit: [FLINK-3327] ExecutionConfig to JobGraph

Repository: flink Updated Branches: refs/heads/master d0a390f9b -> 0f8d76c6f http://git-wip-us.apache.org/repos/asf/flink/blob/0f8d76c6/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java -- diff

[2/2] flink git commit: [FLINK-3327] ExecutionConfig to JobGraph

[FLINK-3327] ExecutionConfig to JobGraph This closes #1583 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0f8d76c6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0f8d76c6 Diff:

flink git commit: [FLINK-2523] Make the task cancellation interval configurable

Repository: flink Updated Branches: refs/heads/master c0d5ba388 -> 4f11b4016 [FLINK-2523] Make the task cancellation interval configurable This closes #1662 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4f11b401 Tree:

flink git commit: [FLINK-3321] TupleSerializer.getLength() can return fixed-length size

Repository: flink Updated Branches: refs/heads/master 945fc023a -> d7aa989ee [FLINK-3321] TupleSerializer.getLength() can return fixed-length size This closes #1654. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-3169] Remove Key class

[FLINK-3169] Remove Key class This closes #1667. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fe117afd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fe117afd Diff:

flink git commit: [hotfix] Improve exception message in TaskManagerTest#testRemotePartitionNotFound

Repository: flink Updated Branches: refs/heads/master fe117afd3 -> 09ce3dcc3 [hotfix] Improve exception message in TaskManagerTest#testRemotePartitionNotFound This closes #1658 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3811] [tableAPI] Use only Java ExecutionEnvironments in TableEnvironments

Repository: flink Updated Branches: refs/heads/master 0cf04108f -> 172fcfa1e [FLINK-3811] [tableAPI] Use only Java ExecutionEnvironments in TableEnvironments This closes #1930 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-3777] Add openIF/closeIF methods to IF lifecycle

Repository: flink Updated Branches: refs/heads/master 879bb1bb0 -> ac2137cfa [FLINK-3777] Add openIF/closeIF methods to IF lifecycle This closes #1903 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ac2137cf Tree:

[1/5] flink git commit: [FLINK-3817] Remove unused guava dependency from RocksDb backend

Repository: flink Updated Branches: refs/heads/master e6cc86284 -> 445d5e3e6 [FLINK-3817] Remove unused guava dependency from RocksDb backend This closes #1934 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9ea4159c

[3/5] flink git commit: [FLINK-3818] Remove Guava dependency from flink-gelly-examples

[FLINK-3818] Remove Guava dependency from flink-gelly-examples This closes #1936 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6ef08cfe Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6ef08cfe Diff:

[4/5] flink git commit: [FLINK-3815] Replace Guava Preconditions usage in flink-gelly

[FLINK-3815] Replace Guava Preconditions usage in flink-gelly This closes #1932 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/eed6f0f7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/eed6f0f7 Diff:

[5/5] flink git commit: [FLINK-3815] Replace Guava Preconditions usage in flink-clients

[FLINK-3815] Replace Guava Preconditions usage in flink-clients This closes #1933 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/445d5e3e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/445d5e3e Diff:

flink git commit: This closes #1925

Repository: flink Updated Branches: refs/heads/master 44c2d2f0a -> 3f4e2f88b This closes #1925 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3f4e2f88 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3f4e2f88

[3/3] flink git commit: [FLINK-2732] Display TM logs in Dashboard

[FLINK-2732] Display TM logs in Dashboard This closes #1790 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6d53bbc4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6d53bbc4 Diff:

[2/3] flink git commit: [FLINK-2732] Display TM logs in Dashboard

http://git-wip-us.apache.org/repos/asf/flink/blob/6d53bbc4/flink-runtime-web/web-dashboard/web/js/index.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/index.js b/flink-runtime-web/web-dashboard/web/js/index.js index

flink git commit: [FLINK-3773] Scanners are left unclosed in SqlExplainTest

Repository: flink Updated Branches: refs/heads/master 6d53bbc4b -> fabc5f96e [FLINK-3773] Scanners are left unclosed in SqlExplainTest This closes #1902 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fabc5f96 Tree:

flink git commit: [FLINK-3764] [tests] Improve LeaderChangeStateCleanupTest stability

Repository: flink Updated Branches: refs/heads/master 4be297ec2 -> 716d83209 [FLINK-3764] [tests] Improve LeaderChangeStateCleanupTest stability The LeaderElectionRetrievalTestingCluster now also waits for the Flink resource manager to be properly started before trying to send leader change

[1/2] flink git commit: [FLINK-3664] Create DataSetUtils method to easily summarize a DataSet of Tuples

Repository: flink Updated Branches: refs/heads/master fabc5f96e -> 7eb58773e http://git-wip-us.apache.org/repos/asf/flink/blob/7eb58773/flink-java/src/test/java/org/apache/flink/api/java/summarize/aggregation/CompensatedSumTest.java

flink git commit: [FLINK-2125][streaming] Delimiter change from char to string

Repository: flink Updated Branches: refs/heads/master 588830aaa -> 177168b2f [FLINK-2125][streaming] Delimiter change from char to string This closes #2233 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/177168b2 Tree:

flink git commit: [hotfix] [docu] Fix System Metrics table

Repository: flink Updated Branches: refs/heads/master 7359ffe2e -> 12dc39ec6 [hotfix] [docu] Fix System Metrics table Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/12dc39ec Tree:

flink git commit: [FLINK-4269] [webfrontend] Decrease log level in RuntimeMonitorHandler

Repository: flink Updated Branches: refs/heads/master 12dc39ec6 -> d618b13e8 [FLINK-4269] [webfrontend] Decrease log level in RuntimeMonitorHandler This closes #2307. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [hotfix] [docu] Add missing tick

Repository: flink Updated Branches: refs/heads/master 5d7e949fe -> 7359ffe2e [hotfix] [docu] Add missing tick Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7359ffe2 Tree:

flink git commit: [FLINK-4284] [docu] Fix broken links

Repository: flink Updated Branches: refs/heads/master 4bfc20ace -> aed56aeeb [FLINK-4284] [docu] Fix broken links This closes #2311 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aed56aee Tree:

[2/2] flink git commit: [FLINK-4277] Fix TaskManagerConfigurationTest#testDefaultFsParameterLoading

[FLINK-4277] Fix TaskManagerConfigurationTest#testDefaultFsParameterLoading This closes #2310 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3537579b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3537579b Diff:

[1/2] flink git commit: [FLINK-4279] [py] Set flink dependencies to provided

Repository: flink Updated Branches: refs/heads/master a30ec83da -> 3537579b7 [FLINK-4279] [py] Set flink dependencies to provided This closes #2308 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6edc7f1e Tree:

[3/6] flink git commit: [FLINK-4192] [metrics] Move metrics classes out of 'flink-core'

http://git-wip-us.apache.org/repos/asf/flink/blob/e3fec1f9/flink-metrics/flink-metrics-jmx/src/test/java/org/apache/flink/metrics/jmx/JMXReporterTest.java -- diff --git

[1/6] flink git commit: [FLINK-4192] [metrics] Move metrics classes out of 'flink-core'

Repository: flink Updated Branches: refs/heads/master e4fe89d6e -> e3fec1f9a http://git-wip-us.apache.org/repos/asf/flink/blob/e3fec1f9/flink-runtime/src/test/java/org/apache/flink/runtime/metrics/groups/TaskManagerGroupTest.java

[5/6] flink git commit: [FLINK-4192] [metrics] Move metrics classes out of 'flink-core'

http://git-wip-us.apache.org/repos/asf/flink/blob/e3fec1f9/flink-core/src/main/java/org/apache/flink/metrics/groups/UnregisteredMetricsGroup.java -- diff --git

flink git commit: [FLINK-4210][metrics] Move close()/isClosed() out of MetricGroup

Repository: flink Updated Branches: refs/heads/master 0b4c04d7d -> e4fe89d6e [FLINK-4210][metrics] Move close()/isClosed() out of MetricGroup This closes #2286 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e4fe89d6

[6/6] flink git commit: [FLINK-4192] [metrics] Move metrics classes out of 'flink-core'

[FLINK-4192] [metrics] Move metrics classes out of 'flink-core' - moved user-facing API to 'flink-metrics/flink-metrics-core' - moved JMXReporter to 'flink-metrics/flink-metrics-jmx' - moved remaining metric classes to 'flink-runtime' This closes #2226 Project:

[2/6] flink git commit: [FLINK-4192] [metrics] Move metrics classes out of 'flink-core'

http://git-wip-us.apache.org/repos/asf/flink/blob/e3fec1f9/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGroup.java -- diff --git

flink git commit: [FLINK-4143][metrics] Configurable delimiter

Repository: flink Updated Branches: refs/heads/master 90658c838 -> 790a654c5 [FLINK-4143][metrics] Configurable delimiter This closes #2219 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/790a654c Tree:

flink git commit: [FLINK-4200] [Kafka Connector] Kafka consumers logs the offset from which they restore

Repository: flink Updated Branches: refs/heads/master 6b7bb7614 -> 435ffd9c0 [FLINK-4200] [Kafka Connector] Kafka consumers logs the offset from which they restore This closes #2230 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-4142][docs] Add warning about YARN HA bug

Repository: flink Updated Branches: refs/heads/master 7f9580061 -> d08b18971 [FLINK-4142][docs] Add warning about YARN HA bug This closes #2255 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d08b1897 Tree:

flink git commit: [FLINK-4053] Add tests for RMQ sink and check connection for null

Repository: flink Updated Branches: refs/heads/master 45edafda5 -> a0c3b879b [FLINK-4053] Add tests for RMQ sink and check connection for null This closes #2128 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a0c3b879

flink git commit: [licenses] Remove not included dependency from LICENSE

Repository: flink Updated Branches: refs/heads/master d08b18971 -> 45edafda5 [licenses] Remove not included dependency from LICENSE This closes #2186 Flink does not include the anchor.js file but loads it dynamically when displaying the documentation. Therefore, we don't have to include

flink git commit: [FLINK-4017] [py] Add Aggregation support to Python API

Repository: flink Updated Branches: refs/heads/master a0c3b879b -> 2218cb4c1 [FLINK-4017] [py] Add Aggregation support to Python API Assembles and applies a GroupReduceFunction using pre-defined AggregationOperations in Python. References to aggregations in PythonOperationInfo and other Java

flink git commit: [hotfix] [metrics] Prevent log flooding from collisions

Repository: flink Updated Branches: refs/heads/master 9a2057310 -> 7f9580061 [hotfix] [metrics] Prevent log flooding from collisions This closes #2135 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7f958006 Tree:

flink git commit: [FLINK-3666] Remove all remaining Nephele references

Repository: flink Updated Branches: refs/heads/master 234646844 -> 273f54ba4 [FLINK-3666] Remove all remaining Nephele references Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/273f54ba Tree:

flink git commit: [FLINK-4159] Remove Quickstart exclusions for unused dependencies

Repository: flink Updated Branches: refs/heads/master 435ffd9c0 -> 90658c838 [FLINK-4159] Remove Quickstart exclusions for unused dependencies This closes #2217 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90658c83

[2/3] flink git commit: [FLINK-3951] Add Histogram metric type

http://git-wip-us.apache.org/repos/asf/flink/blob/ee3c7a88/flink-metrics/flink-metrics-dropwizard/src/test/java/org/apache/flink/dropwizard/metrics/DropwizardFlinkHistogramWrapperTest.java -- diff --git

[3/3] flink git commit: [FLINK-3951] Add Histogram metric type

[FLINK-3951] Add Histogram metric type This closes #2112 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ee3c7a88 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ee3c7a88 Diff:

[1/3] flink git commit: [FLINK-4093] Expose metric interfaces

Repository: flink Updated Branches: refs/heads/master 62cb954d9 -> ee3c7a88b [FLINK-4093] Expose metric interfaces This closes #2134 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d43bf8d9 Tree:

flink git commit: [hotfix][docs] Add warning to Cassandra documentation

Repository: flink Updated Branches: refs/heads/master 35b4da273 -> 6744b852d [hotfix][docs] Add warning to Cassandra documentation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6744b852 Tree:

flink git commit: [FLINK-4087] [metrics] Improved JMX port handling

Repository: flink Updated Branches: refs/heads/master 19ff8db68 -> 62cb954d9 [FLINK-4087] [metrics] Improved JMX port handling This closes #2145 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/62cb954d Tree:

flink git commit: [FLINK-4119] Refactor null checks in Cassandra IOF

Repository: flink Updated Branches: refs/heads/master 6744b852d -> 9487fcbfb [FLINK-4119] Refactor null checks in Cassandra IOF This closes #2163 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9487fcbf Tree:

[2/2] flink git commit: [hotfix] [metrics] Prevent registration exceptions

[hotfix] [metrics] Prevent registration exceptions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/19ff8db6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/19ff8db6 Diff:

[1/2] flink git commit: [FLINK-4074] Make metric reporters less blocking

Repository: flink Updated Branches: refs/heads/master 9487fcbfb -> 19ff8db68 [FLINK-4074] Make metric reporters less blocking This closes #2105 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/56cdec7d Tree:

flink git commit: [FLINK-4145] Harden JMX tests

Repository: flink Updated Branches: refs/heads/master 18995c8c7 -> 647b4c577 [FLINK-4145] Harden JMX tests Use distinct non-default port ranges for all tests. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/647b4c57

[2/2] flink git commit: [FLINK-4158] Fix Scala QS StreamingJob import

[FLINK-4158] Fix Scala QS StreamingJob import This closes #2204 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/515148f5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/515148f5 Diff:

[1/2] flink git commit: [hotfix] Quickstart docs respect artifactId

Repository: flink Updated Branches: refs/heads/master cdd5e4cad -> aea86ac66 [hotfix] Quickstart docs respect artifactId This closes #2203 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aea86ac6 Tree:

flink git commit: [hotfix][metrics] Declare all used dependencies

Repository: flink Updated Branches: refs/heads/master 230847d52 -> 0dce0381c [hotfix][metrics] Declare all used dependencies Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0dce0381 Tree:

flink git commit: [hotfix][metrics] Fix typos

Repository: flink Updated Branches: refs/heads/master 0dce0381c -> aaa6c7aed [hotfix][metrics] Fix typos Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aaa6c7ae Tree:

flink git commit: [FLINK-4160][yarn] Show input validation errors

Repository: flink Updated Branches: refs/heads/master aea86ac66 -> 1e8c85235 [FLINK-4160][yarn] Show input validation errors This closes #2207 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1e8c8523 Tree:

[1/2] flink git commit: [FLINK-4116] Metrics documentation

Repository: flink Updated Branches: refs/heads/master 68277a431 -> 9178076db [FLINK-4116] Metrics documentation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/221ab8ee Tree:

flink git commit: [hotfix][metrics] Remove leftover comment Registry

Repository: flink Updated Branches: refs/heads/master 8f6876218 -> 20aecf033 [hotfix][metrics] Remove leftover comment Registry Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20aecf03 Tree:

flink git commit: [FLINK-4096] Ensure JarOutputStream is always closed

Repository: flink Updated Branches: refs/heads/master 9178076db -> 8f6876218 [FLINK-4096] Ensure JarOutputStream is always closed This closes #2172 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8f687621 Tree:

[2/2] flink git commit: [FLINK-4116][metrics] Move config keys to ConfigConstants

[FLINK-4116][metrics] Move config keys to ConfigConstants This closes #2158 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9178076d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9178076d Diff:

[1/2] flink git commit: [FLINK-4276] Fix TextInputFormatTest#testNestedFileRead

Repository: flink Updated Branches: refs/heads/master 0e0c40d8a -> f1e9daece [FLINK-4276] Fix TextInputFormatTest#testNestedFileRead This closes #2312 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a2219b0b Tree:

[2/2] flink git commit: [FLINK-4291] [metrics] Add log entry for scheduled reporters

[FLINK-4291] [metrics] Add log entry for scheduled reporters This closes #2318 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f1e9daec Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f1e9daec Diff:

flink git commit: [hotfix] Fx TestingyYarnJobManager constructor

Repository: flink Updated Branches: refs/heads/master 0483ba583 -> f36aa6ff3 [hotfix] Fx TestingyYarnJobManager constructor Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f36aa6ff Tree:

  1   2   3   4   5   6   7   8   9   10   >