Clone Tools
  • last updated 26 mins ago
Constraints
Constraints: committers
 
Constraints: files
Constraints: dates
[ASTERIXDB-2256] Reformat sources using code format template

Change-Id: I4faa141c1a8c9700d5e9ac50b839acc9d1eede73

Reviewed-on: https://asterix-gerrit.ics.uci.edu/2310

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <mhubail@apache.org>

  1. … 982 more files in changeset.
[ASTERIXDB-2110] Introduce Cluster Controller Id

Change-Id: Iec1b01444bfbd923e38f5c162c5244e17c4d5f03

Reviewed-on: https://asterix-gerrit.ics.uci.edu/2323

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <mhubail@apache.org>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

    • -1
    • +2
    ./active/message/ActiveManagerMessage.java
  1. … 79 more files in changeset.
[ASTERIXDB-1564][CONF] Consistently Use Log4j2

- user model changes: no

- storage format changes: no

- interface changes: no

Details:

- Replace java.util.logging by Log4j2.

- Excluded classes due to their tests:

- IoUtil

- Tracer

Change-Id: Ic137571292f45de1f1994c61d328b97185012197

Reviewed-on: https://asterix-gerrit.ics.uci.edu/2226

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Michael Blow <mblow@apache.org>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

    • -4
    • +4
    ./active/ActiveSourceOperatorNodePushable.java
  1. … 388 more files in changeset.
[ASTERIXDB-1911][HYR,RT,CLUS] Fixes and Improvements for Deployed Jobs

Rename Predistributed Jobs to Deployed Jobs

Enable job executions to have a map of job parameters

Add an Asterix function to retrieve these parameters

which are can be assigned when the job is run, e.g. for Deployed jobs

Allow Deployed jobs to have new TxnIds and JobIds for each execution

Allow simultaneous execution of one Deployed Job

Change-Id: I8f493c1fa977d07dfe8a875f9ebe9515d01d1473

Reviewed-on: https://asterix-gerrit.ics.uci.edu/2045

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Xikui Wang <xkkwww@gmail.com>

    • -0
    • +108
    ./active/DeployedJobService.java
  1. … 73 more files in changeset.
[NO ISSUE][STO] Fix memory leaks in storage

- user model changes: no

- storage format changes: no

- interface changes: yes

- Added javadocs to:

-- IBufferCache

-- IExtraPageBlockHelper

- Moved IBufferCache.setPageDiskId -> ICachedPage.setDiskPageId

- Renamed:

-- IBufferCache.flushDirtyPage -> IBufferCache.flush

-- IBufferCache.getNumPages -> IBufferCache.getPageBudget

- Removed:

-- IBufferCache.adviseWontNeed [not used]

-- IBufferCache.tryPin [not used]

details:

- Previously, when adding a kv pair to the metadata of a memory

component, we add a new Pair item to the ArrayList. After

this change, we only update it if it exists.

- VirtualBufferCache used to leak pages when reclaiming pages

of a file after deletion. This has also been fixed.

- New tests for VirtualBufferCache added:

- Checks for memory budget after end of testDisjointPins

- Concurrent Users pinning pages concurrently

- Test for large pages and ensuring allocated large

pages are accounted for through removal of cached

free pages.

Change-Id: I4ae9736c9b5fdba5795245bdf835c023e3f73b15

Reviewed-on: https://asterix-gerrit.ics.uci.edu/2115

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <mhubail@apache.org>

    • -84
    • +0
    ./active/SingleThreadEventProcessor.java
  1. … 39 more files in changeset.
[NO ISSUE] Minor active refactoring

- Remove unused ActiveRuntimeManager

- Rename StatsRequestMessage -> ActiveStatsRequestMessage

- Add ActiveManager API to return all active runtimes

- Interrupt running HTTP requests after 5s upon shutdown

- Log thread dump when HTTP requests do not complete after interruption

Change-Id: I79249f7cd42496d6679eb9b0acbe8cda1892f9d3

Reviewed-on: https://asterix-gerrit.ics.uci.edu/2021

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Michael Blow <mblow@apache.org>

Tested-by: Michael Blow <mblow@apache.org>

    • -0
    • +35
    ./active/message/ActiveStatsRequestMessage.java
    • -35
    • +0
    ./active/message/StatsRequestMessage.java
  1. … 14 more files in changeset.
[NO ISSUE][RT] Minor interface refactoring for IActiveEventListener

- user model changes: no

- storage format changes: no

- interface changes: yes

Details:

Add getStatsName() method for IActiveEventListener to enable different

activeEventListeners to provide customized label for their stats.

Change-Id: Ife21078aa06bb14c2c733b48f3eaa8e02b9be905

Reviewed-on: https://asterix-gerrit.ics.uci.edu/2003

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

    • -0
    • +6
    ./active/IActiveEntityEventsListener.java
  1. … 3 more files in changeset.
[NO ISSUE][ING] Caller checks for active jobs failures

- user model changes: no

- storage format changes: no

- interface changes: yes

-IActiveEntityEventSubscriber.sync() does not throw failure anymore

and caller is responsible for checking for failures.

details:

- Previously, certain kinds of failures are sometimes thrown

and sometimes not when syncing a subscriber. This lead to

confusions and bugs. After this change, the caller to sync

is responsible for checking for failures.

Change-Id: I85146028be70f4631d1ef2696489a4624bf23ad4

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1986

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <mhubail@apache.org>

    • -2
    • +2
    ./active/IActiveEntityEventSubscriber.java
  1. … 6 more files in changeset.
[ASTERIXDB-2049][ING] Fix hang in Start Feed

- user model changes: no

- storage format changes: no

- interface changes: no

details:

- The hang is caused by one runtime finishing and unregistering

before another runtime registers. When that happens, the number

of registered runtimes never reaches the total number of runtimes

and so the start feed statement doesn't complete.

- To avoid the situation described above, we use different counters

for registration and deregistration. Since deregistration count

is now kept in another variable, the registrations will either

reach the expected count or a failure will happen and both

cases completes the start feed request.

Change-Id: I0019f5634009bf924fb37acc78eb796842eef492

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1953

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Till Westmann <tillw@apache.org>

  1. … 8 more files in changeset.
[ASTERIXDB-2049][ING] Improve logging for Active messages

- user model changes: no

- storage format changes: no

- interface changes: no

details:

- With each active message, log the runtime which sent it.

Change-Id: I9663277cadf922b7e0ec224b056357b0f24bbb05

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1951

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <mhubail@apache.org>

[ASTERIXDB-2039][OTH] Log Http Server direct memory budget

- user model changes: no

- storage format changes: no

- interface changes: no

details:

- Calculate mem budget = number of executors x max high watermark.

- Log the calculated budget.

Change-Id: I4a324f10db52e77c7e69ca4246b9d84b4479f25d

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1941

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Contrib: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <mhubail@apache.org>

  1. … 6 more files in changeset.
[ASTERIXDB-2008][CLUS] Only add pending removal if node known

[ASTERIXDB-2023][ING] Introduce Enums instead of using bytes

- user model changes: no

- storage format changes: no

- interface changes: no

details:

- Only nodes which are known to cluster manager are added

to the list of nodes pending removal. Other nodes are ignored

- Enums introduced:

- ActiveEvent.Kind

- ActivePartitionMessage.Event

- Remove AdapterRuntimeManager

- Remove AdapterExecutor

Change-Id: I7044896559798426c04a3f46861bc5335b25d140

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1921

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <mhubail@apache.org>

    • -2
    • +5
    ./active/ActiveSourceOperatorNodePushable.java
    • -13
    • +19
    ./active/SingleThreadEventProcessor.java
    • -5
    • +7
    ./active/message/ActiveManagerMessage.java
    • -2
    • +2
    ./active/message/StatsRequestMessage.java
  1. … 97 more files in changeset.
[ASTERIXDB-1992][ING] Suspend/Resume active entities

- user model changes: wait for completion only returns

when the entity becomes inactive.

- storage format changes: no

- interface changes:

01) Introduce:

IMetadataLockManager for entity locking.

IActiveNotificationHandler for handling active events.

IRetryPolicy for recovery of failed active jobs.

IActiveEntityController for controlling active entities.

02) IJobLifecycleListener.notifyJobFinish now passes the

JobStatus and Exceptions.

03) IActiveEntityEventsListener.isActive() returns true,

if entity is active, false otherwise.

04) IActiveEntityEventsListener.unregister() removes the

listener upon entity deletion.

05) IActiveEntityEventsListener.getJobFailure() returns

the job failure if the entity is in a failed state.

06) IStatementExecutor.getComponentProvider() returns

the storage component provider.

07) IStatementExecutor.getApplicationContext() returns

the application context.

08) IMetadataManager.upsertEntity to perfrom metadata

entities' upsert operations.

09) IMetadataNode.upsertEntity to perfrom metadata

entities' upsert operations

10) ICcApplicationContext.getMetadataLockManager() returns

the lock manger.

11) ICcApplicationContext.getClusterStateManager() returns

the cluster state manager.

details:

- Starting and stopping of active entities now go through

their listeners rather than having the listener indicating

active entity and not having it indicating inactive entity.

This facilitates suspend/resume operations of long running

active jobs for the sake of DDL operations or topology

changes.

- Unit tests for the vast majority of code paths and

different possible scenarios have been added.

Change-Id: Ifeac8c73e6bad39a13663b84a52121356e3c6b40

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1875

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

BAD: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Murtadha Hubail <mhubail@apache.org>

    • -169
    • +0
    ./active/ActiveJobNotificationHandler.java
    • -86
    • +0
    ./active/ActiveLifecycleListener.java
    • -0
    • +39
    ./active/CountRetryPolicy.java
    • -0
    • +34
    ./active/CountRetryPolicyFactory.java
    • -0
    • +57
    ./active/IActiveEntityEventSubscriber.java
    • -1
    • +18
    ./active/IActiveEntityEventsListener.java
    • -62
    • +0
    ./active/IActiveEventSubscriber.java
    • -0
    • +93
    ./active/IActiveNotificationHandler.java
    • -0
    • +27
    ./active/IRetryPolicy.java
    • -0
    • +27
    ./active/IRetryPolicyFactory.java
    • -0
    • +42
    ./active/InfiniteRetryPolicy.java
    • -0
    • +28
    ./active/InfiniteRetryPolicyFactory.java
  1. … 126 more files in changeset.
[ASTERIXDB-1970][ING] Fix Active Stats Test

- user model changes: no

- storage format changes: no

- interface changes: no

details:

- Active Stats Test fails because it issues many async

calls and doesn't wait until the calls complete. In

addition, it bypass the active event inbox incorrectly.

Change-Id: I518a6b1f7d8e86703ee5537869d207e609a7c293

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1865

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

BAD: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Xikui Wang <xkkwww@gmail.com>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

    • -0
    • +1
    ./active/ActiveJobNotificationHandler.java
  1. … 6 more files in changeset.
[ASTERIXDB-1950][ING][API] REST API for ActiveEntity stats

- user model changes: yes

Added ActiveEntity stats REST API.

- storage format changes: no

- interface changes: yes

Changed ActiveEntityEventsListener & EventSubscrber interfaces.

Added getStats method to IActiveRuntime.

Details:

1. Added HttpAPI for active feed stats.

2. Replaced FeedEventSubscriber with WaitForStateSubscriber.

3. Added StatsSubscriber for monitoring stats request.

4. Moved the message related methods from FeedEventsListener to

ActiveEntityEventsListener for possible reuses in other cases.

Change-Id: I46b48b52a1c9906510c5bdce778d1672845f75ca

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1748

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

    • -6
    • +12
    ./active/ActiveSourceOperatorNodePushable.java
    • -10
    • +27
    ./active/IActiveEntityEventsListener.java
    • -2
    • +16
    ./active/IActiveEventSubscriber.java
    • -7
    • +2
    ./active/message/ActiveManagerMessage.java
    • -0
    • +77
    ./active/message/ActiveStatsResponse.java
    • -0
    • +35
    ./active/message/StatsRequestMessage.java
  1. … 29 more files in changeset.
Remove static cc application context instance

Change-Id: Ia2e250405967ec880e7af6387aa981f39b3392c0

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1606

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Michael Blow <mblow@apache.org>

    • -2
    • +1
    ./active/ActiveJobNotificationHandler.java
    • -7
    • +12
    ./active/ActiveLifecycleListener.java
    • -2
    • +2
    ./active/ActiveSourceOperatorNodePushable.java
    • -7
    • +5
    ./active/message/ActiveManagerMessage.java
  1. … 177 more files in changeset.
Fix creation of callback factories

Change-Id: Idbeacf5af01b77c5f81b59aa6acec9b13762d629

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1613

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Michael Blow <mblow@apache.org>

    • -1
    • +11
    ./active/ActiveSourceOperatorNodePushable.java
  1. … 7 more files in changeset.
Add Active Partition Event Message

Enable active runtimes to send messages to the listener. In addition

this change introduces extension locks to metadata lock manager.

Change-Id: I7b4629752e912614927b816d4ce3422ac89c5426

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1596

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

BAD: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

  1. … 11 more files in changeset.
Shutdown ActiveManager Before Killing Thread Executors

Avoid race conditions with start / stop of active runtimes by stopping

the ActiveManager & and started runtimes before terminating the thread

executor

Change-Id: I45e83b0378198f80297fd2741969507741914dea

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1594

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

BAD: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

  1. … 14 more files in changeset.
Unify structure of Cluster Controller and Node Controller

Change-Id: Ife3a002371a07ee9cdd32e1ffd50cc775bf1d453

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1514

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Michael Blow <mblow@apache.org>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

    • -2
    • +2
    ./active/ActiveSourceOperatorNodePushable.java
    • -4
    • +1
    ./active/message/ActiveManagerMessage.java
  1. … 159 more files in changeset.
Enable Feed Changes to work with BAD project

Extracts the ActiveListener

Enables listeners to survive after job executions

Change-Id: Ib62184b67aff564475ef9b58790ff96409195b77

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1524

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

    • -4
    • +10
    ./active/ActiveJobNotificationHandler.java
  1. … 2 more files in changeset.
Feed Connection Refactoring

1. The feed subscription network using FeedJoint is removed.

2. FeedConnection metadata dataset is added (pkeys: dataverseName,

feedName, datasetName).

3. Replaced the old intake job + collect job combination with one single

job using SplitOperator.

4. Now one feed can connect to multiple datasets.

5. The disconnect feed job is replaced by ActiveManagerMessage.

6. The new feed life cycle is:

- Create feed

- Connect feed to dataset0, dataset1, dataset2, etc.

- Start feed

- Stop feed

- Disconnect feed

7. New feedEventListner framework by Abdullah

Change-Id: Ic36267eb9a10df21734ce1cc1f38583e23c9e8f0

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1259

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Till Westmann <tillw@apache.org>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

    • -102
    • +45
    ./active/ActiveJobNotificationHandler.java
    • -7
    • +36
    ./active/IActiveEntityEventsListener.java
    • -0
    • +48
    ./active/IActiveEventSubscriber.java
  1. … 191 more files in changeset.
ASTERIXDB-1747 Implemented full lifecycle capabilities for pre-distributed jobs

Added distribute and destroy functionality

Removed serialization and bytes when running pred-distributed jobs

Cleaned up methods

Enabled Mockito testing for CCS and NCS

Added Unit Test for Distributed Jobs

Change-Id: I59c3422d5c1ab7756a6a4685ac527dfe50434954

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1377

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Yingyi Bu <buyingyi@gmail.com>

    • -19
    • +25
    ./active/ActiveJobNotificationHandler.java
  1. … 40 more files in changeset.
ASTERIXDB-1711: remove more mentions of Asterix

Change-Id: I21666fd54075ac56de8aab76bb7d5cdbec020121

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1387

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Steven Jacobs <sjaco002@ucr.edu>

    • -2
    • +2
    ./active/ActiveSourceOperatorNodePushable.java
    • -3
    • +3
    ./active/message/ActiveManagerMessage.java
  1. … 569 more files in changeset.
Prepare AsterixDB for Pre-Distributed Jobs

Change-Id: Id809f4b563bbed808c7764d1af664a15919db35b

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1366

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

    • -6
    • +3
    ./active/ActiveSourceOperatorNodePushable.java
  1. … 9 more files in changeset.
Enhanced Insert AQL

The optional "as Variable" provides a variable binding for the inserted records

The optional "returning Query" allows users to run simple

queries/functions on the records returned by the insert, and can refer

to the variable bound in "as Variable"

Allow commits to be non-sink operators (contnue job pipeline after commit)

Additionally, this change makes small modifications to

the extension code to prepare for the BAD extension

Also made the OptimizerTests able to work for Extensions

Change-Id: I65789d2a861d15232dd29156a6987d0635ec6c94

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1150

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

    • -1
    • +1
    ./active/IActiveEntityEventsListener.java
  1. … 80 more files in changeset.
Wait For Metadata Registration Before Active, Etc.

Also:

- metadata.port moved to [app]; honored

- += metadata.node to [app] to optionally specify metadata node

- += metadata.callback.port to [app]

- Decrease timeout for metadata registration from 7 days to default of

one minute, configurable with property

- Log swallowed exception in SynchronizableWork

- Add missing properties (metadata) to cluster state http api

- Make AsterixPropertiesAccessor, to ensure consistent values when

accessed in virtual cluster

Change-Id: I48d7c10b3e43181ec307f7d890ba721f61bc2ab0

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1247

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Till Westmann <tillw@apache.org>

    • -1
    • +1
    ./active/message/ActiveManagerMessage.java
  1. … 42 more files in changeset.
Run Active Shutdown On Separate Thread

- As feed shutdown can be slow, do it on another thread to not tie up

worker.

- use nc thread executor for feed adapter thread

- error handling

Change-Id: I8fd9bc454b290420682160364ac78e4b91a9abc3

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1223

Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: Till Westmann <tillw@apache.org>

    • -9
    • +4
    ./active/ActiveSourceOperatorNodePushable.java
  1. … 3 more files in changeset.
Small Cleanup Towards Fixing LifeCycle Issues

Before this change, dataset lifecycle manager was providing a set

of functionalities that are loosly related to management of datasets

and indexes. However, it was not clear what the possible states of

a dataset or an index and what is the responsibility of each object.

This change takes the first step towards fixing this area. Indexes

of a dataset are now grouped together under a single lifecycle class

A resource aka dataset must be created outside the lifecycle manager

and registered with it before it can be assigned resources (memory)

and before it can be used by any operation. This is still not the

case.

Change-Id: I84005a33837725f41ae63297a3711215dccce1d8

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1148

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

    • -4
    • +4
    ./active/message/ActiveManagerMessage.java
  1. … 69 more files in changeset.
Refactor Messaging

In this refactoring, each message implementation includes

a handle method. This avoids bloating of message brokers

and enable better extensibility for messaging.

Change-Id: I7c918bf504058c98ecf89f5b019503278e9aa01f

Reviewed-on: https://asterix-gerrit.ics.uci.edu/1128

Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

Reviewed-by: abdullah alamoudi <bamousaa@gmail.com>

    • -0
    • +82
    ./active/ActiveLifecycleListener.java
    • -5
    • +18
    ./active/message/ActiveManagerMessage.java
  1. … 124 more files in changeset.