Enabling Lineage V3¶

Applies from version 2022.1.2

Lineage V3 must be enabled if users want the ability to create lineage manually.

In order to enable Lineage V3 on an existing Alation instance, you need to migrate your lineage data from Lineage V2 to Lineage V3. Lineage V3 will become enabled automatically after the migration completes. If the migration fails, your instance will remain on Lineage V2.

Important

Alation recommends upgrading your Alation instance to version 2022.1.2 or newer in order to perform migration from Lineage V2 to V3.

Warning

The Lineage V2 to V3 migration may be a time-consuming and resource-intensive process, depending on the size of the existing lineage data. It requires a restart of several important Alation services. It is recommended to perform the lineage migration during off-peak hours when there is little user activity and when other resource-intensive processes, such as MDE, QLI, or search indexing are not running. The migration may take from a few minutes to a few hours depending on the size of the existing lineage data.

The migration process requires backend access to the Alation server. In case of HA pair configuration, perform the migration on the primary instance.

Prerequisites¶

You may be performing the lineage migration the very first time or retrying it after a failed attempt.

If this is your first time migrating the lineage data from Lineage V2 to V3, go to Lineage Migration Steps.

If you are retrying the migration after a failed attempt, begin with resetting the migration status pointer and then rerun the migration.

Resetting the Migration Status Pointer¶

If you had previously attempted to migrate the lineage data from Lineage V2 to V3 but your attempt resulted in a failure, you can rerun the migration from the very beginning. In order to do this, begin with resetting the migration status pointer to zero. The migration status pointer is a record in the internal database that documents the number of lineage links that were successfully migrated before the migration failed.

To reset the pointer:

Use SSH to connect to the Alation host.
Enter the Alation shell.
sudo /etc/init.d/alation shell
Enter the Alation Postgres shell.
alation_psql

Run the query given below to reset the migration pointer to zero:

update message_queue_pointer set pointer=0 where job_name='Lineage_V2_To_V3_Migration';

Run the next query to ensure that the message_queue_pointer was updated. The result should be zero.
select * from message_queue_pointer where job_name='Lineage_V2_To_V3_Migration';
Exit the Postgres shell.
\q
Stay in the Alation shell and perform the lineage migration steps below to rerun the migration from the beginning.

Lineage Migration Steps¶

Use the steps below to migrate lineage data from Lineage V2 to Lineage V3 and to activate the Lineage V3 functionality:

Before migrating, in your Alation Catalog, find data sources or BI sources that have lineage data. Save the URLs for Table or BI report pages with lineage. After running the migration script, you can use these data objects to validate that the lineage data is successfully migrated and the lineage diagrams are displayed without issues.
Use SSH to connect to the Alation server.
Enter the Alation shell:
sudo /etc/init.d/alation shell
Set the lineage logger level to debug. This logger setting will create more detailed logs, which will be helpful if troubleshooting is necessary.
4.1 Change the logger level:
alation_conf lineage-service.logger.level -s debug
4.2 Restart the lineage service for the changes to take effect:
alation_supervisor restart lineage
Ensure that the lineage service is running.
alation_supervisor status lineage
This command should return the status Running, for example:
(env) PROD [admin@ip-177-71-27-47 /]$ alation_supervisor status lineage lineage RUNNING pid 1184, uptime 5 days, 19:10:35
The Lineage service should be in the Running state even though the Lineage V3 has not been enabled yet. It is the expected state of the system.

Ensure that the Event Bus is running.

alation_supervisor status event-bus:*

This command should return the status Running, for example:

​(env) PROD [admin@ip-177-71-27-47 /]$ alation_supervisor status event-bus:*
event-bus:kafka-server       RUNNING   pid 1128, uptime 5 days, 19:11:05
event-bus:zookeeper-server   RUNNING   pid 1127, uptime 5 days, 19:11:05

Next, check the size of the lineage data to be migrated. This number can be used to estimate the time required for the migration. It takes about an hour to migrate 1GB of lineage data on an instance where the migration is not competing for resources with multiple other processes.

7.1 Enter the Postgres shell:
alation_psql
7.2 Run the following query:
select pg_size_pretty(pg_total_relation_size('object_lineage_link'));
Sample output:
```
rosemeta=# select pg_size_pretty(pg_total_relation_size('object_lineage_link'));

pg_size_pretty
----------------
1358 MB
(1 row)
```

Still in the Postgres shell, run the next query to get the unique link count from the object_lineage_link table. This number shows how many lineage links will need to be migrated. Take note of this number. It will be used to validate the completeness of the migration later.

select count(*) from (select distinct source, source_otype, target, target_otype from object_lineage_link) as links;

Sample output:

rosemeta=# select count(*) from (select distinct source, source_otype, target, target_otype from object_lineage_link) as links;

count
-------
427947
(1 row)

Exit the Postgres shell:
\q
(Optional step). If your lineage data is very large, you can optionally enable the Event Bus consumer throttling. If not, you can skip this step. During a very large V2 to V3 migration, the lineage service can potentially use a lot of memory which may affect other applications. Event Bus consumers can be throttled to allow small breaks between every batch so that they use less memory. This results in a slightly slower migration.

To enable the Event Bus consumer throttling:

10.1. In the Alation shell, enable the throttling:
alation_conf lineage-service.kafka.topics.consumer_throttling.enabled -s True
10.2. By default, the throttling begins when memory usage of the lineage service is at 90%. To change this value, use the command given below:
alation_conf lineage-service.kafka.topics.consumer_throttling.threshold -s <new threshold>
Example:
alation_conf lineage-service.kafka.topics.consumer_throttling.threshold -s 60
10.3. By default, the throttling allows for 1,000 milliseconds (1 second) to pass before another batch is consumed. To change this value, run:
alation_conf lineage-service.kafka.topics.consumer_throttling.duration -s <new duration in milliseconds>
Example:
alation_conf lineage-service.kafka.topics.consumer_throttling.duration -s 2000
10.4. Restart the service for the changes to take effect:
alation_supervisor restart lineage
The logs resulting from the lineage migration are written to the celery-default_error.log file. Alation recommends tailing this file during the migration. Open a separate terminal window and prepare to tail the logs, in the Alation shell. If you’re using a screen multiplexer, prepare to tail in a separate screen:
```
tail -f  /opt/alation/site/logs/celery-default_error.log
```
In the terminal window that is connected to the Alation host and Alation shell, enter the Alation Django shell:
```
alation_django_shell
```

Run the Lineage V3 migration script:

from rosemeta.tasks.migrations import migrate_lineage_v2_data_to_v3_database
migrate_lineage_v2_data_to_v3_database.delay()

This will kick off the migration job. The information about progress will be printed to the celery-default_error.log. At the end of the migration, you should see a success message similar to the following:

[2022-03-05 00:12:51,622: INFO/ForkPoolWorker-8] rosemeta.tasks.migrations.migrate_lineage_v2_data_to_v3_database[23e9a161-64cf-4da7-a1d0-ee1b1e783b8c]:
Lineage v2 to v3 migration task completed successfully.
You can check the job status in alation_django_shell by running....`j = Job.objects.filter(job_type=33).order_by('-ts_finished')` and then `j[0].__dict__`

After the migration completes, check the migration status. Still in the Django shell, run the following code:

job = Job.objects.filter(job_type=33).order_by("ts_started")
job[0].__dict__

In the output, look for the lines which contain status and state. Migration has succeeded if you find:

status: 1: means SUCCEEDED (migration has completed successfully)

state: 3 means FINISHED (migration has finished)

If you find out that the migration failed or has issues (the result is different from status: 1 and state: 3), see Troubleshooting Lineage V3 Migration.

Note

Job Status values:

N/A = 0

SUCCEEDED = 1

FAILED = 2

PARTIAL_SUCCESS = 3

SKIPPED = 4

Job State values:

NOT_STARTED = 0

QUEUED = 1

STARTED = 2

FINISHED = 3

The output will look similar to the following:

In [3]: job = Job.objects.filter(job_type=33).order_by("ts_started")

In [4]: job[0].__dict__
Out[4]:
{'_state': <django.db.models.base.ModelState at 0x7f7c402c6438>,
'id': 1695,
'user_id': None,
'_enum_job_type': 33,
'job_type': 33,
'external_service_aid': None,
'_enum_external_service_otype': None,
'external_service_otype': None,
'ts_started': datetime.datetime(2021, 12, 9, 2, 7, 45, 937116, tzinfo=<UTC>),
'ts_updated': datetime.datetime(2021, 12, 9, 2, 7, 48, 2729, tzinfo=<UTC>),
'ts_finished': datetime.datetime(2021, 12, 9, 2, 7, 48, 2729, tzinfo=<UTC>),
'_enum_status': 1,
'status': 1,
'_enum_state': 3,
'state': 3,
'state_message': 'Published 435 links',
'persisting_message': ['Processed batch with 545 links, is_last_batch: True',
'Published 435 links'],
'details': None,
'sync_subprocess_info': {'LINEAGE_V2_TO_V3_DATA_MIGRATION': '18685_797741740'},
'async_subprocess_info': {},
'disabled_task_name': None}

Exit the Django shell:
```
exit
```
Validate the number of the migrated lineage links.

16.1. Enter the Postgres shell:
alation_psql
16.2. Switch to the lineage database:
\c lineage
16.3. Run the following query:
select count(*) from edge where relation_type=1;
The count should be equal to the count of unique links you retrieved in Step 8 from the object_lineage_link table in Rosemeta. If the counts are not equal then there is some issue with the migration. See Troubleshooting Lineage V3 Migration.
16.4. Exit the Postgres shell:
\q
Restart the Celery component:
```
alation_supervisor restart celery:*
```
You can return to the default lineage logger level (info).
18.1. Run:
alation_conf -s info lineage-service.logger.level
18.2. Restart the lineage service.
Note

If you enabled Event Bus throttling before the migration, you can first disable it and then perform this restart. See the next step.

alation_supervisor restart lineage
If before the migration you enabled Event Bus throttling, you can now disable it.
19.1. Disable the corresponding alation_conf flag:
alation_conf lineage-service.kafka.topics.consumer_throttling.enabled -s False
19.2. Restart the service:
alation_supervisor restart lineage
Exit the Alation shell:
```
exit
```
Log in to Alation and verify your lineage data in the Alation UI. There should be no changes to the content of the lineage diagrams. If the lineage data does not appear or there are issues with the diagrams, for example, existing objects appear as temporary objects or diagrams only show partial data, contact the Alation Support.

The migration script automatically enables the Lineage V3 service. No additional actions are required to enable it. Next, you can enable Manual Lineage Curation. See Enabling Manual Lineage Curation <Manual_Lineage_Curation-Enable>.

Disabling Lineage V3¶

Alation does not recommend going back to Lineage V2 after enabling and using Lineage V3 as disabling V3 will result in an outdated state of the lineage data in the Catalog. Although not recommended, turning off Lineage V3 is still possible.

If you observe issues with the CPU or memory consumption while using Lineage V3 that you consider critical to the instance health, you can fall back onto Lineage V2.

Note that the new lineage data that was created on Lineage V3 will not be auto-migrated to Lineage V2 when you disable Lineage V3. The lineage graphs that were created manually, automatically, or using the API on Lineage V3 will not be available after Lineage V3 is disabled. The lineage data will return to the state before the lineage data was migrated to Lineage V3.

Contact Alation Support to help you return to using Lineage V2.