[
https://issues.apache.org/jira/browse/KAFKA-9504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032739#comment-17032739
]
Ted Yu commented on KAFKA-9504:
---
It seems the closing of metrics is not enough in terms of preventing
[
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=17022970#comment-17022970
]
Ted Yu commented on KAFKA-9471:
---
[~vitojeng]
Please let me know if I should proceed with this or, do you
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022595#comment-17022595
]
Ted Yu commented on KAFKA-9471:
---
[~vitojeng]
Looks like the following query depends on the empty collection
[
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)
>
[
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() ==
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022589#comment-17022589
]
Ted Yu commented on KAFKA-9471:
---
I will send out a PR soon alone the above line of thinking.
> Return
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() ==
[
https://issues.apache.org/jira/browse/KAFKA-9471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022373#comment-17022373
]
Ted Yu commented on KAFKA-9471:
---
[~mjsax][~guozhang]
Please comment.
> Return empty collection for
[
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:
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
[
https://issues.apache.org/jira/browse/KAFKA-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17020262#comment-17020262
]
Ted Yu commented on KAFKA-9461:
---
Since we may not see the complete record given any threshold for size
[
https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019191#comment-17019191
]
Ted Yu commented on KAFKA-9455:
---
Maybe we can also look at (profile) Maps from fastutil such as:
[
https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018602#comment-17018602
]
Ted Yu commented on KAFKA-9450:
---
w.r.t. separate column family, since the data in this family tends to be
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:26 AM:
Looking at js2.log , I am
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:22 AM:
Looking at js2.log , I am
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/18/20 2:21 AM:
Looking at js2.log , I am
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018368#comment-17018368
]
Ted Yu edited comment on KAFKA-8532 at 1/17/20 10:42 PM:
-
Looking at js2.log , I
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018368#comment-17018368
]
Ted Yu commented on KAFKA-8532:
---
Looking at js2.log , I am not sure deadlock was observed. Maybe
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018352#comment-17018352
]
Ted Yu commented on KAFKA-8532:
---
Looking at KafkaController.scala in trunk, I don't see
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018175#comment-17018175
]
Ted Yu commented on KAFKA-8532:
---
Created https://github.com/apache/kafka/pull/7978
>
[
https://issues.apache.org/jira/browse/KAFKA-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018152#comment-17018152
]
Ted Yu edited comment on KAFKA-8532 at 1/17/20 4:13 PM:
How about making the
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16846843#comment-16846843
]
Ted Yu commented on KAFKA-5998:
---
Can you move state directory outside of /tmp which is subject to cleaning
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827123#comment-16827123
]
Ted Yu edited comment on KAFKA-5998 at 4/26/19 5:31 PM:
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827123#comment-16827123
]
Ted Yu edited comment on KAFKA-5998 at 4/26/19 5:12 PM:
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827123#comment-16827123
]
Ted Yu commented on KAFKA-5998:
---
https://pastebin.com/Y247UZgb shows what I mentioned earlier.
In
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827089#comment-16827089
]
Ted Yu commented on KAFKA-5998:
---
[~mparthas]:
>From your comment on Apr 8th, it seems that making the value
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822564#comment-16822564
]
Ted Yu commented on KAFKA-5998:
---
One doubt I had after reading recent comments is that, if the state
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822446#comment-16822446
]
Ted Yu commented on KAFKA-5998:
---
I wonder if we can use a file, which records reference count (for
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16811681#comment-16811681
]
Ted Yu commented on KAFKA-5998:
---
I made the following change:
{code}
diff --git
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16811603#comment-16811603
]
Ted Yu commented on KAFKA-5998:
---
It seems StreamTask can keep track of active tasks. After commit()
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16811551#comment-16811551
]
Ted Yu edited comment on KAFKA-5998 at 4/6/19 10:55 AM:
Cleanup delay is
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16811551#comment-16811551
]
Ted Yu commented on KAFKA-5998:
---
Cleanup delay is controlled by:
{code}
public static final String
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794549#comment-16794549
]
Ted Yu edited comment on KAFKA-3729 at 3/18/19 3:06 AM:
3729.v6.txt shows the
[
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=16794549#comment-16794549
]
Ted Yu edited comment on KAFKA-3729 at 3/17/19 6:39 PM:
3729.v6.txt shows the
[
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=16794549#comment-16794549
]
Ted Yu commented on KAFKA-3729:
---
3729.v6.txt shows the progress toward passing StreamsConfig to
[
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=16787312#comment-16787312
]
Ted Yu commented on KAFKA-3729:
---
https://github.com/apache/kafka/pull/6399
> Auto-configure non-default
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16785119#comment-16785119
]
Ted Yu commented on KAFKA-3729:
---
Attached tentative patch.
If it is on right track, I can send out a PR.
>
[
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=16784755#comment-16784755
]
Ted Yu commented on KAFKA-3729:
---
Can AbstractProcessorContext#appConfigs() be used to obtain the Map which
[
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
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784019#comment-16784019
]
Ted Yu commented on KAFKA-3729:
---
Joined class was added Sep 6 10:55:43 2017
Guozhang's comment above was
[
https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783778#comment-16783778
]
Ted Yu commented on KAFKA-3729:
---
I wonder if a third person can work on this - considering the lack of
[
https://issues.apache.org/jira/browse/KAFKA-7276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16634727#comment-16634727
]
Ted Yu commented on KAFKA-7276:
---
For #1, see the following:
[
https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333251#comment-16333251
]
Ted Yu edited comment on KAFKA-6303 at 10/1/18 10:42 PM:
-
+1 from me.
was
[
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}
[
https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607291#comment-16607291
]
Ted Yu edited comment on KAFKA-6904 at 9/22/18 7:06 PM:
Haven't seen this failure
[
https://issues.apache.org/jira/browse/KAFKA-6303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16333251#comment-16333251
]
Ted Yu edited comment on KAFKA-6303 at 9/21/18 1:50 AM:
+1 from me .
was
[
https://issues.apache.org/jira/browse/KAFKA-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574181#comment-16574181
]
Ted Yu edited comment on KAFKA-7175 at 9/16/18 6:15 PM:
Thanks for taking this,
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16616834#comment-16616834
]
Ted Yu commented on KAFKA-7316:
---
Can this be resolved ?
> Use of filter method in KTable.scala may result
[
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
[
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,
[
https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16607291#comment-16607291
]
Ted Yu commented on KAFKA-6904:
---
Haven't seen this failure lately.
>
[
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]
[
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();
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16595315#comment-16595315
]
Ted Yu commented on KAFKA-7304:
---
[~yuyang08]:
Please confirm that the gap between the following two metrics
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16595251#comment-16595251
]
Ted Yu commented on KAFKA-7304:
---
One potential cause for the delayed closing of idle connections is that
[
https://issues.apache.org/jira/browse/KAFKA-7345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16593820#comment-16593820
]
Ted Yu commented on KAFKA-7345:
---
Replied on PR, copied below.
>From the javadoc of FileLock:
{code}
*
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=16592857#comment-16592857
]
Ted Yu commented on KAFKA-7304:
---
I am looking at SaslSslAdminClientIntegrationTest .
It seems some getter
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592765#comment-16592765
]
Ted Yu commented on KAFKA-7304:
---
Thanks for the feedback, Yu.
There are a few {{log.error()}} calls in the
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16592752#comment-16592752
]
Ted Yu commented on KAFKA-7304:
---
In patch v7, I added some assertion to SslTransportLayerTest#teardown
The
[
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=16590729#comment-16590729
]
Ted Yu commented on KAFKA-5998:
---
Logged KAFKA-7334 for improving exception message.
The stack trace in the
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
[
https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590547#comment-16590547
]
Ted Yu commented on KAFKA-5998:
---
bq. java.nio.file.NoSuchFileException:
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590450#comment-16590450
]
Ted Yu commented on KAFKA-7316:
---
When would PR #5539 be merged ?
> Use of filter method in KTable.scala
[
https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16589609#comment-16589609
]
Ted Yu commented on KAFKA-7327:
---
Have you seen KAFKA-7304 ?
BTW my patch over KAFKA-7304 may not fix the
[
https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16589606#comment-16589606
]
Ted Yu commented on KAFKA-7327:
---
Please use English when reporting bug.
How about the following as subject
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16586909#comment-16586909
]
Ted Yu edited comment on KAFKA-7316 at 8/22/18 12:20 AM:
-
Patch v4 makes the code
[
https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16587961#comment-16587961
]
Ted Yu commented on KAFKA-7316:
---
I closed my PR since there was an earlier PR addressing the same problem:
[
https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16587955#comment-16587955
]
Ted Yu commented on KAFKA-6904:
---
testUncleanLeaderElectionEnable was the latest which may fail.
[
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
[
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
[
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=16586909#comment-16586909
]
Ted Yu commented on KAFKA-7316:
---
Patch v4 makes the code compile.
> 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:
--
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=16586897#comment-16586897
]
Ted Yu commented on KAFKA-7316:
---
Patch v2 reduces compilation errors to 20.
> Use of filter method in
[
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=16586841#comment-16586841
]
Ted Yu commented on KAFKA-7316:
---
[~guozhang] [~mjsax] :
Can you take a look at patch v1 to see if the
[
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=16586738#comment-16586738
]
Ted Yu commented on KAFKA-7316:
---
I was thinking about removing the implicit wrapKTable .
Then the following
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=16585392#comment-16585392
]
Ted Yu commented on KAFKA-7304:
---
Selector has {{lowMemThreshold}} which used to determine iteration order.
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584928#comment-16584928
]
Ted Yu commented on KAFKA-7304:
---
Without the fix, the test would fail with:
{code}
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584922#comment-16584922
]
Ted Yu commented on KAFKA-7304:
---
Patch v4 adds an assertion for the count of Channels in closingChannels in
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-7304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16584894#comment-16584894
]
Ted Yu edited comment on KAFKA-7304 at 8/18/18 7:38 PM:
Through a bit more
1 - 100 of 493 matches
Mail list logo
