[flink] branch master updated: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9 (#7981)
This is an automated email from the ASF dual-hosted git repository.
kurt pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new c6878ac [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest
does not compile with Java 9 (#7981)
c6878ac is described below
commit c6878aca6c5aeee46581b4d6744b31049db9de95
Author: Kurt Young
AuthorDate: Thu Mar 14 21:39:01 2019 +0800
[FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not
compile with Java 9 (#7981)
---
.../table/runtime/compression/BlockCompressionTest.java | 16
1 file changed, 16 deletions(-)
diff --git
a/flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/compression/BlockCompressionTest.java
b/flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/compression/BlockCompressionTest.java
index ebcfec7..bfc888c 100644
---
a/flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/compression/BlockCompressionTest.java
+++
b/flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/compression/BlockCompressionTest.java
@@ -20,8 +20,6 @@ package org.apache.flink.table.runtime.compression;
import org.junit.Assert;
import org.junit.Test;
-import sun.misc.Cleaner;
-import sun.nio.ch.DirectBuffer;
import java.nio.ByteBuffer;
@@ -174,19 +172,5 @@ public class BlockCompressionTest {
for (int i = 0; i < decompressedLen; i++) {
assertEquals((byte) i, decompressedData.get());
}
-
- if (isDirect) {
- cleanDirectBuffer(data);
- cleanDirectBuffer(compressedData);
- cleanDirectBuffer(copiedCompressedData);
- cleanDirectBuffer(decompressedData);
- }
- }
-
- private void cleanDirectBuffer(ByteBuffer buffer) {
- Cleaner cleaner = ((DirectBuffer) buffer).cleaner();
- if (cleaner != null) {
- cleaner.clean();
- }
}
}
[flink] branch master updated: [FLINK-11881][table-planner-blink] Introduce code generated typed sorter to blink table (#7958)
This is an automated email from the ASF dual-hosted git repository.
kurt pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new e20a9f8 [FLINK-11881][table-planner-blink] Introduce code generated
typed sorter to blink table (#7958)
e20a9f8 is described below
commit e20a9f8947244315f7732c719ebf8f77e7699a57
Author: Jingsong Lee
AuthorDate: Thu Mar 14 21:36:23 2019 +0800
[FLINK-11881][table-planner-blink] Introduce code generated typed sorter to
blink table (#7958)
---
.../flink/table/calcite/FlinkPlannerImpl.scala | 24 +-
.../apache/flink/table/codegen/CodeGenUtils.scala | 203
.../flink/table/codegen/SortCodeGenerator.scala| 485 ++
.../flink/table/codegen/SortCodeGeneratorTest.java | 550 +
.../table/dataformat/AbstractBinaryWriter.java | 14 +-
.../apache/flink/table/dataformat/BinaryArray.java | 9 +
.../flink/table/dataformat/BinaryFormat.java | 81 +++
.../flink/table/dataformat/BinaryGeneric.java | 13 +
.../apache/flink/table/dataformat/BinaryRow.java | 28 ++
.../flink/table/dataformat/BinaryString.java | 38 --
.../flink/table/dataformat/BinaryWriter.java | 6 +-
.../table/dataformat/DataFormatConverters.java | 55 +--
.../apache/flink/table/dataformat/JoinedRow.java | 9 +
.../apache/flink/table/dataformat/NestedRow.java | 8 +
.../flink/table/dataformat/ObjectArrayRow.java | 5 +
.../flink/table/dataformat/TypeGetterSetters.java | 7 +
.../apache/flink/table/generated/CompileUtils.java | 14 +
.../flink/table/generated/GeneratedClass.java | 5 +-
.../GeneratedNormalizedKeyComputer.java} | 28 +-
.../GeneratedRecordComparator.java}| 28 +-
.../sort => generated}/NormalizedKeyComputer.java | 27 +-
.../sort => generated}/RecordComparator.java | 20 +-
.../table/runtime/sort/BinaryExternalMerger.java | 1 +
.../table/runtime/sort/BinaryExternalSorter.java | 3 +-
.../runtime/sort/BinaryInMemorySortBuffer.java | 2 +
.../table/runtime/sort/BinaryIndexedSortable.java | 2 +
.../table/runtime/sort/BinaryKVExternalMerger.java | 1 +
.../runtime/sort/BinaryKVInMemorySortBuffer.java | 2 +
.../table/runtime/sort/BinaryMergeIterator.java| 1 +
.../runtime/sort/BufferedKVExternalSorter.java | 2 +
.../apache/flink/table/runtime/sort/SortUtil.java | 101 +++-
.../org/apache/flink/table/type/ArrayType.java | 2 +
.../table/type/{TimeType.java => BinaryType.java} | 18 +-
.../org/apache/flink/table/type/BooleanType.java | 2 +
.../java/org/apache/flink/table/type/ByteType.java | 2 +
.../java/org/apache/flink/table/type/CharType.java | 2 +
.../java/org/apache/flink/table/type/DateType.java | 2 +
.../org/apache/flink/table/type/DecimalType.java | 2 +
.../org/apache/flink/table/type/DoubleType.java| 2 +
.../org/apache/flink/table/type/FloatType.java | 2 +
.../org/apache/flink/table/type/GenericType.java | 2 +
.../java/org/apache/flink/table/type/IntType.java | 2 +
.../org/apache/flink/table/type/InternalTypes.java | 2 +-
.../java/org/apache/flink/table/type/LongType.java | 2 +
.../java/org/apache/flink/table/type/MapType.java | 2 +
.../org/apache/flink/table/type/PrimitiveType.java | 2 +
.../java/org/apache/flink/table/type/RowType.java | 2 +
.../org/apache/flink/table/type/ShortType.java | 2 +
.../org/apache/flink/table/type/StringType.java| 2 +
.../java/org/apache/flink/table/type/TimeType.java | 2 +
.../org/apache/flink/table/type/TimestampType.java | 2 +
.../apache/flink/table/type/TypeConverters.java| 1 +
.../apache/flink/table/dataformat/BaseRowTest.java | 20 +-
.../flink/table/dataformat/BinaryArrayTest.java| 15 +
.../flink/table/dataformat/BinaryRowTest.java | 14 +
.../flink/table/dataformat/BinaryStringTest.java | 6 +-
.../runtime/sort/BinaryMergeIteratorTest.java | 1 +
.../runtime/sort/BufferedKVExternalSorterTest.java | 2 +
.../runtime/sort/IntNormalizedKeyComputer.java | 3 +-
.../table/runtime/sort/IntRecordComparator.java| 3 +-
.../flink/table/runtime/sort/SortUtilTest.java | 4 +-
61 files changed, 1730 insertions(+), 167 deletions(-)
diff --git
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/calcite/FlinkPlannerImpl.scala
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/calcite/FlinkPlannerImpl.scala
index 951bc05..8560a1c 100644
---
a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/calcite/FlinkPlannerImpl.scala
+++
b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/calcite/FlinkPlannerImpl.scala
@@ -20,9 +20,8 @@ package org.apache.flink.table.calcite
import java.util
import java.util.Properties
-
import com.go
[flink] 01/02: [FLINK-10076][table-planner] Upgrade Calcite dependency to 1.18
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 93a2c79188b7fa3dbbc9921a58fc83bb19343895
Author: Rong Rong
AuthorDate: Wed Jan 30 10:32:37 2019 -0800
[FLINK-10076][table-planner] Upgrade Calcite dependency to 1.18
This closes #7607.
---
.../client/gateway/local/LocalExecutorITCase.java | 3 +-
flink-table/flink-table-planner/pom.xml| 87
.../calcite/sql/validate/SqlValidatorImpl.java | 150 +++--
.../src/main/resources/META-INF/NOTICE | 15 ++-
.../flink/table/api/StreamTableEnvironment.scala | 2 +-
.../apache/flink/table/api/TableEnvironment.scala | 3 +-
.../flink/table/calcite/FlinkPlannerImpl.scala | 2 +-
.../flink/table/calcite/FlinkRelBuilder.scala | 2 +
.../table/calcite/FlinkRelBuilderFactory.scala | 50 +++
.../table/functions/utils/AggSqlFunction.scala | 2 +
.../plan/schema/TimeIndicatorRelDataType.scala | 4 +
.../table/api/batch/sql/GroupWindowTest.scala | 14 +-
.../table/api/batch/table/GroupWindowTest.scala| 14 +-
.../batch/table/stringexpr/SetOperatorsTest.scala | 2 +-
.../table/api/stream/sql/GroupWindowTest.scala | 14 +-
.../table/api/stream/sql/OverWindowTest.scala | 22 +--
.../table/api/stream/table/GroupWindowTest.scala | 14 +-
.../table/api/stream/table/OverWindowTest.scala| 7 +-
.../flink/table/plan/QueryDecorrelationTest.scala | 2 +-
flink-table/pom.xml| 2 +-
20 files changed, 282 insertions(+), 129 deletions(-)
diff --git
a/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/LocalExecutorITCase.java
b/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/LocalExecutorITCase.java
index 0ec7605..01e986f 100644
---
a/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/LocalExecutorITCase.java
+++
b/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/LocalExecutorITCase.java
@@ -229,7 +229,6 @@ public class LocalExecutorITCase extends TestLogger {
final SessionContext session = new
SessionContext("test-session", new Environment());
final List expectedTableHints = Arrays.asList(
- "TABLE",
"TableNumber1",
"TableNumber2",
"TableSourceSink");
@@ -238,7 +237,7 @@ public class LocalExecutorITCase extends TestLogger {
final List expectedClause =
Collections.singletonList("WHERE");
assertEquals(expectedClause,
executor.completeStatement(session, "SELECT * FROM TableNumber2 WH", 29));
- final List expectedField = Arrays.asList("INTERVAL",
"IntegerField1");
+ final List expectedField =
Arrays.asList("IntegerField1");
assertEquals(expectedField, executor.completeStatement(session,
"SELECT * FROM TableNumber1 WHERE Inte", 37));
}
diff --git a/flink-table/flink-table-planner/pom.xml
b/flink-table/flink-table-planner/pom.xml
index ca3832c..4fc9352 100644
--- a/flink-table/flink-table-planner/pom.xml
+++ b/flink-table/flink-table-planner/pom.xml
@@ -16,7 +16,7 @@ specific language governing permissions and limitations
under the License.
-->
http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/maven-v4_0_0.xsd";>
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/maven-v4_0_0.xsd";>
4.0.0
@@ -57,6 +57,22 @@ under the License.
janino
${janino.version}
+
+
+ com.fasterxml.jackson.core
+ jackson-annotations
+ 2.9.6
+
+
+ com.fasterxml.jackson.core
+ jackson-core
+ 2.9.6
+
+
+ com.fasterxml.jackson.core
+ jackson-databind
+ 2.9.6
+
@@ -114,26 +130,30 @@ under the License.
org.apache.calcite
calcite-core
- 1.17.0
+ 1.18.0
-
+
org.apach
[flink] 02/02: [FLINK-10076][table-planner-blink] Upgrade Calcite dependency to 1.18
This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0c062a34ddff41cda38f9492680f40fc8d49d499
Author: Timo Walther
AuthorDate: Wed Mar 13 13:35:45 2019 +0100
[FLINK-10076][table-planner-blink] Upgrade Calcite dependency to 1.18
---
flink-table/flink-table-planner-blink/pom.xml | 89 ++
.../src/main/resources/META-INF/NOTICE | 16 ++--
2 files changed, 69 insertions(+), 36 deletions(-)
diff --git a/flink-table/flink-table-planner-blink/pom.xml
b/flink-table/flink-table-planner-blink/pom.xml
index cb38352..b4640f8 100644
--- a/flink-table/flink-table-planner-blink/pom.xml
+++ b/flink-table/flink-table-planner-blink/pom.xml
@@ -59,6 +59,22 @@ under the License.
janino
${janino.version}
+
+
+ com.fasterxml.jackson.core
+ jackson-annotations
+ 2.9.6
+
+
+ com.fasterxml.jackson.core
+ jackson-core
+ 2.9.6
+
+
+ com.fasterxml.jackson.core
+ jackson-databind
+ 2.9.6
+
@@ -98,37 +114,35 @@ under the License.
provided
-
- org.apache.flink
- flink-shaded-jackson
- provided
-
-
org.apache.calcite
calcite-core
- 1.17.0
+ 1.18.0
-
+
org.apache.calcite.avatica
avatica-metrics
-
com.fasterxml.jackson.core
- jackson-core
-
-
-
com.fasterxml.jackson.core
-
jackson-annotations
-
-
-
com.fasterxml.jackson.core
-
jackson-databind
-
-
com.google.protobuf
protobuf-java
@@ -141,13 +155,25 @@ under the License.
httpcore
- commons-dbcp
- commons-dbcp
+ org.apache.commons
+ commons-dbcp2
com.esri.geometry
esri-geometry-api
+
+
com.fasterxml.jackson.dataformat
+
jackson-dataformat-yaml
+
+
+
com.yahoo.datasketches
+ sketches-core
+
+
+ net.hydromatic
+
aggdesigner-algorithm
+
@@ -189,6 +215,7 @@ under the License.
shade-flink
+
false
*:*
@@ -198,16 +225,11 @@ under the License.
common.proto
requests.proto
[flink] branch master updated (76b9f8b -> 0c062a3)
This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 76b9f8b [FLINK-11903][tests] Improve FileStateBackendTest by using JUnit's parameterized new 93a2c79 [FLINK-10076][table-planner] Upgrade Calcite dependency to 1.18 new 0c062a3 [FLINK-10076][table-planner-blink] Upgrade Calcite dependency to 1.18 The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../client/gateway/local/LocalExecutorITCase.java | 3 +- flink-table/flink-table-planner-blink/pom.xml | 89 +++- .../src/main/resources/META-INF/NOTICE | 16 ++- flink-table/flink-table-planner/pom.xml| 87 .../calcite/sql/validate/SqlValidatorImpl.java | 150 +++-- .../src/main/resources/META-INF/NOTICE | 15 ++- .../flink/table/api/StreamTableEnvironment.scala | 2 +- .../apache/flink/table/api/TableEnvironment.scala | 3 +- .../flink/table/calcite/FlinkPlannerImpl.scala | 2 +- .../flink/table/calcite/FlinkRelBuilder.scala | 2 + .../table/calcite/FlinkRelBuilderFactory.scala | 50 +++ .../table/functions/utils/AggSqlFunction.scala | 2 + .../plan/schema/TimeIndicatorRelDataType.scala | 4 + .../table/api/batch/sql/GroupWindowTest.scala | 14 +- .../table/api/batch/table/GroupWindowTest.scala| 14 +- .../batch/table/stringexpr/SetOperatorsTest.scala | 2 +- .../table/api/stream/sql/GroupWindowTest.scala | 14 +- .../table/api/stream/sql/OverWindowTest.scala | 22 +-- .../table/api/stream/table/GroupWindowTest.scala | 14 +- .../table/api/stream/table/OverWindowTest.scala| 7 +- .../flink/table/plan/QueryDecorrelationTest.scala | 2 +- flink-table/pom.xml| 2 +- 22 files changed, 351 insertions(+), 165 deletions(-) create mode 100644 flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/calcite/FlinkRelBuilderFactory.scala
[flink] annotated tag release-1.8.0-rc2 created (now c77a329)
This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a change to annotated tag release-1.8.0-rc2 in repository https://gitbox.apache.org/repos/asf/flink.git. at c77a329 (tag) tagging 032ff2462a577451b5187a9d0e317c94f751f517 (commit) replaces pre-apache-rename by Aljoscha Krettek on Wed Mar 13 15:26:24 2019 +0100 - Log - Release 1.8.0 -BEGIN PGP SIGNATURE- iQIzBAABCgAdFiEE8qZ6gEdJm7s5CNF6qPT9lxIdcpMFAlyJExAACgkQqPT9lxId cpPS9w/+LK1l7Ruh61Srrowu0++mEcR9a1UipHOkNRo1zRbap2t22JL0VklPIw6P +gk8cwITmTS1+mIncn4oCK5ZrgXfqETCkOoMLBfKp+qMHZLtlqeCTA/PLiU562+m MNwO5+eF4mHm3ys5O7oMCSbocsDdEDUEneReUdtCjHQkvcDN/CCchQL/4uSUV4K7 oMpaqsy/9yyMksOe/BwhfUBCK5z4azGVfFf0ce8zGAYzHCxX/bRiK4/W8D/d4Ees E9nvhUWNFeCPe3cl2sxrlPuEilo0+JoEO7qU6jT3ExlsStFdwNk5yPjFLgqREVR/ XA74uIlIJAqjeSVKbPuscCFdESUnsqOFNBEih5YG0wOMOlL/pgvM1w2vlC9RmBCB ScT8+dQaV3Y8uhPEkeHm14m8SgUCpDgakEfWXV7vP7usOH3R/H80zTaR0jL29wZ3 fFLilv8gIj9vtkFi30g5VW3CFjQY9pTqCE+VU3faJfq7UgpzKG0eAuXS2+kKEvwG AI0Qr3NlQqvypxb02pC5vSy1yaNb0rWIXf/GRM2ziK/M0oRITIOR6MeTy/dFkKpA tKnCKAUgjqLT+4qvWwtwjRSTyUW2LX1b33BhSQgmA79RAon6lfCPeOJDeRJiiBZV egnhqKIuGGK6lMx7wygpfRlUl7Ne00pUK7nCGk0gjB4LQkijp0g= =w1ty -END PGP SIGNATURE- --- This annotated tag includes the following new commits: new 032ff24 Commit for release 1.8.0 The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[flink] 01/01: Commit for release 1.8.0
This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to annotated tag release-1.8.0-rc2 in repository https://gitbox.apache.org/repos/asf/flink.git commit 032ff2462a577451b5187a9d0e317c94f751f517 Author: Aljoscha Krettek AuthorDate: Wed Mar 13 15:25:48 2019 +0100 Commit for release 1.8.0 --- docs/_config.yml | 4 ++-- flink-annotations/pom.xml | 2 +- flink-clients/pom.xml | 2 +- flink-connectors/flink-connector-cassandra/pom.xml| 2 +- flink-connectors/flink-connector-elasticsearch-base/pom.xml | 2 +- flink-connectors/flink-connector-elasticsearch/pom.xml| 2 +- flink-connectors/flink-connector-elasticsearch2/pom.xml | 2 +- flink-connectors/flink-connector-elasticsearch5/pom.xml | 2 +- flink-connectors/flink-connector-elasticsearch6/pom.xml | 2 +- flink-connectors/flink-connector-filesystem/pom.xml | 2 +- flink-connectors/flink-connector-kafka-0.10/pom.xml | 2 +- flink-connectors/flink-connector-kafka-0.11/pom.xml | 2 +- flink-connectors/flink-connector-kafka-0.8/pom.xml| 2 +- flink-connectors/flink-connector-kafka-0.9/pom.xml| 2 +- flink-connectors/flink-connector-kafka-base/pom.xml | 2 +- flink-connectors/flink-connector-kafka/pom.xml| 2 +- flink-connectors/flink-connector-kinesis/pom.xml | 2 +- flink-connectors/flink-connector-nifi/pom.xml | 2 +- flink-connectors/flink-connector-rabbitmq/pom.xml | 2 +- flink-connectors/flink-connector-twitter/pom.xml | 2 +- flink-connectors/flink-hadoop-compatibility/pom.xml | 2 +- flink-connectors/flink-hbase/pom.xml | 2 +- flink-connectors/flink-hcatalog/pom.xml | 2 +- flink-connectors/flink-jdbc/pom.xml | 2 +- flink-connectors/flink-orc/pom.xml| 2 +- flink-connectors/flink-sql-connector-elasticsearch6/pom.xml | 2 +- flink-connectors/flink-sql-connector-kafka-0.10/pom.xml | 2 +- flink-connectors/flink-sql-connector-kafka-0.11/pom.xml | 2 +- flink-connectors/flink-sql-connector-kafka-0.9/pom.xml| 2 +- flink-connectors/flink-sql-connector-kafka/pom.xml| 2 +- flink-connectors/pom.xml | 2 +- flink-container/pom.xml | 2 +- flink-contrib/flink-connector-wikiedits/pom.xml | 2 +- flink-contrib/pom.xml | 2 +- flink-core/pom.xml| 2 +- flink-dist/pom.xml| 2 +- flink-docs/pom.xml| 2 +- flink-end-to-end-tests/flink-bucketing-sink-test/pom.xml | 2 +- flink-end-to-end-tests/flink-cli-test/pom.xml | 2 +- flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml| 2 +- flink-end-to-end-tests/flink-dataset-allround-test/pom.xml| 2 +- flink-end-to-end-tests/flink-datastream-allround-test/pom.xml | 2 +- flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml | 2 +- flink-end-to-end-tests/flink-e2e-test-utils/pom.xml | 2 +- flink-end-to-end-tests/flink-elasticsearch1-test/pom.xml | 2 +- flink-end-to-end-tests/flink-elasticsearch2-test/pom.xml | 2 +- flink-end-to-end-tests/flink-elasticsearch5-test/pom.xml | 2 +- flink-end-to-end-tests/flink-elasticsearch6-test/pom.xml | 2 +- flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml | 4 ++-- flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml | 2 +- flink-end-to-end-tests/flink-high-parallelism-iterations-test/pom.xml | 2 +- .../flink-local-recovery-and-allocation-test/pom.xml | 2 +- flink-end-to-end-tests/flink-metrics-availability-test/pom.xml| 2 +- flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml | 2 +- .../flink-parent-child-classloading-test-lib-package/pom.xml | 2 +- .../flink-parent-child-classloading-test-program/pom.xml | 2 +- flink-end-to-end-tests/flink-queryable-state-test/pom.xml | 2 +- flink-end-to-end-tests/flink-quickstart-test/pom.xml | 2 +- flink-end-to-end-tests/flink-sql-client-test/pom.xml | 2 +- flink-end-to-end-tests/flink-state-evolution-test/p
svn commit: r32917 - /dev/flink/flink-1.8.0-rc2/
Author: aljoscha Date: Thu Mar 14 11:30:59 2019 New Revision: 32917 Log: Add new Flink 1.8.0 RC2 to dist/dev/flink/ Added: dev/flink/flink-1.8.0-rc2/ dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz (with props) dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz.asc dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz.sha512 dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz (with props) dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz.asc dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz.sha512 dev/flink/flink-1.8.0-rc2/flink-1.8.0-src.tgz (with props) dev/flink/flink-1.8.0-rc2/flink-1.8.0-src.tgz.asc dev/flink/flink-1.8.0-rc2/flink-1.8.0-src.tgz.sha512 Added: dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz == Binary file - no diff available. Propchange: dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz -- svn:mime-type = application/octet-stream Added: dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz.asc == --- dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz.asc (added) +++ dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz.asc Thu Mar 14 11:30:59 2019 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEE8qZ6gEdJm7s5CNF6qPT9lxIdcpMFAlyKNnIACgkQqPT9lxId +cpOqNA//UmtyEQTYn1VV2KaY6goaL7w7P0/zVG8ZV9cYBpO4h8OcEfiKfxnhGwJE +vGcdgT0q+C+cW/hmw4nieKjU99XMqgiGQXe2WawiQa6q9vJYSt8c7/Cyxwqv84jJ +c4lsOMuwaGfI2LolC/d5nW1EvhKeu3Y6lfBms8EgqWAR1UizXnuZFSz1aoeBtdTZ +KD0etm9F22ODlDhs//+S8FCY37SpEGTaEbuhLhgET/S2y1Z0INjN/JB01jPELBSC +/cqMp9zHdILjvoZO1rqDS7pGoExZzc5cvqJ5xLnPjE7MSj4yinCfqcXYHw0A4n/O +cGEhjJcLXc2rmvXJeJ4LN61aiZh4qEYgSS2f6X0Zo9T5+hP0pXbeD/dy24vCMNXh +no0OMNT+TsfUhJkqysIehltSKBgQ66CAcAKhd+tTVdtQXfG+b6BRPJLr8p3/2/xj +JMW8QGo9VninYh+MDdBIo8FMcrHSjof9ujWyyTUo9P9u5itmOPN8Oe/RZPaGcYE3 +BAF6Z7UUEBquTBNH8Oo6H++gsj+QqyzbWqvRYfMH5bPMpjXX7KevUdDEHT3Dnyzi +polZgdZCyWhCu7ODIhItVIoPmA1wdCTOk7SJUPIlLv9++I4mkSEEOe1vDixGBx1E +767PWNAp0VnO8e9aDK+aOiNVzmgFjwWEhhsImBv/GdrUu//JtRQ= +=ONpg +-END PGP SIGNATURE- Added: dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz.sha512 == --- dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz.sha512 (added) +++ dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.11.tgz.sha512 Thu Mar 14 11:30:59 2019 @@ -0,0 +1 @@ +3ccae993c5c0451e992c1257c65597e8b16ca7e15d24f254064760ace46d5aeb21bddf2e39eda294ac7a4c423229db0e6aa09f694507f6bce851f6ec054a116f flink-1.8.0-bin-scala_2.11.tgz Added: dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz == Binary file - no diff available. Propchange: dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz -- svn:mime-type = application/octet-stream Added: dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz.asc == --- dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz.asc (added) +++ dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz.asc Thu Mar 14 11:30:59 2019 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEE8qZ6gEdJm7s5CNF6qPT9lxIdcpMFAlyKNCcACgkQqPT9lxId +cpNy9BAApmpmHXb5ffoKNNdWcpo5UStyXE0zIXHP7w2OvhnV2W1D8x8j2NrL0LVe +fnmc6sInvNuv51CJcMwvOLXTCvOsiw9iEn1uCDi2PRPoM2CQIuEPpRfXxbv0qthB +WSqrNKsGs3YvBm9f/4L3SZPERlWmCdh9I/Ck6hG94VWD2yHHGKxdTzUqfbSDGeNa +0ofhmlILRaJwByJUD3QDZZgnhA7eePLod9Vcn54D5NnhfPUNg/8ZDXDUxjOaJPQZ +QMU7VqeuHm5AVW+XpvT7Ps17NDw/HBLSslh53VhbZ6SflOPb5qbfDHrFPN68t3Fb +/R3MqyY+V+76uWc3sluXQ0ok5eCumIIIEF7MHwaYSvVhgXFOUFHIjlNQZo8CtNFX +hGWS1wzfTvLl4/fGXu3gBUKWnqN2S0hKiJIwyU9ioftyfO0BRG6Au3CR6aAdZy9P +mSly7/6CPrr9YvCKdAwaDQ6au4UJrPMu+1ojVyMO5cWT2mjDyPon/GsZ6ja5F0uL +3t7jRf8Zvc49KBpAkSvNCb5sDxkB41bEO+ruXZu8FGNlZ2d8KSbnuxJ4p3djC5df +GlkjwLlGJOKnbqDD2X++oeK4/JtWIBuprFfmXAZ8SWvqEYC5Kq5C6m/2oARPvOxb +NasID/cserJVZYwIVLLMdtAngRZB4/I55bVEHJAZX1hu0zXK1kE= +=bLC6 +-END PGP SIGNATURE- Added: dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz.sha512 == --- dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz.sha512 (added) +++ dev/flink/flink-1.8.0-rc2/flink-1.8.0-bin-scala_2.12.tgz.sha512 Thu Mar 14 11:30:59 2019 @@ -0,0 +1 @@ +cb61e8a930381531073c91b892dd2de7232ab74db5dfdd7cf752f2d1f5358dbab700565fa5412740bef33793f7dcc096eff956384466f811fafeb87e2661cb3f flink-1.8.0-bin-scala_2.12.tgz Added: dev/flink/flink-1.8.0-rc2/flink-1.8.0-src.tgz == Binary file - no diff
[flink] branch master updated: [FLINK-11903][tests] Improve FileStateBackendTest by using JUnit's parameterized
This is an automated email from the ASF dual-hosted git repository.
srichter pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 76b9f8b [FLINK-11903][tests] Improve FileStateBackendTest by using
JUnit's parameterized
76b9f8b is described below
commit 76b9f8b5a4a2e0384850ec1cfb3dfa7607189933
Author: Congxian Qiu
AuthorDate: Thu Mar 14 19:12:04 2019 +0800
[FLINK-11903][tests] Improve FileStateBackendTest by using JUnit's
parameterized
This closes #7973.
---
.../runtime/state/AsyncFileStateBackendTest.java | 27 --
.../flink/runtime/state/FileStateBackendTest.java | 19 +++
2 files changed, 14 insertions(+), 32 deletions(-)
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/AsyncFileStateBackendTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/state/AsyncFileStateBackendTest.java
deleted file mode 100644
index dd73e42..000
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/AsyncFileStateBackendTest.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.runtime.state;
-
-public class AsyncFileStateBackendTest extends FileStateBackendTest {
-
- @Override
- protected boolean useAsyncMode() {
- return true;
- }
-}
\ No newline at end of file
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java
index beea0c2..8b03745 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java
+++
b/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java
@@ -24,26 +24,35 @@ import org.junit.Ignore;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.TemporaryFolder;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
import java.io.File;
+import java.util.Arrays;
+import java.util.List;
/**
* Tests for the keyed state backend and operator state backend, as created by
the
* {@link FsStateBackend}.
*/
+@RunWith(Parameterized.class)
public class FileStateBackendTest extends StateBackendTestBase
{
+ @Parameterized.Parameters
+ public static List modes() {
+ return Arrays.asList(true, false);
+ }
+
+ @Parameterized.Parameter
+ public boolean useAsyncMode;
+
@Rule
public final TemporaryFolder tempFolder = new TemporaryFolder();
@Override
protected FsStateBackend getStateBackend() throws Exception {
File checkpointPath = tempFolder.newFolder();
- return new FsStateBackend(checkpointPath.toURI(),
useAsyncMode());
- }
-
- protected boolean useAsyncMode() {
- return false;
+ return new FsStateBackend(checkpointPath.toURI(), useAsyncMode);
}
@Override
[flink] branch master updated: [FLINK-11904][tests]Improve MemoryStateBackendTest by using JUnit's Parameterized
This is an automated email from the ASF dual-hosted git repository.
srichter pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 6c7ddf3 [FLINK-11904][tests]Improve MemoryStateBackendTest by using
JUnit's Parameterized
6c7ddf3 is described below
commit 6c7ddf39af5bd3bd3e9131332c104be7f0f894fb
Author: Congxian Qiu
AuthorDate: Thu Mar 14 19:08:47 2019 +0800
[FLINK-11904][tests]Improve MemoryStateBackendTest by using JUnit's
Parameterized
This closes #7984.
---
.../runtime/state/AsyncMemoryStateBackendTest.java | 27 --
.../runtime/state/MemoryStateBackendTest.java | 20
2 files changed, 15 insertions(+), 32 deletions(-)
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/AsyncMemoryStateBackendTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/state/AsyncMemoryStateBackendTest.java
deleted file mode 100644
index ba4a89d..000
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/AsyncMemoryStateBackendTest.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.runtime.state;
-
-public class AsyncMemoryStateBackendTest extends MemoryStateBackendTest {
-
- @Override
- protected boolean useAsyncMode() {
- return true;
- }
-}
\ No newline at end of file
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/MemoryStateBackendTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/state/MemoryStateBackendTest.java
index 2ac1ea1..9dd60a1 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/state/MemoryStateBackendTest.java
+++
b/flink-runtime/src/test/java/org/apache/flink/runtime/state/MemoryStateBackendTest.java
@@ -22,19 +22,29 @@ import
org.apache.flink.runtime.state.memory.MemoryStateBackend;
import org.junit.Ignore;
import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+
+import java.util.Arrays;
+import java.util.List;
/**
* Tests for the {@link
org.apache.flink.runtime.state.memory.MemoryStateBackend}.
*/
+@RunWith(Parameterized.class)
public class MemoryStateBackendTest extends
StateBackendTestBase {
- @Override
- protected MemoryStateBackend getStateBackend() throws Exception {
- return new MemoryStateBackend(useAsyncMode());
+ @Parameterized.Parameters(name = "useAsyncmode")
+ public static List modes() {
+ return Arrays.asList(true, false);
}
- protected boolean useAsyncMode() {
- return false;
+ @Parameterized.Parameter
+ public boolean useAsyncmode;
+
+ @Override
+ protected MemoryStateBackend getStateBackend() {
+ return new MemoryStateBackend(useAsyncmode);
}
@Override
[flink] branch master updated: [FLINK-11874][checkpoint] Split CheckpointStorage interface to distinguish JM and TM side
This is an automated email from the ASF dual-hosted git repository.
srichter pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new b6b4baf [FLINK-11874][checkpoint] Split CheckpointStorage interface
to distinguish JM and TM side
b6b4baf is described below
commit b6b4baf588fae0494e32492ac16df8977d8cfc1b
Author: Yun Tang
AuthorDate: Thu Mar 14 18:48:39 2019 +0800
[FLINK-11874][checkpoint] Split CheckpointStorage interface to distinguish
JM and TM side
This closes #7970.
---
.../runtime/checkpoint/CheckpointCoordinator.java | 12 ++-
.../flink/runtime/state/CheckpointStorage.java | 117 +
java => CheckpointStorageCoordinatorView.java} | 57 ++
.../runtime/state/CheckpointStorageWorkerView.java | 71 +
.../state/filesystem/FsCheckpointStorage.java | 4 +-
.../memory/MemoryBackendCheckpointStorage.java | 6 +-
.../flink/runtime/dispatcher/DispatcherTest.java | 4 +-
.../flink/runtime/state/StateBackendTestBase.java | 10 +-
.../state/testutils/BackendForTestStream.java | 12 +--
.../runtime/state/ttl/StateBackendTestContext.java | 14 +--
.../runtime/operators/GenericWriteAheadSink.java | 4 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 6 +-
.../flink/streaming/util/MockStreamTask.java | 8 +-
.../streaming/util/MockStreamTaskBuilder.java | 3 +-
14 files changed, 129 insertions(+), 199 deletions(-)
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
index 9935455..ac4c1e2 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
@@ -35,13 +35,14 @@ import org.apache.flink.runtime.jobgraph.JobVertexID;
import org.apache.flink.runtime.jobgraph.OperatorID;
import org.apache.flink.runtime.messages.checkpoint.AcknowledgeCheckpoint;
import org.apache.flink.runtime.messages.checkpoint.DeclineCheckpoint;
-import org.apache.flink.runtime.state.CheckpointStorage;
+import org.apache.flink.runtime.state.CheckpointStorageCoordinatorView;
import org.apache.flink.runtime.state.CheckpointStorageLocation;
import org.apache.flink.runtime.state.CompletedCheckpointStorageLocation;
import org.apache.flink.runtime.state.SharedStateRegistry;
import org.apache.flink.runtime.state.SharedStateRegistryFactory;
import org.apache.flink.runtime.state.StateBackend;
import org.apache.flink.runtime.taskmanager.DispatcherThreadFactory;
+import org.apache.flink.util.FlinkRuntimeException;
import org.apache.flink.util.Preconditions;
import org.apache.flink.util.StringUtils;
@@ -50,6 +51,7 @@ import org.slf4j.LoggerFactory;
import javax.annotation.Nullable;
+import java.io.IOException;
import java.util.ArrayDeque;
import java.util.HashMap;
import java.util.Iterator;
@@ -119,7 +121,7 @@ public class CheckpointCoordinator {
/** The root checkpoint state backend, which is responsible for
initializing the
* checkpoint, storing the metadata, and cleaning up the checkpoint. */
- private final CheckpointStorage checkpointStorage;
+ private final CheckpointStorageCoordinatorView checkpointStorage;
/** A list of recent checkpoint IDs, to identify late messages (vs
invalid ones). */
private final ArrayDeque recentPendingCheckpoints;
@@ -247,7 +249,11 @@ public class CheckpointCoordinator {
try {
this.checkpointStorage =
checkpointStateBackend.createCheckpointStorage(job);
+ } catch (IOException e) {
+ throw new FlinkRuntimeException("Failed to create
checkpoint storage at checkpoint coordinator side.", e);
+ }
+ try {
// Make sure the checkpoint ID enumerator is running.
Possibly
// issues a blocking call to ZooKeeper.
checkpointIDCounter.start();
@@ -1140,7 +1146,7 @@ public class CheckpointCoordinator {
}
}
- public CheckpointStorage getCheckpointStorage() {
+ public CheckpointStorageCoordinatorView getCheckpointStorage() {
return checkpointStorage;
}
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorage.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorage.java
index 0f8aa69..af02da5 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorage.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorage.java
@@ -18,119 +18,10 @@
package org.apache.flink.runtime.state;
-import
[flink] branch master updated: [FLINK-11845][runtime] Drop legacy InfoMessage
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new d67f7db [FLINK-11845][runtime] Drop legacy InfoMessage
d67f7db is described below
commit d67f7dbaa096f7b2915675a1012fe31003441e7c
Author: ZiLi Chen
AuthorDate: Thu Mar 14 18:02:59 2019 +0800
[FLINK-11845][runtime] Drop legacy InfoMessage
---
.../clusterframework/messages/InfoMessage.java | 58 --
.../messages/RegisterInfoMessageListener.java | 70 --
.../messages/UnRegisterInfoMessageListener.java| 70 --
.../InfoMessageListenerRpcGateway.java | 34 ---
.../runtime/resourcemanager/ResourceManager.java | 61 ---
.../resourcemanager/ResourceManagerGateway.java| 15 -
.../utils/TestingResourceManagerGateway.java | 10
7 files changed, 318 deletions(-)
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/InfoMessage.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/InfoMessage.java
deleted file mode 100644
index 81670d7..000
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/InfoMessage.java
+++ /dev/null
@@ -1,58 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.runtime.clusterframework.messages;
-
-import java.util.Date;
-
-import static java.util.Objects.requireNonNull;
-
-/**
- * A simple informational message sent by the resource master to the client.
- */
-public class InfoMessage implements java.io.Serializable {
-
- private static final long serialVersionUID = 5534993035539629765L;
-
- private final String message;
-
- private final Date date;
-
- public InfoMessage(String message) {
- this.message = message;
- this.date = new Date();
- }
-
- public InfoMessage(String message, Date date) {
- this.message = requireNonNull(message);
- this.date = requireNonNull(date);
- }
-
- public String message() {
- return message;
- }
-
- public Date date() {
- return date;
- }
-
- @Override
- public String toString() {
- return "InfoMessage { message='" + message + "', date=" + date
+ " }";
- }
-}
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/RegisterInfoMessageListener.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/RegisterInfoMessageListener.java
deleted file mode 100644
index d39ff9b..000
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/messages/RegisterInfoMessageListener.java
+++ /dev/null
@@ -1,70 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.runtime.clusterframework.messages;
-
-import org.apache.flink.runtime.messages.RequiresLeaderSessionID;
-
-/**
- * This message signals to the resource master to register the sender as an
- * info message listener.
- */
-public class RegisterInfoMessageListener implements RequiresLeaderSessionID,
java.io.Serializable {
-
- private st
[flink] branch release-1.7 updated (e10a98f -> a35bfef)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git. from e10a98f [FLINK-11183][metrics] Properly measure current memory usage new 17aaca4 [hotfix][rest] Remove "Impl. error" from log message new a35bfef [FLINK-11902][rest] Do not wrap all exceptions in RestHandlerException The 15344 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../flink/runtime/webmonitor/handlers/JarRunHandler.java | 10 +- .../flink/runtime/webmonitor/handlers/JarRunHandlerTest.java | 4 .../org/apache/flink/runtime/rest/handler/AbstractHandler.java | 2 +- 3 files changed, 6 insertions(+), 10 deletions(-)
[flink] branch release-1.8 updated (9776162 -> a3e3852)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git. from 9776162 [FLINK-11183][metrics] Properly measure current memory usage new 5423f87 [hotfix][rest] Remove "Impl. error" from log message new a3e3852 [FLINK-11902][rest] Do not wrap all exceptions in RestHandlerException The 16054 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../flink/runtime/webmonitor/handlers/JarRunHandler.java | 10 +- .../flink/runtime/webmonitor/handlers/JarRunHandlerTest.java | 4 .../org/apache/flink/runtime/rest/handler/AbstractHandler.java | 2 +- 3 files changed, 6 insertions(+), 10 deletions(-)
[flink] branch master updated (d9803ac -> f3c5dd9)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from d9803ac [FLINK-11183][metrics] Properly measure current memory usage new ada4154 [hotfix][rest] Remove "Impl. error" from log message new f3c5dd9 [FLINK-11902][rest] Do not wrap all exceptions in RestHandlerException The 16112 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../flink/runtime/webmonitor/handlers/JarRunHandler.java | 10 +- .../flink/runtime/webmonitor/handlers/JarRunHandlerTest.java | 4 .../org/apache/flink/runtime/rest/handler/AbstractHandler.java | 2 +- 3 files changed, 6 insertions(+), 10 deletions(-)
[flink] branch release-1.7 updated (c3488dd -> e10a98f)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.7 in repository https://gitbox.apache.org/repos/asf/flink.git. from c3488dd [FLINK-11866][py][docs] Fix method name new fcb4f6a [FLINK-11183][metrics] Move memory metrics creation into separate method new e10a98f [FLINK-11183][metrics] Properly measure current memory usage The 15342 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../apache/flink/runtime/metrics/MetricNames.java | 4 ++ .../flink/runtime/metrics/util/MetricUtils.java| 38 +-- .../runtime/metrics/util/MetricUtilsTest.java | 55 ++ 3 files changed, 83 insertions(+), 14 deletions(-)
[flink] branch release-1.8 updated (f7e7fbd -> 9776162)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git. from f7e7fbd [FLINK-11901][build] Update NOTICE files with year 2019 new fad1661 [FLINK-11183][metrics] Move memory metrics creation into separate method new 9776162 [FLINK-11183][metrics] Properly measure current memory usage The 16052 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../apache/flink/runtime/metrics/MetricNames.java | 4 ++ .../flink/runtime/metrics/util/MetricUtils.java| 38 +-- .../runtime/metrics/util/MetricUtilsTest.java | 55 ++ 3 files changed, 83 insertions(+), 14 deletions(-)
[flink] branch master updated (9976c70 -> d9803ac)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 9976c70 [hotfix][tests] Improve error message in GenericTypeInfoTest new ced9725 [FLINK-11183][metrics] Move memory metrics creation into separate method new d9803ac [FLINK-11183][metrics] Properly measure current memory usage The 16110 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../apache/flink/runtime/metrics/MetricNames.java | 4 ++ .../flink/runtime/metrics/util/MetricUtils.java| 38 +-- .../runtime/metrics/util/MetricUtilsTest.java | 55 ++ 3 files changed, 83 insertions(+), 14 deletions(-)
[flink] branch master updated: [hotfix][tests] Improve error message in GenericTypeInfoTest
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 9976c70 [hotfix][tests] Improve error message in GenericTypeInfoTest
9976c70 is described below
commit 9976c709d9a5a3b5d6361edabc9d63aaf4b1e748
Author: zentol
AuthorDate: Wed Mar 13 16:07:01 2019 +0100
[hotfix][tests] Improve error message in GenericTypeInfoTest
---
.../src/test/java/org/apache/flink/test/misc/GenericTypeInfoTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/flink-tests/src/test/java/org/apache/flink/test/misc/GenericTypeInfoTest.java
b/flink-tests/src/test/java/org/apache/flink/test/misc/GenericTypeInfoTest.java
index c004759..6922689 100644
---
a/flink-tests/src/test/java/org/apache/flink/test/misc/GenericTypeInfoTest.java
+++
b/flink-tests/src/test/java/org/apache/flink/test/misc/GenericTypeInfoTest.java
@@ -26,6 +26,8 @@ import
org.apache.flink.test.operators.util.CollectionDataSets;
import org.junit.Assert;
import org.junit.Test;
+import static org.hamcrest.core.StringStartsWith.startsWith;
+
/**
* Test TypeInfo serializer tree.
*/
@@ -41,7 +43,7 @@ public class GenericTypeInfoTest {
String serTree = Utils.getSerializerTree(ti);
// We can not test against the entire output because the fields
of 'String' differ
// between java versions
- Assert.assertTrue(serTree.startsWith("GenericTypeInfo
(PojoWithCollectionGeneric)\n" +
+ Assert.assertThat(serTree, startsWith("GenericTypeInfo
(PojoWithCollectionGeneric)\n" +
"pojos:java.util.List\n" +
"key:int\n" +
"sqlDate:java.sql.Date\n" +
[flink-web] branch asf-site updated: [hotfix] fix typos
This is an automated email from the ASF dual-hosted git repository. rmetzger pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new 7f8f58b [hotfix] fix typos 7f8f58b is described below commit 7f8f58ba80360f8d798e3bad9226d93893ee8c00 Author: cphe AuthorDate: Thu Mar 14 15:33:52 2019 +0800 [hotfix] fix typos --- _posts/2019-02-15-release-1.7.2.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/_posts/2019-02-15-release-1.7.2.md b/_posts/2019-02-15-release-1.7.2.md index dd7a19d..be5b0f6 100644 --- a/_posts/2019-02-15-release-1.7.2.md +++ b/_posts/2019-02-15-release-1.7.2.md @@ -129,7 +129,7 @@ List of resolved issues: [FLINK-11023] - Update LICENSE and NOTICE files for flink-connectors -[FLINK-11079] - Skip deployment for flnk-storm-examples +[FLINK-11079] - Skip deployment for flink-storm-examples [FLINK-11207] - Update Apache commons-compress from 1.4.1 to 1.18
