[jira] [Commented] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-08-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16584928#comment-16584928 ] Ted Yu commented on KAFKA-7304: --- Without the fix, the test would fail with: {code} org.apac

[jira] [Commented] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-08-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16584922#comment-16584922 ] Ted Yu commented on KAFKA-7304: --- Patch v4 adds an assertion for the count of Channels in cl

[jira] [Updated] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-08-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-7304: -- Attachment: 7304.v4.txt > memory leakage in org.apache.kafka.common.network.Selector >

[jira] [Comment Edited] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-08-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16584894#comment-16584894 ] Ted Yu edited comment on KAFKA-7304 at 8/18/18 7:57 PM: Through a

[jira] [Comment Edited] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-08-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16584894#comment-16584894 ] Ted Yu edited comment on KAFKA-7304 at 8/18/18 7:38 PM: Through a

[jira] [Commented] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-08-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16584894#comment-16584894 ] Ted Yu commented on KAFKA-7304: --- Through a bit more additional logging, here is what happen

[jira] [Commented] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-08-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1658#comment-1658 ] Ted Yu commented on KAFKA-7304: --- By running test suite with additional logging, I saw the f

[jira] [Comment Edited] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-08-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16583570#comment-16583570 ] Ted Yu edited comment on KAFKA-7304 at 8/17/18 12:18 PM: - Looking

[jira] [Commented] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-08-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16583570#comment-16583570 ] Ted Yu commented on KAFKA-7304: --- Looking at the close() method, I don't see where the chann

[jira] [Commented] (KAFKA-7304) memory leakage in org.apache.kafka.common.network.Selector

2018-08-17 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16583558#comment-16583558 ] Ted Yu commented on KAFKA-7304: --- Was there any exception in broker log ? thanks > memory

[jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2018-08-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 8/16/18 11:06 PM: - +1 from

[jira] [Created] (KAFKA-7276) Consider using re2j to speed up regex operations

2018-08-10 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-7276: - Summary: Consider using re2j to speed up regex operations Key: KAFKA-7276 URL: https://issues.apache.org/jira/browse/KAFKA-7276 Project: Kafka Issue Type: Task

[jira] [Commented] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

2018-08-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574181#comment-16574181 ] Ted Yu commented on KAFKA-7175: --- Thanks for taking this, Ray. > Make version checking logi

[jira] [Updated] (KAFKA-7174) Improve version probing of subscription info

2018-08-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-7174: -- Labels: compatibility (was: ) > Improve version probing of subscription info > ---

[jira] [Commented] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean (Windows OS)

2018-08-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16572793#comment-16572793 ] Ted Yu commented on KAFKA-6647: --- Using the change from pull request 4702, does the test pas

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2018-08-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 8/3/18 4:15 PM: --- +1 from me

[jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name

2018-08-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392411#comment-16392411 ] Ted Yu edited comment on KAFKA-5946 at 8/3/18 4:14 PM: --- Thanks for

[jira] [Comment Edited] (KAFKA-6678) Upgrade dependencies with later release versions

2018-08-03 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16434768#comment-16434768 ] Ted Yu edited comment on KAFKA-6678 at 8/3/18 3:58 PM: --- 2.0 release

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

2018-08-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5863: -- Description: Here is the call chain: {code} RestServer.httpRequest(reconfigUrl

[jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2018-08-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 8/2/18 1:48 AM: --- +1 from me

[jira] [Commented] (KAFKA-7049) InternalTopicIntegrationTest sometimes fails

2018-08-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566242#comment-16566242 ] Ted Yu commented on KAFKA-7049: --- Haven't seen this error for a little while. > InternalTop

[jira] [Commented] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

2018-08-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16566241#comment-16566241 ] Ted Yu commented on KAFKA-7175: --- What Ray said sounds feasible. > Make version checking lo

[jira] [Created] (KAFKA-7195) StreamStreamJoinIntegrationTest fails in 2.0 Jenkins

2018-07-23 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-7195: - Summary: StreamStreamJoinIntegrationTest fails in 2.0 Jenkins Key: KAFKA-7195 URL: https://issues.apache.org/jira/browse/KAFKA-7195 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

2018-07-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16551526#comment-16551526 ] Ted Yu commented on KAFKA-7175: --- Haven't found a way for python to directly reference const

[jira] [Created] (KAFKA-7175) Make version checking logic more flexible in streams_upgrade_test.py

2018-07-17 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-7175: - Summary: Make version checking logic more flexible in streams_upgrade_test.py Key: KAFKA-7175 URL: https://issues.apache.org/jira/browse/KAFKA-7175 Project: Kafka Issue T

[jira] [Created] (KAFKA-7174) Improve version probing of subscription info

2018-07-17 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-7174: - Summary: Improve version probing of subscription info Key: KAFKA-7174 URL: https://issues.apache.org/jira/browse/KAFKA-7174 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7170) NPE in ConsumerGroupCommand when describe consumer group

2018-07-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545748#comment-16545748 ] Ted Yu commented on KAFKA-7170: --- Can you provide a bit more information: release of Kafka,

[jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

2018-07-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545477#comment-16545477 ] Ted Yu commented on KAFKA-5037: --- In KafkaStreams, I am adding the following method in order

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

2018-07-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16544346#comment-16544346 ] Ted Yu commented on KAFKA-7149: --- Took a look at AssignmentInfo#writeTopicPartitions where :

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2018-07-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 7/10/18 12:16 PM: - +1 from

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

2018-07-10 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Description: Currently connector tests make heavy use of mock (easymock, power mock). This may hide the real l

[jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name

2018-07-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392411#comment-16392411 ] Ted Yu edited comment on KAFKA-5946 at 7/8/18 1:03 PM: --- Thanks for

[jira] [Resolved] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2018-07-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6335. --- Resolution: Cannot Reproduce > SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails >

[jira] [Commented] (KAFKA-6904) DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky

2018-07-04 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16533150#comment-16533150 ] Ted Yu commented on KAFKA-6904: --- Haven't seen this failure lately. > DynamicBrokerReconfig

[jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

2018-07-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16530894#comment-16530894 ] Ted Yu commented on KAFKA-5037: --- Patch v4 rewrites assertions in shouldReturnUnchangedAssi

[jira] [Updated] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

2018-07-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5037: -- Attachment: 5037.v4.txt > Infinite loop if all input topics are unknown at startup > --

[jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2018-07-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 7/3/18 5:38 AM: --- +1 from me

[jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

2018-07-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16530807#comment-16530807 ] Ted Yu commented on KAFKA-5037: --- Currently both SubscriptionInfo.LATEST_SUPPORTED_VERSION a

[jira] [Commented] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

2018-07-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16530724#comment-16530724 ] Ted Yu commented on KAFKA-5037: --- Originally I threw exception in the if block for the follo

[jira] [Updated] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

2018-07-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5037: -- Attachment: (was: 5037.v1.txt) > Infinite loop if all input topics are unknown at startup > ---

[jira] [Updated] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

2018-07-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5037: -- Attachment: 5037.v2.txt > Infinite loop if all input topics are unknown at startup > --

[jira] [Updated] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

2018-07-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5037: -- Attachment: 5037.v1.txt > Infinite loop if all input topics are unknown at startup > --

[jira] [Commented] (KAFKA-6583) Metadata should include number of state stores for task

2018-07-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16530087#comment-16530087 ] Ted Yu commented on KAFKA-6583: --- Shouldn't this be marked Resolved when KAFKA-4696 (Open as

[jira] [Commented] (KAFKA-7126) Reduce number of rebalance period for large consumer groups after a topic is created

2018-07-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529390#comment-16529390 ] Ted Yu commented on KAFKA-7126: --- Maybe we can introduce some jitter (say 1/10 of metadata.m

[jira] [Commented] (KAFKA-7126) Reduce number of rebalance period for large consumer groups after a topic is created

2018-07-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529381#comment-16529381 ] Ted Yu commented on KAFKA-7126: --- I don't find ConsumerCoordinator.needRejoin() in the code

[jira] [Commented] (KAFKA-7125) Calling StreamsBuilderbuilder.build().describe() causes java.util.NoSuchElementException: null

2018-07-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16529255#comment-16529255 ] Ted Yu commented on KAFKA-7125: --- I wonder if adding call to {{addGlobalStore}} would change

[jira] [Resolved] (KAFKA-7124) Number of AnyLogDir should match the length of the replicas list

2018-07-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-7124. --- Resolution: Not A Problem > Number of AnyLogDir should match the length of the replicas list > --

[jira] [Updated] (KAFKA-7124) Number of AnyLogDir should match the length of the replicas list

2018-07-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-7124: -- Description: See discussion under 'Partitions reassignment is failing in Kafka 1.1.0' thread reported by Debra

[jira] [Created] (KAFKA-7124) Number of AnyLogDir should match the length of the replicas list

2018-07-01 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-7124: - Summary: Number of AnyLogDir should match the length of the replicas list Key: KAFKA-7124 URL: https://issues.apache.org/jira/browse/KAFKA-7124 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-7121) Intermittently, Connectors fail to assign tasks and keep retrying every second forever.

2018-06-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528494#comment-16528494 ] Ted Yu edited comment on KAFKA-7121 at 6/30/18 2:10 AM: Which rel

[jira] [Commented] (KAFKA-7121) Intermittently, Connectors fail to assign tasks and keep retrying every second forever.

2018-06-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528494#comment-16528494 ] Ted Yu commented on KAFKA-7121: --- Which release of Connect were you using ? Looking at ./c

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

2018-06-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16528488#comment-16528488 ] Ted Yu commented on KAFKA-5998: --- For v1 patch, probably you want to uncomment the following

[jira] [Commented] (KAFKA-6177) kafka-mirror-maker.sh RecordTooLargeException

2018-06-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16526015#comment-16526015 ] Ted Yu commented on KAFKA-6177: --- I searched server.properties attached to the JIRA but didn

[jira] [Commented] (KAFKA-7113) AdminClient.create has an infinite retry loop bug

2018-06-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16525944#comment-16525944 ] Ted Yu commented on KAFKA-7113: --- How about exposing the following method of NetworkClient t

[jira] [Comment Edited] (KAFKA-7108) "Exactly-once" stream breaks production exception handler contract

2018-06-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524716#comment-16524716 ] Ted Yu edited comment on KAFKA-7108 at 6/27/18 7:43 AM: In Stream

[jira] [Commented] (KAFKA-7108) "Exactly-once" stream breaks production exception handler contract

2018-06-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16524716#comment-16524716 ] Ted Yu commented on KAFKA-7108: --- {code} if (eosEnabled) {

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

2018-06-25 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16522031#comment-16522031 ] Ted Yu commented on KAFKA-7088: --- Maybe set log level to DEBUG when you have a chance. Than

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

2018-06-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520844#comment-16520844 ] Ted Yu commented on KAFKA-7088: --- Lukasz: I was looking at code related to how queued TxnReq

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

2018-06-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520094#comment-16520094 ] Ted Yu commented on KAFKA-7088: --- What's the value for "processing.guarantee" ? {code}

[jira] [Commented] (KAFKA-7088) Kafka streams thread waits infinitely on transaction init

2018-06-21 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16519542#comment-16519542 ] Ted Yu commented on KAFKA-7088: --- Is it possible to reproduce this behavior using 1.1.1 RC ?

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

2018-06-14 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16513045#comment-16513045 ] Ted Yu commented on KAFKA-7012: --- bq. not treating this case at all and suffering the (rare?

[jira] [Created] (KAFKA-7049) InternalTopicIntegrationTest sometimes fails

2018-06-12 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-7049: - Summary: InternalTopicIntegrationTest sometimes fails Key: KAFKA-7049 URL: https://issues.apache.org/jira/browse/KAFKA-7049 Project: Kafka Issue Type: Test Rep

[jira] [Commented] (KAFKA-7048) NPE when creating connector

2018-06-12 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16509862#comment-16509862 ] Ted Yu commented on KAFKA-7048: --- Can you show the stack trace involving the NPE ? > NPE w

[jira] [Issue Comment Deleted] (KAFKA-7028) super.users doesn't work with custom principals

2018-06-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-7028: -- Comment: was deleted (was: {code} superUsers = configs.get(SimpleAclAuthorizer.SuperUsersProp).collect {

[jira] [Commented] (KAFKA-7028) super.users doesn't work with custom principals

2018-06-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16506993#comment-16506993 ] Ted Yu commented on KAFKA-7028: --- {code} superUsers = configs.get(SimpleAclAuthorizer.Su

[jira] [Commented] (KAFKA-7028) super.users doesn't work with custom principals

2018-06-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16506984#comment-16506984 ] Ted Yu commented on KAFKA-7028: --- This means retrieving principalBuilder thru KafkaConfig#P

[jira] [Commented] (KAFKA-7012) Performance issue upgrading to kafka 1.0.1 or 1.1

2018-06-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16504986#comment-16504986 ] Ted Yu commented on KAFKA-7012: --- You can precede quoted comment with 'bq.' (note the traili

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2018-06-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 6/5/18 10:53 PM: +1 was

[jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2018-06-05 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 6/5/18 10:53 PM: +1 was

[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

2018-06-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16498741#comment-16498741 ] Ted Yu commented on KAFKA-4628: --- [~abellemare]: Would you start a KIP for this enhancement

[jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name

2018-05-31 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392411#comment-16392411 ] Ted Yu edited comment on KAFKA-5946 at 5/31/18 10:51 PM: - Thanks

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

2018-05-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16493050#comment-16493050 ] Ted Yu commented on KAFKA-6335: --- [~Sonia]: Does this test still fail on your computer ? Th

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2018-05-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 5/29/18 3:18 AM: lgtm wa

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

2018-05-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5863: -- Description: Here is the call chain: {code} RestServer.httpRequest(reconfigUrl,

[jira] [Resolved] (KAFKA-6698) ConsumerBounceTest#testClose sometimes fails

2018-05-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6698. --- Resolution: Cannot Reproduce > ConsumerBounceTest#testClose sometimes fails > ---

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2018-05-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 5/23/18 12:51 AM: - +1 was

[jira] [Resolved] (KAFKA-6875) EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky

2018-05-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-6875. --- Resolution: Cannot Reproduce > EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky > ---

[jira] [Comment Edited] (KAFKA-5946) Give connector method parameter better name

2018-05-22 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392411#comment-16392411 ] Ted Yu edited comment on KAFKA-5946 at 5/22/18 11:55 PM: - Thanks f

[jira] [Comment Edited] (KAFKA-5846) Use singleton NoOpConsumerRebalanceListener in subscribe() call where listener is not specified

2018-05-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16191405#comment-16191405 ] Ted Yu edited comment on KAFKA-5846 at 5/21/18 3:38 AM: lgtm was

[jira] [Updated] (KAFKA-5943) Reduce dependency on mock in connector tests

2018-05-19 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5943: -- Labels: connector mock (was: connector) > Reduce dependency on mock in connector tests > --

[jira] [Comment Edited] (KAFKA-6303) Potential lack of synchronization in NioEchoServer#AcceptorThread

2018-05-19 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16333251#comment-16333251 ] Ted Yu edited comment on KAFKA-6303 at 5/19/18 1:50 PM: lgtm was

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

2018-05-18 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16480809#comment-16480809 ] Ted Yu commented on KAFKA-6188: --- The above code came from: KAFKA-4763; Handle disk failure

[jira] [Commented] (KAFKA-6904) DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky

2018-05-16 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478122#comment-16478122 ] Ted Yu commented on KAFKA-6904: --- Another subtest failed: https://builds.apache.org/job/kafk

[jira] [Comment Edited] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

2018-05-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476100#comment-16476100 ] Ted Yu edited comment on KAFKA-6188 at 5/15/18 5:14 PM: >From the

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

2018-05-15 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16476100#comment-16476100 ] Ted Yu commented on KAFKA-6188: --- >From the stack trace Manna provided, it seems we can catch

[jira] [Created] (KAFKA-6904) DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky

2018-05-14 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6904: - Summary: DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky Key: KAFKA-6904 URL: https://issues.apache.org/jira/browse/KAFKA-6904 Project: Kafka Issue

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

2018-05-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6566: -- Attachment: (was: 6566.txt) > SourceTask#stop() not called after exception raised in poll() > --

[jira] [Issue Comment Deleted] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

2018-05-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6566: -- Comment: was deleted (was: Attached 6566.txt, reflecting Robert's comment. Waiting for Randall's response.) >

[jira] [Updated] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

2018-05-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6566: -- Attachment: 6566.txt > SourceTask#stop() not called after exception raised in poll() > -

[jira] [Commented] (KAFKA-6566) SourceTask#stop() not called after exception raised in poll()

2018-05-11 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16472411#comment-16472411 ] Ted Yu commented on KAFKA-6566: --- Attached 6566.txt, reflecting Robert's comment. Waiting fo

[jira] [Commented] (KAFKA-6878) NPE when querying global state store not in READY state

2018-05-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16467689#comment-16467689 ] Ted Yu commented on KAFKA-6878: --- How about this: {code} diff --git a/streams/src/main/java/

[jira] [Issue Comment Deleted] (KAFKA-6878) NPE when querying global state store not in READY state

2018-05-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6878: -- Comment: was deleted (was: How about the following change ? {code} diff --git a/streams/src/main/java/org/apach

[jira] [Commented] (KAFKA-6879) Controller deadlock following session expiration

2018-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466713#comment-16466713 ] Ted Yu commented on KAFKA-6879: --- Moving only {{beforeInitializingSession}} outside of {{init

[jira] [Commented] (KAFKA-6878) NPE when querying global state store not in READY state

2018-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466681#comment-16466681 ] Ted Yu commented on KAFKA-6878: --- How about the following change ? {code} diff --git a/strea

[jira] [Commented] (KAFKA-6875) EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky

2018-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466514#comment-16466514 ] Ted Yu commented on KAFKA-6875: --- The above error happened at the end of the failed test. I d

[jira] [Commented] (KAFKA-6875) EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky

2018-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466503#comment-16466503 ] Ted Yu commented on KAFKA-6875: --- {code} if (!taskDir.exists() && !taskDir.mkdir()) {

[jira] [Commented] (KAFKA-6875) EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky

2018-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466426#comment-16466426 ] Ted Yu commented on KAFKA-6875: --- >From Jenkins: Failed 1 times in the last 10 runs. Flakine

[jira] [Commented] (KAFKA-6875) EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky

2018-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16466344#comment-16466344 ] Ted Yu commented on KAFKA-6875: --- Test output was truncated: {code} [2018-05-07 19:01:22,039]

[jira] [Updated] (KAFKA-6875) EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky

2018-05-07 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-6875: -- Attachment: EosIntegrationTest.out > EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky > ---

[jira] [Created] (KAFKA-6875) EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky

2018-05-07 Thread Ted Yu (JIRA)
Ted Yu created KAFKA-6875: - Summary: EosIntegrationTest#shouldNotViolateEosIfOneTaskFails is flaky Key: KAFKA-6875 URL: https://issues.apache.org/jira/browse/KAFKA-6875 Project: Kafka Issue Type: Te

<    1   2   3   4   5   6   >