Skip to content

Conversation

@EmmyMiao87
Copy link
Contributor

  1. fix the nesting lock of db and txn
  2. the txn of task will be init in task scheduler before take task from queue

1. fix the nesting lock of db and txn
2. the txn of task will be init in task scheduler before take task from queue
}
}

public List<Long> getBackendIdsByCluster(String clusterName) throws MetaNotFoundException {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We already have a method in SystemInfoService

ConnectContext.get().getQualifiedUser(),
ConnectContext.get().getRemoteIP(),
routineLoadJob.getTableName());
try {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Check priv does not throw MetaNotFoundException

public long getMinTaskBeId() throws LoadException {
public long getMinTaskBeId(String clusterName) throws LoadException {
List<Long> beIdsInCluster = new ArrayList<>();
try {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Use method in SystemInfoService


abstract TRoutineLoadTask createRoutineLoadTask() throws LoadException, UserException;

public void setTxn() throws LabelAlreadyUsedException, BeginTransactionException, AnalysisException {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

better to name it 'beginTxn'?

@morningman morningman merged commit 11d6e3a into apache:kafka_routine_load Mar 5, 2019
morningman pushed a commit to morningman/doris that referenced this pull request Mar 25, 2019
1. fix the nesting lock of db and txn
2. the txn of task will be init in task scheduler before take task from queue
morningman pushed a commit that referenced this pull request Mar 25, 2019
1. fix the nesting lock of db and txn
2. the txn of task will be init in task scheduler before take task from queue
morningman pushed a commit to morningman/doris that referenced this pull request Apr 4, 2019
1. fix the nesting lock of db and txn
2. the txn of task will be init in task scheduler before take task from queue
morningman pushed a commit that referenced this pull request Apr 4, 2019
1. fix the nesting lock of db and txn
2. the txn of task will be init in task scheduler before take task from queue
morningman pushed a commit that referenced this pull request Apr 19, 2019
1. fix the nesting lock of db and txn
2. the txn of task will be init in task scheduler before take task from queue
EmmyMiao87 added a commit to EmmyMiao87/incubator-doris that referenced this pull request Apr 23, 2019
1. fix the nesting lock of db and txn
2. the txn of task will be init in task scheduler before take task from queue
morningman pushed a commit that referenced this pull request Apr 24, 2019
1. fix the nesting lock of db and txn
2. the txn of task will be init in task scheduler before take task from queue
imay pushed a commit that referenced this pull request Apr 28, 2019
1. fix the nesting lock of db and txn
2. the txn of task will be init in task scheduler before take task from queue
luwei16 pushed a commit to luwei16/Doris that referenced this pull request Sep 12, 2022
…pache#687)

Some basic unit test for meta service
* create_instance get_cluster
* get_tablet_stats
* begin_txn precommit_txn commit_txn

there are more to be done.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants