[jira] [Commented] (TUBEMQ-437) When using flink connector tubemq to create a table environment error

[ https://issues.apache.org/jira/browse/TUBEMQ-437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242290#comment-17242290 ] duli commented on TUBEMQ-437: - Thanks for your report, I will fix this issue as soon as possible > When

[jira] [Resolved] (TUBEMQ-208) Change the test resource file's folder name to 'resources'

[ https://issues.apache.org/jira/browse/TUBEMQ-208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli resolved TUBEMQ-208. - Resolution: Fixed > Change the test resource file's folder name to 'resources' >

[jira] [Resolved] (TUBEMQ-242) Support Table interface for TubeMQ flink connector

[ https://issues.apache.org/jira/browse/TUBEMQ-242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli resolved TUBEMQ-242. - Resolution: Implemented > Support Table interface for TubeMQ flink connector >

[jira] [Resolved] (TUBEMQ-199) Support TubeMQ sink for flink

[ https://issues.apache.org/jira/browse/TUBEMQ-199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli resolved TUBEMQ-199. - Resolution: Implemented > Support TubeMQ sink for flink > - > > Key:

[jira] [Updated] (TUBEMQ-243) Add some debug level logs to trace exceptions

[ https://issues.apache.org/jira/browse/TUBEMQ-243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-243: Description: Currently, the most codes in project only logged a brief exception message by log4j when throwing

[jira] [Assigned] (TUBEMQ-243) Add some debug level logs to trace exceptions

[ https://issues.apache.org/jira/browse/TUBEMQ-243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli reassigned TUBEMQ-243: --- Assignee: duli > Add some debug level logs to trace exceptions >

[jira] [Created] (TUBEMQ-243) Add some debug level logs to trace exceptions

duli created TUBEMQ-243: --- Summary: Add some debug level logs to trace exceptions Key: TUBEMQ-243 URL: https://issues.apache.org/jira/browse/TUBEMQ-243 Project: Apache TubeMQ Issue Type: Improvement

[jira] [Assigned] (TUBEMQ-242) Support Table interface for TubeMQ flink connector

[ https://issues.apache.org/jira/browse/TUBEMQ-242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli reassigned TUBEMQ-242: --- Assignee: duli > Support Table interface for TubeMQ flink connector >

[jira] [Created] (TUBEMQ-242) Support Table interface for TubeMQ flink connector

duli created TUBEMQ-242: --- Summary: Support Table interface for TubeMQ flink connector Key: TUBEMQ-242 URL: https://issues.apache.org/jira/browse/TUBEMQ-242 Project: Apache TubeMQ Issue Type: Sub-task

[jira] [Created] (TUBEMQ-210) Add log4j properties file for unit tests

duli created TUBEMQ-210: --- Summary: Add log4j properties file for unit tests Key: TUBEMQ-210 URL: https://issues.apache.org/jira/browse/TUBEMQ-210 Project: Apache TubeMQ Issue Type: Bug

[jira] [Assigned] (TUBEMQ-210) Add log4j properties file for unit tests

[ https://issues.apache.org/jira/browse/TUBEMQ-210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli reassigned TUBEMQ-210: --- Assignee: duli > Add log4j properties file for unit tests > > >

[jira] [Commented] (TUBEMQ-208) Change the test resource file's folder name to 'resources'

[ https://issues.apache.org/jira/browse/TUBEMQ-208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125891#comment-17125891 ] duli commented on TUBEMQ-208: - [~gosonzhang] > Change the test resource file's folder name to 'resources' >

[jira] [Created] (TUBEMQ-208) Change the test resource file's folder name to 'resources'

duli created TUBEMQ-208: --- Summary: Change the test resource file's folder name to 'resources' Key: TUBEMQ-208 URL: https://issues.apache.org/jira/browse/TUBEMQ-208 Project: Apache TubeMQ Issue Type:

[jira] [Assigned] (TUBEMQ-208) Change the test resource file's folder name to 'resources'

[ https://issues.apache.org/jira/browse/TUBEMQ-208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli reassigned TUBEMQ-208: --- Assignee: duli > Change the test resource file's folder name to 'resources' >

[jira] [Assigned] (TUBEMQ-206) There are some residual files after executed unit tests

[ https://issues.apache.org/jira/browse/TUBEMQ-206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli reassigned TUBEMQ-206: --- Assignee: duli > There are some residual files after executed unit tests >

[jira] [Created] (TUBEMQ-206) There are some residual files after executed unit tests

duli created TUBEMQ-206: --- Summary: There are some residual files after executed unit tests Key: TUBEMQ-206 URL: https://issues.apache.org/jira/browse/TUBEMQ-206 Project: Apache TubeMQ Issue Type: Bug

[jira] [Assigned] (TUBEMQ-199) Support TubeMQ sink for flink

[ https://issues.apache.org/jira/browse/TUBEMQ-199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli reassigned TUBEMQ-199: --- Assignee: duli > Support TubeMQ sink for flink > - > > Key:

[jira] [Assigned] (TUBEMQ-198) Support TubeMQ source for flink

[ https://issues.apache.org/jira/browse/TUBEMQ-198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli reassigned TUBEMQ-198: --- Assignee: duli > Support TubeMQ source for flink > --- > > Key:

[jira] [Commented] (TUBEMQ-205) Duplicate dependency of jetty in tuber-server pom file

[ https://issues.apache.org/jira/browse/TUBEMQ-205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125711#comment-17125711 ] duli commented on TUBEMQ-205: - yes, it is. > Duplicate dependency of jetty in tuber-server pom file >

[jira] [Updated] (TUBEMQ-205) Duplicate dependency of jetty in tuber-server pom file

[ https://issues.apache.org/jira/browse/TUBEMQ-205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-205: Description: There are two dependency of jetty config in tuber-server pom.xml, it will produce some warns like

[jira] [Updated] (TUBEMQ-205) Duplicate dependency of jetty in tuber-server pom file

[ https://issues.apache.org/jira/browse/TUBEMQ-205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-205: Summary: Duplicate dependency of jetty in tuber-server pom file (was: Duplicate dependency of jettty in

[jira] [Assigned] (TUBEMQ-205) Duplicate dependency of jetty in tuber-server pom file

[ https://issues.apache.org/jira/browse/TUBEMQ-205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli reassigned TUBEMQ-205: --- Assignee: duli > Duplicate dependency of jetty in tuber-server pom file >

[jira] [Created] (TUBEMQ-205) Duplicate dependency of jettty in tuber-server pom file

duli created TUBEMQ-205: --- Summary: Duplicate dependency of jettty in tuber-server pom file Key: TUBEMQ-205 URL: https://issues.apache.org/jira/browse/TUBEMQ-205 Project: Apache TubeMQ Issue Type: Bug

[jira] [Commented] (TUBEMQ-197) Support TubeMQ connector for Apache Flink

[ https://issues.apache.org/jira/browse/TUBEMQ-197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125488#comment-17125488 ] duli commented on TUBEMQ-197: - Thanks, [~gosonzhang], i think is ok. > Support TubeMQ connector for Apache

[jira] [Created] (TUBEMQ-199) Support TubeMQ sink for flink

duli created TUBEMQ-199: --- Summary: Support TubeMQ sink for flink Key: TUBEMQ-199 URL: https://issues.apache.org/jira/browse/TUBEMQ-199 Project: Apache TubeMQ Issue Type: Sub-task Reporter:

[jira] [Created] (TUBEMQ-198) Support TubeMQ source for flink

duli created TUBEMQ-198: --- Summary: Support TubeMQ source for flink Key: TUBEMQ-198 URL: https://issues.apache.org/jira/browse/TUBEMQ-198 Project: Apache TubeMQ Issue Type: Sub-task

[jira] [Updated] (TUBEMQ-197) Support TubeMQ connector for Apache Flink

[ https://issues.apache.org/jira/browse/TUBEMQ-197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-197: Description: Apache Flink is a popular real-time streaming computing engine, and MQ is the most important

[jira] [Updated] (TUBEMQ-197) Support TubeMQ connector for Apache Flink

[ https://issues.apache.org/jira/browse/TUBEMQ-197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-197: Description: Apache Flink is a popular real-time streaming computing engine, and MQ is the most important

[jira] [Updated] (TUBEMQ-197) Support Tube connector for Apache Flink

[ https://issues.apache.org/jira/browse/TUBEMQ-197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-197: Description: Apache Flink is a popular real-time streaming computing engine, and MQ is the most important

[jira] [Created] (TUBEMQ-197) Support Tube connector for Apache Flink

duli created TUBEMQ-197: --- Summary: Support Tube connector for Apache Flink Key: TUBEMQ-197 URL: https://issues.apache.org/jira/browse/TUBEMQ-197 Project: Apache TubeMQ Issue Type: New Feature

[jira] [Commented] (TUBEMQ-85) There is NPE when creating PullConsumer with TubeSingleSessionFactory

[ https://issues.apache.org/jira/browse/TUBEMQ-85?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096367#comment-17096367 ] duli commented on TUBEMQ-85: Thanks a lot, [~gosonzhang] > There is NPE when creating PullConsumer with

[jira] [Updated] (TUBEMQ-85) There is NPE when creating PullConsumer with TubeSingleSessionFactory

[ https://issues.apache.org/jira/browse/TUBEMQ-85?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-85: --- Attachment: 15882229425471.png > There is NPE when creating PullConsumer with TubeSingleSessionFactory >

[jira] [Updated] (TUBEMQ-85) There is NPE when creating PullConsumer with TubeSingleSessionFactory

[ https://issues.apache.org/jira/browse/TUBEMQ-85?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-85: --- Attachment: (was: 企业微信截图_15882229425471.png) > There is NPE when creating PullConsumer with

[jira] [Updated] (TUBEMQ-85) There is NPE when creating PullConsumer with TubeSingleSessionFactory

[ https://issues.apache.org/jira/browse/TUBEMQ-85?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-85: --- Attachment: 企业微信截图_15882229425471.png > There is NPE when creating PullConsumer with TubeSingleSessionFactory >

[jira] [Updated] (TUBEMQ-85) There is NPE when creating PullConsumer with TubeSingleSessionFactory

[ https://issues.apache.org/jira/browse/TUBEMQ-85?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-85: --- Description: There is NullPointException when when creating PullConsumer with code like this: {code:java}

[jira] [Updated] (TUBEMQ-85) There is NPE when creating PullConsumer with TubeSingleSessionFactory

[ https://issues.apache.org/jira/browse/TUBEMQ-85?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-85: --- Description: There is NullPointException when when creating PullConsumer with code like This: {code:java}

[jira] [Updated] (TUBEMQ-85) There is NPE when creating PullConsumer with TubeSingleSessionFactory

[ https://issues.apache.org/jira/browse/TUBEMQ-85?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] duli updated TUBEMQ-85: --- Description: There is NullPointException when when creating PullConsumer with code like This: {code:java}

[jira] [Created] (TUBEMQ-85) There is NPE when creating PullConsumer with TubeSingleSessionFactory

duli created TUBEMQ-85: -- Summary: There is NPE when creating PullConsumer with TubeSingleSessionFactory Key: TUBEMQ-85 URL: https://issues.apache.org/jira/browse/TUBEMQ-85 Project: Apache TubeMQ Issue