[jira] [Updated] (HUDI-2540) Wrong validation for MetadataTableEnabled
[ https://issues.apache.org/jira/browse/HUDI-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated HUDI-2540: -- Status: In Progress (was: Open) > Wrong validation for MetadataTableEnabled > - > > Key: HUDI-2540 > URL: https://issues.apache.org/jira/browse/HUDI-2540 > Project: Apache Hudi > Issue Type: Bug > Components: CLI >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Major > Labels: pull-request-available > Attachments: p1.png > > > !p1.png! > https://github.com/apache/hudi/blob/ad63938890151c4c13e78acfd448259c3af80f80/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java#L713 > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Resolved] (HUDI-2540) Wrong validation for MetadataTableEnabled
[ https://issues.apache.org/jira/browse/HUDI-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal resolved HUDI-2540. --- Resolution: Fixed > Wrong validation for MetadataTableEnabled > - > > Key: HUDI-2540 > URL: https://issues.apache.org/jira/browse/HUDI-2540 > Project: Apache Hudi > Issue Type: Bug > Components: CLI >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Major > Labels: pull-request-available > Attachments: p1.png > > > !p1.png! > https://github.com/apache/hudi/blob/ad63938890151c4c13e78acfd448259c3af80f80/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java#L713 > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (HUDI-2540) Wrong validation for MetadataTableEnabled
[ https://issues.apache.org/jira/browse/HUDI-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427405#comment-17427405 ] Roc Marshal commented on HUDI-2540: --- Fixed in f14d4e65e7edab58aa86c495e4bd4caa79086d6b of master > Wrong validation for MetadataTableEnabled > - > > Key: HUDI-2540 > URL: https://issues.apache.org/jira/browse/HUDI-2540 > Project: Apache Hudi > Issue Type: Bug > Components: CLI >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Major > Labels: pull-request-available > Attachments: p1.png > > > !p1.png! > https://github.com/apache/hudi/blob/ad63938890151c4c13e78acfd448259c3af80f80/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java#L713 > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (HUDI-2540) Wrong validation for MetadataTableEnabled
[ https://issues.apache.org/jira/browse/HUDI-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal reassigned HUDI-2540: - Assignee: Roc Marshal > Wrong validation for MetadataTableEnabled > - > > Key: HUDI-2540 > URL: https://issues.apache.org/jira/browse/HUDI-2540 > Project: Apache Hudi > Issue Type: Bug > Components: CLI >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Major > Attachments: p1.png > > > !p1.png! > https://github.com/apache/hudi/blob/ad63938890151c4c13e78acfd448259c3af80f80/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java#L713 > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (HUDI-2540) Wrong validation for MetadataTableEnabled
[ https://issues.apache.org/jira/browse/HUDI-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal reassigned HUDI-2540: - Assignee: (was: Roc Marshal) > Wrong validation for MetadataTableEnabled > - > > Key: HUDI-2540 > URL: https://issues.apache.org/jira/browse/HUDI-2540 > Project: Apache Hudi > Issue Type: Bug > Components: CLI >Reporter: Roc Marshal >Priority: Major > Attachments: p1.png > > > !p1.png! > https://github.com/apache/hudi/blob/ad63938890151c4c13e78acfd448259c3af80f80/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java#L713 > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (HUDI-2540) Wrong validation for MetadataTableEnabled
[ https://issues.apache.org/jira/browse/HUDI-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426743#comment-17426743 ] Roc Marshal edited comment on HUDI-2540 at 10/11/21, 6:33 AM: -- Hi, [~xleesf] , Could you help me to confirm it ? Thank you. was (Author: rocmarshal): cc [~danny0405]. Please let me know what's your opinion. Thank you. > Wrong validation for MetadataTableEnabled > - > > Key: HUDI-2540 > URL: https://issues.apache.org/jira/browse/HUDI-2540 > Project: Apache Hudi > Issue Type: Bug > Components: CLI >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Major > Attachments: p1.png > > > !p1.png! > https://github.com/apache/hudi/blob/ad63938890151c4c13e78acfd448259c3af80f80/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java#L713 > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (HUDI-2540) Wrong validation for MetadataTableEnabled
[ https://issues.apache.org/jira/browse/HUDI-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17426743#comment-17426743 ] Roc Marshal commented on HUDI-2540: --- cc [~danny0405]. Please let me know what's your opinion. Thank you. > Wrong validation for MetadataTableEnabled > - > > Key: HUDI-2540 > URL: https://issues.apache.org/jira/browse/HUDI-2540 > Project: Apache Hudi > Issue Type: Bug > Components: CLI >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Major > Attachments: p1.png > > > !p1.png! > https://github.com/apache/hudi/blob/ad63938890151c4c13e78acfd448259c3af80f80/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java#L713 > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (HUDI-2540) Wrong validation for MetadataTableEnabled
Roc Marshal created HUDI-2540: - Summary: Wrong validation for MetadataTableEnabled Key: HUDI-2540 URL: https://issues.apache.org/jira/browse/HUDI-2540 Project: Apache Hudi Issue Type: Bug Components: CLI Reporter: Roc Marshal Assignee: Roc Marshal Attachments: p1.png !p1.png! https://github.com/apache/hudi/blob/ad63938890151c4c13e78acfd448259c3af80f80/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java#L713 -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (HUDI-490) Add DeltaStream API example to hudi-examples
[ https://issues.apache.org/jira/browse/HUDI-490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal reassigned HUDI-490: Assignee: (was: Roc Marshal) > Add DeltaStream API example to hudi-examples > > > Key: HUDI-490 > URL: https://issues.apache.org/jira/browse/HUDI-490 > Project: Apache Hudi > Issue Type: Sub-task >Reporter: dengziming >Priority: Major > Labels: starter, user-support-issues > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (HUDI-1846) Add hudi-python module and add python API into it
[ https://issues.apache.org/jira/browse/HUDI-1846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal reassigned HUDI-1846: - Assignee: Roc Marshal > Add hudi-python module and add python API into it > - > > Key: HUDI-1846 > URL: https://issues.apache.org/jira/browse/HUDI-1846 > Project: Apache Hudi > Issue Type: New Feature >Reporter: Roc Marshal >Assignee: Roc Marshal >Priority: Major > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (HUDI-1846) Add hudi-python module and add python API into it
Roc Marshal created HUDI-1846: - Summary: Add hudi-python module and add python API into it Key: HUDI-1846 URL: https://issues.apache.org/jira/browse/HUDI-1846 Project: Apache Hudi Issue Type: New Feature Reporter: Roc Marshal -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (HUDI-89) Clean up placement, naming, defaults of HoodieWriteConfig
[ https://issues.apache.org/jira/browse/HUDI-89?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325435#comment-17325435 ] Roc Marshal edited comment on HUDI-89 at 4/20/21, 3:05 AM: --- [~wenningd] IMO, It will be an evolutionary process. Backward compatible over a period of versions. Allow admissible time for user use. Work to make the experience of version switching friendly. was (Author: rocmarshal): [~wenningd] It will be an evolutionary process. Backward compatible over a period of versions. Allow admissible time for user use. Work to make the experience of version switching friendly. > Clean up placement, naming, defaults of HoodieWriteConfig > - > > Key: HUDI-89 > URL: https://issues.apache.org/jira/browse/HUDI-89 > Project: Apache Hudi > Issue Type: Improvement > Components: Code Cleanup, Usability, Writer Core >Reporter: Vinoth Chandar >Assignee: Vinoth Chandar >Priority: Blocker > Labels: pull-request-available > Fix For: 0.9.0 > > > # Rename HoodieWriteConfig to HoodieClientConfig > # Move bunch of configs from CompactionConfig to StorageConfig > # Introduce new HoodieCleanConfig > # Should we consider lombok or something to automate the > defaults/getters/setters > # Consistent name of properties/defaults > # Enforce bounds more strictly -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (HUDI-89) Clean up placement, naming, defaults of HoodieWriteConfig
[ https://issues.apache.org/jira/browse/HUDI-89?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325435#comment-17325435 ] Roc Marshal commented on HUDI-89: - [~wenningd] It will be an evolutionary process. Backward compatible over a period of versions. Allow admissible time for user use. Work to make the experience of version switching friendly. > Clean up placement, naming, defaults of HoodieWriteConfig > - > > Key: HUDI-89 > URL: https://issues.apache.org/jira/browse/HUDI-89 > Project: Apache Hudi > Issue Type: Improvement > Components: Code Cleanup, Usability, Writer Core >Reporter: Vinoth Chandar >Assignee: Vinoth Chandar >Priority: Blocker > Labels: pull-request-available > Fix For: 0.9.0 > > > # Rename HoodieWriteConfig to HoodieClientConfig > # Move bunch of configs from CompactionConfig to StorageConfig > # Introduce new HoodieCleanConfig > # Should we consider lombok or something to automate the > defaults/getters/setters > # Consistent name of properties/defaults > # Enforce bounds more strictly -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (HUDI-1737) Extract common method in HoodieCreateHandle & FlinkCreateHandle
[
https://issues.apache.org/jira/browse/HUDI-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roc Marshal updated HUDI-1737:
--
Priority: Major (was: Minor)
> Extract common method in HoodieCreateHandle & FlinkCreateHandle
> ---
>
> Key: HUDI-1737
> URL: https://issues.apache.org/jira/browse/HUDI-1737
> Project: Apache Hudi
> Issue Type: Improvement
> Components: Code Cleanup
>Reporter: Roc Marshal
>Assignee: Roc Marshal
>Priority: Major
> Labels: hudi-client, pull-request-available
>
> {code:java}
> // HoodieCreateHandle.java
> //...
> @Override
> public List close() {
> LOG.info("Closing the file " + writeStatus.getFileId() + " as we are done
> with all the records " + recordsWritten);
> try {
> fileWriter.close();
> HoodieWriteStat stat = new HoodieWriteStat();
> stat.setPartitionPath(writeStatus.getPartitionPath());
> stat.setNumWrites(recordsWritten);
> stat.setNumDeletes(recordsDeleted);
> stat.setNumInserts(insertRecordsWritten);
> stat.setPrevCommit(HoodieWriteStat.NULL_COMMIT);
> stat.setFileId(writeStatus.getFileId());
> stat.setPath(new Path(config.getBasePath()), path);
> long fileSizeInBytes = FSUtils.getFileSize(fs, path);
> stat.setTotalWriteBytes(fileSizeInBytes);
> stat.setFileSizeInBytes(fileSizeInBytes);
> stat.setTotalWriteErrors(writeStatus.getTotalErrorRecords());
> RuntimeStats runtimeStats = new RuntimeStats();
> runtimeStats.setTotalCreateTime(timer.endTimer());
> stat.setRuntimeStats(runtimeStats);
> writeStatus.setStat(stat);
> LOG.info(String.format("CreateHandle for partitionPath %s fileID %s, took
> %d ms.", stat.getPartitionPath(),
> stat.getFileId(), runtimeStats.getTotalCreateTime()));
> return Collections.singletonList(writeStatus);
> } catch (IOException e) {
> throw new HoodieInsertException("Failed to close the Insert Handle for
> path " + path, e);
> }
> }
> //FlinkCreateHandle.java
> private void setUpWriteStatus() throws IOException {
> long fileSizeInBytes = fileWriter.getBytesWritten();
> long incFileSizeInBytes = fileSizeInBytes - lastFileSize;
> this.lastFileSize = fileSizeInBytes;
> HoodieWriteStat stat = new HoodieWriteStat();
> stat.setPartitionPath(writeStatus.getPartitionPath());
> stat.setNumWrites(recordsWritten);
> stat.setNumDeletes(recordsDeleted);
> stat.setNumInserts(insertRecordsWritten);
> stat.setPrevCommit(HoodieWriteStat.NULL_COMMIT);
> stat.setFileId(writeStatus.getFileId());
> stat.setPath(new Path(config.getBasePath()), path);
> stat.setTotalWriteBytes(incFileSizeInBytes);
> stat.setFileSizeInBytes(fileSizeInBytes);
> stat.setTotalWriteErrors(writeStatus.getTotalErrorRecords());
> HoodieWriteStat.RuntimeStats runtimeStats = new
> HoodieWriteStat.RuntimeStats();
> runtimeStats.setTotalCreateTime(timer.endTimer());
> stat.setRuntimeStats(runtimeStats);
> writeStatus.setStat(stat);
> }{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (HUDI-1737) Extract common method in HoodieCreateHandle & FlinkCreateHandle
[
https://issues.apache.org/jira/browse/HUDI-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roc Marshal updated HUDI-1737:
--
Summary: Extract common method in HoodieCreateHandle & FlinkCreateHandle
(was: Extract public method in HoodieCreateHandle & FlinkCreateHandle)
> Extract common method in HoodieCreateHandle & FlinkCreateHandle
> ---
>
> Key: HUDI-1737
> URL: https://issues.apache.org/jira/browse/HUDI-1737
> Project: Apache Hudi
> Issue Type: Improvement
> Components: Code Cleanup
>Reporter: Roc Marshal
>Assignee: Roc Marshal
>Priority: Minor
> Labels: hudi-client
>
> {code:java}
> // HoodieCreateHandle.java
> //...
> @Override
> public List close() {
> LOG.info("Closing the file " + writeStatus.getFileId() + " as we are done
> with all the records " + recordsWritten);
> try {
> fileWriter.close();
> HoodieWriteStat stat = new HoodieWriteStat();
> stat.setPartitionPath(writeStatus.getPartitionPath());
> stat.setNumWrites(recordsWritten);
> stat.setNumDeletes(recordsDeleted);
> stat.setNumInserts(insertRecordsWritten);
> stat.setPrevCommit(HoodieWriteStat.NULL_COMMIT);
> stat.setFileId(writeStatus.getFileId());
> stat.setPath(new Path(config.getBasePath()), path);
> long fileSizeInBytes = FSUtils.getFileSize(fs, path);
> stat.setTotalWriteBytes(fileSizeInBytes);
> stat.setFileSizeInBytes(fileSizeInBytes);
> stat.setTotalWriteErrors(writeStatus.getTotalErrorRecords());
> RuntimeStats runtimeStats = new RuntimeStats();
> runtimeStats.setTotalCreateTime(timer.endTimer());
> stat.setRuntimeStats(runtimeStats);
> writeStatus.setStat(stat);
> LOG.info(String.format("CreateHandle for partitionPath %s fileID %s, took
> %d ms.", stat.getPartitionPath(),
> stat.getFileId(), runtimeStats.getTotalCreateTime()));
> return Collections.singletonList(writeStatus);
> } catch (IOException e) {
> throw new HoodieInsertException("Failed to close the Insert Handle for
> path " + path, e);
> }
> }
> //FlinkCreateHandle.java
> private void setUpWriteStatus() throws IOException {
> long fileSizeInBytes = fileWriter.getBytesWritten();
> long incFileSizeInBytes = fileSizeInBytes - lastFileSize;
> this.lastFileSize = fileSizeInBytes;
> HoodieWriteStat stat = new HoodieWriteStat();
> stat.setPartitionPath(writeStatus.getPartitionPath());
> stat.setNumWrites(recordsWritten);
> stat.setNumDeletes(recordsDeleted);
> stat.setNumInserts(insertRecordsWritten);
> stat.setPrevCommit(HoodieWriteStat.NULL_COMMIT);
> stat.setFileId(writeStatus.getFileId());
> stat.setPath(new Path(config.getBasePath()), path);
> stat.setTotalWriteBytes(incFileSizeInBytes);
> stat.setFileSizeInBytes(fileSizeInBytes);
> stat.setTotalWriteErrors(writeStatus.getTotalErrorRecords());
> HoodieWriteStat.RuntimeStats runtimeStats = new
> HoodieWriteStat.RuntimeStats();
> runtimeStats.setTotalCreateTime(timer.endTimer());
> stat.setRuntimeStats(runtimeStats);
> writeStatus.setStat(stat);
> }{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Created] (HUDI-1737) Extract public method in HoodieCreateHandle & FlinkCreateHandle
Roc Marshal created HUDI-1737:
-
Summary: Extract public method in HoodieCreateHandle &
FlinkCreateHandle
Key: HUDI-1737
URL: https://issues.apache.org/jira/browse/HUDI-1737
Project: Apache Hudi
Issue Type: Improvement
Components: Code Cleanup
Reporter: Roc Marshal
Assignee: Roc Marshal
{code:java}
// HoodieCreateHandle.java
//...
@Override
public List close() {
LOG.info("Closing the file " + writeStatus.getFileId() + " as we are done
with all the records " + recordsWritten);
try {
fileWriter.close();
HoodieWriteStat stat = new HoodieWriteStat();
stat.setPartitionPath(writeStatus.getPartitionPath());
stat.setNumWrites(recordsWritten);
stat.setNumDeletes(recordsDeleted);
stat.setNumInserts(insertRecordsWritten);
stat.setPrevCommit(HoodieWriteStat.NULL_COMMIT);
stat.setFileId(writeStatus.getFileId());
stat.setPath(new Path(config.getBasePath()), path);
long fileSizeInBytes = FSUtils.getFileSize(fs, path);
stat.setTotalWriteBytes(fileSizeInBytes);
stat.setFileSizeInBytes(fileSizeInBytes);
stat.setTotalWriteErrors(writeStatus.getTotalErrorRecords());
RuntimeStats runtimeStats = new RuntimeStats();
runtimeStats.setTotalCreateTime(timer.endTimer());
stat.setRuntimeStats(runtimeStats);
writeStatus.setStat(stat);
LOG.info(String.format("CreateHandle for partitionPath %s fileID %s, took
%d ms.", stat.getPartitionPath(),
stat.getFileId(), runtimeStats.getTotalCreateTime()));
return Collections.singletonList(writeStatus);
} catch (IOException e) {
throw new HoodieInsertException("Failed to close the Insert Handle for path
" + path, e);
}
}
//FlinkCreateHandle.java
private void setUpWriteStatus() throws IOException {
long fileSizeInBytes = fileWriter.getBytesWritten();
long incFileSizeInBytes = fileSizeInBytes - lastFileSize;
this.lastFileSize = fileSizeInBytes;
HoodieWriteStat stat = new HoodieWriteStat();
stat.setPartitionPath(writeStatus.getPartitionPath());
stat.setNumWrites(recordsWritten);
stat.setNumDeletes(recordsDeleted);
stat.setNumInserts(insertRecordsWritten);
stat.setPrevCommit(HoodieWriteStat.NULL_COMMIT);
stat.setFileId(writeStatus.getFileId());
stat.setPath(new Path(config.getBasePath()), path);
stat.setTotalWriteBytes(incFileSizeInBytes);
stat.setFileSizeInBytes(fileSizeInBytes);
stat.setTotalWriteErrors(writeStatus.getTotalErrorRecords());
HoodieWriteStat.RuntimeStats runtimeStats = new
HoodieWriteStat.RuntimeStats();
runtimeStats.setTotalCreateTime(timer.endTimer());
stat.setRuntimeStats(runtimeStats);
writeStatus.setStat(stat);
}{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (HUDI-490) Add DeltaStream API example to hudi-examples
[ https://issues.apache.org/jira/browse/HUDI-490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17160926#comment-17160926 ] Roc Marshal commented on HUDI-490: -- [~vbalaji] I'm willing to do this. Could you assign this ticket to me if no one is working on this ? Thank You. > Add DeltaStream API example to hudi-examples > > > Key: HUDI-490 > URL: https://issues.apache.org/jira/browse/HUDI-490 > Project: Apache Hudi > Issue Type: Sub-task >Reporter: dengziming >Priority: Major > Labels: starter > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Issue Comment Deleted] (HUDI-490) Add DeltaStream API example to hudi-examples
[ https://issues.apache.org/jira/browse/HUDI-490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated HUDI-490: - Comment: was deleted (was: Could someone kindly assign this to me? Thank you.) > Add DeltaStream API example to hudi-examples > > > Key: HUDI-490 > URL: https://issues.apache.org/jira/browse/HUDI-490 > Project: Apache Hudi > Issue Type: Sub-task >Reporter: dengziming >Priority: Major > Labels: starter > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (HUDI-490) Add DeltaStream API example to hudi-examples
[ https://issues.apache.org/jira/browse/HUDI-490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159654#comment-17159654 ] Roc Marshal commented on HUDI-490: -- Could someone kindly assign this to me? Thank you. > Add DeltaStream API example to hudi-examples > > > Key: HUDI-490 > URL: https://issues.apache.org/jira/browse/HUDI-490 > Project: Apache Hudi > Issue Type: Sub-task >Reporter: dengziming >Priority: Major > Labels: starter > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (HUDI-490) Add DeltaStream API example to hudi-examples
[ https://issues.apache.org/jira/browse/HUDI-490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154603#comment-17154603 ] Roc Marshal commented on HUDI-490: -- Hi, [~dengziming]. I'm willing to do this. Could you assign this ticket to me if no one is working on this ? Thank You. > Add DeltaStream API example to hudi-examples > > > Key: HUDI-490 > URL: https://issues.apache.org/jira/browse/HUDI-490 > Project: Apache Hudi > Issue Type: Sub-task >Reporter: dengziming >Priority: Major > Labels: starter > -- This message was sent by Atlassian Jira (v8.3.4#803005)
