You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2017/05/07 20:36:00 UTC
flink git commit: FLINK-6474 Potential loss of precision in 32 bit
integer multiplication
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 <yu...@gmail.com>
Authored: Sun May 7 12:20:27 2017 -0700
Committer: Stefan Richter <s....@data-artisans.com>
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 {}.",