Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Remove index_realtime and index_realtime_appenderator tasks #16602

Merged
merged 27 commits into from
Jun 25, 2024
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
27 commits
Select commit Hold shift + click to select a range
60ceeed
Remove index_realtime and index_realtime_appenderator tasks.
gianm Jan 18, 2024
2548eeb
Updates.
gianm Jan 18, 2024
abfef32
Style.
gianm Jan 18, 2024
3396f17
Fixes for static analysis.
gianm Jan 18, 2024
c773fcd
Fix test.
gianm Jan 18, 2024
7fd4f4f
Updates for static analysis, ITs.
gianm Jan 18, 2024
a319f16
Fix test.
gianm Jan 18, 2024
676dd4c
Fixes.
gianm Jan 19, 2024
7f39083
Remove function.
gianm Jan 19, 2024
0e77cd2
Merge branch 'master' into realtime-rampage
gianm Jan 19, 2024
1fbb38e
Merge branch 'master' into realtime-rampage
gianm Jan 20, 2024
42680fe
IT WIP
gianm Jan 20, 2024
cfb4faf
delete
gianm Jan 20, 2024
c85f6ff
Merge branch 'master' into realtime-rampage
gianm Mar 20, 2024
d7ec2cf
Merge branch 'master' into realtime-rampage
gianm Mar 20, 2024
9a90795
Fix style.
gianm Mar 20, 2024
2eff3ea
Merge remote-tracking branch 'upstream/master' into realtime-rampage
clintropolis Jun 14, 2024
7e6d38b
fix inspection, add union query integration test using new framework
clintropolis Jun 14, 2024
8499c4a
style
clintropolis Jun 14, 2024
e165efd
style again
clintropolis Jun 14, 2024
7d663fd
dependencies
clintropolis Jun 14, 2024
b3dceea
adjust
clintropolis Jun 14, 2024
f2401cd
revert some unintended changes
clintropolis Jun 14, 2024
aaf2812
Merge remote-tracking branch 'upstream/master' into realtime-rampage
clintropolis Jun 14, 2024
9f3da17
fix test
clintropolis Jun 14, 2024
e06647a
maybe fix tests
clintropolis Jun 14, 2024
f3ce50b
missed a spot
clintropolis Jun 14, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Fixes for static analysis.
  • Loading branch information
gianm committed Jan 18, 2024
commit 3396f17d4da67a2fe00622cc26fa8e9ebbdae4eb

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -64,16 +64,6 @@ public Signal call()
);
}

/**
* Run callable repeatedly with the given delay between calls, after the given
* initial delay, until it returns Signal.STOP. Exceptions are caught and
* logged as errors.
*/
public static void scheduleWithFixedDelay(ScheduledExecutorService exec, Duration delay, Callable<Signal> callable)
{
scheduleWithFixedDelay(exec, delay, delay, callable);
}

/**
* Run callable repeatedly with the given delay between calls, until it
* returns Signal.STOP. Exceptions are caught and logged as errors.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -108,11 +108,6 @@ public Metadata putAll(@Nullable Map<String, Object> other)
return this;
}

public Object get(String key)
{
return container.get(key);
}

// arbitrary key-value pairs from the metadata just follow the semantics of last one wins if same
// key exists in multiple input Metadata containers
// for others e.g. Aggregators, appropriate merging is done
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -97,10 +97,4 @@ public boolean isRowAdded()
{
return reasonOfNotAdded == null && parseException == null;
}

@Nullable
public String getReasonOfNotAdded()
{
return reasonOfNotAdded;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -278,7 +278,7 @@ SegmentPublishResult commitSegmentsAndMetadata(
Set<DataSegment> segments,
@Nullable DataSourceMetadata startMetadata,
@Nullable DataSourceMetadata endMetadata
) throws IOException;
);

/**
* Commits segments created by an APPEND task. This method also handles segment
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -413,7 +413,7 @@ public SegmentPublishResult commitSegmentsAndMetadata(
final Set<DataSegment> segments,
@Nullable final DataSourceMetadata startMetadata,
@Nullable final DataSourceMetadata endMetadata
) throws IOException
)
{
if (segments.isEmpty()) {
throw new IllegalArgumentException("segment set must not be empty");
Expand Down
Loading