Repository: flink Updated Branches: refs/heads/master 38003c282 -> 12b941d36
FLINK-6474 Potential loss of precision in 32 bit integer multiplication Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/12b941d3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/12b941d3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/12b941d3 Branch: refs/heads/master Commit: 12b941d361a546e5fd7eae9cd8b6563f090d6d90 Parents: 38003c2 Author: tedyu <[email protected]> Authored: Sun May 7 12:20:27 2017 -0700 Committer: Stefan Richter <[email protected]> Committed: Sun May 7 22:35:18 2017 +0200 ---------------------------------------------------------------------- .../runtime/taskexecutor/TaskManagerServicesConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/12b941d3/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesConfiguration.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesConfiguration.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesConfiguration.java index 3fee689..d1cfc4c 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesConfiguration.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesConfiguration.java @@ -308,7 +308,7 @@ public class TaskManagerServicesConfiguration { if (!hasNewNetworkBufConf(configuration)) { // map old config to new one: - networkBufMin = networkBufMax = numNetworkBuffers * pageSize; + networkBufMin = networkBufMax = ((long)numNetworkBuffers) * pageSize; } else { if (configuration.contains(TaskManagerOptions.NETWORK_NUM_BUFFERS)) { LOG.info("Ignoring old (but still present) network buffer configuration via {}.",
