- 
                Notifications
    
You must be signed in to change notification settings  - Fork 4.9k
 
[DSIP-90][plugin] Introduce new task plugin for Flink materialized table #17201
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
base: dev
Are you sure you want to change the base?
Conversation
| 
           Thanks for opening this pull request! Please check out our contributing guidelines. (https://github.com/apache/dolphinscheduler/blob/dev/docs/docs/en/contribute/join/pull-request.md)  | 
    
adb610e    to
    04d013f      
    Compare
  
    | 
           Hi, @ruanwenjun, @SbloodyS can you help review this pr?  | 
    
| 
           Please check the failed CI. @hackergin  | 
    
284d06b    to
    ab0a878      
    Compare
  
            
          
                ...able/src/main/java/org/apache/dolphinscheduler/plugin/task/flink/gateway/FlinkSqlClient.java
              
                Fixed
          
            Show fixed
            Hide fixed
        
      888b7dc    to
    033c3d4      
    Compare
  
            
          
                ...k-materialized-table/catalog_store/mydb/full_users_shops/schema/full_users_shops_schema.json
              
                Outdated
          
            Show resolved
            Hide resolved
        
              
          
                ...c/test/java/org/apache/dolphinscheduler/e2e/cases/WorkflowFlinkMaterializedTableE2ETest.java
          
            Show resolved
            Hide resolved
        
      ab3c85c    to
    0e1151d      
    Compare
  
    0032ecd    to
    5343781      
    Compare
  
    5343781    to
    55aab6a      
    Compare
  
    
          
 | 
    
| 
           Two CI issues: 
 @SbloodyS Should I address the coverage issue or is it OK to proceed as-is?  | 
    
          
 
 Yes.  | 
    


Purpose of the pull request
Add a new task plugin for refresh flink materialized table.
close #17086
Brief change log
Verify this pull request