Piotr Nowojski created FLINK-7343:
-
Summary: Kafka010ProducerITCase instability
Key: FLINK-7343
URL: https://issues.apache.org/jira/browse/FLINK-7343
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-6996.
-
Resolution: Fixed
Those test failures most likely are not caused by actual bug in Flink, but a
Piotr Nowojski created FLINK-7175:
-
Summary: Add simple benchmark suite for Flink
Key: FLINK-7175
URL: https://issues.apache.org/jira/browse/FLINK-7175
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7210:
--
Description: To implement exactly-once sink there is a re-occurring pattern
for doing it - two
Piotr Nowojski created FLINK-7210:
-
Summary: Add TwoPhaseCommitSinkFunction (implementing exactly-once
semantic in generic way)
Key: FLINK-7210
URL: https://issues.apache.org/jira/browse/FLINK-7210
Piotr Nowojski created FLINK-7174:
-
Summary: Bump dependency of Kafka 0.10.x to the latest one
Key: FLINK-7174
URL: https://issues.apache.org/jira/browse/FLINK-7174
Project: Flink
Issue
Piotr Nowojski created FLINK-7238:
-
Summary: Kafka integration tests do not restart Kafka brokers
properly
Key: FLINK-7238
URL: https://issues.apache.org/jira/browse/FLINK-7238
Project: Flink
Piotr Nowojski created FLINK-7032:
-
Summary: Intellij is constantly changing language level of sub
projects back to 1.6
Key: FLINK-7032
URL: https://issues.apache.org/jira/browse/FLINK-7032
Project:
Piotr Nowojski created FLINK-7058:
-
Summary: flink-scala-shell unintended dependencies for scala 2.11
Key: FLINK-7058
URL: https://issues.apache.org/jira/browse/FLINK-7058
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7058:
--
Affects Version/s: 1.3.0
1.3.1
> flink-scala-shell unintended
[
https://issues.apache.org/jira/browse/FLINK-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-7058:
-
Assignee: Piotr Nowojski
> flink-scala-shell unintended dependencies for scala 2.11
>
Piotr Nowojski created FLINK-7066:
-
Summary: Kafka integration tests failing in "airplane mode"
Key: FLINK-7066
URL: https://issues.apache.org/jira/browse/FLINK-7066
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7066.
-
> Kafka integration tests failing in "airplane mode"
>
Piotr Nowojski created FLINK-7030:
-
Summary: Build with scala-2.11 by default
Key: FLINK-7030
URL: https://issues.apache.org/jira/browse/FLINK-7030
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7343.
-
Resolution: Fixed
Fix Version/s: 1.4.0
Hopefully with two recent changes this issue will
Piotr Nowojski created FLINK-7476:
-
Summary: Try to recover from failure in
TwoPhaseCommitSinkFunction.beginTransaction
Key: FLINK-7476
URL: https://issues.apache.org/jira/browse/FLINK-7476
Project:
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-6988:
--
Description:
Kafka 0.11 (it will be released very soon) add supports for transactions.
Thanks
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059699#comment-16059699
]
Piotr Nowojski edited comment on FLINK-6988 at 6/22/17 5:15 PM:
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-6988:
--
Description:
Kafka 0.11 (it will be released very soon) add supports for transactions.
Thanks
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16059699#comment-16059699
]
Piotr Nowojski commented on FLINK-6988:
---
Unfortunately KafkaProducer's API is very limited.
Piotr Nowojski created FLINK-6988:
-
Summary: Add Apache Kafka 0.11 connector
Key: FLINK-6988
URL: https://issues.apache.org/jira/browse/FLINK-6988
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-6996:
--
Description: FlinkKafkaProducer010 doesn't implement CheckpointedFunction
interface. This
[
https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061168#comment-16061168
]
Piotr Nowojski commented on FLINK-6996:
---
Yes, you are correct. Fixed description.
>
[
https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16061168#comment-16061168
]
Piotr Nowojski edited comment on FLINK-6996 at 6/23/17 4:20 PM:
Yes,
Piotr Nowojski created FLINK-6996:
-
Summary: FlinkKafkaProducer010 doesn't guarantee at-least-once
semantic
Key: FLINK-6996
URL: https://issues.apache.org/jira/browse/FLINK-6996
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16066021#comment-16066021
]
Piotr Nowojski commented on FLINK-6996:
---
[~tzulitai] I guess we were both wrong. I added tests for
[
https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-4034.
-
Resolution: Duplicate
It seems like this work was abandoned. Closing as it is a subset of
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205607#comment-16205607
]
Piotr Nowojski commented on FLINK-7368:
---
I will take a look at this in this or the following week.
[
https://issues.apache.org/jira/browse/FLINK-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-7623:
-
Assignee: Piotr Nowojski
> Detecting whether an operator is restored doesn't work with
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-7368:
-
Assignee: Piotr Nowojski
> MetricStore makes cpu spin at 100%
>
[
https://issues.apache.org/jira/browse/FLINK-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205605#comment-16205605
]
Piotr Nowojski commented on FLINK-7623:
---
I will take a look at this in this or the following week.
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16205876#comment-16205876
]
Piotr Nowojski commented on FLINK-7368:
---
For 1.4 this was fixed by [~till.rohrmann] as a part of
Piotr Nowojski created FLINK-7765:
-
Summary: Enable dependency convergence
Key: FLINK-7765
URL: https://issues.apache.org/jira/browse/FLINK-7765
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7765:
--
Description: For motivation check
https://issues.apache.org/jira/browse/FLINK-7739 (was: For
[
https://issues.apache.org/jira/browse/FLINK-7765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7765:
--
Description: For motivation check
https://issues.apache.org/jira/browse/FLINK-7765 (was: For
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16206046#comment-16206046
]
Piotr Nowojski commented on FLINK-7368:
---
[~Zentol] 1.3 branch doesn't have [~till.rohrmann]'s FLIP-6
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16206046#comment-16206046
]
Piotr Nowojski edited comment on FLINK-7368 at 10/16/17 3:15 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16206046#comment-16206046
]
Piotr Nowojski edited comment on FLINK-7368 at 10/16/17 3:31 PM:
-
Piotr Nowojski created FLINK-7838:
-
Summary: Kafka 0.11 producer exactly-once test failure
Key: FLINK-7838
URL: https://issues.apache.org/jira/browse/FLINK-7838
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7838:
--
Description: See attached log (was:
[
https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7838:
--
Attachment: log.txt
> Kafka 0.11 producer exactly-once test failure
>
Piotr Nowojski created FLINK-7812:
-
Summary: Log system resources as metrics
Key: FLINK-7812
URL: https://issues.apache.org/jira/browse/FLINK-7812
Project: Flink
Issue Type: New Feature
Piotr Nowojski created FLINK-7561:
-
Summary: Add support for pre-aggregation in DataStream API
Key: FLINK-7561
URL: https://issues.apache.org/jira/browse/FLINK-7561
Project: Flink
Issue
Piotr Nowojski created FLINK-7683:
-
Summary: Add method to iterate over all of the existing keys in a
statebackend
Key: FLINK-7683
URL: https://issues.apache.org/jira/browse/FLINK-7683
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7684:
--
Issue Type: Improvement (was: New Feature)
> Avoid multiple data copies in MergingWindowSet
>
Piotr Nowojski created FLINK-7684:
-
Summary: Avoid multiple data copies in MergingWindowSet
Key: FLINK-7684
URL: https://issues.apache.org/jira/browse/FLINK-7684
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7683:
--
Description: This is required to make possible preserving backward
compatibility while changing
[
https://issues.apache.org/jira/browse/FLINK-7684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-7684:
-
Assignee: Piotr Nowojski
Affects Version/s: 1.2.0
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7683:
--
Description: This is required to make possible preserving backward
compatibility while changing
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski resolved FLINK-7683.
---
Resolution: Fixed
Fix Version/s: 1.4.0
> Add method to iterate over all of the
[
https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7683.
-
> Add method to iterate over all of the existing keys in a statebackend
>
[
https://issues.apache.org/jira/browse/FLINK-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski resolved FLINK-7541.
---
Resolution: Fixed
Fix Version/s: 1.4.0
> Redistribute operator state using OperatorID
[
https://issues.apache.org/jira/browse/FLINK-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7541.
-
There are still parts of the code in the Flink that Relays on operator order
> Redistribute operator
Piotr Nowojski created FLINK-7739:
-
Summary: Improve Kafka*ITCase tests stability
Key: FLINK-7739
URL: https://issues.apache.org/jira/browse/FLINK-7739
Project: Flink
Issue Type: Improvement
Piotr Nowojski created FLINK-7497:
-
Summary: Allow users to add custom user context stored in state in
TwoPhaseCommitSinkFunction
Key: FLINK-7497
URL: https://issues.apache.org/jira/browse/FLINK-7497
[
https://issues.apache.org/jira/browse/FLINK-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7497:
--
Description:
Currently when using TwoPhaseCommitSinkFunction there is no way to store on
state
Piotr Nowojski created FLINK-7498:
-
Summary: Bind together state fields of TwoPhaseCommitSinkFunction
Key: FLINK-7498
URL: https://issues.apache.org/jira/browse/FLINK-7498
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7498:
--
Description: Make sure that state fields are coupled together between
checkpoints. This way all
[
https://issues.apache.org/jira/browse/FLINK-7498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7498:
--
Issue Type: Improvement (was: Bug)
> Bind together state fields of TwoPhaseCommitSinkFunction
[
https://issues.apache.org/jira/browse/FLINK-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-7476.
-
Resolution: Won't Fix
Release Note: Currently there is no way in Flink for operator to fail
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-6988:
--
Fix Version/s: 1.4.0
> Add Apache Kafka 0.11 connector
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209106#comment-16209106
]
Piotr Nowojski commented on FLINK-7368:
---
Ops my bad. I assumed that copying should be fast (one
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209106#comment-16209106
]
Piotr Nowojski edited comment on FLINK-7368 at 10/18/17 10:15 AM:
--
Ops my
[
https://issues.apache.org/jira/browse/FLINK-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16210951#comment-16210951
]
Piotr Nowojski commented on FLINK-7623:
---
As [~srichter] suggested I have checked for couple of more
[
https://issues.apache.org/jira/browse/FLINK-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16209552#comment-16209552
]
Piotr Nowojski commented on FLINK-7623:
---
It seems like indeed this bug was fixed in
[
https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16212540#comment-16212540
]
Piotr Nowojski commented on FLINK-5789:
---
After short discussion with [~aljoscha] about
[
https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16212540#comment-16212540
]
Piotr Nowojski edited comment on FLINK-5789 at 10/20/17 12:17 PM:
--
After
[
https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16212534#comment-16212534
]
Piotr Nowojski commented on FLINK-7737:
---
After discussion with [~aljoscha] I confirmed that this PR
[
https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16212540#comment-16212540
]
Piotr Nowojski edited comment on FLINK-5789 at 10/20/17 12:20 PM:
--
After
[
https://issues.apache.org/jira/browse/FLINK-7901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-7901:
-
Assignee: (was: Piotr Nowojski)
> Detecting whether an operator is restored doesn't
[
https://issues.apache.org/jira/browse/FLINK-7784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16215088#comment-16215088
]
Piotr Nowojski commented on FLINK-7784:
---
Are we sure that we want to ignore such failures by
[
https://issues.apache.org/jira/browse/FLINK-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-7882:
-
Assignee: Piotr Nowojski
> Writing to S3 from EMR fails with exception
>
[
https://issues.apache.org/jira/browse/FLINK-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7829:
--
Priority: Major (was: Blocker)
Fix Version/s: (was: 1.4.0)
[
https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16211609#comment-16211609
]
Piotr Nowojski edited comment on FLINK-7737 at 10/19/17 7:38 PM:
-
I have
[
https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16211609#comment-16211609
]
Piotr Nowojski commented on FLINK-7737:
---
I have started looking into this. Are you sure that setting
[
https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-7737:
-
Assignee: Piotr Nowojski
> On HCFS systems, FSDataOutputStream does not issue hsync only
[
https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16216750#comment-16216750
]
Piotr Nowojski commented on FLINK-7883:
---
[~aljoscha] indeed it's not well suited, but it's only a
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249223#comment-16249223
]
Piotr Nowojski edited comment on FLINK-7845 at 11/13/17 8:15 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249223#comment-16249223
]
Piotr Nowojski edited comment on FLINK-7845 at 11/13/17 8:15 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249223#comment-16249223
]
Piotr Nowojski commented on FLINK-7845:
---
[~f.pompermaier] could you push a code for {{1.4-SNAPSHOT}}
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249435#comment-16249435
]
Piotr Nowojski commented on FLINK-7845:
---
[~f.pompermaier] your loop seems to extending the job over
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249321#comment-16249321
]
Piotr Nowojski commented on FLINK-7845:
---
Thanks, however it doesn't work for me :( When I try to run
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249385#comment-16249385
]
Piotr Nowojski commented on FLINK-7845:
---
After changing it to public {{IllegaltAccessError}} indeed
Piotr Nowojski created FLINK-8132:
-
Summary: FlinkKafkaProducer011 can commit incorrect transaction
during recovery
Key: FLINK-8132
URL: https://issues.apache.org/jira/browse/FLINK-8132
Project:
[
https://issues.apache.org/jira/browse/FLINK-8132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-8132:
--
Description:
Faulty scenario with producer pool of 2.
1. started transaction 1 with producerA,
Piotr Nowojski created FLINK-8172:
-
Summary: Remove unnecessary synchronisation in RecordSerializer
Key: FLINK-8172
URL: https://issues.apache.org/jira/browse/FLINK-8172
Project: Flink
Issue
Piotr Nowojski created FLINK-8178:
-
Summary: Introduce not threadsafe write only BufferBuilder
Key: FLINK-8178
URL: https://issues.apache.org/jira/browse/FLINK-8178
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-8268:
-
Assignee: Piotr Nowojski
> Test instability for 'TwoPhaseCommitSinkFunctionTest'
>
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247785#comment-16247785
]
Piotr Nowojski commented on FLINK-7845:
---
Could you strip down your example to some minimal code
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7845:
--
Attachment: Screen Shot 2017-11-13 at 14.54.38.png
> Netty Exception when submitting batch job
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249564#comment-16249564
]
Piotr Nowojski commented on FLINK-7845:
---
Why are you suspecting a memory leak? How is this test
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-7845:
--
Priority: Blocker (was: Major)
Fix Version/s: 1.4.0
> Netty Exception when submitting
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reopened FLINK-7845:
---
Assignee: Piotr Nowojski
> Netty Exception when submitting batch job repeatedly
>
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249627#comment-16249627
]
Piotr Nowojski edited comment on FLINK-7845 at 11/13/17 2:08 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249688#comment-16249688
]
Piotr Nowojski commented on FLINK-7845:
---
Please do not close this ticket, since
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249627#comment-16249627
]
Piotr Nowojski edited comment on FLINK-7845 at 11/13/17 2:06 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16249627#comment-16249627
]
Piotr Nowojski commented on FLINK-7845:
---
IllegalAccessError is irrelevant to any memory leak for
[
https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski resolved FLINK-7845.
---
Resolution: Fixed
This is not a bug in Flink after all. According to discussion in this
[
https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski resolved FLINK-8086.
---
Resolution: Fixed
> FlinkKafkaProducer011 can permanently fail in recovery through
>
[
https://issues.apache.org/jira/browse/FLINK-8086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-8086:
-
Assignee: Piotr Nowojski
> FlinkKafkaProducer011 can permanently fail in recovery
1 - 100 of 4426 matches
Mail list logo
