[
https://issues.apache.org/jira/browse/KAFKA-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17032739#comment-17032739
]
Ted Yu commented on KAFKA-9504:
---
It seems the closing of metrics is not enough in terms of
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-9471.
---
Resolution: Duplicate
> Throw exception for DEAD StreamThread.State
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022970#comment-17022970
]
Ted Yu commented on KAFKA-9471:
---
[~vitojeng]
Please let me know if I should proceed with th
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022595#comment-17022595
]
Ted Yu commented on KAFKA-9471:
---
[~vitojeng]
Looks like the following query depends on the
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Comment: was deleted
(was: I will send out a PR soon alone the above line of thinking.)
> Throw exception for
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Summary: Throw exception for DEAD StreamThread.State (was: Return empty
collection for PENDING_SHUTDOWN)
> Th
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Description:
In StreamThreadStateStoreProvider we have:
{code}
if (streamThread.state() == StreamThread.State.D
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022589#comment-17022589
]
Ted Yu commented on KAFKA-9471:
---
I will send out a PR soon alone the above line of thinking
Ted Yu created KAFKA-9471:
-
Summary: Return empty collection for PENDING_SHUTDOWN
Key: KAFKA-9471
URL: https://issues.apache.org/jira/browse/KAFKA-9471
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-9471:
--
Description:
In StreamThreadStateStoreProvider we have:
{code}
if (streamThread.state() == StreamThread.State.D
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022373#comment-17022373
]
Ted Yu commented on KAFKA-9471:
---
[~mjsax][~guozhang]
Please comment.
> Return empty collec
[
https://issues.apache.org/jira/browse/KAFKA-9464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved KAFKA-9464.
---
Resolution: Not A Problem
> Close the producer in completeShutdown
> --
>
Ted Yu created KAFKA-9465:
-
Summary: Enclose consumer call with catching InvalidOffsetException
Key: KAFKA-9465
URL: https://issues.apache.org/jira/browse/KAFKA-9465
Project: Kafka
Issue Type: Improv
Ted Yu created KAFKA-9464:
-
Summary: Close the producer in completeShutdown
Key: KAFKA-9464
URL: https://issues.apache.org/jira/browse/KAFKA-9464
Project: Kafka
Issue Type: Bug
Reporter:
Ted Yu created KAFKA-9463:
-
Summary: Transient failure in KafkaAdminClientTest.testListOffsets
Key: KAFKA-9463
URL: https://issues.apache.org/jira/browse/KAFKA-9463
Project: Kafka
Issue Type: Test
Ted Yu created KAFKA-9462:
-
Summary: Correct exception message in DistributedHerder
Key: KAFKA-9462
URL: https://issues.apache.org/jira/browse/KAFKA-9462
Project: Kafka
Issue Type: Bug
Re
[
https://issues.apache.org/jira/browse/KAFKA-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17020262#comment-17020262
]
Ted Yu commented on KAFKA-9461:
---
Since we may not see the complete record given any thresho
[
https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17019191#comment-17019191
]
Ted Yu commented on KAFKA-9455:
---
Maybe we can also look at (profile) Maps from fastutil suc
[
https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018602#comment-17018602
]
Ted Yu commented on KAFKA-9450:
---
w.r.t. separate column family, since the data in this fami
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:26 AM:
Looking a
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:22 AM:
Looking a
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:21 AM:
Looking a
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/17/20 10:42 PM:
-
Looking
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018368#comment-17018368
]
Ted Yu commented on KAFKA-8532:
---
Looking at js2.log , I am not sure deadlock was observed.
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018352#comment-17018352
]
Ted Yu commented on KAFKA-8532:
---
Looking at KafkaController.scala in trunk, I don't see
Ex
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018175#comment-17018175
]
Ted Yu commented on KAFKA-8532:
---
Created https://github.com/apache/kafka/pull/7978
> contr
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018152#comment-17018152
]
Ted Yu edited comment on KAFKA-8532 at 1/17/20 4:13 PM:
How about
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018152#comment-17018152
]
Ted Yu commented on KAFKA-8532:
---
How about making the following change ?
{code}
diff --git
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846843#comment-16846843
]
Ted Yu commented on KAFKA-5998:
---
Can you move state directory outside of /tmp which is subj
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16827123#comment-16827123
]
Ted Yu edited comment on KAFKA-5998 at 4/26/19 5:31 PM:
https://p
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16827123#comment-16827123
]
Ted Yu edited comment on KAFKA-5998 at 4/26/19 5:12 PM:
https://p
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16827123#comment-16827123
]
Ted Yu commented on KAFKA-5998:
---
https://pastebin.com/Y247UZgb shows what I mentioned earli
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16827089#comment-16827089
]
Ted Yu commented on KAFKA-5998:
---
[~mparthas]:
>From your comment on Apr 8th, it seems that
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16822564#comment-16822564
]
Ted Yu commented on KAFKA-5998:
---
One doubt I had after reading recent comments is that, if
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16822446#comment-16822446
]
Ted Yu commented on KAFKA-5998:
---
I wonder if we can use a file, which records reference cou
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811681#comment-16811681
]
Ted Yu commented on KAFKA-5998:
---
I made the following change:
{code}
diff --git
a/streams/
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811603#comment-16811603
]
Ted Yu commented on KAFKA-5998:
---
It seems StreamTask can keep track of active tasks. After
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811551#comment-16811551
]
Ted Yu edited comment on KAFKA-5998 at 4/6/19 10:55 AM:
Cleanup d
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811551#comment-16811551
]
Ted Yu commented on KAFKA-5998:
---
Cleanup delay is controlled by:
{code}
public static f
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794549#comment-16794549
]
Ted Yu edited comment on KAFKA-3729 at 3/18/19 3:06 AM:
3729.v6.t
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-3729:
--
Attachment: (was: 3729.v6.txt)
> Auto-configure non-default SerDes passed alongside the topology builder
>
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794549#comment-16794549
]
Ted Yu edited comment on KAFKA-3729 at 3/17/19 6:39 PM:
3729.v6.t
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-3729:
--
Attachment: 3729.v6.txt
> Auto-configure non-default SerDes passed alongside the topology builder
> --
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794549#comment-16794549
]
Ted Yu commented on KAFKA-3729:
---
3729.v6.txt shows the progress toward passing StreamsConfi
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-3729:
--
Attachment: 3729.v6.txt
> Auto-configure non-default SerDes passed alongside the topology builder
> --
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787312#comment-16787312
]
Ted Yu commented on KAFKA-3729:
---
https://github.com/apache/kafka/pull/6399
> Auto-configu
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16787272#comment-16787272
]
Ted Yu commented on KAFKA-3729:
---
The following seems to result in compilation error:
{code}
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16785119#comment-16785119
]
Ted Yu commented on KAFKA-3729:
---
Attached tentative patch.
If it is on right track, I can s
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-3729:
--
Attachment: 3729.txt
> Auto-configure non-default SerDes passed alongside the topology builder
> -
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784755#comment-16784755
]
Ted Yu commented on KAFKA-3729:
---
Can AbstractProcessorContext#appConfigs() be used to obtai
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-3729:
--
Comment: was deleted
(was: Joined class was added Sep 6 10:55:43 2017
Guozhang's comment above was made in 201
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16784019#comment-16784019
]
Ted Yu commented on KAFKA-3729:
---
Joined class was added Sep 6 10:55:43 2017
Guozhang's com
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16783778#comment-16783778
]
Ted Yu commented on KAFKA-3729:
---
I wonder if a third person can work on this - considering
[
https://issues.apache.org/jira/browse/KAFKA-7276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16634727#comment-16634727
]
Ted Yu commented on KAFKA-7276:
---
For #1, see the following:
http://hadoop.apache.org/docs/r
[
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 10/1/18 10:42 PM:
-
+1 from
[
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,
[
https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16607291#comment-16607291
]
Ted Yu edited comment on KAFKA-6904 at 9/22/18 7:06 PM:
Haven't s
[
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 9/21/18 1:50 AM:
+1 from m
[
https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16574181#comment-16574181
]
Ted Yu edited comment on KAFKA-7175 at 9/16/18 6:15 PM:
Thanks fo
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16616834#comment-16616834
]
Ted Yu commented on KAFKA-7316:
---
Can this be resolved ?
> Use of filter method in KTable.s
[
https://issues.apache.org/jira/browse/KAFKA-7276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7276:
--
Description:
https://github.com/google/re2j
re2j claims to do linear time regular expression matching in Java.
[
https://issues.apache.org/jira/browse/KAFKA-7344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7344:
--
Description:
After re-assigning existing active tasks to clients that previously had the
same active task, the
[
https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16607291#comment-16607291
]
Ted Yu commented on KAFKA-6904:
---
Haven't seen this failure lately.
> DynamicBrokerReconfig
[
https://issues.apache.org/jira/browse/KAFKA-7334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7334:
--
Description:
Quoting stack trace from KAFKA-5998 :
{code}
WARN [2018-08-22 03:17:03,745]
org.apache.kafka.stre
[
https://issues.apache.org/jira/browse/KAFKA-7345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7345:
--
Description:
{code}
locks.remove(taskId);
lockAndOwner.lock.release();
log.
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596801#comment-16596801
]
Ted Yu commented on KAFKA-7304:
---
1.8.0_102 was old .
Is the TLS patch integrated in newer
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16595315#comment-16595315
]
Ted Yu commented on KAFKA-7304:
---
[~yuyang08]:
Please confirm that the gap between the follo
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16595251#comment-16595251
]
Ted Yu commented on KAFKA-7304:
---
One potential cause for the delayed closing of idle connec
[
https://issues.apache.org/jira/browse/KAFKA-7345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16593820#comment-16593820
]
Ted Yu commented on KAFKA-7345:
---
Replied on PR, copied below.
>From the javadoc of FileLock
Ted Yu created KAFKA-7345:
-
Summary: Potentially unclosed FileChannel in StateDirectory#unlock
Key: KAFKA-7345
URL: https://issues.apache.org/jira/browse/KAFKA-7345
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592857#comment-16592857
]
Ted Yu commented on KAFKA-7304:
---
I am looking at SaslSslAdminClientIntegrationTest .
It se
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592765#comment-16592765
]
Ted Yu commented on KAFKA-7304:
---
Thanks for the feedback, Yu.
There are a few {{log.error(
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16592752#comment-16592752
]
Ted Yu commented on KAFKA-7304:
---
In patch v7, I added some assertion to SslTransportLayerTe
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7304:
--
Attachment: 7304.v7.txt
> memory leakage in org.apache.kafka.common.network.Selector
>
Ted Yu created KAFKA-7344:
-
Summary: Return early when all tasks are assigned in
StickyTaskAssignor#assignActive
Key: KAFKA-7344
URL: https://issues.apache.org/jira/browse/KAFKA-7344
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16590729#comment-16590729
]
Ted Yu commented on KAFKA-5998:
---
Logged KAFKA-7334 for improving exception message.
The st
Ted Yu created KAFKA-7334:
-
Summary: Suggest changing config for state.dir in case of
FileNotFoundException
Key: KAFKA-7334
URL: https://issues.apache.org/jira/browse/KAFKA-7334
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16590547#comment-16590547
]
Ted Yu commented on KAFKA-5998:
---
bq. java.nio.file.NoSuchFileException:
/tmp/kafka-stream
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16590508#comment-16590508
]
Ted Yu commented on KAFKA-5998:
---
bq. via "state.dir" config to another directory (default i
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16590450#comment-16590450
]
Ted Yu commented on KAFKA-7316:
---
When would PR #5539 be merged ?
> Use of filter method in
[
https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589609#comment-16589609
]
Ted Yu commented on KAFKA-7327:
---
Have you seen KAFKA-7304 ?
BTW my patch over KAFKA-7304 m
[
https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589606#comment-16589606
]
Ted Yu commented on KAFKA-7327:
---
Please use English when reporting bug.
How about the follo
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586909#comment-16586909
]
Ted Yu edited comment on KAFKA-7316 at 8/22/18 12:20 AM:
-
Patch v
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16587961#comment-16587961
]
Ted Yu commented on KAFKA-7316:
---
I closed my PR since there was an earlier PR addressing th
[
https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16587957#comment-16587957
]
Ted Yu commented on KAFKA-6904:
---
In the above test output, there was:
{code}
2018-08-21 18:
[
https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16587955#comment-16587955
]
Ted Yu commented on KAFKA-6904:
---
testUncleanLeaderElectionEnable was the latest which may f
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7316:
--
Comment: was deleted
(was: I was thinking about removing the implicit wrapKTable .
Then the following compilati
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7316:
--
Comment: was deleted
(was: Patch v2 reduces compilation errors to 20.)
> Use of filter method in KTable.scala
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7316:
--
Comment: was deleted
(was: [~guozhang] [~mjsax] :
Can you take a look at patch v1 to see if the changes to
Ses
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7316:
--
Attachment: (was: 7316.v1.txt)
> Use of filter method in KTable.scala may result in StackOverflowError
> --
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7316:
--
Attachment: (was: 7316.v2.txt)
> Use of filter method in KTable.scala may result in StackOverflowError
> --
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586909#comment-16586909
]
Ted Yu commented on KAFKA-7316:
---
Patch v4 makes the code compile.
> Use of filter method i
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7316:
--
Attachment: 7316.v4.txt
> Use of filter method in KTable.scala may result in StackOverflowError
> -
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586897#comment-16586897
]
Ted Yu commented on KAFKA-7316:
---
Patch v2 reduces compilation errors to 20.
> Use of filte
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7316:
--
Attachment: 7316.v2.txt
> Use of filter method in KTable.scala may result in StackOverflowError
> -
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586841#comment-16586841
]
Ted Yu commented on KAFKA-7316:
---
[~guozhang] [~mjsax] :
Can you take a look at patch v1 to
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated KAFKA-7316:
--
Attachment: 7316.v1.txt
> Use of filter method in KTable.scala may result in StackOverflowError
> -
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16586738#comment-16586738
]
Ted Yu commented on KAFKA-7316:
---
I was thinking about removing the implicit wrapKTable .
Th
Ted Yu created KAFKA-7316:
-
Summary: Use of filter method in KTable.scala may result in
StackOverflowError
Key: KAFKA-7316
URL: https://issues.apache.org/jira/browse/KAFKA-7316
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16585392#comment-16585392
]
Ted Yu commented on KAFKA-7304:
---
Selector has {{lowMemThreshold}} which used to determine i
1 - 100 of 532 matches
Mail list logo
