Skip to content

Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt #786

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.

Sign up for GitHub

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

Jump to bottom
Merged
morningman merged 1 commit into from
Mar 21, 2019
Merged

Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt #786

morningman merged 1 commit into from
Mar 21, 2019

Conversation

@EmmyMiao87
Copy link
Contributor

@EmmyMiao87 EmmyMiao87 commented Mar 21, 2019

  1. ShowRoutineLoadStmt is sames like class description. It does not support show all of routine load job in all of db
  2. ShowRoutineLoadTaskStmt is sames like class description. It does not support show all of routine laod task in all of job
  3. Init partitionIdsToOffset in constructor of KafkaProgress
  4. Change Create/Pause/Resume/Stop routine load job to LabelName such as [db.]name
  5. Exclude final job when updating job
  6. Catch all of exception when scheduling one job. The exception will not block the another jobs.

@EmmyMiao87
Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt
e2ab2fb 
1. ShowRoutineLoadStmt is sames like class description. It does not support show all of routine load job in all of db
2. ShowRoutineLoadTaskStmt is sames like class description. It does not support show all of routine laod task in all of job
3. Init partitionIdsToOffset in constructor of KafkaProgress
4. Change Create/Pause/Resume/Stop routine load job to LabelName such as [db.]name
5. Exclude final job when updating job
6. Catch all of exception when scheduling one job. The exception will not block the another jobs.
@morningman morningman merged commit 9497fe3 into apache:kafka_routine_load Mar 21, 2019
morningman pushed a commit to morningman/doris that referenced this pull request Mar 25, 2019
@EmmyMiao87 @morningman
Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt (apache#786)
d918df5 
1. ShowRoutineLoadStmt is sames like class description. It does not support show all of routine load job in all of db
2. ShowRoutineLoadTaskStmt is sames like class description. It does not support show all of routine laod task in all of job
3. Init partitionIdsToOffset in constructor of KafkaProgress
4. Change Create/Pause/Resume/Stop routine load job to LabelName such as [db.]name
5. Exclude final job when updating job
6. Catch all of exception when scheduling one job. The exception will not block the another jobs.
morningman pushed a commit that referenced this pull request Mar 25, 2019
@EmmyMiao87 @morningman
Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt (#786)
48d1d6b 
1. ShowRoutineLoadStmt is sames like class description. It does not support show all of routine load job in all of db
2. ShowRoutineLoadTaskStmt is sames like class description. It does not support show all of routine laod task in all of job
3. Init partitionIdsToOffset in constructor of KafkaProgress
4. Change Create/Pause/Resume/Stop routine load job to LabelName such as [db.]name
5. Exclude final job when updating job
6. Catch all of exception when scheduling one job. The exception will not block the another jobs.
morningman pushed a commit to morningman/doris that referenced this pull request Apr 4, 2019
@EmmyMiao87 @morningman
Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt (apache#786)
75f8ead 
1. ShowRoutineLoadStmt is sames like class description. It does not support show all of routine load job in all of db
2. ShowRoutineLoadTaskStmt is sames like class description. It does not support show all of routine laod task in all of job
3. Init partitionIdsToOffset in constructor of KafkaProgress
4. Change Create/Pause/Resume/Stop routine load job to LabelName such as [db.]name
5. Exclude final job when updating job
6. Catch all of exception when scheduling one job. The exception will not block the another jobs.
morningman pushed a commit that referenced this pull request Apr 4, 2019
@EmmyMiao87 @morningman
Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt (#786)
ee23195 
1. ShowRoutineLoadStmt is sames like class description. It does not support show all of routine load job in all of db
2. ShowRoutineLoadTaskStmt is sames like class description. It does not support show all of routine laod task in all of job
3. Init partitionIdsToOffset in constructor of KafkaProgress
4. Change Create/Pause/Resume/Stop routine load job to LabelName such as [db.]name
5. Exclude final job when updating job
6. Catch all of exception when scheduling one job. The exception will not block the another jobs.
morningman pushed a commit that referenced this pull request Apr 19, 2019
@EmmyMiao87 @morningman
Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt (#786)
3841719 
1. ShowRoutineLoadStmt is sames like class description. It does not support show all of routine load job in all of db
2. ShowRoutineLoadTaskStmt is sames like class description. It does not support show all of routine laod task in all of job
3. Init partitionIdsToOffset in constructor of KafkaProgress
4. Change Create/Pause/Resume/Stop routine load job to LabelName such as [db.]name
5. Exclude final job when updating job
6. Catch all of exception when scheduling one job. The exception will not block the another jobs.
EmmyMiao87 added a commit to EmmyMiao87/incubator-doris that referenced this pull request Apr 23, 2019
@EmmyMiao87
Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt (apache#786)
c214eac 
1. ShowRoutineLoadStmt is sames like class description. It does not support show all of routine load job in all of db
2. ShowRoutineLoadTaskStmt is sames like class description. It does not support show all of routine laod task in all of job
3. Init partitionIdsToOffset in constructor of KafkaProgress
4. Change Create/Pause/Resume/Stop routine load job to LabelName such as [db.]name
5. Exclude final job when updating job
6. Catch all of exception when scheduling one job. The exception will not block the another jobs.
morningman pushed a commit that referenced this pull request Apr 24, 2019
@EmmyMiao87 @morningman
Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt (#786)
663fb70 
1. ShowRoutineLoadStmt is sames like class description. It does not support show all of routine load job in all of db
2. ShowRoutineLoadTaskStmt is sames like class description. It does not support show all of routine laod task in all of job
3. Init partitionIdsToOffset in constructor of KafkaProgress
4. Change Create/Pause/Resume/Stop routine load job to LabelName such as [db.]name
5. Exclude final job when updating job
6. Catch all of exception when scheduling one job. The exception will not block the another jobs.
imay pushed a commit that referenced this pull request Apr 28, 2019
@EmmyMiao87 @imay
Implement ShowRoutineLoadStmt and ShowRoutineLoadTaskStmt (#786)
d213f92 
1. ShowRoutineLoadStmt is sames like class description. It does not support show all of routine load job in all of db
2. ShowRoutineLoadTaskStmt is sames like class description. It does not support show all of routine laod task in all of job
3. Init partitionIdsToOffset in constructor of KafkaProgress
4. Change Create/Pause/Resume/Stop routine load job to LabelName such as [db.]name
5. Exclude final job when updating job
6. Catch all of exception when scheduling one job. The exception will not block the another jobs.
platoneko pushed a commit to platoneko/doris that referenced this pull request Oct 27, 2022
@mymeiyi
[feature](selectdb-cloud) Copy into: fix list objects and support glob (
7351c4e 
apache#786)

* Fix list objects for OSS
* Support glob syntax in copy stmt
* Remove pattern and files syntax
* Change the error msg to 'no files can be copied
* Change package name from com.selectdb.cloud.objectsigner to com.selectdb.cloud.storage

copy into stmt, e.g.
```
copy into t2 from @ex_stage_1('*.csv');

copy into t2 from @ex_stage_1('{1.csv,2.csv}');

copy into t24 from @mys4('{1_my.csv,2_my.csv}') 
file_format= ( 'type' = 'CSV', 'column_separator' = "," ) 
copy_option = ('on_error'='max_filter_ratio_0.4') 
async = false;

copy into t2 from (select $3, $1, $2 from @ex_stage_1('/*.csv'))
file_format= ( 'type' = 'CSV', 'column_separator' = "," ) 
copy_option = ('on_error'='max_filter_ratio_0.4') 
async = true;
```
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

2 participants

@EmmyMiao87 @morningman