[flink] branch release-1.15 updated: [hotfix][ci] Update libssl download link
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push:
new 8ca31005c54 [hotfix][ci] Update libssl download link
8ca31005c54 is described below
commit 8ca31005c54bf650e7eed9bd7bc72bb025ff5af5
Author: Chesnay Schepler
AuthorDate: Thu May 5 21:11:28 2022 +0200
[hotfix][ci] Update libssl download link
---
tools/azure-pipelines/e2e-template.yml | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tools/azure-pipelines/e2e-template.yml
b/tools/azure-pipelines/e2e-template.yml
index 637ea476d30..7301ff7c8a6 100644
--- a/tools/azure-pipelines/e2e-template.yml
+++ b/tools/azure-pipelines/e2e-template.yml
@@ -102,8 +102,8 @@ jobs:
echo "Installing required software"
sudo apt-get install -y bc libapr1
# install libssl1.0.0 for netty tcnative
-wget
http://security.ubuntu.com/ubuntu/pool/main/o/openssl1.0/libssl1.0.0_1.0.2n-1ubuntu5.8_amd64.deb
-sudo apt install ./libssl1.0.0_1.0.2n-1ubuntu5.8_amd64.deb
+wget
http://security.ubuntu.com/ubuntu/pool/main/o/openssl1.0/libssl1.0.0_1.0.2n-1ubuntu5.9_amd64.deb
+sudo apt install ./libssl1.0.0_1.0.2n-1ubuntu5.9_amd64.deb
displayName: Prepare E2E run
condition: not(eq(variables['SKIP'], '1'))
- script: ${{parameters.environment}} PROFILE="$PROFILE -Dfast
-Pskip-webui-build" ./tools/ci/compile.sh
[flink] 13/13: [release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots
This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a commit to branch 1.15_create in repository https://gitbox.apache.org/repos/asf/flink.git commit 3a30f2714b3e7dce0589aaa9f9aeaf7dc8b6b8bb Author: Yun Gao AuthorDate: Sun May 8 00:37:57 2022 +0800 [release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots --- .../089594ed-2f58-4d20-aa9a-da9d018ae002| Bin 0 -> 684 bytes .../13345fae-1542-4ea6-bfae-e29a8d2872ba| Bin 0 -> 1959 bytes .../200e50e2-6909-4571-bc02-4ec64f2c52f4| Bin 0 -> 8205 bytes .../32243c1b-33e2-4c51-86ca-5600282722b5| Bin 0 -> 684 bytes .../326e2e77-5e4a-4763-89e4-f9331eea0f0b| Bin 0 -> 684 bytes .../5562f012-828d-4421-a727-7972235a66c0| Bin 0 -> 457 bytes .../6a97d964-d395-46b9-a3f7-f728673e77a8| Bin 0 -> 1959 bytes .../92aa11ad-122f-4ed2-8215-2a4c81a78139| Bin 0 -> 10165 bytes .../_metadata | Bin 0 -> 1905 bytes .../ab35adb3-8649-43e6-b2c4-e00b260b5705| Bin 0 -> 1959 bytes .../b9dad9f3-dfe1-4c9c-8485-b4a7a50e2c22| Bin 0 -> 10165 bytes .../ca0fc48a-1ec3-4128-8961-b484916e7a5f| Bin 0 -> 12125 bytes .../d9c140d6-bf78-4d51-9fee-8bd0a3911a76| Bin 0 -> 457 bytes .../e9732c32-2338-4a31-8b53-77695d60df60| Bin 0 -> 684 bytes .../f0760787-e6e2-4392-a22f-2e5fead874fc| Bin 0 -> 1959 bytes .../1446d2b3-88a3-42df-8fc0-0cbf314286f9| Bin 0 -> 1959 bytes .../4d4f766e-12bf-4af2-a00e-9720e012cdb8| Bin 0 -> 1959 bytes .../5ee1b4b3-0eb6-405a-9c38-bd58dfdd00c7| Bin 0 -> 1959 bytes .../5f89eafd-abcb-4f3d-86f0-9d57df1da496| Bin 0 -> 10165 bytes .../6cc27fc4-30d3-46ed-baa3-ce603fe4fd1e| Bin 0 -> 684 bytes .../927da194-6e71-4aa2-a483-b2ba478e1e91| Bin 0 -> 684 bytes .../9a91e108-133b-4511-8f10-60063f15f37f| Bin 0 -> 8205 bytes .../_metadata | Bin 0 -> 1905 bytes .../aba9de6f-ae0d-46b7-bd9b-3463c4bd650d| Bin 0 -> 10165 bytes .../b8f765a4-9d97-40b2-a313-f2959c671cc3| Bin 0 -> 457 bytes .../bdfd9f5e-35eb-42bf-b53c-a8c26048ed58| Bin 0 -> 684 bytes .../c13e50cd-6b0c-4e9c-9a7c-49b7c1900f88| Bin 0 -> 684 bytes .../e3dd146d-784e-4faf-94f2-f730911248b2| Bin 0 -> 12125 bytes .../f6c5156e-8a2c-4770-a19a-c2b03ffb5afc| Bin 0 -> 1959 bytes .../f95821e0-3472-4d17-ad28-c8d6885cd3f9| Bin 0 -> 457 bytes .../0fad68a0-1901-4c76-a351-8d1f0e18818d| Bin 0 -> 684 bytes .../2ec2051b-ef79-4264-afb1-966daa2c7978| Bin 0 -> 457 bytes .../35b11c9d-d021-468a-9fab-e3f95309fa5c| Bin 0 -> 10207 bytes .../409fcc80-3c59-4ae2-b57b-2f21dd6ee84b| Bin 0 -> 1943 bytes .../6068c6fc-2625-425b-b0df-45eb9d99a7d1| Bin 0 -> 1943 bytes .../6c52ea22-1f78-4cd3-bd3d-d0009bb95c9d| Bin 0 -> 10207 bytes .../78d03aaa-5112-4385-8547-1e13f4b44485| Bin 0 -> 684 bytes .../7aa365eb-859f-403c-bc55-02fca134002e| Bin 0 -> 8135 bytes .../7b68e813-44c9-42a2-847b-09bbe06abbd4| Bin 0 -> 457 bytes .../7e8d60e1-bee8-4b12-acbe-f46d953927b9| Bin 0 -> 1943 bytes .../88e0e19a-4a9f-4061-9ae3-a9aad1459135| Bin 0 -> 684 bytes .../8a7978d3-38cf-4587-8d62-49582820882a| Bin 0 -> 12257 bytes .../_metadata | Bin 0 -> 1601 bytes .../adab88ff-f874-4ba6-ab7a-f646b98ef645| Bin 0 -> 1943 bytes .../b310fe20-cd1c-4f3e-96af-b3a5dc72aa11| Bin 0 -> 684 bytes .../0ef22927-6cc8-43fb-9c51-ad1b660e4f0a| Bin 0 -> 12257 bytes .../144220e2-a4cd-48b2-9d52-b04f1b4b65b2| Bin 0 -> 10207 bytes .../1cb1461e-70a4-448d-91d9-3a6eae981d71| Bin 0 -> 1943 bytes .../1ebaeb6e-7f31-4d6a-88e5-11a25182a1c8| Bin 0 -> 457 bytes .../267a46e2-3a6d-47fd-8455-fde983d35a6d| Bin 0 -> 1943 bytes .../3161a920-833b-4dd5-9c93-8e79bef3c4f8| Bin 0 -> 8135 bytes .../4f0730bc-8130-4895-b8eb-ff56fdbec35c| Bin 0 -> 684 bytes .../6395fb41-c202-4c8a-a5ca-7adefe1d9484| Bin 0 -> 684 bytes .../6558d958-50c9-40d1-80bd-42a9e63ea771| Bin 0 -> 1943 bytes .../7dc70b15-e411-4fd7-b3ba-7ad12fd825ad| Bin 0 -> 10207 bytes .../_metadata | Bin 0 -> 2221 bytes .../a0af6b4f-40b7-4ab3-8206-4f098b479341| Bin 0 -> 1943 bytes .../d9ff078e-0fb7-46ef-b101-9daecc1764c9| Bin 0 -> 457 bytes .../e490edee-f26b-457
[flink] 11/13: [release] Upgrade current version to 1.15 for AbstractOperatorRestoreTestBase and create snapshots
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch 1.15_create
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 68cc19f78cb234437cd8638f8738452dede3edc7
Author: Yun Gao
AuthorDate: Sun May 8 00:31:14 2022 +0800
[release] Upgrade current version to 1.15 for
AbstractOperatorRestoreTestBase and create snapshots
---
.../keyed/AbstractKeyedOperatorRestoreTestBase.java | 15 +--
.../AbstractNonKeyedOperatorRestoreTestBase.java| 15 +--
.../operatorstate/complexKeyed-flink1.15/_metadata | Bin 0 -> 13772 bytes
.../operatorstate/nonKeyed-flink1.15/_metadata | Bin 0 -> 3693 bytes
4 files changed, 2 insertions(+), 28 deletions(-)
diff --git
a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
index d9c8733adaf..511829c41ce 100644
---
a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
+++
b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
@@ -28,7 +28,6 @@ import
org.apache.flink.test.state.operator.restore.ExecutionMode;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
-import java.util.Arrays;
import java.util.Collection;
/** Base class for all keyed operator restore tests. */
@@ -39,19 +38,7 @@ public abstract class AbstractKeyedOperatorRestoreTestBase
extends AbstractOpera
@Parameterized.Parameters(name = "Migrate Savepoint: {0}")
public static Collection parameters() {
-return Arrays.asList(
-FlinkVersion.v1_3,
-FlinkVersion.v1_4,
-FlinkVersion.v1_5,
-FlinkVersion.v1_6,
-FlinkVersion.v1_7,
-FlinkVersion.v1_8,
-FlinkVersion.v1_9,
-FlinkVersion.v1_10,
-FlinkVersion.v1_11,
-FlinkVersion.v1_12,
-FlinkVersion.v1_13,
-FlinkVersion.v1_14);
+return FlinkVersion.rangeOf(FlinkVersion.v1_3, FlinkVersion.v1_15);
}
public AbstractKeyedOperatorRestoreTestBase(FlinkVersion flinkVersion) {
diff --git
a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
index 257b8a2a6c9..ba2da3a1ded 100644
---
a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
+++
b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
@@ -28,7 +28,6 @@ import
org.apache.flink.test.state.operator.restore.ExecutionMode;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
-import java.util.Arrays;
import java.util.Collection;
import static
org.apache.flink.test.state.operator.restore.unkeyed.NonKeyedJob.createFirstStatefulMap;
@@ -46,19 +45,7 @@ public abstract class AbstractNonKeyedOperatorRestoreTestBase
@Parameterized.Parameters(name = "Migrate Savepoint: {0}")
public static Collection parameters() {
-return Arrays.asList(
-FlinkVersion.v1_3,
-FlinkVersion.v1_4,
-FlinkVersion.v1_5,
-FlinkVersion.v1_6,
-FlinkVersion.v1_7,
-FlinkVersion.v1_8,
-FlinkVersion.v1_9,
-FlinkVersion.v1_10,
-FlinkVersion.v1_11,
-FlinkVersion.v1_12,
-FlinkVersion.v1_13,
-FlinkVersion.v1_14);
+return FlinkVersion.rangeOf(FlinkVersion.v1_3, FlinkVersion.v1_15);
}
protected AbstractNonKeyedOperatorRestoreTestBase(FlinkVersion
flinkVersion) {
diff --git
a/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.15/_metadata
b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.15/_metadata
new file mode 100644
index 000..216268e0c6d
Binary files /dev/null and
b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.15/_metadata
differ
diff --git
a/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.15/_metadata
b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.15/_metadata
new file mode 100644
index 000..17e95d39e0d
Binary files /dev/null and
b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.15/_metadata
differ
[flink] 04/13: [release] Upgrade current version to 1.15 for FlinkKinesisConsumerMigrationTest and create snapshots
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch 1.15_create
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b3388a510e0f93340b4760c64e299dfe005ce523
Author: Yun Gao
AuthorDate: Sat May 7 14:10:56 2022 +0800
[release] Upgrade current version to 1.15 for
FlinkKinesisConsumerMigrationTest and create snapshots
---
.../kinesis/FlinkKinesisConsumerMigrationTest.java | 3 ++-
...esis-consumer-migration-test-flink1.15-empty-snapshot | Bin 0 -> 2870 bytes
.../kinesis-consumer-migration-test-flink1.15-snapshot | Bin 0 -> 2938 bytes
3 files changed, 2 insertions(+), 1 deletion(-)
diff --git
a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
index 8f17da7a9db..da041effe5a 100644
---
a/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
+++
b/flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerMigrationTest.java
@@ -108,7 +108,8 @@ public class FlinkKinesisConsumerMigrationTest {
FlinkVersion.v1_11,
FlinkVersion.v1_12,
FlinkVersion.v1_13,
-FlinkVersion.v1_14);
+FlinkVersion.v1_14,
+FlinkVersion.v1_15);
}
public FlinkKinesisConsumerMigrationTest(FlinkVersion testMigrateVersion) {
diff --git
a/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.15-empty-snapshot
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.15-empty-snapshot
new file mode 100644
index 000..c96a82729ca
Binary files /dev/null and
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.15-empty-snapshot
differ
diff --git
a/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.15-snapshot
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.15-snapshot
new file mode 100644
index 000..cfae7b6e560
Binary files /dev/null and
b/flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.15-snapshot
differ
[flink] 08/13: [release] Upgrade current version to 1.15 for StatefulJobSnapshotMigrationITCase and create snapshots
This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a commit to branch 1.15_create in repository https://gitbox.apache.org/repos/asf/flink.git commit 8223a11c5bbe9ed6d007465664e2e05ac14504a6 Author: Yun Gao AuthorDate: Sat May 7 18:39:09 2022 +0800 [release] Upgrade current version to 1.15 for StatefulJobSnapshotMigrationITCase and create snapshots --- .../StatefulJobSnapshotMigrationITCase.java | 2 +- .../0f726f2d-22c0-4dda-879b-bb8624330307 | Bin 0 -> 1580 bytes .../0f97e7c0-1cbc-4f83-856b-ea1e116871e9 | Bin 0 -> 1580 bytes .../0fa1caf1-1763-478a-bc82-e7d550c089fc | Bin 0 -> 1508 bytes .../0fccc5e1-3c9e-44bb-9fa4-fa6f9d71d80d | Bin 0 -> 281 bytes .../49dd3271-64d6-4745-b17d-a6194a9b3446 | Bin 0 -> 1161 bytes .../589e9917-2e39-421f-85d3-8629505ff1aa | Bin 0 -> 1161 bytes .../7072833e-bae0-4135-9ac8-fa727fcf | Bin 0 -> 532 bytes .../75a047a9-2b39-4d79-8a78-d949fc0cf641 | Bin 0 -> 532 bytes .../776b43fe-b178-4385-9855-7bf0dc999563 | Bin 0 -> 1508 bytes .../82d091ea-780a-4d37-9ad3-b51602aabcf7 | Bin 0 -> 1508 bytes .../_metadata| Bin 0 -> 2404 bytes .../a9bb379b-5650-4a6d-8212-1b3eed5f6d7c | Bin 0 -> 1508 bytes .../bb2867a1-c55b-4c02-8ac8-f34d9c397fa2 | Bin 0 -> 532 bytes .../d9feff3f-2c9b-4079-8d2f-8247f43f4cf3 | Bin 0 -> 549 bytes .../da5ff3e2-6581-4c0f-8e08-a9ecabead99a | Bin 0 -> 292 bytes .../df42dd03-a2ac-4853-bb18-d4a8fce7a08c | Bin 0 -> 532 bytes .../e1cd5e43-6878-4514-b461-0524577a4988 | Bin 0 -> 549 bytes .../00b2d84f-e311-4a24-934f-e45595809bff | Bin 0 -> 532 bytes .../02ea1d61-d4a7-41a9-9473-5eb59d7100a1 | Bin 0 -> 1161 bytes .../081c1952-d7d4-4fb5-a004-84121ecb2836 | Bin 0 -> 292 bytes .../0d86033f-614d-4747-b21c-56920fc5113e | Bin 0 -> 1580 bytes .../1416576d-4f63-46c9-b37a-470eff1b259b | Bin 0 -> 549 bytes .../279f4a2e-5c51-4dcd-88a1-c07df44bcee5 | Bin 0 -> 532 bytes .../45a3cfc7-5dcc-4f83-a655-27afe96b88f6 | Bin 0 -> 1161 bytes .../491b3fd2-44a5-49ea-8912-03248569e9e3 | Bin 0 -> 281 bytes .../6817568e-4d0d-4a79-87d8-c7414006addc | Bin 0 -> 532 bytes .../7d3a8daa-7397-4727-a876-ab4fe80f32ac | Bin 0 -> 549 bytes .../82e2a261-9c19-4fa9-9910-ddc03c5a7cd1 | Bin 0 -> 1508 bytes .../_metadata| Bin 0 -> 2404 bytes .../b87309a9-90be-4cd0-a841-dc53139d2aed | Bin 0 -> 532 bytes .../b9b0eb64-8aa3-46e4-ad5c-5a3912a00199 | Bin 0 -> 1580 bytes .../c4f2d6db-93a9-4de1-8852-05dc0af7321f | Bin 0 -> 1508 bytes .../d4722991-5b34-4ecb-a167-3c80a0153afe | Bin 0 -> 1508 bytes .../f3a2d60c-634e-4eb4-9465-fb2779e1104b | Bin 0 -> 1508 bytes .../1f8f7136-fe0a-46b0-b160-c426a3ad0232 | Bin 0 -> 535 bytes .../24d8d7aa-fa9b-4fc5-b7be-cf5b79a0062a | Bin 0 -> 1145 bytes .../2ff8cbe1-e401-4cea-9b33-fe2a2104eaa9 | Bin 0 -> 1620 bytes .../36b8f4be-e1b3-4d87-9d88-80bf9ba4f446 | Bin 0 -> 1145 bytes .../50b62350-80d5-40f6-ad0d-70937ba81840 | Bin 0 -> 535 bytes .../5c5ab7b4-f0b5-4121-85e5-63161d313f72 | Bin 0 -> 561 bytes .../62ac366a-f346-44a5-aeba-6712926f1046 | Bin 0 -> 561 bytes .../6ebee5ce-86b8-420c-bc18-d554603230bf | Bin 0 -> 1521 bytes .../94b7bbf5-8f1d-48e4-aa16-5b0b8aaed183 | Bin 0 -> 1521 bytes .../98596625-5eb0-4d29-b884-d398ba982811 | Bin 0 -> 535 bytes .../_metadata| Bin 0 -> 1872 bytes .../b8fdc030-5aa2-488d-8780-6025cc1bacdf | Bin 0 -> 535 bytes .../b94d1838-1ba5-4f6f-bd1a-d8e7471998d2 | Bin 0 -> 1521 bytes .../c7ffda36-7a31-4d9e-8dc7-e61939575d17 | Bin 0 -> 1521 bytes .../c95c6554-acbf-4b64-858e-35d147549d7a | Bin 0 -> 1620 bytes .../d719e1ae-34be-4ca3-97bd-9d16c7f0ca0b | Bin 0 -> 281 bytes .../fbdf5b8e-8c2e-4089-b22b-1748b426ad19 | Bin 0 -> 292 bytes .../2077517d-f5aa-426d-a66a-2b80fd60919d | Bin 0 -> 561 bytes .../29153b77-923e-4b66-94b9-147373fbba0b | Bin 0 -> 1521 bytes .../2a6c5fb1-9332-4fce-8b5f-0b710f26dbe3 | Bin 0 -> 1145 bytes .../4a4a9416-73ec-4ad0-ad3b-b421dc419c1d | Bin 0 -> 1620 bytes .../4ec579e4-6937-4068-bab2-01d6df049bf7 | Bin 0 -> 535 bytes .../6d76840f-510b-4479-badf-85918301ba40 | Bin 0 -> 535 bytes
[flink] 10/13: [release] Upgrade current version to 1.15 for TypeSerializerSnapshotMigrationITCase and create snapshots
This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a commit to branch 1.15_create in repository https://gitbox.apache.org/repos/asf/flink.git commit d1b47bbdc79dd0e641c54e04f32acb5684dff546 Author: Yun Gao AuthorDate: Sat May 7 18:59:55 2022 +0800 [release] Upgrade current version to 1.15 for TypeSerializerSnapshotMigrationITCase and create snapshots --- .../migration/TypeSerializerSnapshotMigrationITCase.java | 2 +- .../95ac2fd3-cd2e-458d-b7a3-eeebb77c0ea7 | Bin 0 -> 609 bytes .../_metadata | Bin 0 -> 381 bytes .../ea58951f-6090-4285-802f-8eacefd354cf | Bin 0 -> 292 bytes .../213443f4-6e70-4333-a4cd-64cc6e210de1 | Bin 0 -> 292 bytes .../213c4746-830c-4da3-80ec-01a41ab78aa3 | Bin 0 -> 609 bytes .../_metadata | Bin 0 -> 381 bytes .../7a28d2df-54c8-4415-b055-1e48e83427ed | Bin 0 -> 639 bytes .../_metadata | Bin 0 -> 343 bytes .../e00ed3e4-e8af-4ead-8e2e-5477fcb74780 | Bin 0 -> 292 bytes .../0fb32bfd-093a-43d6-b1cc-e3ae9f277e4b | Bin 0 -> 639 bytes .../1b2988c1-ec2f-4fa2-af44-51ae2f21443d | Bin 0 -> 292 bytes .../_metadata | Bin 0 -> 381 bytes .../6e1f6918-2e88-4357-82c7-1bdf533ef301 | Bin 0 -> 292 bytes .../8936e936-8b0f-40ae-85c9-82907b0ee605 | Bin 0 -> 639 bytes .../_metadata | Bin 0 -> 343 bytes .../10e5c37a-3ca9-48f9-b06c-95fd44f0b996 | Bin 0 -> 292 bytes .../58b28015-e14e-4514-91f1-3cc4900708ab | Bin 0 -> 639 bytes .../_metadata | Bin 0 -> 343 bytes 19 files changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java index 96d607bcc93..b56e2359631 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java @@ -63,7 +63,7 @@ public class TypeSerializerSnapshotMigrationITCase extends SnapshotMigrationTest private static final int NUM_SOURCE_ELEMENTS = 4; // TODO increase this to newer version to create and test snapshot migration for newer versions -private static final FlinkVersion currentVersion = FlinkVersion.v1_14; +private static final FlinkVersion currentVersion = FlinkVersion.v1_15; // TODO change this to CREATE_SNAPSHOT to (re)create binary snapshots // TODO Note: You should generate the snapshot based on the release branch instead of the diff --git a/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/95ac2fd3-cd2e-458d-b7a3-eeebb77c0ea7 b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/95ac2fd3-cd2e-458d-b7a3-eeebb77c0ea7 new file mode 100644 index 000..2ec60abdc1b Binary files /dev/null and b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/95ac2fd3-cd2e-458d-b7a3-eeebb77c0ea7 differ diff --git a/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/_metadata b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/_metadata new file mode 100644 index 000..2cf98021776 Binary files /dev/null and b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/_metadata differ diff --git a/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/ea58951f-6090-4285-802f-8eacefd354cf b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/ea58951f-6090-4285-802f-8eacefd354cf new file mode 100644 index 000..2f020711c6f Binary files /dev/null and b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-checkpoint/ea58951f-6090-4285-802f-8eacefd354cf differ diff --git a/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-savepoint-native/213443f4-6e70-4333-a4cd-64cc6e210de1 b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-savepoint-native/213443f4-6e70-4333-a4cd-64cc6e210de1 new file mode 100644 index 000..2f020711c6f Binary files /dev/null and b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.15-hashmap-savepoi
[flink] 09/13: [release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots
This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a commit to branch 1.15_create in repository https://gitbox.apache.org/repos/asf/flink.git commit b8618c21c33ea3257b90e373708a06be9d720309 Author: Yun Gao AuthorDate: Sat May 7 18:58:34 2022 +0800 [release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots --- .../StatefulJobWBroadcastStateMigrationITCase.java | 2 +- .../4b5079fa-e717-4e10-b2c4-8a802e89bcea | Bin 0 -> 704 bytes .../4c7c9c93-35c9-4dca-b8ce-78e05e7deecb | Bin 0 -> 786 bytes .../4d985f85-8f12-403b-b20c-c9757803676e | Bin 0 -> 786 bytes .../569f64fc-5b0a-4155-b583-85bcefddf6c3 | Bin 0 -> 704 bytes .../69cf5401-62e2-49c8-bdf1-ddca7e715e9c | Bin 0 -> 346 bytes .../6a80ecb7-08f5-438f-b48d-47f952fe6815 | Bin 0 -> 281 bytes .../75b2bf59-13f5-4005-a790-87c578d830b6 | Bin 0 -> 346 bytes .../7e8ed8a9-9f30-4260-9a41-bc1b753cc241 | Bin 0 -> 292 bytes .../87a4742c-8b19-49fa-9d44-fb436d2c3d55 | Bin 0 -> 786 bytes .../8e8e15d8-a729-49c8-824e-f35d69a7eb27 | Bin 0 -> 786 bytes .../8ec2e3f6-d6e7-494a-999c-320d8430e840 | Bin 0 -> 346 bytes .../9dd0ece3-2846-4ad7-96c3-e6ed1f240b00 | Bin 0 -> 281 bytes .../_metadata| Bin 0 -> 2716 bytes .../a7a92281-af21-4bff-92b9-796dac4a5d8b | Bin 0 -> 346 bytes .../a8f40852-fef2-4692-aab5-0c5b7b4795b7 | Bin 0 -> 704 bytes .../acf08fa6-8f88-4eda-bb33-5a59b57c15a2 | Bin 0 -> 786 bytes .../df37ac32-6ee6-4515-8949-d22d834bb602 | Bin 0 -> 786 bytes .../e00940d2-26c9-4df1-baa7-91fe14fb22ff | Bin 0 -> 786 bytes .../ecd5797c-e28e-483c-bf9e-9fb65bb65d0c | Bin 0 -> 786 bytes .../ee8efabe-9d32-4938-a929-49111eaa604b | Bin 0 -> 292 bytes .../fd302dc6-6626-4667-be02-7977abd22951 | Bin 0 -> 704 bytes .../03a3a2fc-4a96-40be-9335-385a0c197af1 | Bin 0 -> 704 bytes .../23ab27ad-ad73-4301-9c66-8489ce73f15b | Bin 0 -> 786 bytes .../35ccf95e-2d8f-472c-930e-505fc6192f55 | Bin 0 -> 786 bytes .../37e7749e-caca-4c6f-a37c-a108500b064a | Bin 0 -> 704 bytes .../477bd007-8515-4899-8f59-db439bddfcd1 | Bin 0 -> 292 bytes .../5006528f-67f3-45ee-8ba6-3f0723c6e7f6 | Bin 0 -> 786 bytes .../6989aa3d-0bac-4c4f-beb5-0b37ce22fedc | Bin 0 -> 346 bytes .../75e9f691-54e2-4d6f-b452-3f7f3315c4b8 | Bin 0 -> 704 bytes .../946ea2be-f497-4f5a-b146-aadd37987bed | Bin 0 -> 786 bytes .../9980a6de-8584-4ffc-9212-ab8b7b1fbd6d | Bin 0 -> 292 bytes .../9c688e98-92ad-4cbe-b9eb-2ec0eb721f92 | Bin 0 -> 704 bytes .../9eee63c8-4ef4-4a24-9746-2369bf368128 | Bin 0 -> 786 bytes .../_metadata| Bin 0 -> 2716 bytes .../b09d095c-824c-4031-b70d-9418db96def2 | Bin 0 -> 346 bytes .../bed0e914-2759-45d2-88f3-cc738d3636db | Bin 0 -> 281 bytes .../c53bc18f-fe96-4c76-9a8e-44e831b2ea0b | Bin 0 -> 786 bytes .../cd253f16-8f00-4cca-ab4e-e301eeeb7f4f | Bin 0 -> 786 bytes .../d1dc0055-4a6a-412a-9c41-04992cd57ec4 | Bin 0 -> 281 bytes .../e3d661ce-138e-4e12-9a8f-a0f21dd80819 | Bin 0 -> 786 bytes .../f1473696-0449-4694-94fd-4e25508028bf | Bin 0 -> 346 bytes .../fb3ae0a2-38c5-4f9d-897d-8af8ca73aa6b | Bin 0 -> 346 bytes .../1ae28f9a-3a1b-45c7-87d8-a06a5f62745f | Bin 0 -> 770 bytes .../2053a329-7a99-400c-8c01-da3e7d051472 | Bin 0 -> 770 bytes .../3278afbd-d04c-4b9c-9c3c-fdb67910f7c1 | Bin 0 -> 704 bytes .../4212bda0-8bdb-49af-b74e-136a7f9b1d8c | Bin 0 -> 346 bytes .../475271f3-4869-4e43-9c7f-9bbdf4985ce1 | Bin 0 -> 281 bytes .../4c472f03-e617-4ec6-b228-d3aa86a96118 | Bin 0 -> 770 bytes .../4cf87420-7df2-4ceb-b281-f6282000755c | Bin 0 -> 292 bytes .../4d8967a4-ee89-4de7-a666-b0739061f651 | Bin 0 -> 770 bytes .../516059bc-19a1-41b4-b3d6-09f42e1a860c | Bin 0 -> 770 bytes .../58c51c75-a5c3-48c8-adf1-dc09d0dc8005 | Bin 0 -> 346 bytes .../814813d2-a7e6-4178-8159-8c6697a501a3 | Bin 0 -> 292 bytes .../84789399-ea8e-4927-8eda-5b445c98ab82 | Bin 0 -> 770 bytes .../_metadata| Bin 0 -> 2412 bytes .../c8370c7a-5d33-440a-a1f7-7801495a211c | Bin 0 -> 704 bytes .../d9b3dd9b-9b61-4a1d-943f-5468f502ca16 | Bin 0 -> 281 bytes .../db03b1c8-dfd9-4f
[flink] 07/13: [release] Upgrade current version to 1.15 for WindowOperatorMigrationTest and create snapshots
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch 1.15_create
in repository https://gitbox.apache.org/repos/asf/flink.git
commit ab28f7430f4747ce43be79b653de99e43a3e6efe
Author: Yun Gao
AuthorDate: Sat May 7 18:23:16 2022 +0800
[release] Upgrade current version to 1.15 for WindowOperatorMigrationTest
and create snapshots
---
.../operators/windowing/WindowOperatorMigrationTest.java | 15 +--
...op-migration-test-apply-event-time-flink1.15-snapshot | Bin 0 -> 1799 bytes
...gration-test-apply-processing-time-flink1.15-snapshot | Bin 0 -> 1691 bytes
...migration-test-kryo-serialized-key-flink1.15-snapshot | Bin 0 -> 4021 bytes
...p-migration-test-reduce-event-time-flink1.15-snapshot | Bin 0 -> 1655 bytes
...ration-test-reduce-processing-time-flink1.15-snapshot | Bin 0 -> 1596 bytes
...test-session-with-stateful-trigger-flink1.15-snapshot | Bin 0 -> 2707 bytes
...session-with-stateful-trigger-mint-flink1.15-snapshot | Bin 0 -> 2201 bytes
8 files changed, 1 insertion(+), 14 deletions(-)
diff --git
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java
index 5d34b7eb5f4..33da08f1fc0 100644
---
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java
+++
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorMigrationTest.java
@@ -61,7 +61,6 @@ import org.junit.Test;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
-import java.util.Arrays;
import java.util.Collection;
import java.util.Comparator;
import java.util.concurrent.ConcurrentLinkedQueue;
@@ -85,19 +84,7 @@ public class WindowOperatorMigrationTest {
@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection parameters() {
-return Arrays.asList(
-FlinkVersion.v1_3,
-FlinkVersion.v1_4,
-FlinkVersion.v1_5,
-FlinkVersion.v1_6,
-FlinkVersion.v1_7,
-FlinkVersion.v1_8,
-FlinkVersion.v1_9,
-FlinkVersion.v1_10,
-FlinkVersion.v1_11,
-FlinkVersion.v1_12,
-FlinkVersion.v1_13,
-FlinkVersion.v1_14);
+return FlinkVersion.rangeOf(FlinkVersion.v1_3, FlinkVersion.v1_15);
}
private static final TypeInformation>
STRING_INT_TUPLE =
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.15-snapshot
new file mode 100644
index 000..0aa53ce4408
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.15-snapshot
new file mode 100644
index 000..a8f3ab38bfb
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.15-snapshot
new file mode 100644
index 000..2afb02375bb
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.15-snapshot
new file mode 100644
index 000..eca89981174
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.15-snapshot
new file mode 100644
index 000..ade4333cb36
Binary files /dev/null and
b/flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.15-snapshot
differ
diff --git
a/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.15-snapshot
b/flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.15-snapshot
new file mo
[flink] 05/13: [release] Upgrade current version to 1.15 for ContinuousFileProcessingMigrationTest and create snapshots
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch 1.15_create
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5cae5c5a17a54c1f07d4a0087336a870202180bc
Author: Yun Gao
AuthorDate: Sat May 7 18:15:35 2022 +0800
[release] Upgrade current version to 1.15 for
ContinuousFileProcessingMigrationTest and create snapshots
---
.../hdfstests/ContinuousFileProcessingMigrationTest.java | 3 ++-
...ction-migration-test-165191845-flink1.15-snapshot | Bin 0 -> 324 bytes
...ction-migration-test-1651918451000-flink1.15-snapshot | Bin 0 -> 324 bytes
...ction-migration-test-1651918452000-flink1.15-snapshot | Bin 0 -> 324 bytes
.../resources/reader-migration-test-flink1.15-snapshot | Bin 0 -> 2622 bytes
5 files changed, 2 insertions(+), 1 deletion(-)
diff --git
a/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java
b/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java
index 08895c621f8..49254c0ce91 100644
---
a/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java
+++
b/flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java
@@ -84,7 +84,8 @@ public class ContinuousFileProcessingMigrationTest {
Tuple2.of(FlinkVersion.v1_11, 1594561663000L),
Tuple2.of(FlinkVersion.v1_12, 1613720148000L),
Tuple2.of(FlinkVersion.v1_13, 1627550216000L),
-Tuple2.of(FlinkVersion.v1_14, 1633938795000L));
+Tuple2.of(FlinkVersion.v1_14, 1633938795000L),
+Tuple2.of(FlinkVersion.v1_15, 165191845L));
}
/**
diff --git
a/flink-fs-tests/src/test/resources/monitoring-function-migration-test-165191845-flink1.15-snapshot
b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-165191845-flink1.15-snapshot
new file mode 100644
index 000..008d20a2aae
Binary files /dev/null and
b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-165191845-flink1.15-snapshot
differ
diff --git
a/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1651918451000-flink1.15-snapshot
b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1651918451000-flink1.15-snapshot
new file mode 100644
index 000..619f020e01c
Binary files /dev/null and
b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1651918451000-flink1.15-snapshot
differ
diff --git
a/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1651918452000-flink1.15-snapshot
b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1651918452000-flink1.15-snapshot
new file mode 100644
index 000..fa8e3e38fba
Binary files /dev/null and
b/flink-fs-tests/src/test/resources/monitoring-function-migration-test-1651918452000-flink1.15-snapshot
differ
diff --git
a/flink-fs-tests/src/test/resources/reader-migration-test-flink1.15-snapshot
b/flink-fs-tests/src/test/resources/reader-migration-test-flink1.15-snapshot
new file mode 100644
index 000..ba9d842c199
Binary files /dev/null and
b/flink-fs-tests/src/test/resources/reader-migration-test-flink1.15-snapshot
differ
[flink] 12/13: [release] Upgrade current version to 1.15 for StatefulJobSavepointMigrationITCase and create snapshots
This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a commit to branch 1.15_create in repository https://gitbox.apache.org/repos/asf/flink.git commit f2e75c591b4ae169e257c33fa47f4bcf390e398d Author: Yun Gao AuthorDate: Sun May 8 00:33:49 2022 +0800 [release] Upgrade current version to 1.15 for StatefulJobSavepointMigrationITCase and create snapshots --- .../3274cbaf-eb41-4cd4-b4e1-0498a8b561f6| Bin 0 -> 12185 bytes .../3ed5904f-af16-443b-a49b-b123aa1aeace| Bin 0 -> 457 bytes .../_metadata | Bin 0 -> 791 bytes .../af59b4b8-c925-4b32-b080-366794e3c3c1| Bin 0 -> 8205 bytes .../b91f3d7c-89e9-4bf7-8354-89bee7b43abd| Bin 0 -> 10195 bytes .../d79a7c86-3b0b-4ac5-ac52-99fe66b69475| Bin 0 -> 10195 bytes .../6cf48fc1-413c-4619-8224-d845f0304dd7| Bin 0 -> 8205 bytes .../728e5173-51c6-4dac-a2ff-f90daf1cef80| Bin 0 -> 10195 bytes .../_metadata | Bin 0 -> 791 bytes .../ae434126-b093-4a13-9f74-654df745a8bb| Bin 0 -> 457 bytes .../bd5f46c6-8e16-4366-a90d-d1a45eb5e20e| Bin 0 -> 12185 bytes .../c5799547-ffab-4984-a4c5-ee121f66a0bf| Bin 0 -> 10195 bytes .../566e1ea6-5366-412a-9fff-23428811805c| Bin 0 -> 457 bytes .../79915441-05d2-478c-83f8-5c8a5f335903| Bin 0 -> 10237 bytes .../_metadata | Bin 0 -> 639 bytes .../cc6b4832-f701-4572-9ecf-402f02adff4d| Bin 0 -> 10237 bytes .../d6e3633f-528b-4730-8bfc-b2262bedfaff| Bin 0 -> 8135 bytes .../e7383688-9835-4a92-b74d-8eabe476fe2f| Bin 0 -> 12317 bytes .../15991b8c-1b22-4e1b-b8c0-2f4de76d7a38| Bin 0 -> 12317 bytes .../228ae815-95e1-4a2a-b301-22d7b493a54e| Bin 0 -> 20 bytes .../85605c1b-c7c5-45c7-aa4e-6f059b46e9ee| Bin 0 -> 10237 bytes .../_metadata | Bin 0 -> 1107 bytes .../b1debad4-c40d-428c-9d5d-c6e50ebb7283| Bin 0 -> 457 bytes .../b3b80a5d-816d-4a21-8f54-053967df42e4| Bin 0 -> 10237 bytes .../f934f45f-538b-41f3-a3f4-d33d2030485b| Bin 0 -> 8135 bytes .../515f85e7-9bb7-4007-93b4-945e12d80c17| Bin 0 -> 10237 bytes .../52334b32-c0b0-413f-b96e-2cb94d2f464b| Bin 0 -> 457 bytes .../61bdd839-4f9e-4c8f-887a-e7b608abc339| Bin 0 -> 12317 bytes .../_metadata | Bin 0 -> 639 bytes .../dda27a2a-0826-43f3-83b4-148d750bc857| Bin 0 -> 8135 bytes .../e41f4b1b-0cf3-4f1f-9880-387d53d51fd0| Bin 0 -> 10237 bytes .../09152b6f-ec40-45bb-b7ac-cd9809eb9571| Bin 0 -> 12317 bytes .../491281eb-28f1-4fa5-84f3-ae5a743968eb| Bin 0 -> 10237 bytes .../72c1150d-8d58-4b03-9d42-7679c91b026f| Bin 0 -> 8135 bytes .../9fa49837-6352-4fd7-98cf-894e32460d4c| Bin 0 -> 457 bytes .../_metadata | Bin 0 -> 639 bytes .../d5e1395a-c0d0-44bf-a3a9-f8b0921a3232| Bin 0 -> 10237 bytes .../migration/StatefulJobSavepointMigrationITCase.scala | 2 +- 38 files changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.15-hashmap-checkpoint/3274cbaf-eb41-4cd4-b4e1-0498a8b561f6 b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.15-hashmap-checkpoint/3274cbaf-eb41-4cd4-b4e1-0498a8b561f6 new file mode 100644 index 000..e5eff0f0d3b Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.15-hashmap-checkpoint/3274cbaf-eb41-4cd4-b4e1-0498a8b561f6 differ diff --git a/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.15-hashmap-checkpoint/3ed5904f-af16-443b-a49b-b123aa1aeace b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.15-hashmap-checkpoint/3ed5904f-af16-443b-a49b-b123aa1aeace new file mode 100644 index 000..bd10233b3ef Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.15-hashmap-checkpoint/3ed5904f-af16-443b-a49b-b123aa1aeace differ diff --git a/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.15-hashmap-checkpoint/_metadata b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.15-hashmap-checkpoint/_metadata new file mode 100644 index 000..0178baab8dd Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.15-hashmap-checkpoint/_metadata differ diff --git a/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.15-hashmap-checkpoint/af59b4
[flink] 02/13: [release] Upgrade current version to 1.15 for FlinkKafkaConsumerBaseMigrationTest and create snapshots
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch 1.15_create
in repository https://gitbox.apache.org/repos/asf/flink.git
commit c6a0d15891f533787a6423ceab73862a4acfbab5
Author: Yun Gao
AuthorDate: Sat May 7 12:11:13 2022 +0800
[release] Upgrade current version to 1.15 for
FlinkKafkaConsumerBaseMigrationTest and create snapshots
---
.../kafka/FlinkKafkaConsumerBaseMigrationTest.java | 14 +-
...onsumer-migration-test-flink1.15-empty-state-snapshot | Bin 0 -> 1465 bytes
.../kafka-consumer-migration-test-flink1.15-snapshot | Bin 0 -> 1519 bytes
3 files changed, 1 insertion(+), 13 deletions(-)
diff --git
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
index 0ba99452922..645278c9597 100644
---
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
+++
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
@@ -46,7 +46,6 @@ import org.mockito.invocation.InvocationOnMock;
import org.mockito.stubbing.Answer;
import java.util.ArrayList;
-import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
@@ -94,18 +93,7 @@ public class FlinkKafkaConsumerBaseMigrationTest {
@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection parameters() {
-return Arrays.asList(
-FlinkVersion.v1_4,
-FlinkVersion.v1_5,
-FlinkVersion.v1_6,
-FlinkVersion.v1_7,
-FlinkVersion.v1_8,
-FlinkVersion.v1_9,
-FlinkVersion.v1_10,
-FlinkVersion.v1_11,
-FlinkVersion.v1_12,
-FlinkVersion.v1_13,
-FlinkVersion.v1_14);
+return FlinkVersion.rangeOf(FlinkVersion.v1_4, FlinkVersion.v1_15);
}
public FlinkKafkaConsumerBaseMigrationTest(FlinkVersion
testMigrateVersion) {
diff --git
a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-empty-state-snapshot
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-empty-state-snapshot
new file mode 100644
index 000..f6d3a17968c
Binary files /dev/null and
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-empty-state-snapshot
differ
diff --git
a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-snapshot
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-snapshot
new file mode 100644
index 000..7039d10413c
Binary files /dev/null and
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-snapshot
differ
[flink] 06/13: [release] Upgrade current version to 1.15 for CEPMigrationTest and create snapshots
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch 1.15_create
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3b83229944adc769b1d7a3ba9fe267f4581feda1
Author: Yun Gao
AuthorDate: Sat May 7 18:20:29 2022 +0800
[release] Upgrade current version to 1.15 for CEPMigrationTest and create
snapshots
---
.../org/apache/flink/cep/operator/CEPMigrationTest.java | 12 +---
.../cep-migration-after-branching-flink1.15-snapshot | Bin 0 -> 5806 bytes
.../cep-migration-conditions-flink1.15-snapshot | Bin 0 -> 5453 bytes
...igration-single-pattern-afterwards-flink1.15-snapshot | Bin 0 -> 5203 bytes
...cep-migration-starting-new-pattern-flink1.15-snapshot | Bin 0 -> 5610 bytes
5 files changed, 1 insertion(+), 11 deletions(-)
diff --git
a/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java
b/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java
index 7764810f510..05e8ba5212a 100644
---
a/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java
+++
b/flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java
@@ -41,7 +41,6 @@ import org.junit.Test;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
-import java.util.Arrays;
import java.util.Collection;
import java.util.List;
import java.util.Map;
@@ -72,16 +71,7 @@ public class CEPMigrationTest {
@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection parameters() {
-return Arrays.asList(
-FlinkVersion.v1_6,
-FlinkVersion.v1_7,
-FlinkVersion.v1_8,
-FlinkVersion.v1_9,
-FlinkVersion.v1_10,
-FlinkVersion.v1_11,
-FlinkVersion.v1_12,
-FlinkVersion.v1_13,
-FlinkVersion.v1_14);
+return FlinkVersion.rangeOf(FlinkVersion.v1_6, FlinkVersion.v1_15);
}
public CEPMigrationTest(FlinkVersion migrateVersion) {
diff --git
a/flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.15-snapshot
b/flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.15-snapshot
new file mode 100644
index 000..a05be3af1a4
Binary files /dev/null and
b/flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.15-snapshot
differ
diff --git
a/flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.15-snapshot
b/flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.15-snapshot
new file mode 100644
index 000..7d308fb91c2
Binary files /dev/null and
b/flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.15-snapshot
differ
diff --git
a/flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.15-snapshot
b/flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.15-snapshot
new file mode 100644
index 000..89133ae521e
Binary files /dev/null and
b/flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.15-snapshot
differ
diff --git
a/flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.15-snapshot
b/flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.15-snapshot
new file mode 100644
index 000..4b956523c56
Binary files /dev/null and
b/flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.15-snapshot
differ
[flink] 01/13: [release] Upgrade current version to 1.15 for TypeSerializerUpgradeTestBase and create snapshots
This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a commit to branch 1.15_create in repository https://gitbox.apache.org/repos/asf/flink.git commit 18b57b3689c6ef4084dd3e922af1e022e50db995 Author: Yun Gao AuthorDate: Sat May 7 12:06:39 2022 +0800 [release] Upgrade current version to 1.15 for TypeSerializerUpgradeTestBase and create snapshots --- .../context-state-serializer-1.15/serializer-snapshot| Bin 0 -> 126 bytes .../resources/context-state-serializer-1.15/test-data| Bin 0 -> 19 bytes .../serializer-snapshot | Bin 0 -> 134 bytes .../transaction-state-serializer-1.15/test-data | Bin 0 -> 17 bytes .../writeable-serializer-1.15/serializer-snapshot| Bin 0 -> 187 bytes .../test/resources/writeable-serializer-1.15/test-data | Bin 0 -> 7 bytes .../common/typeutils/TypeSerializerUpgradeTestBase.java | 2 +- .../big-dec-serializer-1.15/serializer-snapshot | Bin 0 -> 94 bytes .../src/test/resources/big-dec-serializer-1.15/test-data | Bin 0 -> 24 bytes .../big-int-serializer-1.15/serializer-snapshot | Bin 0 -> 94 bytes .../src/test/resources/big-int-serializer-1.15/test-data | Bin 0 -> 19 bytes .../serializer-snapshot | Bin 0 -> 130 bytes .../boolean-primitive-array-serializer-1.15/test-data| Bin 0 -> 6 bytes .../boolean-serializer-1.15/serializer-snapshot | Bin 0 -> 96 bytes .../src/test/resources/boolean-serializer-1.15/test-data | 1 + .../boolean-value-serializer-1.15/serializer-snapshot| Bin 0 -> 106 bytes .../resources/boolean-value-serializer-1.15/test-data| 1 + .../serializer-snapshot | Bin 0 -> 124 bytes .../byte-primitive-array-serializer-1.15/test-data | Bin 0 -> 14 bytes .../resources/byte-serializer-1.15/serializer-snapshot | Bin 0 -> 90 bytes .../src/test/resources/byte-serializer-1.15/test-data| 1 + .../byte-value-serializer-1.15/serializer-snapshot | Bin 0 -> 100 bytes .../test/resources/byte-value-serializer-1.15/test-data | 1 + .../serializer-snapshot | Bin 0 -> 124 bytes .../char-primitive-array-serializer-1.15/test-data | Bin 0 -> 24 bytes .../resources/char-serializer-1.15/serializer-snapshot | Bin 0 -> 90 bytes .../src/test/resources/char-serializer-1.15/test-data| 1 + .../char-value-serializer-1.15/serializer-snapshot | Bin 0 -> 100 bytes .../test/resources/char-value-serializer-1.15/test-data | Bin 0 -> 2 bytes .../copyable-value-serializer-1.15/serializer-snapshot | Bin 0 -> 199 bytes .../resources/copyable-value-serializer-1.15/test-data | Bin 0 -> 8 bytes .../resources/date-serializer-1.15/serializer-snapshot | Bin 0 -> 90 bytes .../src/test/resources/date-serializer-1.15/test-data| Bin 0 -> 8 bytes .../serializer-snapshot | Bin 0 -> 128 bytes .../double-primitive-array-serializer-1.15/test-data | Bin 0 -> 84 bytes .../resources/double-serializer-1.15/serializer-snapshot | Bin 0 -> 94 bytes .../src/test/resources/double-serializer-1.15/test-data | 1 + .../double-value-serializer-1.15/serializer-snapshot | Bin 0 -> 104 bytes .../resources/double-value-serializer-1.15/test-data | 1 + .../resources/either-serializer-1.15/serializer-snapshot | Bin 0 -> 276 bytes .../src/test/resources/either-serializer-1.15/test-data | 1 + .../resources/enum-serializer-1.15/serializer-snapshot | Bin 0 -> 188 bytes .../src/test/resources/enum-serializer-1.15/test-data| Bin 0 -> 4 bytes .../enum-serializerreconfig-1.15/serializer-snapshot | Bin 0 -> 163 bytes .../resources/enum-serializerreconfig-1.15/test-data | Bin 0 -> 4 bytes .../serializer-snapshot | Bin 0 -> 126 bytes .../float-primitive-array-serializer-1.15/test-data | Bin 0 -> 44 bytes .../resources/float-serializer-1.15/serializer-snapshot | Bin 0 -> 92 bytes .../src/test/resources/float-serializer-1.15/test-data | 1 + .../float-value-serializer-1.15/serializer-snapshot | Bin 0 -> 102 bytes .../test/resources/float-value-serializer-1.15/test-data | 1 + .../generic-array-serializer-1.15/serializer-snapshot| Bin 0 -> 211 bytes .../resources/generic-array-serializer-1.15/test-data| Bin 0 -> 19 bytes .../serializer-snapshot | Bin 0 -> 122 bytes .../int-primitive-array-serializer-1.15/test-data| Bin 0 -> 44 bytes .../resources/int-serializer-1.15/serializer-snapshot| Bin 0 -> 88 bytes .../src/test/resources/int-serializer-1.15/test-data | Bin 0 -> 4 bytes .../int-value-serializer-1.15/serializer-snapshot| Bin 0 -> 98 bytes .../test/resources/int-value-serializer-1.15/test-data | Bin 0 -> 4 bytes .../serializer-snapshot | Bin 0 -> 1718 bytes .../test-data
[flink] branch 1.15_create created (now 3a30f2714b3)
This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a change to branch 1.15_create in repository https://gitbox.apache.org/repos/asf/flink.git at 3a30f2714b3 [release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots This branch includes the following new commits: new 18b57b3689c [release] Upgrade current version to 1.15 for TypeSerializerUpgradeTestBase and create snapshots new c6a0d15891f [release] Upgrade current version to 1.15 for FlinkKafkaConsumerBaseMigrationTest and create snapshots new 78677f4f465 [release] Upgrade current version to 1.15 for FlinkKafkaProducerMigrationTest and create snapshots new b3388a510e0 [release] Upgrade current version to 1.15 for FlinkKinesisConsumerMigrationTest and create snapshots new 5cae5c5a17a [release] Upgrade current version to 1.15 for ContinuousFileProcessingMigrationTest and create snapshots new 3b83229944a [release] Upgrade current version to 1.15 for CEPMigrationTest and create snapshots new ab28f7430f4 [release] Upgrade current version to 1.15 for WindowOperatorMigrationTest and create snapshots new 8223a11c5bb [release] Upgrade current version to 1.15 for StatefulJobSnapshotMigrationITCase and create snapshots new b8618c21c33 [release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots new d1b47bbdc79 [release] Upgrade current version to 1.15 for TypeSerializerSnapshotMigrationITCase and create snapshots new 68cc19f78cb [release] Upgrade current version to 1.15 for AbstractOperatorRestoreTestBase and create snapshots new f2e75c591b4 [release] Upgrade current version to 1.15 for StatefulJobSavepointMigrationITCase and create snapshots new 3a30f2714b3 [release] Upgrade current version to 1.15 for StatefulJobWBroadcastStateMigrationITCase and create snapshots The 13 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] 03/13: [release] Upgrade current version to 1.15 for FlinkKafkaProducerMigrationTest and create snapshots
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a commit to branch 1.15_create
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 78677f4f4653923c1f3b8d65e8e5283ce37e92e8
Author: Yun Gao
AuthorDate: Sat May 7 14:07:27 2022 +0800
[release] Upgrade current version to 1.15 for
FlinkKafkaProducerMigrationTest and create snapshots
---
.../kafka/FlinkKafkaProducerMigrationTest.java | 10 +-
.../kafka-migration-kafka-producer-flink-1.15-snapshot | Bin 0 -> 1242 bytes
2 files changed, 1 insertion(+), 9 deletions(-)
diff --git
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
index 67a74879c64..754d28dff48 100644
---
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
+++
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
@@ -28,7 +28,6 @@ import org.apache.kafka.clients.producer.ProducerConfig;
import org.junit.runner.RunWith;
import org.junit.runners.Parameterized;
-import java.util.Arrays;
import java.util.Collection;
import java.util.Properties;
@@ -43,14 +42,7 @@ import java.util.Properties;
public class FlinkKafkaProducerMigrationTest extends KafkaMigrationTestBase {
@Parameterized.Parameters(name = "Migration Savepoint: {0}")
public static Collection parameters() {
-return Arrays.asList(
-FlinkVersion.v1_8,
-FlinkVersion.v1_9,
-FlinkVersion.v1_10,
-FlinkVersion.v1_11,
-FlinkVersion.v1_12,
-FlinkVersion.v1_13,
-FlinkVersion.v1_14);
+return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_15);
}
public FlinkKafkaProducerMigrationTest(FlinkVersion testMigrateVersion) {
diff --git
a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.15-snapshot
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.15-snapshot
new file mode 100644
index 000..35af28dd7b1
Binary files /dev/null and
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.15-snapshot
differ
[flink] branch master updated (b904c948fb1 -> 2727d0234cf)
This is an automated email from the ASF dual-hosted git repository. wangyang0918 pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from b904c948fb1 [FLINK-27476][tests] Add dedicated import option for selecting production code add 2727d0234cf [FLINK-27461][Kubernetes] Add option to set userAgent for kubeclient No new revisions were added by this update. Summary of changes: .../shortcodes/generated/kubernetes_config_configuration.html | 6 ++ .../flink/kubernetes/configuration/KubernetesConfigOptions.java| 7 +++ .../apache/flink/kubernetes/kubeclient/FlinkKubeClientFactory.java | 5 - 3 files changed, 17 insertions(+), 1 deletion(-)
[flink-table-store] branch master updated: [hotfix][docs] Correct the description of how to build this project
This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-table-store.git The following commit(s) were added to refs/heads/master by this push: new 8f9c5c5 [hotfix][docs] Correct the description of how to build this project 8f9c5c5 is described below commit 8f9c5c5ebe8c1e5cd196ad94ce78c6c9a433ccb6 Author: Yun Tang AuthorDate: Sat May 7 17:54:30 2022 +0800 [hotfix][docs] Correct the description of how to build this project This closes #112 --- README.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index fc7e580..2e2698a 100644 --- a/README.md +++ b/README.md @@ -13,9 +13,9 @@ Check our [quick-start](https://nightlies.apache.org/flink/flink-table-store-doc ## Building -Run the `mvn clean package` command to build the project. +Run the `mvn clean package -DskipTests` command to build the project. -Then you will find a JAR file that contains your application, plus any libraries that you may have added as dependencies to the application: `target/-.jar`. +Then you will find a JAR file with all shaded dependencies: `flink-table-store-dist/target/flink-table-store-dist-.jar`. ## Contributing
[flink-ml] branch master updated: [FLINK-27091] Add Transformer and Estimator of LinearSVC
This is an automated email from the ASF dual-hosted git repository.
lindong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git
The following commit(s) were added to refs/heads/master by this push:
new 4bd9083 [FLINK-27091] Add Transformer and Estimator of LinearSVC
4bd9083 is described below
commit 4bd908312825e3fe4fd7566b15626ad766ebabc5
Author: Zhipeng Zhang
AuthorDate: Sat May 7 15:53:35 2022 +0800
[FLINK-27091] Add Transformer and Estimator of LinearSVC
This closes #93.
---
.../ml/classification/linearsvc/LinearSVC.java | 123
.../classification/linearsvc/LinearSVCModel.java | 174
.../linearsvc/LinearSVCModelData.java | 111 +++
.../linearsvc/LinearSVCModelParams.java| 55 +
.../classification/linearsvc/LinearSVCParams.java | 44
.../apache/flink/ml/common/lossfunc/HingeLoss.java | 58 ++
...isticRegressionTest.java => LinearSVCTest.java} | 222 ++---
.../ml/classification/LogisticRegressionTest.java | 8 +-
.../flink/ml/common/lossfunc/HingeLossTest.java| 57 ++
.../flink/ml/regression/LinearRegressionTest.java | 8 +-
10 files changed, 731 insertions(+), 129 deletions(-)
diff --git
a/flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linearsvc/LinearSVC.java
b/flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linearsvc/LinearSVC.java
new file mode 100644
index 000..4169d48
--- /dev/null
+++
b/flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linearsvc/LinearSVC.java
@@ -0,0 +1,123 @@
+/*
+ * 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.ml.classification.linearsvc;
+
+import org.apache.flink.api.common.functions.ReduceFunction;
+import org.apache.flink.ml.api.Estimator;
+import org.apache.flink.ml.common.datastream.DataStreamUtils;
+import org.apache.flink.ml.common.feature.LabeledPointWithWeight;
+import org.apache.flink.ml.common.lossfunc.HingeLoss;
+import org.apache.flink.ml.common.optimizer.Optimizer;
+import org.apache.flink.ml.common.optimizer.SGD;
+import org.apache.flink.ml.linalg.DenseVector;
+import org.apache.flink.ml.param.Param;
+import org.apache.flink.ml.util.ParamUtils;
+import org.apache.flink.ml.util.ReadWriteUtils;
+import org.apache.flink.streaming.api.datastream.DataStream;
+import org.apache.flink.table.api.Table;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
+import org.apache.flink.table.api.internal.TableImpl;
+import org.apache.flink.util.Preconditions;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * An Estimator which implements the linear support vector classification.
+ *
+ * See https://en.wikipedia.org/wiki/Support-vector_machine#Linear_SVM.
+ */
+public class LinearSVC implements Estimator,
LinearSVCParams {
+
+private final Map, Object> paramMap = new HashMap<>();
+
+public LinearSVC() {
+ParamUtils.initializeMapWithDefaultValues(paramMap, this);
+}
+
+@Override
+@SuppressWarnings({"rawTypes", "ConstantConditions"})
+public LinearSVCModel fit(Table... inputs) {
+Preconditions.checkArgument(inputs.length == 1);
+StreamTableEnvironment tEnv =
+(StreamTableEnvironment) ((TableImpl)
inputs[0]).getTableEnvironment();
+
+DataStream trainData =
+tEnv.toDataStream(inputs[0])
+.map(
+dataPoint -> {
+double weight =
+getWeightCol() == null
+? 1.0
+: (Double)
dataPoint.getField(getWeightCol());
+double label = (Double)
dataPoint.getField(getLabelCol());
+Preconditions.checkState(
+Double.compare(0.0, label) == 0
+|| Double.compare(1.0,
label) == 0,
+"LinearSVC only
