[jira] [Updated] (HADOOP-14623) fixed some bugs in KafkaSink

2017-07-23 Thread Hongyuan Li (JIRA)
[ https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongyuan Li updated HADOOP-14623: - Attachment: HADOOP-14623-004.patch modify compile error and check style warn > fixed some bugs

[jira] [Updated] (HADOOP-14623) fixed some bugs in KafkaSink

2017-07-23 Thread Hongyuan Li (JIRA)
[ https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongyuan Li updated HADOOP-14623: - Attachment: HADOOP-14623-003.patch > fixed some bugs in KafkaSink > ---

[jira] [Updated] (HADOOP-14623) fixed some bugs in KafkaSink

2017-07-08 Thread Hongyuan Li (JIRA)
[ https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongyuan Li updated HADOOP-14623: - Attachment: HADOOP-14623-002.patch > fixed some bugs in KafkaSink > ---

[jira] [Updated] (HADOOP-14623) fixed some bugs in KafkaSink

2017-07-08 Thread Hongyuan Li (JIRA)
[ https://issues.apache.org/jira/browse/HADOOP-14623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hongyuan Li updated HADOOP-14623: - Summary: fixed some bugs in KafkaSink (was: KafkaSink#init should set acks to 1,not 0 and key.