[
https://issues.apache.org/jira/browse/GOBBLIN-1413?focusedWorklogId=581308&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-581308
]
ASF GitHub Bot logged work on GOBBLIN-1413:
-------------------------------------------
Author: ASF GitHub Bot
Created on: 12/Apr/21 20:03
Start Date: 12/Apr/21 20:03
Worklog Time Spent: 10m
Work Description: autumnust commented on a change in pull request #3252:
URL: https://github.com/apache/gobblin/pull/3252#discussion_r611866991
##########
File path:
gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/publisher/GobblinMCEPublisher.java
##########
@@ -18,11 +18,13 @@
package org.apache.gobblin.iceberg.publisher;
import com.google.common.io.Closer;
+import java.util.PriorityQueue;
Review comment:
Looks like the import order is not right here. Please consider using the
style file on gobblin-oss webpage to help auto-formatting
--
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:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 581308)
Time Spent: 1.5h (was: 1h 20m)
> Emit GMCE as long as watermark moved
> ------------------------------------
>
> Key: GOBBLIN-1413
> URL: https://issues.apache.org/jira/browse/GOBBLIN-1413
> Project: Apache Gobblin
> Issue Type: Bug
> Reporter: Hanghang Liu
> Priority: Critical
> Time Spent: 1.5h
> Remaining Estimate: 0h
>
> Emit GMCE(Gobblin Metadata Change Event) as long as watermark moved on
> streaming pipeline.
> Currently the GMCE won't be triggered within streaming pipeline if no new
> file being generated. This causes problem if watermarks moved, while no file
> being generated(for example, data been filtered out by quality checker), GMCE
> will be missed.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
