Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]

2024-05-23 Thread via GitHub
lsyldliu merged PR #24821: URL: https://github.com/apache/flink/pull/24821 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]

2024-05-23 Thread via GitHub
lsyldliu commented on code in PR #24821: URL: https://github.com/apache/flink/pull/24821#discussion_r1612535733 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/workflow/scheduler/EmbeddedQuartzScheduler.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed

Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]

2024-05-23 Thread via GitHub
lsyldliu commented on code in PR #24821: URL: https://github.com/apache/flink/pull/24821#discussion_r1612532405 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/workflow/scheduler/QuartzSchedulerUtils.java: ## @@ -0,0 +1,125 @@ +/* + * Licensed to

Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]

2024-05-23 Thread via GitHub
hackergin commented on code in PR #24821: URL: https://github.com/apache/flink/pull/24821#discussion_r1611566207 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/workflow/scheduler/EmbeddedQuartzScheduler.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed

Re: [PR] [FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table [flink]

2024-05-23 Thread via GitHub
hackergin commented on code in PR #24821: URL: https://github.com/apache/flink/pull/24821#discussion_r1611267560 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/SqlGatewayRestEndpoint.java: ## @@ -181,11 +193,57 @@ private void