-
Notifications
You must be signed in to change notification settings - Fork 3.7k
[feat](job)Implementing Job in Nereids #41391
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
Conversation
|
Thank you for your contribution to Apache Doris. Since 2024-03-18, the Document has been moved to doris-website. |
fe/fe-core/src/main/antlr4/org/apache/doris/nereids/DorisParser.g4
Outdated
Show resolved
Hide resolved
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CreateJobCommand.java
Show resolved
Hide resolved
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateJobInfo.java
Outdated
Show resolved
Hide resolved
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateJobInfo.java
Outdated
Show resolved
Hide resolved
...c/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java
Show resolved
Hide resolved
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateJobInfo.java
Outdated
Show resolved
Hide resolved
morningman
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
|
PR approved by at least one committer and no changes requested. |
|
PR approved by anyone and no changes requested. |
|
run buildall |
TPC-H: Total hot run time: 40888 ms |
TPC-DS: Total hot run time: 192017 ms |
ClickBench: Total hot run time: 32.76 s |
|
run buildall |
TPC-H: Total hot run time: 40872 ms |
TPC-DS: Total hot run time: 191587 ms |
ClickBench: Total hot run time: 33.02 s |
8ddd998 to
2f13bb9
Compare
|
run buildall |
TPC-H: Total hot run time: 40702 ms |
TPC-DS: Total hot run time: 192290 ms |
ClickBench: Total hot run time: 33.36 s |
|
run buildall |
TPC-H: Total hot run time: 40382 ms |
TPC-DS: Total hot run time: 192027 ms |
|
run performance |
| | SHOW CREATE MATERIALIZED VIEW mvName=multipartIdentifier #showCreateMTMV | ||
| ; | ||
|
|
||
| jobScheduleStatement |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| jobScheduleStatement | |
| supportedJobStatement |
| long base = TimeUnit.MINUTES.toMillis(connectionAgeBase); | ||
| long now = System.currentTimeMillis(); | ||
| long rand = random.nextLong(base); | ||
| long rand = random.nextLong() % base; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
already fixed, please rebase to newest master
| Optional<Long> interval = ctx.timeInterval == null ? Optional.empty() : | ||
| Optional.of(Long.valueOf(ctx.timeInterval.getText())); | ||
| Optional<String> intervalUnit = ctx.timeUnit == null ? Optional.empty() : Optional.of(ctx.timeUnit.getText()); | ||
| String commentSpec = ctx.commentSpec() == null ? "''" : ctx.commentSpec().STRING_LITERAL().getText(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
could u have add override visitCommentSpec, let it return processed comment string?
| sql """ | ||
| SET enable_fallback_to_original_planner=false; | ||
| """ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this variable has been removed and u do not need to add it
| ; | ||
|
|
||
| jobScheduleStatement | ||
| : CREATE JOB label=multipartIdentifier ON SCHEDULE |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove create job syntax in sql_parser.cup and remove CreateJobStmt.java
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I want to directly pick to 2.1, as 2.1 allows for a rollback. Therefore, this change will be provided in the next PR.:)
morningman
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
|
run buildall |
|
PR approved by at least one committer and no changes requested. |
|
run feut |
morningman
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
|
run cloud_p0 |
## Proposed changes The JOB's execution SQL is currently defined by an older CUP file, which causes some issues with lexical analysis in the new optimizer as it doesn't pass under the old optimizer. Since the JOB's underlying execution already uses the new optimizer, we're planning to fully migrate to ANTLR4 for consistency.
## Proposed changes The JOB's execution SQL is currently defined by an older CUP file, which causes some issues with lexical analysis in the new optimizer as it doesn't pass under the old optimizer. Since the JOB's underlying execution already uses the new optimizer, we're planning to fully migrate to ANTLR4 for consistency. (cherry picked from commit 334b473)
## Proposed changes The JOB's execution SQL is currently defined by an older CUP file, which causes some issues with lexical analysis in the new optimizer as it doesn't pass under the old optimizer. Since the JOB's underlying execution already uses the new optimizer, we're planning to fully migrate to ANTLR4 for consistency. (cherry picked from commit 334b473)
## Proposed changes The JOB's execution SQL is currently defined by an older CUP file, which causes some issues with lexical analysis in the new optimizer as it doesn't pass under the old optimizer. Since the JOB's underlying execution already uses the new optimizer, we're planning to fully migrate to ANTLR4 for consistency. (cherry picked from commit 334b473) #41391
Proposed changes
The JOB's execution SQL is currently defined by an older CUP file, which causes some issues with lexical analysis in the new optimizer as it doesn't pass under the old optimizer. Since the JOB's underlying execution already uses the new optimizer, we're planning to fully migrate to ANTLR4 for consistency.