You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by "DalongZhenZ (via GitHub)" <gi...@apache.org> on 2023/11/03 05:45:20 UTC

[I] [Bug] [Module Name] Bug title seatunnel2.3.3 use Dolphinscheduler can not save task [dolphinscheduler]

DalongZhenZ opened a new issue, #15113:
URL: https://github.com/apache/dolphinscheduler/issues/15113

   ### Search before asking
   
   - [X] I had searched in the [issues](https://github.com/apache/dolphinscheduler/issues?q=is%3Aissue) and found no similar issues.
   
   
   ### What happened
   
   version:
   Dolphinscheduler   3.1.7
   seatunnel                2.3.3 
   
   what happend:
   seatunne use Dolphinscheduler can not save task
   
   
   ### What you expected to happen
   
   
   my seatunnel config:  use Dolphinscheduler    can not save 
   -------------------------------------------------------------------------
   env {
    
     job.mode = "BATCH"
    
   }
   
   source {
     Jdbc {
    driver = "com.mysql.cj.jdbc.Driver"
    url = "jdbc:mysql://xxxx:xxxxx/uat_sycompreappealm?serverTimezone=GMT%2b8&characterEncoding=utf-8"
    user = "root"
    password = "xx"
    query = "select phone,card_no from uat_sycompreappealm.complaint_handling"
    } 
   }
   sink {
    Jdbc {
    url = "jdbc:mysql://xxxx:xxxxx:xxxx/test?serverTimezone=GMT%2b8&characterEncoding=utf-8"
    driver = "com.mysql.cj.jdbc.Driver"
    user = "root"
    password = "xxx"
    generate_sink_sql = true
    database = test
    table = ddddddd
    
   } 
   }
   -----------------------------------------------------------------------
   
   but   like this:
   
   ---------------------
   env {
     job.mode = "BATCH"
   }
   
   source {
   console{}
   }
   sink {
   console{}
   }
   
   it can save 
   
   ### How to reproduce
   
   seatunnel can not save task
   
   ### Anything else
   
   ![image](https://github.com/apache/dolphinscheduler/assets/60906603/f9c1c9e0-2775-4e9b-8b46-74a162ee5c49)
   
   
   ### Version
   
   3.1.x
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
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: commits-unsubscribe@dolphinscheduler.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] [Bug] [Task] Bug title seatunnel2.3.3 use Dolphinscheduler can not save task [dolphinscheduler]

Posted by "zhongjiajie (via GitHub)" <gi...@apache.org>.
zhongjiajie closed issue #15113: [Bug] [Task] Bug title seatunnel2.3.3 use Dolphinscheduler can not save task
URL: https://github.com/apache/dolphinscheduler/issues/15113


-- 
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: commits-unsubscribe@dolphinscheduler.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] [Bug] [Task] Bug title seatunnel2.3.3 use Dolphinscheduler can not save task [dolphinscheduler]

Posted by "DalongZhenZ (via GitHub)" <gi...@apache.org>.
DalongZhenZ commented on issue #15113:
URL: https://github.com/apache/dolphinscheduler/issues/15113#issuecomment-1803168525

   this is all log,  i want to know ,where reason cause this wrong, it's mysql catalog database  or othen reason?
   
   
   
   Caused by: org.eclipse.jetty.io.EofException: Early EOF
   	at org.eclipse.jetty.server.HttpInput$3.getError(HttpInput.java:1207)
   	at org.eclipse.jetty.server.HttpInput$3.noContent(HttpInput.java:1195)
   	at org.eclipse.jetty.server.HttpInput.read(HttpInput.java:333)
   	at org.eclipse.jetty.server.HttpInput.read(HttpInput.java:270)
   	at org.eclipse.jetty.util.UrlEncoded.decodeUtf8To(UrlEncoded.java:485)
   	at org.eclipse.jetty.util.UrlEncoded.decodeTo(UrlEncoded.java:577)
   	at org.eclipse.jetty.server.Request.extractFormParameters(Request.java:595)
   	... 77 common frames omitted
   [WARN] 2023-11-09 10:57:04.751 +0800 org.springframework.web.servlet.mvc.method.annotation.ExceptionHandlerExceptionResolver:[434] - Failure in @ExceptionHandler org.apache.dolphinscheduler.api.exceptions.ApiExceptionHandler#exceptionHandler(Exception, HandlerMethod)
   org.eclipse.jetty.io.EofException: null
   	at org.eclipse.jetty.io.ChannelEndPoint.flush(ChannelEndPoint.java:280)
   	at org.eclipse.jetty.io.WriteFlusher.flush(WriteFlusher.java:422)
   	at org.eclipse.jetty.io.WriteFlusher.write(WriteFlusher.java:277)
   	at org.eclipse.jetty.io.AbstractEndPoint.write(AbstractEndPoint.java:381)
   	at org.eclipse.jetty.server.HttpConnection$SendCallback.process(HttpConnection.java:825)
   	at org.eclipse.jetty.util.IteratingCallback.processing(IteratingCallback.java:241)
   	at org.eclipse.jetty.util.IteratingCallback.iterate(IteratingCallback.java:223)
   	at org.eclipse.jetty.server.HttpConnection.send(HttpConnection.java:555)
   	at org.eclipse.jetty.server.HttpChannel.sendResponse(HttpChannel.java:1009)
   	at org.eclipse.jetty.server.HttpChannel.write(HttpChannel.java:1086)
   	at org.eclipse.jetty.server.handler.gzip.GzipHttpOutputInterceptor$GzipBufferCB.process(GzipHttpOutputInterceptor.java:414)
   	at org.eclipse.jetty.util.IteratingCallback.processing(IteratingCallback.java:241)
   	at org.eclipse.jetty.util.IteratingCallback.iterate(IteratingCallback.java:223)
   	at org.eclipse.jetty.server.handler.gzip.GzipHttpOutputInterceptor.gzip(GzipHttpOutputInterceptor.java:137)
   	at org.eclipse.jetty.server.handler.gzip.GzipHttpOutputInterceptor.commit(GzipHttpOutputInterceptor.java:238)
   	at org.eclipse.jetty.server.handler.gzip.GzipHttpOutputInterceptor.write(GzipHttpOutputInterceptor.java:107)
   	at org.eclipse.jetty.server.HttpOutput.channelWrite(HttpOutput.java:285)
   	at org.eclipse.jetty.server.HttpOutput.channelWrite(HttpOutput.java:269)
   	at org.eclipse.jetty.server.HttpOutput.flush(HttpOutput.java:751)
   	at java.io.FilterOutputStream.flush(FilterOutputStream.java:140)
   	at com.fasterxml.jackson.core.json.UTF8JsonGenerator.flush(UTF8JsonGenerator.java:1187)
   	at com.fasterxml.jackson.databind.ObjectWriter.writeValue(ObjectWriter.java:1009)
   	at org.springframework.http.converter.json.AbstractJackson2HttpMessageConverter.writeInternal(AbstractJackson2HttpMessageConverter.java:456)
   	at org.springframework.http.converter.AbstractGenericHttpMessageConverter.write(AbstractGenericHttpMessageConverter.java:104)
   	at org.springframework.web.servlet.mvc.method.annotation.AbstractMessageConverterMethodProcessor.writeWithMessageConverters(AbstractMessageConverterMethodProcessor.java:290)
   	at org.springframework.web.servlet.mvc.method.annotation.RequestResponseBodyMethodProcessor.handleReturnValue(RequestResponseBodyMethodProcessor.java:183)
   	at org.springframework.web.method.support.HandlerMethodReturnValueHandlerComposite.handleReturnValue(HandlerMethodReturnValueHandlerComposite.java:78)
   	at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:135)
   	at org.springframework.web.servlet.mvc.method.annotation.ExceptionHandlerExceptionResolver.doResolveHandlerMethodException(ExceptionHandlerExceptionResolver.java:428)
   	at org.springframework.web.servlet.handler.AbstractHandlerMethodExceptionResolver.doResolveException(AbstractHandlerMethodExceptionResolver.java:75)
   	at org.springframework.web.servlet.handler.AbstractHandlerExceptionResolver.resolveException(AbstractHandlerExceptionResolver.java:142)
   	at org.springframework.web.servlet.handler.HandlerExceptionResolverComposite.resolveException(HandlerExceptionResolverComposite.java:80)
   	at org.springframework.web.servlet.DispatcherServlet.processHandlerException(DispatcherServlet.java:1330)
   	at org.springframework.web.servlet.DispatcherServlet.processDispatchResult(DispatcherServlet.java:1141)
   	at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1087)
   	at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:963)
   	at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)
   	at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:909)
   	at javax.servlet.http.HttpServlet.service(HttpServlet.java:517)
   	at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)
   	at javax.servlet.http.HttpServlet.service(HttpServlet.java:584)
   	at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:799)
   	at org.eclipse.jetty.servlet.ServletHandler$ChainEnd.doFilter(ServletHandler.java:1656)
   	at org.springframework.web.filter.CorsFilter.doFilterInternal(CorsFilter.java:91)
   	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
   	at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
   	at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1626)
   	at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)
   	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
   	at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
   	at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1626)
   	at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)
   	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
   	at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
   	at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1626)
   	at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:96)
   	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
   	at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
   	at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1626)
   	at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)
   	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
   	at org.eclipse.jetty.servlet.FilterHolder.doFilter(FilterHolder.java:193)
   	at org.eclipse.jetty.servlet.ServletHandler$Chain.doFilter(ServletHandler.java:1626)
   	at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:552)
   	at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
   	at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:600)
   	at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
   	at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:235)
   	at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1624)
   	at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
   	at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1440)
   	at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
   	at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:505)
   	at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1594)
   	at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
   	at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1355)
   	at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
   	at org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:772)
   	at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
   	at org.eclipse.jetty.server.Server.handle(Server.java:516)
   	at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:487)
   	at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:732)
   	at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:479)
   	at org.eclipse.jetty.server.HttpChannelOverHttp.earlyEOF(HttpChannelOverHttp.java:237)
   	at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:1620)
   	at org.eclipse.jetty.server.HttpConnection.parseRequestBuffer(HttpConnection.java:381)
   	at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:265)
   	at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
   	at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:105)
   	at org.eclipse.jetty.io.ChannelEndPoint$1.run(ChannelEndPoint.java:104)
   	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:338)
   	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:315)
   	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:173)
   	at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:131)
   	at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:409)
   	at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:883)
   	at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:1034)
   	at java.lang.Thread.run(Thread.java:748)
   Caused by: java.io.IOException: 断开的管道
   	at sun.nio.ch.FileDispatcherImpl.writev0(Native Method)
   	at sun.nio.ch.SocketDispatcher.writev(d.java:51)
   	at sun.nio.ch.IOUtil.write(IOUtil.java:148)
   	at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:504)
   	at java.nio.channels.SocketChannel.write(SocketChannel.java:502)
   	at org.eclipse.jetty.io.ChannelEndPoint.flush(ChannelEndPoint.java:274)
   	... 97 common frames omitted
   


-- 
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: commits-unsubscribe@dolphinscheduler.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] [Bug] [Task] Bug title seatunnel2.3.3 use Dolphinscheduler can not save task [dolphinscheduler]

Posted by "zhongjiajie (via GitHub)" <gi...@apache.org>.
zhongjiajie commented on issue #15113:
URL: https://github.com/apache/dolphinscheduler/issues/15113#issuecomment-1916338048

   if you have further issue, please reopen it


-- 
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: commits-unsubscribe@dolphinscheduler.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] [Bug] [Module Name] Bug title seatunnel2.3.3 use Dolphinscheduler can not save task [dolphinscheduler]

Posted by "DalongZhenZ (via GitHub)" <gi...@apache.org>.
DalongZhenZ commented on issue #15113:
URL: https://github.com/apache/dolphinscheduler/issues/15113#issuecomment-1800920838

   when i click  save   ,the interface param rawScript is not current,  make this wrong 


-- 
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: commits-unsubscribe@dolphinscheduler.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] [Bug] [Module Name] Bug title seatunnel2.3.3 use Dolphinscheduler can not save task [dolphinscheduler]

Posted by "DalongZhenZ (via GitHub)" <gi...@apache.org>.
DalongZhenZ commented on issue #15113:
URL: https://github.com/apache/dolphinscheduler/issues/15113#issuecomment-1800897625

   
   This problem may be caused by front-end parameter \n resulting in parameter error
   ![image](https://github.com/apache/dolphinscheduler/assets/60906603/b19c24ea-dc64-46bd-8ccf-fd72045fc7e4)
   


-- 
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: commits-unsubscribe@dolphinscheduler.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] [Bug] [Task] Bug title seatunnel2.3.3 use Dolphinscheduler can not save task [dolphinscheduler]

Posted by "zhongjiajie (via GitHub)" <gi...@apache.org>.
zhongjiajie commented on issue #15113:
URL: https://github.com/apache/dolphinscheduler/issues/15113#issuecomment-1916337330

   > I have solved this problem @davidzollo
   > 
   > seatunnel 2.2.3 dolphinscheduler 3.2.0 mysql to mysql
   > 
   > ## the source query must use select 'field1',`field2` (for all fields) from database.table,
   > and the fields must be marked with `` instead of using select * from database.table ,
   > otherwise the workflow creation will fail
   > ,it's can throw
   > org.eclipse.jetty.io.RuntimeIOException: org.eclipse.jetty.io.EofException: Early EOF and org.apache.dolphinscheduler.api.exceptions.ApiExceptionHandler:[52] - 创建工作流错误
   > major reason is it's can use (select `id`,`code` from xx.xx) ,it's can't use(select * from xx.xx)
   > 
   > i use my computer it's naomal, but it's not good in my company linux server, i test dolphinscheduler 3.1.0 , 3.1.7 , 3.2.0 , in my now linux server, althrough have this question, i still don't know what course ? i guest maby my mysql database reason
   
   maybe your database administrator disable the `select *` for, please contact them, and I think is unrelated to dolphinscheduler


-- 
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: commits-unsubscribe@dolphinscheduler.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] [Bug] [Module Name] Bug title seatunnel2.3.3 use Dolphinscheduler can not save task [dolphinscheduler]

Posted by "DalongZhenZ (via GitHub)" <gi...@apache.org>.
DalongZhenZ commented on issue #15113:
URL: https://github.com/apache/dolphinscheduler/issues/15113#issuecomment-1800919635

   it‘s this 


-- 
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: commits-unsubscribe@dolphinscheduler.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] [Bug] [Task] Bug title seatunnel2.3.3 use Dolphinscheduler can not save task [dolphinscheduler]

Posted by "DalongZhenZ (via GitHub)" <gi...@apache.org>.
DalongZhenZ commented on issue #15113:
URL: https://github.com/apache/dolphinscheduler/issues/15113#issuecomment-1803391927

   I have solved this problem, and the source query must use 'select' for all fields, and the fields must be marked with '' instead of using 'select *', otherwise the workflow creation will fail  
   *----------------------------------------------------------------+
   but it's good in other linux server,i still don't know what course ?
   [https://github.com/apache/dolphinscheduler/issues/15113](url)


-- 
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: commits-unsubscribe@dolphinscheduler.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org