date:20160919

buildbot success in on flink-docs-release-0.10

2016-09-19 Thread buildbot

The Buildbot has detected a restored build on builder flink-docs-release-0.10 
while building . Full details are available at:
https://ci.apache.org/builders/flink-docs-release-0.10/builds/336

Buildbot URL: https://ci.apache.org/

Buildslave for this Build: bb_slave1_ubuntu

Build Reason: The Nightly scheduler named 'flink-nightly-docs-release-0.10' 
triggered this build
Build Source Stamp: [branch release-0.10] HEAD
Blamelist: 

Build succeeded!

Sincerely,
 -The Buildbot

flink git commit: [FLINK-4625] [core] Add a safety net to forcibly terminate JVM is clean shutdown freezed.

2016-09-19 Thread sewen

Repository: flink
Updated Branches:
  refs/heads/master 4b1a9c72e -> 5066125f9


[FLINK-4625] [core] Add a safety net to forcibly terminate JVM is clean 
shutdown freezed.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5066125f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5066125f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5066125f

Branch: refs/heads/master
Commit: 5066125f9a377d232f77f6fbcac3c22ebea66b39
Parents: 4b1a9c7
Author: Stephan Ewen 
Authored: Thu Sep 15 19:27:06 2016 +0200
Committer: Stephan Ewen 
Committed: Mon Sep 19 20:00:53 2016 +0200

--
 .../MesosApplicationMasterRunner.java   |   2 +
 .../MesosTaskManagerRunner.java |   5 +-
 .../runtime/util/JvmShutdownSafeguard.java  | 126 ++
 .../flink/runtime/jobmanager/JobManager.scala   |   1 +
 .../flink/runtime/taskmanager/TaskManager.scala |   1 +
 .../runtime/testutils/CommonTestUtils.java  |  10 +-
 .../flink/runtime/testutils/TestJvmProcess.java | 163 +
 .../runtime/util/BlockingShutdownTest.java  | 229 +++
 .../cassandra/CassandraConnectorITCase.java |  19 +-
 .../flink/core/testutils/CommonTestUtils.java   |  26 +++
 .../flink/yarn/TestingApplicationMaster.java|   2 +
 .../flink/yarn/YarnApplicationMasterRunner.java |   2 +
 .../flink/yarn/YarnTaskManagerRunner.java   |   5 +-
 13 files changed, 525 insertions(+), 66 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/flink/blob/5066125f/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
--
diff --git 
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
 
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
index 9916a87..8fb6af4 100644
--- 
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
+++ 
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java
@@ -45,6 +45,7 @@ import 
org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService;
 import org.apache.flink.runtime.process.ProcessReaper;
 import org.apache.flink.runtime.taskmanager.TaskManager;
 import org.apache.flink.runtime.util.EnvironmentInformation;
+import org.apache.flink.runtime.util.JvmShutdownSafeguard;
 import org.apache.flink.runtime.util.LeaderRetrievalUtils;
 import org.apache.flink.runtime.util.SignalHandler;
 import org.apache.flink.runtime.webmonitor.WebMonitor;
@@ -109,6 +110,7 @@ public class MesosApplicationMasterRunner {
public static void main(String[] args) {
EnvironmentInformation.logEnvironmentInfo(LOG, "Mesos 
AppMaster", args);
SignalHandler.register(LOG);
+   JvmShutdownSafeguard.installAsShutdownHook(LOG);
 
// run and exit with the proper return code
int returnCode = new MesosApplicationMasterRunner().run(args);

http://git-wip-us.apache.org/repos/asf/flink/blob/5066125f/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerRunner.java
--
diff --git 
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerRunner.java
 
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerRunner.java
index 94a9e99..ddc2097 100644
--- 
a/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerRunner.java
+++ 
b/flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerRunner.java
@@ -29,6 +29,8 @@ import 
org.apache.flink.runtime.clusterframework.types.ResourceID;
 import org.apache.flink.runtime.taskmanager.TaskManager;
 import org.apache.flink.runtime.util.EnvironmentInformation;
 
+import org.apache.flink.runtime.util.JvmShutdownSafeguard;
+import org.apache.flink.runtime.util.SignalHandler;
 import org.apache.flink.util.Preconditions;
 import org.apache.hadoop.security.UserGroupInformation;
 import org.apache.hadoop.security.token.Token;
@@ -49,7 +51,8 @@ public class MesosTaskManagerRunner {
 
public static void runTaskManager(String[] args, final Class taskManager) throws IOException {
EnvironmentInformation.logEnvironmentInfo(LOG, 
taskManager.getSimpleName(), args);
-   org.apache.flink.runtime.util.SignalHandler.register(LOG);
+   SignalHandler.register(LOG);
+   JvmShutdownSafeguard.installAsShutdownHook(LOG);
 
// try to parse the command line argume

flink git commit: [FLINK-4081] [core] [table] FieldParsers should support empty strings

2016-09-19 Thread twalthr

Repository: flink
Updated Branches:
  refs/heads/master d7b59d761 -> 4b1a9c72e


[FLINK-4081] [core] [table] FieldParsers should support empty strings

This closes #2297.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4b1a9c72
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4b1a9c72
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4b1a9c72

Branch: refs/heads/master
Commit: 4b1a9c72e99125680035e5dadc148b187d9d4124
Parents: d7b59d7
Author: twalthr 
Authored: Tue Jul 26 16:24:24 2016 +0200
Committer: twalthr 
Committed: Mon Sep 19 14:35:59 2016 +0200

--
 .../flink/types/parser/BooleanParser.java   |  4 +++
 .../apache/flink/types/parser/ByteParser.java   |  2 +-
 .../flink/types/parser/ByteValueParser.java |  2 +-
 .../apache/flink/types/parser/DoubleParser.java |  4 +++
 .../flink/types/parser/DoubleValueParser.java   |  4 +++
 .../apache/flink/types/parser/FieldParser.java  |  4 +--
 .../apache/flink/types/parser/FloatParser.java  |  4 +++
 .../flink/types/parser/FloatValueParser.java|  4 +++
 .../apache/flink/types/parser/IntParser.java|  2 +-
 .../flink/types/parser/IntValueParser.java  |  2 +-
 .../apache/flink/types/parser/LongParser.java   |  2 +-
 .../flink/types/parser/LongValueParser.java |  2 +-
 .../apache/flink/types/parser/ShortParser.java  |  2 +-
 .../flink/types/parser/ShortValueParser.java|  2 +-
 .../apache/flink/types/parser/StringParser.java |  8 -
 .../flink/types/parser/StringValueParser.java   |  6 
 .../types/parser/BooleanValueParserTest.java|  2 +-
 .../flink/types/parser/ByteParserTest.java  |  3 --
 .../flink/types/parser/ByteValueParserTest.java |  2 --
 .../flink/types/parser/DoubleParserTest.java|  3 --
 .../types/parser/DoubleValueParserTest.java |  2 --
 .../flink/types/parser/FloatParserTest.java |  3 --
 .../types/parser/FloatValueParserTest.java  |  2 --
 .../flink/types/parser/IntParserTest.java   |  3 --
 .../flink/types/parser/IntValueParserTest.java  |  2 --
 .../flink/types/parser/LongParserTest.java  |  3 --
 .../flink/types/parser/LongValueParserTest.java |  2 --
 .../flink/types/parser/ParserTestBase.java  |  2 ++
 .../types/parser/QuotedStringParserTest.java|  2 +-
 .../parser/QuotedStringValueParserTest.java |  4 +--
 .../flink/types/parser/ShortParserTest.java |  3 --
 .../types/parser/ShortValueParserTest.java  |  2 --
 .../types/parser/UnquotedStringParserTest.java  |  5 +--
 .../types/parser/VarLengthStringParserTest.java |  1 -
 .../table/runtime/io/RowCsvInputFormat.scala| 14 +---
 .../runtime/io/RowCsvInputFormatTest.scala  | 37 ++--
 36 files changed, 77 insertions(+), 74 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/flink/blob/4b1a9c72/flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java
--
diff --git 
a/flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java 
b/flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java
index 90fa41e..f8b890a 100644
--- a/flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java
+++ b/flink-core/src/main/java/org/apache/flink/types/parser/BooleanParser.java
@@ -44,6 +44,10 @@ public class BooleanParser extends FieldParser {
 
while (i < limit) {
if (i < delimLimit && delimiterNext(bytes, i, delim)) {
+   if (i == startPos) {
+   
setErrorState(ParseErrorState.EMPTY_COLUMN);
+   return -1;
+   }
break;
}
i++;

http://git-wip-us.apache.org/repos/asf/flink/blob/4b1a9c72/flink-core/src/main/java/org/apache/flink/types/parser/ByteParser.java
--
diff --git 
a/flink-core/src/main/java/org/apache/flink/types/parser/ByteParser.java 
b/flink-core/src/main/java/org/apache/flink/types/parser/ByteParser.java
index a521ac1..7ee257e 100644
--- a/flink-core/src/main/java/org/apache/flink/types/parser/ByteParser.java
+++ b/flink-core/src/main/java/org/apache/flink/types/parser/ByteParser.java
@@ -48,7 +48,7 @@ public class ByteParser extends FieldParser {
for (int i = startPos; i < limit; i++) {
if (i < delimLimit && delimiterNext(bytes, i, 
delimiter)) {
if (i == startPos) {
-   
setErrorState(ParseErrorState.EMPTY_STRING);
+   
setErrorState(ParseErrorState.EMPTY_COLUMN);

buildbot success in on flink-docs-release-0.10

flink git commit: [FLINK-4625] [core] Add a safety net to forcibly terminate JVM is clean shutdown freezed.

flink git commit: [FLINK-4081] [core] [table] FieldParsers should support empty strings

3 matches

Site Navigation

Mail list logo

Footer information