This is an automated email from the ASF dual-hosted git repository.
loogn pushed a commit to branch release-0.7.0-rc3
in repository https://gitbox.apache.org/repos/asf/geaflow.git
The following commit(s) were added to refs/heads/release-0.7.0-rc3 by this push:
new db502117 fix(incubator): Fix LICENSE/NOTICE and add proper headers to
derived files
db502117 is described below
commit db50211797258cecc9499d09dbe28c6007d4a618
Author: loogn zhou <[email protected]>
AuthorDate: Tue Nov 4 17:29:03 2025 +0800
fix(incubator): Fix LICENSE/NOTICE and add proper headers to derived files
---
LICENSE | 81 ++++++++++++++++++----
NOTICE | 34 +++------
.../core/status/GeaflowStatusRecorder.java | 6 +-
.../analytics/service/client/HttpResponse.java | 4 ++
.../service/client/jdbc/AnalyticsDriver.java | 4 ++
.../jdbc/property/AbstractConnectProperty.java | 4 ++
.../client/jdbc/property/ConnectProperties.java | 4 ++
.../client/jdbc/property/ConnectProperty.java | 4 ++
.../analytics/service/query/IQueryStatus.java | 4 ++
.../analytics/service/query/QueryIdGenerator.java | 4 ++
.../analytics/service/query/QueryResults.java | 4 ++
.../apache/geaflow/common/binary/BinaryString.java | 4 ++
.../geaflow/shuffle/network/netty/NettyClient.java | 4 ++
.../shuffle/network/netty/NettyFrameDecoder.java | 4 ++
.../geaflow/shuffle/network/netty/NettyServer.java | 4 ++
.../network/netty/SliceRequestClientHandler.java | 4 ++
.../network/protocol/AbstractFileRegion.java | 4 ++
.../network/protocol/CompositeFileRegion.java | 4 ++
.../network/protocol/MemoryBytesFileRegion.java | 4 ++
.../shuffle/network/protocol/NettyMessage.java | 4 ++
.../pipeline/channel/AbstractInputChannel.java | 4 ++
.../shuffle/pipeline/channel/ChannelId.java | 4 ++
.../pipeline/channel/LocalInputChannel.java | 4 ++
.../pipeline/fetcher/MultiShardFetcher.java | 4 ++
.../shuffle/pipeline/fetcher/OneShardFetcher.java | 4 ++
.../shuffle/pipeline/fetcher/ShardFetcher.java | 4 ++
.../geaflow/shuffle/util/TransportException.java | 4 ++
.../cluster/k8s/config/KubernetesConfigKeys.java | 4 ++
.../k8s/entrypoint/KubernetesContainerRunner.java | 4 ++
.../k8s/entrypoint/KubernetesDriverRunner.java | 4 ++
.../k8s/entrypoint/KubernetesMasterRunner.java | 4 ++
.../apache/geaflow/dsl/udf/table/string/Like.java | 4 ++
.../main/java/org/apache/geaflow/memory/Chunk.java | 4 ++
.../org/apache/geaflow/memory/DirectMemory.java | 4 ++
.../main/java/org/apache/geaflow/memory/Page.java | 4 ++
.../apache/geaflow/memory/PlatformDependent.java | 4 ++
.../org/apache/geaflow/memory/cleaner/Cleaner.java | 3 +
.../geaflow/memory/cleaner/CleanerJava6.java | 4 ++
.../geaflow/memory/cleaner/CleanerJava9.java | 4 ++
.../geaflow/state/iterator/MultiIterator.java | 4 ++
.../geaflow/utils/keygroup/KeyGroupAssignment.java | 4 ++
41 files changed, 235 insertions(+), 37 deletions(-)
diff --git a/LICENSE b/LICENSE
index f116cb4d..53993da3 100644
--- a/LICENSE
+++ b/LICENSE
@@ -201,8 +201,19 @@
See the License for the specific language governing permissions and
limitations under the License.
-Apache Software Foundation License 2.0
---------------------------------------
+
+------------------------------------------------------------------------------------
+This product includes derivative works from the following third-party projects:
+
+
+------------------------------------------------------------------------------------
+Apache Flink (https://github.com/apache/flink, version 1.18)
+Licensed under the Apache License, Version 2.0.
+
+Original copyright notice:
+ Copyright 2014-2025 The Apache Software Foundation
+
+The following files are derived from Apache Flink:
geaflow/geaflow-utils/src/main/java/org/apache/geaflow/utils/KeyGroupAssignment.java
geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyClient.java
geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyServer.java
@@ -219,22 +230,42 @@
geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k
geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesDriverRunner.java
geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesContainerRunner.java
geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/config/KubernetesConfigKeys.java
-from https://github.com/apache/flink version 1.18
+
+------------------------------------------------------------------------------------
+Apache Flink Kubernetes Operator
(https://github.com/apache/flink-kubernetes-operator, version 1.1)
+Licensed under the Apache License, Version 2.0.
+
+Original copyright notice:
+ Copyright 2014-2025 The Apache Software Foundation
+
+The following file is derived from Apache Flink Kubernetes Operator:
geaflow-kubernetes-operator/geaflow-kubernetes-operator-core/src/main/java/org/apache/geaflow/kubernetes/operator/core/status/GeaflowStatusRecorder.java
-from https://github.com/apache/flink-kubernetes-operator version 1.1
+
+------------------------------------------------------------------------------------
+Apache Spark (https://github.com/apache/spark, version 3.0)
+Licensed under the Apache License, Version 2.0.
+
+Original copyright notice:
+ Copyright 2014 and onwards The Apache Software Foundation
+
+The following files are derived from Apache Spark:
geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/AbstractFileRegion.java
geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/CompositeFileRegion.java
geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/MemoryBytesFileRegion.java
geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyFrameDecoder.java
geaflow/geaflow-common/src/main/java/org/apache/geaflow/common/binary/BinaryString.java
-from https://github.com/apache/spark version 3.0
-geaflow/geaflow-dsl/geaflow-dsl-parser/*
-geaflow/geaflow-dsl/geaflow-dsl-plan/*
-from https://github.com/apache/calcite version 1.18.0
+------------------------------------------------------------------------------------
+Netty (https://github.com/netty/netty, version 4.1)
+Licensed under the Apache License, Version 2.0.
+
+Original copyright notice:
+ Copyright 2012-2024 The Netty Project
+
+The following files are derived from Netty:
geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Chunk.java
geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/DirectMemory.java
geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Page.java
@@ -242,8 +273,16 @@
geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/PlatformDependent
geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/Cleaner.java
geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava6.java
geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava9.java
-from https://github.com/netty/netty/ version 4.1
+
+------------------------------------------------------------------------------------
+Presto (https://github.com/prestodb/presto, version 0.276)
+Licensed under the Apache License, Version 2.0.
+
+Original copyright notice:
+ Copyright (c) 2012-2024 Meta Platforms, Inc. and affiliates.
+
+The following files are derived from Presto:
geaflow/geaflow-analytics-service/geaflow-analytics-service-client/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperty.java
geaflow/geaflow-analytics-service/geaflow-analytics-service-client/org/apache/geaflow/analytics/service/client/jdbc/property/AbstractConnectProperty.java
geaflow/geaflow-analytics-service/geaflow-analytics-service-client/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperties.java
@@ -252,10 +291,28 @@
geaflow/geaflow-analytics-service/geaflow-analytics-service-client/org/apache/ge
geaflow/geaflow-analytics-service/geaflow-analytics-service-common/org/apache/geaflow/analytics/service/query/IQueryStatus.java
geaflow/geaflow-analytics-service/geaflow-analytics-service-common/org/apache/geaflow/analytics/service/query/QueryIdGenerator.java
geaflow/geaflow-analytics-service/geaflow-analytics-service-common/org/apache/geaflow/analytics/service/query/QueryResults.java
-from https://github.com/prestodb/presto version 0.276
+
+------------------------------------------------------------------------------------
+Apache Hive (https://github.com/apache/hive, version 3.0)
+Licensed under the Apache License, Version 2.0.
+
+Original copyright notice:
+ Copyright 2008-2025 The Apache Software Foundation
+
+The following file is derived from Apache Hive:
geaflow/geaflow-dsl/geaflow-dsl-plan/org/apache/geaflow/dsl/udf/table/string/Like.java
-from https://github.com/apache/hive version 3.0
+
+------------------------------------------------------------------------------------
+Guava (https://github.com/google/guava, version 22.0)
+Licensed under the Apache License, Version 2.0.
+
+Original copyright notice:
+ Copyright (C) 2006-2024 Google LLC
+
+The following file is derived from Guava:
geaflow/geaflow-state/geaflow-state-common/org/apache/geaflow/state/iterator/MultiIterator.java
-from https://github.com/google/guava version 22.0
\ No newline at end of file
+
+
+------------------------------------------------------------------------------------
\ No newline at end of file
diff --git a/NOTICE b/NOTICE
index 8348c830..14ad26d9 100644
--- a/NOTICE
+++ b/NOTICE
@@ -13,37 +13,23 @@ Copyright 2014-2025 The Apache Software Foundation
Apache Spark
Copyright 2014 and onwards The Apache Software Foundation
-Apache Calcite
-Copyright 2012-2025 The Apache Software Foundation
-
Apache Hive
-Copyright 2008-2018 The Apache Software Foundation
-
-Netty
-Copyright 2012-2024 The Netty Project
+Copyright 2008-2025 The Apache Software Foundation
----------------------------------------------------------
-Prosto
-Copyright 2012-2022 The Presto Foundation
-Licensed 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
+Netty
+Copyright 2012-2024 The Netty Project
-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.
+This product includes software developed at
+The Netty Project (http://netty.io/).
----------------------------------------------------------
-Guava
-Copyright 2006-2022 Google LLC
-Licensed 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
+Presto
+Copyright (c) 2012-2024 Meta Platforms, Inc. and affiliates.
-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.
+This product includes software developed at
+Presto (https://prestodb.github.io/).
-----------------------------------------------------------
\ No newline at end of file
+----------------------------------------------------------
diff --git
a/geaflow-kubernetes-operator/geaflow-kubernetes-operator-core/src/main/java/org/apache/geaflow/kubernetes/operator/core/status/GeaflowStatusRecorder.java
b/geaflow-kubernetes-operator/geaflow-kubernetes-operator-core/src/main/java/org/apache/geaflow/kubernetes/operator/core/status/GeaflowStatusRecorder.java
index 4328c175..f1035daf 100644
---
a/geaflow-kubernetes-operator/geaflow-kubernetes-operator-core/src/main/java/org/apache/geaflow/kubernetes/operator/core/status/GeaflowStatusRecorder.java
+++
b/geaflow-kubernetes-operator/geaflow-kubernetes-operator-core/src/main/java/org/apache/geaflow/kubernetes/operator/core/status/GeaflowStatusRecorder.java
@@ -29,8 +29,12 @@ import
org.apache.geaflow.kubernetes.operator.core.model.customresource.Abstract
import
org.apache.geaflow.kubernetes.operator.core.model.exception.StatusConflictException;
import org.apache.geaflow.kubernetes.operator.core.util.KubernetesUtil;
+/* This file is based on source code from the Flink Kubernetes Operator
Project (http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
- * This class is an adaptation of Flink's
org.apache.flink.kubernetes.operator.utils.StatusRecorder.
+ * This class is an adaptation of Flink Kubernetes Operator's
org.apache.flink.kubernetes.operator.utils.StatusRecorder.
*/
@Slf4j
public class GeaflowStatusRecorder<CR extends AbstractGeaflowResource<?, STAT>,
diff --git
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/HttpResponse.java
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/HttpResponse.java
index 9c5c62dd..5c40de82 100644
---
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/HttpResponse.java
+++
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/HttpResponse.java
@@ -39,6 +39,10 @@ import org.apache.http.impl.client.CloseableHttpClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Presto Project
(https://prestodb.github.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Presto's
com.facebook.presto.client.JsonResponse.
*/
diff --git
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/AnalyticsDriver.java
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/AnalyticsDriver.java
index e36abe0a..d6d7bd36 100644
---
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/AnalyticsDriver.java
+++
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/AnalyticsDriver.java
@@ -37,6 +37,10 @@ import java.util.stream.Collectors;
import org.apache.geaflow.analytics.service.client.utils.JDBCUtils;
import org.apache.geaflow.common.exception.GeaflowRuntimeException;
+/* This file is based on source code from the Presto Project
(https://prestodb.github.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Presto's
com.facebook.presto.jdbc.PrestoDriver.
*/
diff --git
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/AbstractConnectProperty.java
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/AbstractConnectProperty.java
index da79ef32..47670af7 100644
---
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/AbstractConnectProperty.java
+++
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/AbstractConnectProperty.java
@@ -36,6 +36,10 @@ import
org.apache.geaflow.common.exception.GeaflowRuntimeException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Presto Project
(https://prestodb.github.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Presto's
com.facebook.presto.jdbc.AbstractConnectionProperty.
*/
diff --git
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperties.java
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperties.java
index 2900f822..5467fe83 100644
---
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperties.java
+++
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperties.java
@@ -32,6 +32,10 @@ import java.util.Properties;
import java.util.Set;
import java.util.function.Predicate;
+/* This file is based on source code from the Presto Project
(https://prestodb.github.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Presto's
com.facebook.presto.jdbc.ConnectionProperties.
*/
diff --git
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperty.java
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperty.java
index b43412dc..abe2761f 100644
---
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperty.java
+++
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperty.java
@@ -25,6 +25,10 @@ import java.util.Optional;
import java.util.Properties;
import org.apache.geaflow.common.exception.GeaflowRuntimeException;
+/* This file is based on source code from the Presto Project
(https://prestodb.github.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Presto's
com.facebook.presto.jdbc.ConnectionProperty.
*/
diff --git
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/IQueryStatus.java
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/IQueryStatus.java
index 347274d2..aa8e64b3 100644
---
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/IQueryStatus.java
+++
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/IQueryStatus.java
@@ -19,6 +19,10 @@
package org.apache.geaflow.analytics.service.query;
+/* This file is based on source code from the Presto Project
(https://prestodb.github.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Presto's
com.facebook.presto.client.QueryStatusInfo.
*/
diff --git
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryIdGenerator.java
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryIdGenerator.java
index 5b01c8ef..92b41e7f 100644
---
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryIdGenerator.java
+++
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryIdGenerator.java
@@ -31,6 +31,10 @@ import java.util.concurrent.TimeUnit;
import org.joda.time.format.DateTimeFormat;
import org.joda.time.format.DateTimeFormatter;
+/* This file is based on source code from the Presto Project
(https://prestodb.github.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Presto's
com.facebook.presto.execution.QueryIdGenerator.
*/
diff --git
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryResults.java
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryResults.java
index 072b767a..558e0b56 100644
---
a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryResults.java
+++
b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryResults.java
@@ -31,6 +31,10 @@ import org.apache.calcite.rel.type.RelDataType;
import org.apache.geaflow.cluster.response.ResponseResult;
import org.apache.geaflow.dsl.common.data.impl.ObjectRow;
+/* This file is based on source code from the Presto Project
(https://prestodb.github.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Presto's
com.facebook.presto.client.QueryResults.
*/
diff --git
a/geaflow/geaflow-common/src/main/java/org/apache/geaflow/common/binary/BinaryString.java
b/geaflow/geaflow-common/src/main/java/org/apache/geaflow/common/binary/BinaryString.java
index ba90ea7f..d8a5c836 100644
---
a/geaflow/geaflow-common/src/main/java/org/apache/geaflow/common/binary/BinaryString.java
+++
b/geaflow/geaflow-common/src/main/java/org/apache/geaflow/common/binary/BinaryString.java
@@ -48,6 +48,10 @@ import java.nio.ByteOrder;
import java.nio.charset.StandardCharsets;
import java.util.Objects;
+/* This file is based on source code from the Spark Project
(http://spark.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Spark's
org.apache.spark.unsafe.types.UTF8String.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyClient.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyClient.java
index e2b8d798..c7bd011f 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyClient.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyClient.java
@@ -41,6 +41,10 @@ import org.apache.geaflow.shuffle.network.NettyUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.runtime.io.network.netty.NettyClient.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyFrameDecoder.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyFrameDecoder.java
index 1b772ca6..301a1fa1 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyFrameDecoder.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyFrameDecoder.java
@@ -28,6 +28,10 @@ import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import java.util.LinkedList;
+/* This file is based on source code from the Spark Project
(http://spark.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Spark's
org.apache.spark.network.util.TransportFrameDecoder.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyServer.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyServer.java
index 5cb6d48b..628e329d 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyServer.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyServer.java
@@ -42,6 +42,10 @@ import org.apache.geaflow.shuffle.network.NettyUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.runtime.io.network.netty.NettyServer.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/SliceRequestClientHandler.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/SliceRequestClientHandler.java
index adedfeda..6e461b6f 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/SliceRequestClientHandler.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/SliceRequestClientHandler.java
@@ -38,6 +38,10 @@ import org.apache.geaflow.shuffle.util.TransportException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandler.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/AbstractFileRegion.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/AbstractFileRegion.java
index 7c3d39ae..48be9c9e 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/AbstractFileRegion.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/AbstractFileRegion.java
@@ -22,6 +22,10 @@ package org.apache.geaflow.shuffle.network.protocol;
import io.netty.channel.FileRegion;
import io.netty.util.AbstractReferenceCounted;
+/* This file is based on source code from the Spark Project
(http://spark.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Spark's
org.apache.spark.network.util.AbstractFileRegion.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/CompositeFileRegion.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/CompositeFileRegion.java
index cec53db4..6bb223d0 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/CompositeFileRegion.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/CompositeFileRegion.java
@@ -27,6 +27,10 @@ import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.WritableByteChannel;
+/* This file is based on source code from the Spark Project
(http://spark.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Spark's
org.apache.spark.network.protocol.MessageWithHeader.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/MemoryBytesFileRegion.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/MemoryBytesFileRegion.java
index 6abc95d9..7b0d4e0b 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/MemoryBytesFileRegion.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/MemoryBytesFileRegion.java
@@ -23,6 +23,10 @@ import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.WritableByteChannel;
+/* This file is based on source code from the Spark Project
(http://spark.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Spark's
org.apache.spark.util.io.ChunkedByteBufferFileRegion.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/NettyMessage.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/NettyMessage.java
index 99c9f21f..c5bfeca9 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/NettyMessage.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/NettyMessage.java
@@ -24,6 +24,10 @@ import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufAllocator;
import java.io.Serializable;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.runtime.io.network.netty.NettyMessage.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/AbstractInputChannel.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/AbstractInputChannel.java
index 3a8073c3..f7945ab9 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/AbstractInputChannel.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/AbstractInputChannel.java
@@ -26,6 +26,10 @@ import org.apache.geaflow.shuffle.message.SliceId;
import org.apache.geaflow.shuffle.pipeline.buffer.PipeChannelBuffer;
import org.apache.geaflow.shuffle.pipeline.fetcher.OneShardFetcher;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.runtime.io.network.partition.consumer.InputChannel.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/ChannelId.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/ChannelId.java
index 8b9fd16b..48a46aca 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/ChannelId.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/ChannelId.java
@@ -24,6 +24,10 @@ import java.io.Serializable;
import java.util.Objects;
import java.util.UUID;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's org.apache.flink.util.AbstractID.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/LocalInputChannel.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/LocalInputChannel.java
index 0a33bfc1..f98853d5 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/LocalInputChannel.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/LocalInputChannel.java
@@ -35,6 +35,10 @@ import
org.apache.geaflow.shuffle.util.SliceNotFoundException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/MultiShardFetcher.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/MultiShardFetcher.java
index 7f3638de..098a4a96 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/MultiShardFetcher.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/MultiShardFetcher.java
@@ -36,6 +36,10 @@ import java.util.stream.Collectors;
import org.apache.geaflow.common.tuple.Tuple;
import org.apache.geaflow.shuffle.pipeline.buffer.PipeFetcherBuffer;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* Interface to fetch data from multiple {@link OneShardFetcher}.
* This class is an adaptation of Flink's
org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/OneShardFetcher.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/OneShardFetcher.java
index b04a42f4..1cfdadfc 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/OneShardFetcher.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/OneShardFetcher.java
@@ -49,6 +49,10 @@ import
org.apache.geaflow.shuffle.pipeline.channel.RemoteInputChannel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/ShardFetcher.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/ShardFetcher.java
index 972bc28d..0ab58f18 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/ShardFetcher.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/ShardFetcher.java
@@ -24,6 +24,10 @@ import java.io.IOException;
import java.util.Optional;
import org.apache.geaflow.shuffle.pipeline.buffer.PipeFetcherBuffer;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.runtime.io.network.partition.consumer.InputGate.
*/
diff --git
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/util/TransportException.java
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/util/TransportException.java
index dfb5002c..3a930104 100644
---
a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/util/TransportException.java
+++
b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/util/TransportException.java
@@ -22,6 +22,10 @@ package org.apache.geaflow.shuffle.util;
import java.io.IOException;
import java.net.SocketAddress;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.runtime.io.network.netty.exception.TransportException.
*/
diff --git
a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/config/KubernetesConfigKeys.java
b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/config/KubernetesConfigKeys.java
index 2b6dac7d..ff57a4aa 100644
---
a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/config/KubernetesConfigKeys.java
+++
b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/config/KubernetesConfigKeys.java
@@ -23,6 +23,10 @@ import
org.apache.geaflow.cluster.k8s.config.KubernetesConfig.ServiceExposedType
import org.apache.geaflow.common.config.ConfigKey;
import org.apache.geaflow.common.config.ConfigKeys;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.kubernetes.configuration.KubernetesConfigOptions.
*/
diff --git
a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesContainerRunner.java
b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesContainerRunner.java
index c9e99204..f7658658 100644
---
a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesContainerRunner.java
+++
b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesContainerRunner.java
@@ -32,6 +32,10 @@ import org.apache.geaflow.common.config.Configuration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner.
*/
diff --git
a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesDriverRunner.java
b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesDriverRunner.java
index afa5276a..40861d6e 100644
---
a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesDriverRunner.java
+++
b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesDriverRunner.java
@@ -32,6 +32,10 @@ import org.apache.geaflow.common.config.Configuration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner.
*/
diff --git
a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesMasterRunner.java
b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesMasterRunner.java
index b53cee49..8f78594d 100644
---
a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesMasterRunner.java
+++
b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesMasterRunner.java
@@ -46,6 +46,10 @@ import
org.apache.geaflow.ha.leaderelection.LeaderContenderType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
* org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner.
diff --git
a/geaflow/geaflow-dsl/geaflow-dsl-plan/src/main/java/org/apache/geaflow/dsl/udf/table/string/Like.java
b/geaflow/geaflow-dsl/geaflow-dsl-plan/src/main/java/org/apache/geaflow/dsl/udf/table/string/Like.java
index 8b350fb3..82630157 100644
---
a/geaflow/geaflow-dsl/geaflow-dsl-plan/src/main/java/org/apache/geaflow/dsl/udf/table/string/Like.java
+++
b/geaflow/geaflow-dsl/geaflow-dsl-plan/src/main/java/org/apache/geaflow/dsl/udf/table/string/Like.java
@@ -24,6 +24,10 @@ import java.util.regex.Pattern;
import org.apache.geaflow.dsl.common.function.Description;
import org.apache.geaflow.dsl.common.function.UDF;
+/* This file is based on source code from the Hive Project
(http://hive.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Hive's org.apache.hadoop.hive.ql.udf.UDFLike.
*/
diff --git
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Chunk.java
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Chunk.java
index 43da7b83..76460747 100644
--- a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Chunk.java
+++ b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Chunk.java
@@ -21,6 +21,10 @@ package org.apache.geaflow.memory;
import org.apache.geaflow.memory.metric.ChunkMetric;
+/* This file is based on source code from the Netty Project
(http://netty.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Netty's io.netty.buffer.PoolChunk.
*/
diff --git
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/DirectMemory.java
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/DirectMemory.java
index f99235de..ec6bb99d 100644
---
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/DirectMemory.java
+++
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/DirectMemory.java
@@ -34,6 +34,10 @@ import
org.apache.geaflow.memory.exception.GeaflowOutOfMemoryException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Netty Project
(http://netty.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Netty's io.netty.util.internal.DirectMemory.
*/
diff --git
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Page.java
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Page.java
index 28dab990..4dc6bbd8 100644
--- a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Page.java
+++ b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Page.java
@@ -21,6 +21,10 @@ package org.apache.geaflow.memory;
import org.apache.geaflow.memory.metric.PageMetric;
+/* This file is based on source code from the Netty Project
(http://netty.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Netty's io.netty.buffer.PoolSubpage.
*/
diff --git
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/PlatformDependent.java
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/PlatformDependent.java
index 1b6f3718..0a2248cd 100644
---
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/PlatformDependent.java
+++
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/PlatformDependent.java
@@ -34,6 +34,10 @@ import org.apache.geaflow.common.utils.ReflectionUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Netty Project
(http://netty.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Netty's
io.netty.util.internal.PlatformDependent.
*/
diff --git
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/Cleaner.java
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/Cleaner.java
index 5c902603..7f16880e 100644
---
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/Cleaner.java
+++
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/Cleaner.java
@@ -21,6 +21,9 @@ package org.apache.geaflow.memory.cleaner;
import java.nio.ByteBuffer;
+/* This file is based on source code from the Netty Project
(http://netty.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
/**
* This class is an adaptation of Netty's io.netty.util.internal.Cleaner.
diff --git
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava6.java
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava6.java
index 5bd8275c..27b973ea 100644
---
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava6.java
+++
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava6.java
@@ -45,6 +45,10 @@ import org.apache.geaflow.memory.PlatformDependent;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Netty Project
(http://netty.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Netty's io.netty.util.internal.CleanerJava6.
* Allows to free direct {@link ByteBuffer} by using Cleaner for Java version
less than 9.
diff --git
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava9.java
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava9.java
index f307a4d4..04a017de 100644
---
a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava9.java
+++
b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava9.java
@@ -44,6 +44,10 @@ import org.apache.geaflow.memory.PlatformDependent;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+/* This file is based on source code from the Netty Project
(http://netty.io/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Netty's io.netty.util.internal.CleanerJava9.
* Allows to free direct {@link ByteBuffer} by using Cleaner for Java version
equal or greater than 9.
diff --git
a/geaflow/geaflow-state/geaflow-state-common/src/main/java/org/apache/geaflow/state/iterator/MultiIterator.java
b/geaflow/geaflow-state/geaflow-state-common/src/main/java/org/apache/geaflow/state/iterator/MultiIterator.java
index a4497bd2..9b8cb59f 100644
---
a/geaflow/geaflow-state/geaflow-state-common/src/main/java/org/apache/geaflow/state/iterator/MultiIterator.java
+++
b/geaflow/geaflow-state/geaflow-state-common/src/main/java/org/apache/geaflow/state/iterator/MultiIterator.java
@@ -23,6 +23,10 @@ import java.util.Arrays;
import java.util.Iterator;
import org.apache.geaflow.common.iterator.CloseableIterator;
+/* This file is based on source code from the Guava Project
(https://guava.dev/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Guava's Iterators.concat
* by fixing the issue https://github.com/google/guava/issues/3178.
diff --git
a/geaflow/geaflow-utils/src/main/java/org/apache/geaflow/utils/keygroup/KeyGroupAssignment.java
b/geaflow/geaflow-utils/src/main/java/org/apache/geaflow/utils/keygroup/KeyGroupAssignment.java
index cdfb5721..6d59ec0b 100644
---
a/geaflow/geaflow-utils/src/main/java/org/apache/geaflow/utils/keygroup/KeyGroupAssignment.java
+++
b/geaflow/geaflow-utils/src/main/java/org/apache/geaflow/utils/keygroup/KeyGroupAssignment.java
@@ -27,6 +27,10 @@ import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import org.apache.geaflow.utils.math.MathUtil;
+/* This file is based on source code from the Flink Project
(http://flink.apache.org/), licensed by the Apache
+ * Software Foundation (ASF) under the Apache License, Version 2.0. See the
NOTICE file distributed with this work for
+ * additional information regarding copyright ownership. */
+
/**
* This class is an adaptation of Flink's
org.apache.flink.runtime.state.KeyGroupRangeAssignment.
*/
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
