GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/908
[FLINK-2353] Respect JobConfigurable interface in Hadoop mapred wrappers
Hadoop's mapred API features the `JobConfigurable` interface which offers a
function `configure(JobConf)` to configure user-defined classes such as
InputFormats, OutputFormats, and InputSplits.
Flink's Hadoop compatibility wrappers do not respect this interface.
Only the last commit is part of this commit due to sync problems of GH
mirror.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fhueske/flink hadoopConfig
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/908.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #908
----
commit aa5e5b3087a68f2aac792c0b0fc64b4f9c707e9b
Author: Robert Metzger <[email protected]>
Date: 2015-06-29T14:52:38Z
[FLINK-2008] [FLINK-2296] Fix checkpoint committing & KafkaITCase
This closes #895
commit 910e8c438477f27c6d20392d00dd0cfbe8496c8b
Author: Maximilian Michels <[email protected]>
Date: 2015-06-22T15:47:11Z
[FLINK-2235] fix calculation of free memory for local execution
The Java runtime may return Long.MAX_VALUE for a call to the maxMemory()
method of the Runtime class. In these cases, we can get hold of the
physical memory size of the operating system by using a proprietary
Oracle JDK method. Otherwise, we fail with an explanatory exception.
The Oracle JVM defines the max memory to be 1/4 of the physical memory
if the user has more than 192 Megabytes which is assumed here.
This closes #859
commit 2ccb5fdb47aa0e3766fd7fbd17a41feaca29fcbc
Author: Till Rohrmann <[email protected]>
Date: 2015-07-07T09:41:44Z
[FLINK-2329] [runtime] Introduces InstanceGateway as an abstraction to
communicate with the TaskManager.
Replaces AkkaUtils.globalExecutionContext with instance dependent
ExecutionContext.
This closes #893
commit b0b0cb50d63e2f831196fc9219858467a07d8302
Author: Stephan Ewen <[email protected]>
Date: 2015-07-13T14:22:04Z
[FLINK-2235] Fix tests to allow exception in
'EnvironmentInformationTest.getSizeOfFreeHeapMemory()' if Xmx is not set.
commit 84b39dcb50167368d45882a88842760237fa3560
Author: Stephan Ewen <[email protected]>
Date: 2015-07-13T14:27:01Z
[hotfix] Fix error messages in EnvironmentInformation when accessing user
information
commit 91675296e1d0fcc503ab3af9c5da7fdb83b78fc5
Author: Fabian Hueske <[email protected]>
Date: 2015-07-13T22:59:20Z
[FLINK-2353] Respect JobConfigurable interface in Hadoop mapred wrappers
This closes #908
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
