[jira] [Commented] (FLINK-22610) The test-jar and test-source-jar of flink-connector-kafka should include all classes

[ https://issues.apache.org/jira/browse/FLINK-22610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369319#comment-17369319 ] LIU Xiao commented on FLINK-22610: -- I've done some testing, removing "..." can solve ou

[jira] [Updated] (FLINK-22610) The test-jar and test-source-jar of flink-connector-kafka should include all classes

[ https://issues.apache.org/jira/browse/FLINK-22610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-22610: - Description: The test-jar of old kafka connector (flink-connector-kafka-base and flink-connector-kafka-

[jira] [Updated] (FLINK-22610) The test-jar and test-source-jar of flink-connector-kafka should include all classes

[ https://issues.apache.org/jira/browse/FLINK-22610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-22610: - Summary: The test-jar and test-source-jar of flink-connector-kafka should include all classes (was: The

[jira] [Updated] (FLINK-22610) The test-jar and test-source-jar of flink-connector-kafka should include all test classes

[ https://issues.apache.org/jira/browse/FLINK-22610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-22610: - Summary: The test-jar and test-source-jar of flink-connector-kafka should include all test classes (was

[jira] [Commented] (FLINK-23057) flink-console.sh doesn't do variable expansion for FLINK_ENV_JAVA_OPTS like flink-daemon.sh

[ https://issues.apache.org/jira/browse/FLINK-23057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367058#comment-17367058 ] LIU Xiao commented on FLINK-23057: -- [~fly_in_gis] PR created > flink-console.sh doesn'

[jira] [Updated] (FLINK-23057) flink-console.sh doesn't do variable expansion for FLINK_ENV_JAVA_OPTS like flink-daemon.sh

[ https://issues.apache.org/jira/browse/FLINK-23057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-23057: - Description: In flink-deamon.sh:   {code:java} ... # Evaluate user options for local variable expansio

[jira] [Created] (FLINK-23057) flink-console.sh doesn't do variable expansion for FLINK_ENV_JAVA_OPTS like flink-daemon.sh

LIU Xiao created FLINK-23057: Summary: flink-console.sh doesn't do variable expansion for FLINK_ENV_JAVA_OPTS like flink-daemon.sh Key: FLINK-23057 URL: https://issues.apache.org/jira/browse/FLINK-23057 P

[jira] [Created] (FLINK-22610) The test-jar of flink-connector-kafka should include all test classes

LIU Xiao created FLINK-22610: Summary: The test-jar of flink-connector-kafka should include all test classes Key: FLINK-22610 URL: https://issues.apache.org/jira/browse/FLINK-22610 Project: Flink

[jira] [Updated] (FLINK-11987) Kafka producer occasionally throws NullpointerException

[ https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-11987: - Description: We are using Flink 1.6.2 in our production environment, and kafka producer occasionally th

[jira] [Commented] (FLINK-11987) Kafka producer occasionally throws NullpointerException

[ https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833650#comment-16833650 ] LIU Xiao commented on FLINK-11987: -- [~StephanEwen] We don't have much knowledge on this

[jira] [Updated] (FLINK-11987) Kafka producer occasionally throws NullpointerException

[ https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-11987: - Description: We are using Flink 1.6.2 in our production environment, and kafka producer occasionally th

[jira] [Updated] (FLINK-11987) Kafka producer occasionally throws NullpointerException

[ https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LIU Xiao updated FLINK-11987: - Description: We are using Flink 1.6.2 in our production environment, and kafka producer occasionally th

[jira] [Created] (FLINK-11987) Kafka producer occasionally throws NullpointerException

LIU Xiao created FLINK-11987: Summary: Kafka producer occasionally throws NullpointerException Key: FLINK-11987 URL: https://issues.apache.org/jira/browse/FLINK-11987 Project: Flink Issue Type: B