[jira] [Closed] (HUDI-1377) clean duplicate code in HoodieSparkSqlWriter
[ https://issues.apache.org/jira/browse/HUDI-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] karl wang closed HUDI-1377. --- > clean duplicate code in HoodieSparkSqlWriter > > > Key: HUDI-1377 > URL: https://issues.apache.org/jira/browse/HUDI-1377 > Project: Apache Hudi > Issue Type: Improvement > Components: Spark Integration >Reporter: karl wang >Priority: Major > Labels: pull-request-available > Fix For: 0.6.1 > > > clean duplicate code in HoodieSparkSqlWriter -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (HUDI-1381) Schedule compaction based on time elapsed
[ https://issues.apache.org/jira/browse/HUDI-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232036#comment-17232036 ] karl wang edited comment on HUDI-1381 at 11/15/20, 4:28 AM: I want to try it. Can u assign to me was (Author: wangshikai): I want to try it. > Schedule compaction based on time elapsed > -- > > Key: HUDI-1381 > URL: https://issues.apache.org/jira/browse/HUDI-1381 > Project: Apache Hudi > Issue Type: New Feature > Components: Compaction >Reporter: Balaji Varadarajan >Priority: Major > Fix For: 0.7.0 > > > GH : [https://github.com/apache/hudi/issues/2229] > It would be helpful to introduce configuration to schedule compaction based > on time elapsed since last scheduled compaction. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (HUDI-1381) Schedule compaction based on time elapsed
[ https://issues.apache.org/jira/browse/HUDI-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232036#comment-17232036 ] karl wang edited comment on HUDI-1381 at 11/15/20, 4:28 AM: I want to try it. was (Author: wangshikai): I am not sure if I can do it . But I want try it. > Schedule compaction based on time elapsed > -- > > Key: HUDI-1381 > URL: https://issues.apache.org/jira/browse/HUDI-1381 > Project: Apache Hudi > Issue Type: New Feature > Components: Compaction >Reporter: Balaji Varadarajan >Priority: Major > Fix For: 0.7.0 > > > GH : [https://github.com/apache/hudi/issues/2229] > It would be helpful to introduce configuration to schedule compaction based > on time elapsed since last scheduled compaction. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (HUDI-1390) [UMBRELLA] Support schema inference for unstructured data
[ https://issues.apache.org/jira/browse/HUDI-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232147#comment-17232147 ] Raymond Xu commented on HUDI-1390: -- [~309637554] glad to hear that! we labelled a series of issues with gsoc2021 for Google Summer of Code next year (basically a 3-month internship program). The plan was to prepare some non-urgent issues for this program. This issue is exactly what you described. So what do you have in-mind on the timeline to work on this? [~vinoth] maybe we can start the work for this earlier? > [UMBRELLA] Support schema inference for unstructured data > - > > Key: HUDI-1390 > URL: https://issues.apache.org/jira/browse/HUDI-1390 > Project: Apache Hudi > Issue Type: Improvement > Components: bootstrap >Reporter: Raymond Xu >Priority: Major > Labels: gsoc, gsoc2021, mentor > > (More details to be added) -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (HUDI-1354) Block updates and replace on file groups in clustering
[ https://issues.apache.org/jira/browse/HUDI-1354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232082#comment-17232082 ] Satish Kotha commented on HUDI-1354: I haven't started on this yet. Thanks for helping > Block updates and replace on file groups in clustering > -- > > Key: HUDI-1354 > URL: https://issues.apache.org/jira/browse/HUDI-1354 > Project: Apache Hudi > Issue Type: Sub-task >Reporter: satish >Priority: Major > Fix For: 0.7.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (HUDI-1354) Block updates and replace on file groups in clustering
[ https://issues.apache.org/jira/browse/HUDI-1354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232068#comment-17232068 ] liwei commented on HUDI-1354: - [~satishkotha] hello , have you begin to work on this issue. I am happy to start this work next week base on your work i https://issues.apache.org/jira/browse/HUDI-1352 > Block updates and replace on file groups in clustering > -- > > Key: HUDI-1354 > URL: https://issues.apache.org/jira/browse/HUDI-1354 > Project: Apache Hudi > Issue Type: Sub-task >Reporter: satish >Priority: Major > Fix For: 0.7.0 > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (HUDI-1390) [UMBRELLA] Support schema inference for unstructured data
[ https://issues.apache.org/jira/browse/HUDI-1390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232067#comment-17232067 ] liwei commented on HUDI-1390: - hello [~xushiyan] now i also do something about this in my work. just as inference unstructured data as csv、json、xml etc. What about this issue background? we can have more discussion:D > [UMBRELLA] Support schema inference for unstructured data > - > > Key: HUDI-1390 > URL: https://issues.apache.org/jira/browse/HUDI-1390 > Project: Apache Hudi > Issue Type: Improvement > Components: bootstrap >Reporter: Raymond Xu >Priority: Major > Labels: gsoc, gsoc2021, mentor > > (More details to be added) -- This message was sent by Atlassian Jira (v8.3.4#803005)
[GitHub] [hudi] lw309637554 commented on pull request #2196: [HUDI-1349]spark sql support overwrite use replace action
lw309637554 commented on pull request #2196: URL: https://github.com/apache/hudi/pull/2196#issuecomment-727229138 > @lw309637554 the plan looks good to me. @satishkotha when the PR is ready, please tag me so I can take a final pass and merge it thanks , @satishkotha @n3nash i thinks add a insertOverwriteTable(JavaRDD> records, final String commitTime) just as https://cwiki.apache.org/confluence/display/HUDI/RFC+-+18+Insert+Overwrite+API#RFC18InsertOverwriteAPI-API will be ok . I will land it This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [hudi] lw309637554 commented on a change in pull request #2136: [HUDI-37] Persist the HoodieIndex type in the hoodie.properties file
lw309637554 commented on a change in pull request #2136:
URL: https://github.com/apache/hudi/pull/2136#discussion_r523427007
##
File path:
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/HoodieIndex.java
##
@@ -97,13 +98,20 @@ public abstract O updateLocation(O writeStatuses,
HoodieEngineContext context,
@PublicAPIMethod(maturity = ApiMaturityLevel.STABLE)
public abstract boolean isImplicitWithStorage();
+ /**
+ * Get the index Type.
+ */
+ public IndexType indexType() {
Review comment:
okay
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [hudi] wangxianghu commented on a change in pull request #2176: [HUDI-1327] Introduce base implementation of hudi-flink-client
wangxianghu commented on a change in pull request #2176:
URL: https://github.com/apache/hudi/pull/2176#discussion_r523426482
##
File path:
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/FlinkHoodieIndex.java
##
@@ -0,0 +1,90 @@
+/*
+ * 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.hudi.index;
+
+import org.apache.hudi.ApiMaturityLevel;
+import org.apache.hudi.PublicAPIMethod;
+import org.apache.hudi.client.WriteStatus;
+import org.apache.hudi.client.common.HoodieEngineContext;
+import org.apache.hudi.client.common.HoodieFlinkEngineContext;
+import org.apache.hudi.common.model.HoodieKey;
+import org.apache.hudi.common.model.HoodieRecord;
+import org.apache.hudi.common.model.HoodieRecordPayload;
+import org.apache.hudi.common.util.ReflectionUtils;
+import org.apache.hudi.common.util.StringUtils;
+import org.apache.hudi.config.HoodieWriteConfig;
+import org.apache.hudi.exception.HoodieIndexException;
+import org.apache.hudi.index.state.FlinkInMemoryStateIndex;
+import org.apache.hudi.table.HoodieTable;
+
+import java.util.List;
+
+/**
+ * Base flink implementation of {@link HoodieIndex}.
+ * @param payload type
+ */
+public abstract class FlinkHoodieIndex extends
HoodieIndex>, List, List> {
+ protected FlinkHoodieIndex(HoodieWriteConfig config) {
+super(config);
+ }
+
+ public static FlinkHoodieIndex createIndex(HoodieFlinkEngineContext context,
HoodieWriteConfig config) {
+// first use index class config to create index.
+if (!StringUtils.isNullOrEmpty(config.getIndexClass())) {
+ Object instance = ReflectionUtils.loadClass(config.getIndexClass(),
config);
+ if (!(instance instanceof HoodieIndex)) {
+throw new HoodieIndexException(config.getIndexClass() + " is not a
subclass of HoodieIndex");
+ }
+ return (FlinkHoodieIndex) instance;
+}
+switch (config.getIndexType()) {
+ case HBASE:
+// TODO
+return null;
+ case INMEMORY:
+return new FlinkInMemoryStateIndex<>(context, config);
+ case BLOOM:
+// TODO
+return null;
+ case GLOBAL_BLOOM:
+// TODO
+return null;
+ case SIMPLE:
+// TODO
+return null;
+ case GLOBAL_SIMPLE:
+// TODO
+return null;
Review comment:
> should we implement some index here ?
how about another pr to add other indexes？ This pr we can focus on basic
functions
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [hudi] wangxianghu commented on pull request #2176: [HUDI-1327] Introduce base implementation of hudi-flink-client
wangxianghu commented on pull request #2176: URL: https://github.com/apache/hudi/pull/2176#issuecomment-727216715 > @wangxianghu thanks for opening the PR, with this PR, how would I start the flink job and verify E2E ? here is the main class `org.apache.hudi.HudiFlinkStreamer` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [hudi] wangxianghu commented on a change in pull request #2176: [HUDI-1327] Introduce base implementation of hudi-flink-client
wangxianghu commented on a change in pull request #2176:
URL: https://github.com/apache/hudi/pull/2176#discussion_r523425971
##
File path:
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java
##
@@ -0,0 +1,227 @@
+/*
+ * 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.hudi.client;
+
+import org.apache.hudi.client.common.HoodieEngineContext;
+import org.apache.hudi.client.common.HoodieFlinkEngineContext;
+import org.apache.hudi.client.embedded.EmbeddedTimelineService;
+import org.apache.hudi.common.model.HoodieCommitMetadata;
+import org.apache.hudi.common.model.HoodieKey;
+import org.apache.hudi.common.model.HoodieRecord;
+import org.apache.hudi.common.model.HoodieRecordPayload;
+import org.apache.hudi.common.model.HoodieWriteStat;
+import org.apache.hudi.common.model.WriteOperationType;
+import org.apache.hudi.common.table.HoodieTableMetaClient;
+import org.apache.hudi.common.table.HoodieTableVersion;
+import org.apache.hudi.common.table.timeline.HoodieInstant;
+import org.apache.hudi.common.table.timeline.HoodieTimeline;
+import org.apache.hudi.common.util.Option;
+import org.apache.hudi.config.HoodieWriteConfig;
+import org.apache.hudi.index.FlinkHoodieIndex;
+import org.apache.hudi.index.HoodieIndex;
+import org.apache.hudi.table.BulkInsertPartitioner;
+import org.apache.hudi.table.HoodieFlinkTable;
+import org.apache.hudi.table.HoodieTable;
+import org.apache.hudi.table.action.HoodieWriteMetadata;
+import org.apache.hudi.table.upgrade.FlinkUpgradeDowngrade;
+
+import com.codahale.metrics.Timer;
+import org.apache.hadoop.conf.Configuration;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@SuppressWarnings("checkstyle:LineLength")
+public class HoodieFlinkWriteClient extends
+AbstractHoodieWriteClient>, List,
List> {
+
+ public HoodieFlinkWriteClient(HoodieEngineContext context, HoodieWriteConfig
clientConfig) {
+super(context, clientConfig);
+ }
+
+ public HoodieFlinkWriteClient(HoodieEngineContext context, HoodieWriteConfig
writeConfig, boolean rollbackPending) {
+super(context, writeConfig, rollbackPending);
+ }
+
+ public HoodieFlinkWriteClient(HoodieEngineContext context, HoodieWriteConfig
writeConfig, boolean rollbackPending,
+Option
timelineService) {
+super(context, writeConfig, rollbackPending, timelineService);
+ }
+
+ /**
+ * Complete changes performed at the given instantTime marker with specified
action.
+ */
+ @Override
+ protected HoodieIndex>, List,
List> createIndex(HoodieWriteConfig writeConfig) {
+return FlinkHoodieIndex.createIndex((HoodieFlinkEngineContext) context,
config);
+ }
+
+ @Override
+ public boolean commit(String instantTime, List writeStatuses,
Option> extraMetadata, String commitActionType, Map> partitionToReplacedFileIds) {
+List writeStats =
writeStatuses.parallelStream().map(WriteStatus::getStat).collect(Collectors.toList());
+return commitStats(instantTime, writeStats, extraMetadata,
commitActionType, partitionToReplacedFileIds);
+ }
+
+ @Override
+ protected HoodieTable>, List,
List> createTable(HoodieWriteConfig config, Configuration
hadoopConf) {
+return HoodieFlinkTable.create(config, (HoodieFlinkEngineContext) context);
+ }
+
+ @Override
+ public List> filterExists(List>
hoodieRecords) {
+// Create a Hoodie table which encapsulated the commits and files visible
+HoodieFlinkTable table = HoodieFlinkTable.create(config,
(HoodieFlinkEngineContext) context);
+Timer.Context indexTimer = metrics.getIndexCtx();
+List> recordsWithLocation =
getIndex().tagLocation(hoodieRecords, context, table);
+metrics.updateIndexMetrics(LOOKUP_STR, metrics.getDurationInMs(indexTimer
== null ? 0L : indexTimer.stop()));
+return recordsWithLocation.stream().filter(v1 ->
!v1.isCurrentLocationKnown()).collect(Collectors.toList());
+ }
+
+ /**
+ * Main API to run bootstrap to hudi.
+ */
+ @Override
+ public void bootstrap(Option> extraMetadata) {
+if (rollbackPending) {
+ rollBackInflightBootstrap();
+}
+getTableAndInitCtx(WriteOperat
[jira] [Commented] (HUDI-1381) Schedule compaction based on time elapsed
[ https://issues.apache.org/jira/browse/HUDI-1381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232036#comment-17232036 ] karl wang commented on HUDI-1381: - I am not sure if I can do it . But I want try it. > Schedule compaction based on time elapsed > -- > > Key: HUDI-1381 > URL: https://issues.apache.org/jira/browse/HUDI-1381 > Project: Apache Hudi > Issue Type: New Feature > Components: Compaction >Reporter: Balaji Varadarajan >Priority: Major > Fix For: 0.7.0 > > > GH : [https://github.com/apache/hudi/issues/2229] > It would be helpful to introduce configuration to schedule compaction based > on time elapsed since last scheduled compaction. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[GitHub] [hudi] wangxianghu commented on a change in pull request #2176: [HUDI-1327] Introduce base implementation of hudi-flink-client
wangxianghu commented on a change in pull request #2176:
URL: https://github.com/apache/hudi/pull/2176#discussion_r523425556
##
File path:
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/FlinkTaskContextSupplier.java
##
@@ -0,0 +1,65 @@
+/*
+ * 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.hudi.client;
+
+import org.apache.hudi.client.common.EngineProperty;
+import org.apache.hudi.client.common.TaskContextSupplier;
+import org.apache.hudi.common.util.Option;
+
+import org.apache.flink.api.common.functions.RuntimeContext;
+
+import java.util.function.Supplier;
+
+/**
+ * Flink task context supplier.
+ */
+public class FlinkTaskContextSupplier extends TaskContextSupplier {
+ private org.apache.flink.api.common.functions.RuntimeContext
flinkRuntimeContext;
+
+ public FlinkTaskContextSupplier(RuntimeContext flinkRuntimeContext) {
+this.flinkRuntimeContext = flinkRuntimeContext;
+ }
+
+ public RuntimeContext getFlinkRuntimeContext() {
+return flinkRuntimeContext;
+ }
+
+ @Override
+ public Supplier getPartitionIdSupplier() {
+return () -> this.flinkRuntimeContext.getIndexOfThisSubtask();
+ }
+
+ @Override
+ public Supplier getStageIdSupplier() {
+// need to check again
Review comment:
> // TODO need to check again?
here flink has no concept of stage， so I used `NumberOfParallelSubtasks` not
sure if it is suitable
any idea ?
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [hudi] wangxianghu commented on a change in pull request #2176: [HUDI-1327] Introduce base implementation of hudi-flink-client
wangxianghu commented on a change in pull request #2176:
URL: https://github.com/apache/hudi/pull/2176#discussion_r523425566
##
File path:
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/FlinkTaskContextSupplier.java
##
@@ -0,0 +1,65 @@
+/*
+ * 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.hudi.client;
+
+import org.apache.hudi.client.common.EngineProperty;
+import org.apache.hudi.client.common.TaskContextSupplier;
+import org.apache.hudi.common.util.Option;
+
+import org.apache.flink.api.common.functions.RuntimeContext;
+
+import java.util.function.Supplier;
+
+/**
+ * Flink task context supplier.
+ */
+public class FlinkTaskContextSupplier extends TaskContextSupplier {
+ private org.apache.flink.api.common.functions.RuntimeContext
flinkRuntimeContext;
Review comment:
> would be changed to `RuntimeContext`?
done
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[jira] [Updated] (HUDI-1350) Support Partition level delete API in HUDI on top on Insert Overwrite
[ https://issues.apache.org/jira/browse/HUDI-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated HUDI-1350: - Labels: pull-request-available (was: ) > Support Partition level delete API in HUDI on top on Insert Overwrite > - > > Key: HUDI-1350 > URL: https://issues.apache.org/jira/browse/HUDI-1350 > Project: Apache Hudi > Issue Type: Sub-task > Components: Writer Core >Reporter: Balaji Varadarajan >Assignee: liwei >Priority: Major > Labels: pull-request-available > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[GitHub] [hudi] lw309637554 opened a new pull request #2254: [HUDI-1350] Support Partition level delete API in HUDI
lw309637554 opened a new pull request #2254: URL: https://github.com/apache/hudi/pull/2254 ## *Tips* - *Thank you very much for contributing to Apache Hudi.* - *Please review https://hudi.apache.org/contributing.html before opening a pull request.* ## What is the purpose of the pull request Support Partition level delete API in HUDI base on replace action. the spark datasource and hudi cli can use this api ## Brief change log *(for example:)* - *Modify AnnotationLocation checkstyle rule in checkstyle.xml* ## Verify this pull request *(Please pick either of the following options)* This pull request is a trivial rework / code cleanup without any test coverage. *(or)* This pull request is already covered by existing tests, such as *(please describe tests)*. (or) This change added tests and can be verified as follows: *(example:)* - *Added integration tests for end-to-end.* - *Added HoodieClientWriteTest to verify the change.* - *Manually verified the change by running a job locally.* ## Committer checklist - [ ] Has a corresponding JIRA in PR title & commit - [ ] Commit message is descriptive of the change - [ ] CI is green - [ ] Necessary doc changes done or have another open PR - [ ] For large changes, please consider breaking it into sub-tasks under an umbrella JIRA. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
