Tzu-Li (Gordon) Tai created FLINK-6849:
--
Summary: Refactor operator state backend and internal operator
state hierarchy
Key: FLINK-6849
URL: https://issues.apache.org/jira/browse/FLINK-6849
Proje
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16038288#comment-16038288
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
[~mingleizhang] I actually alread
Tzu-Li (Gordon) Tai created FLINK-6853:
--
Summary: Migrating from Flink 1.1 fails for FlinkCEP
Key: FLINK-6853
URL: https://issues.apache.org/jira/browse/FLINK-6853
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16038408#comment-16038408
]
Tzu-Li (Gordon) Tai commented on FLINK-6763:
After an offline discussion with
[
https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6764:
---
Labels: (was: flink-rel-1.3.1-blockers)
> Deduplicate stateless TypeSerializers when
[
https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6763:
---
Labels: (was: flink-rel-1.3.1-blockers)
> Inefficient PojoSerializerConfigSnapshot s
[
https://issues.apache.org/jira/browse/FLINK-6804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6804:
---
Labels: flink-rel-1.3.1-blockers (was: )
> Inconsistent state migration behaviour bet
Tzu-Li (Gordon) Tai created FLINK-6856:
--
Summary: Eagerly check if serializer config snapshots are
deserializable when snapshotting
Key: FLINK-6856
URL: https://issues.apache.org/jira/browse/FLINK-6856
Tzu-Li (Gordon) Tai created FLINK-6857:
--
Summary: Add global default Kryo serializer configuration to
StreamExecutionEnvironment
Key: FLINK-6857
URL: https://issues.apache.org/jira/browse/FLINK-6857
[
https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6857:
---
Description:
See ML for original discussion:
http://apache-flink-user-mailing-list-ar
[
https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6857:
---
Description:
See ML for original discussion:
http://apache-flink-user-mailing-list-ar
[
https://issues.apache.org/jira/browse/FLINK-6849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16040439#comment-16040439
]
Tzu-Li (Gordon) Tai commented on FLINK-6849:
Hi [~mingleizhang], your proposal
Tzu-Li (Gordon) Tai created FLINK-6864:
--
Summary: Remove confusing "invalid POJO type" messages from
TypeExtractor
Key: FLINK-6864
URL: https://issues.apache.org/jira/browse/FLINK-6864
Project: F
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6844.
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed for 1.3 via e1e207c898ed436df656
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6844.
--
> TraversableSerializer should implement compatibility methods
> ---
[
https://issues.apache.org/jira/browse/FLINK-6853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6853.
--
> Migrating from Flink 1.1 fails for FlinkCEP
> ---
[
https://issues.apache.org/jira/browse/FLINK-6853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6853.
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.1
Fixed for mas
[
https://issues.apache.org/jira/browse/FLINK-6808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6808.
Resolution: Fixed
Fixed for 1.3.1 via f74caf7062b1cc23a704f8f8b8171be430b60807.
Fixe
[
https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6830.
--
> Add ITTests for savepoint migration from 1.3
> ---
[
https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6830.
Resolution: Fixed
Fix Version/s: 1.4.0
Fixed for master via 3792be4b5f80826d5
[
https://issues.apache.org/jira/browse/FLINK-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6867:
---
Summary: Elasticsearch 1.x ITCase still instable due to embedded node
instability (wa
Tzu-Li (Gordon) Tai created FLINK-6867:
--
Summary: Elasticsearch 1.x IT test still instable due to embedded
node instability
Key: FLINK-6867
URL: https://issues.apache.org/jira/browse/FLINK-6867
P
[
https://issues.apache.org/jira/browse/FLINK-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6867:
---
Description:
The integration tests for Elasticsearch 1.x seems to still be instable, b
Tzu-Li (Gordon) Tai created FLINK-6869:
--
Summary: Scala serializers do not have the serialVersionUID
specified
Key: FLINK-6869
URL: https://issues.apache.org/jira/browse/FLINK-6869
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042864#comment-16042864
]
Tzu-Li (Gordon) Tai edited comment on FLINK-6857 at 6/8/17 3:34 PM:
[
https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042864#comment-16042864
]
Tzu-Li (Gordon) Tai commented on FLINK-6857:
[~StephanEwen] no, the current {{
[
https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042866#comment-16042866
]
Tzu-Li (Gordon) Tai commented on FLINK-6857:
The JIRA would therefore also ent
[
https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042864#comment-16042864
]
Tzu-Li (Gordon) Tai edited comment on FLINK-6857 at 6/8/17 3:36 PM:
[
https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042864#comment-16042864
]
Tzu-Li (Gordon) Tai edited comment on FLINK-6857 at 6/8/17 3:38 PM:
[
https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16042864#comment-16042864
]
Tzu-Li (Gordon) Tai edited comment on FLINK-6857 at 6/8/17 3:38 PM:
Tzu-Li (Gordon) Tai created FLINK-6883:
--
Summary: Serializer for collection of Scala case classes are
generated with different anonymous class names in 1.3
Key: FLINK-6883
URL: https://issues.apache.org/jira/
[
https://issues.apache.org/jira/browse/FLINK-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6883:
---
Description:
In the Scala API, serializers are generated using Scala macros (via the
Tzu-Li (Gordon) Tai created FLINK-6890:
--
Summary: flink-dist Jar contains non-shaded Guava dependencies
(built with Maven 3.0.5)
Key: FLINK-6890
URL: https://issues.apache.org/jira/browse/FLINK-6890
[
https://issues.apache.org/jira/browse/FLINK-6890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6890:
---
Description:
See original discussion on ML:
http://apache-flink-user-mailing-list-arc
[
https://issues.apache.org/jira/browse/FLINK-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6883.
Resolution: Fixed
Fixed for 1.3.1 via 39c8270d39684765484fa4b6b2711e5714b81b64.
Fixe
[
https://issues.apache.org/jira/browse/FLINK-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6883.
--
> Serializer for collection of Scala case classes are generated with different
> anonymous
[
https://issues.apache.org/jira/browse/FLINK-6869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6869.
Resolution: Fixed
Fixed for 1.3.1 via 7aafaf6aa549c30257cf6176fb220ce5150ee9fe.
Fixe
[
https://issues.apache.org/jira/browse/FLINK-6803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6803.
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.1
Fixed for 1.3
[
https://issues.apache.org/jira/browse/FLINK-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reopened FLINK-6883:
> Serializer for collection of Scala case classes are generated with different
> anonym
[
https://issues.apache.org/jira/browse/FLINK-6869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6869:
---
Fix Version/s: 1.4.0
> Scala serializers do not have the serialVersionUID specified
>
[
https://issues.apache.org/jira/browse/FLINK-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6883:
---
Fix Version/s: 1.4.0
> Serializer for collection of Scala case classes are generated w
[
https://issues.apache.org/jira/browse/FLINK-6803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6803.
--
> Add test for PojoSerializer when Pojo changes
> --
[
https://issues.apache.org/jira/browse/FLINK-6883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6883.
--
Resolution: Fixed
> Serializer for collection of Scala case classes are generated with d
[
https://issues.apache.org/jira/browse/FLINK-6869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6869.
--
> Scala serializers do not have the serialVersionUID specified
> ---
[
https://issues.apache.org/jira/browse/FLINK-6796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6796:
---
Fix Version/s: 1.4.0
1.3.1
> Allow setting the user code class load
[
https://issues.apache.org/jira/browse/FLINK-6804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6804.
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.1
Fixed for 1.3
[
https://issues.apache.org/jira/browse/FLINK-6804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6804.
--
> Inconsistent state migration behaviour between different state backends
>
[
https://issues.apache.org/jira/browse/FLINK-6796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6796.
--
> Allow setting the user code class loader for AbstractStreamOperatorTestHarness
> -
[
https://issues.apache.org/jira/browse/FLINK-6796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6796.
Resolution: Fixed
Fixed for master via e35c575ac41f2bdb3855170be883d0e21aa0379e.
Fix
[
https://issues.apache.org/jira/browse/FLINK-6801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6801.
--
> PojoSerializerConfigSnapshot cannot deal with missing Pojo fields
> --
[
https://issues.apache.org/jira/browse/FLINK-6801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6801.
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.1
Fixed for 1.3
[
https://issues.apache.org/jira/browse/FLINK-6848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6848.
--
> Extend the managed state docs with a Scala example
> -
[
https://issues.apache.org/jira/browse/FLINK-6848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6848.
Resolution: Fixed
Assignee: Fokko Driesprong
Fix Version/s: 1.4.0
[
https://issues.apache.org/jira/browse/FLINK-6915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049011#comment-16049011
]
Tzu-Li (Gordon) Tai commented on FLINK-6915:
This has been fixed in
https://g
[
https://issues.apache.org/jira/browse/FLINK-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049012#comment-16049012
]
Tzu-Li (Gordon) Tai edited comment on FLINK-6914 at 6/14/17 10:20 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-6914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16049012#comment-16049012
]
Tzu-Li (Gordon) Tai commented on FLINK-6914:
This has been fixed in This has b
Tzu-Li (Gordon) Tai created FLINK-6917:
--
Summary: Introduce test base for end-to-end testing serializer
config snapshotting, restoring, and compatibility check roundtrips
Key: FLINK-6917
URL: https://issues.
[
https://issues.apache.org/jira/browse/FLINK-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050152#comment-16050152
]
Tzu-Li (Gordon) Tai commented on FLINK-6263:
Could you briefly describe how /
[
https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050157#comment-16050157
]
Tzu-Li (Gordon) Tai commented on FLINK-6928:
I agree that the {{defaultTopic}}
[
https://issues.apache.org/jira/browse/FLINK-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6917:
---
Labels: (was: ta)
> Introduce test base for end-to-end testing serializer config sna
[
https://issues.apache.org/jira/browse/FLINK-6917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6917:
---
Labels: ta (was: )
> Introduce test base for end-to-end testing serializer config sna
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5991:
---
Labels: (was: api-breaking api-deprecation)
> Expose Broadcast Operator State throug
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5991:
---
Labels: api-breaking api-deprecation (was: )
> Expose Broadcast Operator State throug
Tzu-Li (Gordon) Tai created FLINK-6944:
--
Summary: Introduce DefaultTypeSerializerConfigSnapshot as a base
implementation for serializer compatibility checks
Key: FLINK-6944
URL: https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055136#comment-16055136
]
Tzu-Li (Gordon) Tai commented on FLINK-6951:
I've replied to the thread. The p
[
https://issues.apache.org/jira/browse/FLINK-6922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-6922:
--
Assignee: Tzu-Li (Gordon) Tai
> Enum(Value)SerializerConfigSnapshot uses Java s
[
https://issues.apache.org/jira/browse/FLINK-6921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6921.
Resolution: Fixed
Fix Version/s: 1.3.1
Fixed for master via e520023ac768ac739
[
https://issues.apache.org/jira/browse/FLINK-6948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6948.
Resolution: Fixed
Fix Version/s: 1.3.1
Fixed for master via 228faf8c2a113de0d
[
https://issues.apache.org/jira/browse/FLINK-6921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055697#comment-16055697
]
Tzu-Li (Gordon) Tai commented on FLINK-6921:
Thanks for the fix Till!
> EnumV
[
https://issues.apache.org/jira/browse/FLINK-6922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6922.
Resolution: Fixed
Fix Version/s: 1.3.1
Fixed for master via f24a499b37515b437
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055806#comment-16055806
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
[~shashank734] do you mean that a
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055807#comment-16055807
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
btw, please test this on the late
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055809#comment-16055809
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
For example, there were some othe
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055818#comment-16055818
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
[~shashank734]
Can you try https
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055819#comment-16055819
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
Then I'm pretty sure that you act
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055827#comment-16055827
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
The thing is, I can't tell anythi
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055836#comment-16055836
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
Yes, so what I mean is, the check
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16055861#comment-16055861
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
Didn't you mention this error:
{c
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16056044#comment-16056044
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
[~shashank734]
I've tested CEP +
[
https://issues.apache.org/jira/browse/FLINK-6844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16056917#comment-16056917
]
Tzu-Li (Gordon) Tai commented on FLINK-6844:
[~shashank734] I think the next r
[
https://issues.apache.org/jira/browse/FLINK-6954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16056918#comment-16056918
]
Tzu-Li (Gordon) Tai commented on FLINK-6954:
As discussed in FLINK-6844, this
Tzu-Li (Gordon) Tai created FLINK-10492:
---
Summary: Document generic support for configuring AwsKinesisClient
in the Kinesis Consumer
Key: FLINK-10492
URL: https://issues.apache.org/jira/browse/FLINK-10492
[
https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-6998.
Resolution: Fixed
Fix Version/s: 1.3.2
1.4.0
Thanks for th
[
https://issues.apache.org/jira/browse/FLINK-7287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-7287.
Resolution: Fixed
Fix Version/s: 1.3.2
1.4.0
Thanks for th
[
https://issues.apache.org/jira/browse/FLINK-7248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-7248.
--
> Invalid checkRestoredNullCheckpointWhenFetcherNotReady test in
> FlinkKafkaConsumerBaseTe
[
https://issues.apache.org/jira/browse/FLINK-7248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-7248.
Resolution: Fixed
Fixed in master via c5221c85a1c532a5234ec0b4331a04cffa04ba5c.
> I
[
https://issues.apache.org/jira/browse/FLINK-7287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-7287.
--
> test instability in Kafka010ITCase.testCommitOffsetsToKafka
>
[
https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-6998.
--
> Kafka connector needs to expose metrics for failed/successful offset commits
> in the Kaf
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-7143.
Resolution: Fixed
Fix Version/s: 1.4.0
Tests are now also ported to master, v
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-7143.
--
> Partition assignment for Kafka consumer is not stable
> --
[
https://issues.apache.org/jira/browse/FLINK-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-7195.
--
> FlinkKafkaConsumer should not respect fetched partitions to filter restored
> partition s
[
https://issues.apache.org/jira/browse/FLINK-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16105103#comment-16105103
]
Tzu-Li (Gordon) Tai commented on FLINK-7195:
There actually isn't any tests ne
[
https://issues.apache.org/jira/browse/FLINK-7195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-7195.
Resolution: Fixed
> FlinkKafkaConsumer should not respect fetched partitions to filt
Tzu-Li (Gordon) Tai created FLINK-7300:
--
Summary: End-to-end tests are instable on Travis
Key: FLINK-7300
URL: https://issues.apache.org/jira/browse/FLINK-7300
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16107043#comment-16107043
]
Tzu-Li (Gordon) Tai commented on FLINK-7300:
https://travis-ci.org/apache/flin
[
https://issues.apache.org/jira/browse/FLINK-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16107050#comment-16107050
]
Tzu-Li (Gordon) Tai commented on FLINK-4789:
I would like to close this issue
[
https://issues.apache.org/jira/browse/FLINK-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-4789.
--
Resolution: Won't Fix
> Avoid Kafka partition discovery on restore and share consumer in
[
https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5704:
---
Fix Version/s: 1.4.0
> Deprecate FlinkKafkaConsumer constructors in favor of improveme
[
https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16107058#comment-16107058
]
Tzu-Li (Gordon) Tai commented on FLINK-5704:
Setting "Fix Version" to 1.4.0 f
[
https://issues.apache.org/jira/browse/FLINK-7303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16107065#comment-16107065
]
Tzu-Li (Gordon) Tai commented on FLINK-7303:
+1
> Build elasticsearch5 by def
901 - 1000 of 3295 matches
Mail list logo
