Repository: flink
Updated Branches:
refs/heads/master 55fd5f32d -> d359a974a
[FLINK-3082] Fixed confusing error about an interface that no longer exists
This closes #1411
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
http://git-wip-us.apache.org/repos/asf/flink/blob/80512229/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-2904] [web-dashboard] Fix truncation of task counts when the number is
large.
This closes #1321
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b80ecfdc
Tree:
[FLINK-2950] [ml] [docs] Fix markdown rendering problem in SVM documentation
- Remove unnecessary indentation of table
- Fix wrong `strong` end tag
- Simplify lambda expression in map operation
This closes #1312
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-3056] [web-dashboard] Represent bytes in more readable form.
Bytes are now displayed in the following fashion:
1. For [0, 1000) units, display three significant digits.
2. For [1000,1024) units, display 2 decimal points for the next higher unit.
For example, 1010 KB is displayed as
[FLINK-2351] [core] Remove IOFormat ConfigBuilders
This closes #1420
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6bac9214
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6bac9214
Diff:
[FLINK-3083] [docs] Add docs on how to configure streaming fault tolerance.
This closes #1413
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf913476
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf913476
Diff:
Repository: flink
Updated Branches:
refs/heads/master 2b358cde0 -> d5a6b13ab
http://git-wip-us.apache.org/repos/asf/flink/blob/80512229/flink-runtime-web/web-dashboard/web/partials/jobs/job.plan.node-list.overview.html
--
diff
Repository: flink
Updated Branches:
refs/heads/master cd899f3be -> d1ea365ef
[FLINK-3084] [streaming] FsStateBackend backs up very small state directly with
the metadata.
This closes #1423
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-3051] [streaming] Add mechanisms to control the maximum number of
concurrent checkpoints
This closes #1408
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/55fd5f32
Tree:
Repository: flink
Updated Branches:
refs/heads/master dcce6def9 -> 55fd5f32d
[hotfix] Java-7-ify the ExecutionConfig class
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4097666e
Tree:
[hotfix] [streaming] Fix instantiation of state backends from state backend
factory.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c5f363d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3c5f363d
Diff:
Repository: flink
Updated Branches:
refs/heads/master 8325bc6a6 -> 8b086eb91
[FLINK-3040] [docs] Add docs for State Backends
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8b086eb9
Tree:
Repository: flink
Updated Branches:
refs/heads/release-0.10 a7e799b9f -> db456a761
[FLINK-3040] [docs] Add docs for State Backends
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db456a76
Tree:
[hotfix] [streaming] Fix instantiation of state backends from state backend
factory.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ef709093
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ef709093
Diff:
Repository: flink
Updated Branches:
refs/heads/master 38cf0c610 -> 2f013a204
[hotfix] [docs] Fix errors in streaming docs for fold()
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2f013a20
Tree:
[FLINK-3048] [tests] Increase stability of DataSinkTaskTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/93622001
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/93622001
Diff:
Repository: flink
Updated Branches:
refs/heads/master 1600fe2c2 -> 68a69c76a
[FLINK-2429] [streaming] Deprecate the "enableCheckpointing()" method with no
interval argument.
This closes #1382
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-3005] [core] Bump commons-collections version to fix object
deserialization remote command execution vulnerability
This closes #1381
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7441799e
Tree:
Repository: flink
Updated Branches:
refs/heads/master 6b253d9f8 -> 864357bac
[FLINK-3043] [docs] Fix description of Kafka Consumer and Producer.
This also adds to the deprecated classes pointers forward to the designated
classes.
This closes #1380
Project:
[FLINK-3005] [core] Bump commons-collections version to fix object
deserialization remote command execution vulnerability
This closes #1381
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20612063
Tree:
Repository: flink
Updated Branches:
refs/heads/release-0.10 e977d8274 -> 9defe0cb2
[FLINK-3043] [docs] Fix description of Kafka Consumer and Producer.
This also adds to the deprecated classes pointers forward to the designated
classes.
This closes #1380
Project:
Repository: flink
Updated Branches:
refs/heads/master 65ee28c34 -> 297d75c2e
[FLINK-2832] [tests] Hardens RandomSamplerTest
Increase the level of significance from p=0.01 to p=0.001 and add retry
annotations
to random sampler tests. This should decrease the probability of failing random
[hotfix] [nifi] Minor style cleanups in NiFi source
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b08b64ab
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b08b64ab
Diff:
[FLINK-3405] [nifi] Extend NiFiSource with interface StoppableFunction
This closes #2047
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/38362c40
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/38362c40
Diff:
[FLINK-4000] [RabbitMQ] Fix for checkpoint state restore at
MessageAcknowledgingSourceBase
As says documentation for MessageAcknowledgingSourceBase.restoreState()
This method is invoked when a function is executed as part of a recovery run.
Note that restoreState() is called before open().
So
[FLINK-4000] [RabbitMQ] Style cleanups in MessageAcknowledgingSourceBase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6afb2b00
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6afb2b00
Diff:
[FLINK-3922] [core] Fix case of infinite recursion in TypeExtractor
This closes #2011
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e1b55f03
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e1b55f03
Diff:
Repository: flink
Updated Branches:
refs/heads/master 393bceb58 -> 2bffd7b9e
[hotfix] [core] Make sure Dropwizard reporters do not block operator
creation/teardown while reporting
The "report()" method used to hold the same lock that was needed to create and
shutdown metrics.
Holding that
Repository: flink
Updated Branches:
refs/heads/master ccc86e9f1 -> d760bbc96
[hotfix] [core] Re-enable JMX metrics as the default.
This also does some minor code cleanups, logging fixes, and smoother
concurrency handling.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master d760bbc96 -> 8696e799f
[FLINK-4052] [runtime] Improve test stability for ConnectionUtilsTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8696e799
Tree:
Repository: flink
Updated Branches:
refs/heads/master 65545c2ed -> ccc3e44cb
[hotfix] [core] Fix scope format keys for metrics
This closes #2068
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ccc3e44c
Tree:
[hotfix] Remove leftover config key constant from ExecutionConfig
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5a7f4e33
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5a7f4e33
Diff:
Repository: flink
Updated Branches:
refs/heads/master ef5832d8f -> 573a92fc5
[FLINK-3962] [core] Properly initialize I/O Metric Group
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/573a92fc
Tree:
[hotfix] Fix access to temp file directories in
SpillingAdaptiveSpanningRecordDeserializer
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bf256c7f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bf256c7f
Diff:
[hotfix] [yarn tests] Fix deadlock between YARN Session CLI tests and Surefire
The Surefire Plugin uses stdin to communicate with forked JVMs for tests.
The YARN Session CLI tests also try to read the stdin stream. The tests
deadlock since
Surefire never releases the stdin locks during the
[FLINK-1502] [core] Cleanups, robustness, and performance improvements in the
metrics system
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7ad8375a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7ad8375a
Diff:
Repository: flink
Updated Branches:
refs/heads/master 035f62969 -> da23ee38e
[hotfix] [contrib] Fix robustness of DataStreamUtils stream collecting
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3e3bd52
Tree:
[FLINK-3886] [clients] Give a better error when the application Main class is
not public.
This closes #2043
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6db9e6ae
Tree:
[FLINK-3979] [docs] Add import statements for last code sample in the
quickstart docs.
This closes #2038
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ad52a5f0
Tree:
[FLINK-3978] [core] Add hasBroadcastVariable method to RuntimeContext
New method RuntimeContext.hasBroadcastVariable(String).
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5b028797
Tree:
Repository: flink
Updated Branches:
refs/heads/release-0.10 2d7f0b1af -> dfeee2372
[hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators
This closes #1511
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 2c556f74e -> cfcb5d7ba
[hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators
This closes #1511
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
http://git-wip-us.apache.org/repos/asf/flink/blob/8b8dfc16/flink-contrib/flink-tez/src/main/java/org/apache/flink/tez/dag/TezDAGGenerator.java
--
diff --git
[hotfix] Minor cleanup of warnings, comments, and code style in the Java API
Utils
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/93654413
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/93654413
Diff:
[FLINK-3197] [core] Close InputStream in BinaryInputFormat#createStatistics
reliably
This closes #1494
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2c556f74
Tree:
[hotfix] Remove outdated README for the quickstart projects.
The README was describing non-existing bash scripts removed several versions
ago.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/16cf8b13
Tree:
[FLINK-3219] [java scala] Implement DataSet.count and DataSet.collect using a
single operator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9a53587
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9a53587
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/8b8dfc16/flink-contrib/flink-tez/src/main/java/org/apache/flink/tez/runtime/TezTask.java
--
diff --git
[hotfix] Remove unnecessary dependencies in flink-runtime.
- Removes Apache Commons HTTP Client
- Removes Apache Commons IO
- Removes Jettison JSONparser and consolidates tests to use Jackson instead
(which is included anyways)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
[FLINK-3235] Remove Flink on Tez code
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8b8dfc16
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8b8dfc16
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8b8dfc16
[hotfix] Remove docs for the now removed web client.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9915b339
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9915b339
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/8b8dfc16/flink-contrib/flink-tez/src/test/resources/log4j-test.properties
--
diff --git a/flink-contrib/flink-tez/src/test/resources/log4j-test.properties
Repository: flink
Updated Branches:
refs/heads/master a65cd8db1 -> 2c556f74e
[FLINK-3232] [runtime] Add option to eagerly deploy channels
Adds a flag to the ExecutionGraph's IntermediateResult class indicating whether
the result consumers should be deployed eagerly. If true, the consumers are
[FLINK-3236] [runtime] Flink user code classloader as parent classloader from
Flink core classes
Originally, the user code classloader delegates to the system classloader as
parent.
That works in Flink standalone settings, but not when the Flink core classes
themselves
are not loaded with the
[FLINK-2716] [gelly] [apis] New checksum method on DataSet and Graph
This closes #1462
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a8be52a3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a8be52a3
Diff:
Repository: flink
Updated Branches:
refs/heads/master 98fad04ec -> c0fd36bac
[FLINK-2671] [tests] Fix unstable StreamCheckpointNotifierITCase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c0fd36ba
Tree:
Repository: flink
Updated Branches:
refs/heads/master 7d7d8b68e -> 153a67881
[hotfix] Exclude 'flink-annotations' from fat jars in quickstart poms.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/153a6788
Tree:
[hotfix] Clean up CliFrontend after removing web client
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/17fa6a9b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/17fa6a9b
Diff:
Repository: flink
Updated Branches:
refs/heads/master c0fd36bac -> adbeec2f9
[hotfix] Fix reference to batch Java examples in flink-java8
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/adbeec2f
Tree:
Repository: flink
Updated Branches:
refs/heads/release-0.10 d09a83320 -> 2d7f0b1af
[FLINK-3236] [runtime] Flink user code classloader as parent classloader from
Flink core classes
Originally, the user code classloader delegates to the system classloader as
parent.
That works in Flink
Repository: flink
Updated Branches:
refs/heads/master aeee6efd4 -> 8ccd7544e
[FLINK-3373] [build] Shade away Hadoop's HTTP Components dependency
This closes #1615
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ccd7544
Repository: flink
Updated Branches:
refs/heads/release-0.10 2cd06181f -> 11bfe6f3e
[FLINK-3372] Setting custom YARN application name is ignored
This closes #1607
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/11bfe6f3
[FLINK-3260] [runtime] Enforce terminal state of Executions
This commit fixes the problem that Executions could leave their terminal state
FINISHED to transition to FAILED. Such a transition will be propagated to the
ExecutionGraph where it entails JobStatus changes. Since the Execution already
[hotfix] [tests] Ignore ZooKeeper logs in process tests
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3a643c07
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3a643c07
Diff:
Repository: flink
Updated Branches:
refs/heads/master 8ccd7544e -> 6968a57a1
[FLINK-3341] Make 'auto.offset.reset' compatible with Kafka 0.8 and 0.9
This closes #1597
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-3350] [tests] Increase default test Akka ask and ZooKeeper timeouts
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8f40251
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b8f40251
Diff:
[hotfix] [tests] Log retry rule failures on warn level
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/756cbaff
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/756cbaff
Diff:
[FLINK-3384] [kafka] Add ClosableQueue for message exchanges between Kafka
Threads
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd324ea7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fd324ea7
Diff:
Repository: flink
Updated Branches:
refs/heads/master 8df0bbacb -> fd324ea72
[FLINK-3371] [api-breaking] Move TriggerResult and TriggerContext to dedicated
classes
This closes #1603
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 28c6254ee -> 9ee167949
[FLINK-3355] [rocksdb backend] Allow passing options to the RocksDB backend.
This also cleans up the generics in the RocksDB state classes.
This closes #1608
Project:
Repository: flink
Updated Branches:
refs/heads/master a4f0692e9 -> c57a7e910
[FLINK-3373] [build] Bump version of transitine HTTP Components dependency to
4.4.4 (core) / 4.5.1 (client)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master 7378f014b -> f8f747f22
[FLINK-3268] [tests] Enhance stability of ZooKeeperTestEnvironment.deleteAll()
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f8f747f2
Tree:
Repository: flink
Updated Branches:
refs/heads/master 69f7f6d92 -> 4852302a1
[streaming] [scala] Scala wrapper for DataStreamUtils
This closes #1574
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4852302a
Tree:
[hotfix] Minor code cleanups in AbstractStateBackend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d93b154d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d93b154d
Diff:
http://git-wip-us.apache.org/repos/asf/flink/blob/94cba899/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
--
diff --git
Repository: flink
Updated Branches:
refs/heads/master dcea46e89 -> edae79340
[FLINK-3358] [FLINK-3351] [rocksdb] Add simple constructors and automatic temp
path configuration
This adds constructors that only take a backup dir URI and use it to initialize
both the RocksDB file backups and the
[FLINK-3271] [build] Don't exclude jetty-util dependency from the Hadoop
dependencies
This closes #1543
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82c7383a
Tree:
[FLINK-3389] [rocksdb] Add pre-defined option profiles.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/be72758d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/be72758d
Diff:
Repository: flink
Updated Branches:
refs/heads/master fe0c3b539 -> 2eb2a0ef3
[FLINK-3338] [kafka] Use proper classloader when cloning the deserialization
schema.
This closes #1590
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[hotfix] typo IllegalArgumentException
This closes #1602
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c47f385
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c47f385
Diff:
[FLINK-3334] [conf] Include year-month-day in the log output
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d51bec15
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d51bec15
Diff:
[FLINK-3363] [jobmanager] Properly shut down executor thread pool when
JobManager shuts down
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a277543c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a277543c
Diff:
[FLINK-3357] [core] Drop AbstractID#toShortString()
This closes #1601
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28feede7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/28feede7
Diff:
[FLINK-3337] [runtime] mvn test fails on flink-runtime because curator classes
not found
Removes curator dependency exclusions from flink-runtime. This resolves
NoClassDefFoundError exceptions when running `mvn test`.
This partialy reverts e31a4d8.
This closes #1596
Project:
[hotfix] Update comments in 'ChainingStrategy' and remove outdated
'FORCE_ALWAYS' constant
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9c83ea2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9c83ea2
Diff:
Repository: flink
Updated Branches:
refs/heads/master 22423e23f -> 28c6254ee
[FLINK-3365] [taskmanager] Properly shut down cleanup timer thread
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/457cb145
Tree:
[FLINK-3265] [rabbitmq] Fix concurrency bug in RabbitMQ
This closes #1534
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6b01a890
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6b01a890
Diff:
[FLINK-3242] Also Set User-specified StateBackend without Checkpointing
Before, the user-specified StateBackedn would not be set when generating the
JobGraph if checkpointing was disabled.
This closes #1516
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-3292]Fix for Bug in flink-jdbc. Not all JDBC drivers supported
This closes #1551
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d97fcda6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d97fcda6
Diff:
Repository: flink
Updated Branches:
refs/heads/master 2e2330737 -> 6b01a8902
[FLINK-3178] Don't Emit In-Flight Windows When Closing Window Operator
This closes #1542
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/release-0.10 2aeb6fac3 -> bef39f881
[FLINK-3242] Adjust StateBackendITCase for 0.10 signatures of state backends
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bef39f88
Repository: flink
Updated Branches:
refs/heads/master 67b380d61 -> 92efcd34a
[hotfix] Remove 'ByteArrayInputView' and replace deserialization in
TypeInformationSerializationSchema with more efficient reusable buffers.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/TupleSerializerTestInstance.java
--
diff --git
Repository: flink
Updated Branches:
refs/heads/master 360f02b1f -> 8fc7e7af2
[hotfix] Reduce the heavy sysout verbosity for certain tests
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6f042e78
Tree:
http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/test/java/org/apache/flink/api/java/typeutils/CompositeTypeTest.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java
--
diff --git
a/flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple20.java
http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializer.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/7081836e/flink-java/src/main/java/org/apache/flink/api/java/tuple/builder/Tuple15Builder.java
--
diff --git
http://git-wip-us.apache.org/repos/asf/flink/blob/21a71586/flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/AvroGenericTypeComparatorTest.java
--
diff --git
601 - 700 of 2984 matches
Mail list logo