Tzu-Li (Gordon) Tai created FLINK-6770:
--
Summary: Add excludeSerializersInCheckpoints to ExeuctionConfig
Key: FLINK-6770
URL: https://issues.apache.org/jira/browse/FLINK-6770
Project: Flink
10 AM, Tzu-Li (Gordon) Tai
wrote:
> I think https://issues.apache.org/jira/browse/FLINK-6714 is most likely a
> blocker.
> It basically makes most of our connectors that are not part of the binary
> distribution and uses Java serialization for their operator state unusable
>
Tzu-Li (Gordon) Tai created FLINK-6719:
--
Summary: Add details about fault-tolerance of timers to
ProcessFunction docs
Key: FLINK-6719
URL: https://issues.apache.org/jira/browse/FLINK-6719
I think https://issues.apache.org/jira/browse/FLINK-6714 is most likely a
blocker.
It basically makes most of our connectors that are not part of the binary
distribution and uses Java serialization for their operator state unusable in
standalone mode.
There's a pending PR for the fix: https://g
Tzu-Li (Gordon) Tai created FLINK-6714:
--
Summary: Operator state backend should set user classloader as
context classloader when snapshotting
Key: FLINK-6714
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-6713:
--
Summary: Document how to allow multiple Kafka consumers /
producers to authenticate using different credentials
Key: FLINK-6713
URL: https://issues.apache.org/jira
Tzu-Li (Gordon) Tai created FLINK-6712:
--
Summary: Bump Kafka010 version to 0.10.2.0
Key: FLINK-6712
URL: https://issues.apache.org/jira/browse/FLINK-6712
Project: Flink
Issue Type
Hi Kostas,
Thanks for bringing this up!
I think it is reasonable to keep this coherent with our timely-based release
model guarantees.
With the timely-based release model, there is a guarantee that the current
latest major version and the previous one is supported.
For example, upon releasing 1
Tzu-Li (Gordon) Tai created FLINK-6653:
--
Summary: Avoid directly serializing AWS's Shard class in Kinesis
consumer's checkpoints
Key: FLINK-6653
URL: https://issues.apache.org/jira/browse/
Hi Robert,
There is one last pending fix for the serializer upgrades feature:
https://issues.apache.org/jira/browse/FLINK-6482.
Pending PR: https://github.com/apache/flink/pull/3937.
I can’t say its a complete blocker, but since it will affect serialization
format of checkpoints, it would be be
Tzu-Li (Gordon) Tai created FLINK-6608:
--
Summary: Relax Kerberos login contexts parsing by trimming
whitespaces in contexts list
Key: FLINK-6608
URL: https://issues.apache.org/jira/browse/FLINK-6608
Tzu-Li (Gordon) Tai created FLINK-6607:
--
Summary: Confusing statement in docs that Kafka 010 consumer does
not require timestamp extractors
Key: FLINK-6607
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-6600:
--
Summary: Add key serializer's config snapshot to
KeyedBackendSerializationProxy
Key: FLINK-6600
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-6566:
--
Summary: Narrow down interface for compatibility hook method in
VersionedIOReadableWritable
Key: FLINK-6566
URL: https://issues.apache.org/jira/browse/FLINK-6566
Tzu-Li (Gordon) Tai created FLINK-6565:
--
Summary: Improve error messages for state restore failures
Key: FLINK-6565
URL: https://issues.apache.org/jira/browse/FLINK-6565
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-6520:
--
Summary: FlinkKafkaConsumer09+ does not overwrite props to not
auto commit offsets when commit mode is OffsetCommitMode.ON_CHECKPOINTS
Key: FLINK-6520
URL: https
Hi Alex,
I would start searching in the Flink JIRA for tickets tagged with the component
“Machine Learning Library”, and once you find a ticket you’ll like to work on,
ask for the JIRA to be assigned to you on the mailing lists. From then on you
can also assign any other tasks you’ll like to wo
Tzu-Li (Gordon) Tai created FLINK-6503:
--
Summary: Refactor KinesisDataFetcher to separate concerns for
shard discovery
Key: FLINK-6503
URL: https://issues.apache.org/jira/browse/FLINK-6503
Tzu-Li (Gordon) Tai created FLINK-6482:
--
Summary: Add nested serializers into configuration snapshots of
composite serializers
Key: FLINK-6482
URL: https://issues.apache.org/jira/browse/FLINK-6482
Tzu-Li (Gordon) Tai created FLINK-6478:
--
Summary: Add documentation on how to upgrade serializers for
managed state
Key: FLINK-6478
URL: https://issues.apache.org/jira/browse/FLINK-6478
Project
Hi,
I have 2 parts to discuss about delaying the feature freeze for a bit:
1. Allow upgrades to state serializers (FLINK-6178)
The feature is split up into 2 PRs, one of which is already open and the second
one coming up very soon.
PR #1 reconfigurable TypeSerializers: https://github.com/apache/
Tzu-Li (Gordon) Tai created FLINK-6425:
--
Summary: Integrate serializer reconfiguration into state restore
flow to activate serializer upgrades
Key: FLINK-6425
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-6363:
--
Summary: Document precedence rules of Kryo serializer registrations
Key: FLINK-6363
URL: https://issues.apache.org/jira/browse/FLINK-6363
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-6349:
--
Summary: Enforce per-subtask record ordering on resharding for
FlinkKinesisConsumer
Key: FLINK-6349
URL: https://issues.apache.org/jira/browse/FLINK-6349
Tzu-Li (Gordon) Tai created FLINK-6348:
--
Summary: Migrate from Java serialization for RollingSink's state
Key: FLINK-6348
URL: https://issues.apache.org/jira/browse/FLINK-6348
Project:
Tzu-Li (Gordon) Tai created FLINK-6347:
--
Summary: Migrate from Java serialization for
MessageAcknowledgingSourceBase's state
Key: FLINK-6347
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-6346:
--
Summary: Migrate from Java serialization for
GenericWriteAheadSink's state
Key: FLINK-6346
URL: https://issues.apache.org/jira/browse/FLINK-6346
Pr
Tzu-Li (Gordon) Tai created FLINK-6345:
--
Summary: Migrate from Java serialization for
ContinuousFileReaderOperator's state
Key: FLINK-6345
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-6344:
--
Summary: Migrate from Java serialization for `BucketingSink`'s
state
Key: FLINK-6344
URL: https://issues.apache.org/jira/browse/FLINK-6344
Project:
Tzu-Li (Gordon) Tai created FLINK-6343:
--
Summary: Migrate from discouraged Java serialization for all
sources / sinks
Key: FLINK-6343
URL: https://issues.apache.org/jira/browse/FLINK-6343
Tzu-Li (Gordon) Tai created FLINK-6324:
--
Summary: Refine state access methods in OperatorStateStore
Key: FLINK-6324
URL: https://issues.apache.org/jira/browse/FLINK-6324
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-6316:
--
Summary: Kinesis connector docs should mention that
FlinkKinesisConsumer does not provide strong ordering guarantees on resharding
Key: FLINK-6316
URL: https
Hi Amir,
What do you mean by “modernizing” the FlinkKafkaConsumer implementation? Could
you explain a bit more?
Thanks :) Chiming in just to check if there’s any issue we need to be aware of
..
Cheers,
Gordon
On 14 April 2017 at 5:35:43 AM, amir bahmanyari (amirto...@yahoo.com.invalid)
wrote:
Tzu-Li (Gordon) Tai created FLINK-6311:
--
Summary: NPE in FlinkKinesisConsumer if source was closed before
run
Key: FLINK-6311
URL: https://issues.apache.org/jira/browse/FLINK-6311
Project: Flink
> Do you have any suggestions how to get around this?
>
> Gyula
>
> Tzu-Li (Gordon) Tai ezt írta (időpont: 2017. ápr.
> 10., H, 15:57):
>
> I would prefer to make this a blocker for a future bugfix actually, and
> not 1.2.1.
>
> The reason is that
changes into releases.
On April 10, 2017 at 6:46:29 AM, Gyula Fóra (gyula.f...@gmail.com) wrote:
Thanks for checking this out.
I would say this is definitely a blocking issue for the bugfix release,
what do you think?
Gyula
Tzu-Li (Gordon) Tai ezt írta (időpont: 2017. ápr.
10., H, 15
Hi Gyula,
Yes, I think the semantics of the Partitioner interface is a bit off.
The `numPartitions` value ideally should be the number of partitions of the
`targetTopic`.
Here’s a JIRA I just filed to track the issue:
https://issues.apache.org/jira/browse/FLINK-6288.
Cheers,
Gordon
On April 1
Tzu-Li (Gordon) Tai created FLINK-6288:
--
Summary: FlinkKafkaProducer's custom Partitioner is always invoked
with number of partitions of default topic
Key: FLINK-6288
URL: https://issues.apache.org
Tzu-Li (Gordon) Tai created FLINK-6258:
--
Summary: Deprecate ListCheckpointed interface for managed operator
state
Key: FLINK-6258
URL: https://issues.apache.org/jira/browse/FLINK-6258
Project
Tzu-Li (Gordon) Tai created FLINK-6191:
--
Summary: Make non-primitive, internal built-in serializers
reconfigurable
Key: FLINK-6191
URL: https://issues.apache.org/jira/browse/FLINK-6191
Project
Tzu-Li (Gordon) Tai created FLINK-6190:
--
Summary: Write "Serializer Configurations" metainfo along with
state
Key: FLINK-6190
URL: https://issues.apache.org/jira/browse/FLINK-6190
Proj
ase in the end.
On Fri, Mar 24, 2017 at 7:02 AM, Tzu-Li (Gordon) Tai
wrote:
> Update for 1.2.1:
>
> The last fix was just merged!
>
> Since nobody else seems interested in managing 1.2.1, I can also help with
> this one :)
> I’ll create the release candi
Tzu-Li (Gordon) Tai created FLINK-6178:
--
Summary: Allow upgrades to state serializers
Key: FLINK-6178
URL: https://issues.apache.org/jira/browse/FLINK-6178
Project: Flink
Issue Type
1.2.1.
Status: PR review pending - https://github.com/apache/flink/pull/3587
On March 22, 2017 at 12:23:03 AM, Tzu-Li (Gordon) Tai (tzuli...@apache.org)
wrote:
Update for Flink 1.2.1:
There’s only one PR pending that is LGTM -
https://issues.apache.org/jira/browse/FLINK-6084
Fix for Cassandra
The Apache Flink community is pleased to announce the availability of Flink
1.1.5, which is the next bugfix release for the 1.1 series.
The official release announcement:
https://flink.apache.org/news/2017/03/23/release-1.1.5.html
Release binaries: http://apache.lauf-forum.at/flink/flink-1.1.5
Fo
celling the vote, but then I realized that since Flink 0.10
>> (november 2015) we never released the module:
>> http://search.maven.org/#search%7Cgav%7C1%7Cg%3A%22org.
>> apache.flink%22%20AND%20a%3A%22flink-java8%22
>>
>>
>> On Fri, Mar 17, 2017 at
- https://github.com/apache/flink/pull/3587
On March 22, 2017 at 12:23:03 AM, Tzu-Li (Gordon) Tai (tzuli...@apache.org)
wrote:
Update for Flink 1.2.1:
There’s only one PR pending that is LGTM -
https://issues.apache.org/jira/browse/FLINK-6084
Fix for Cassandra connector dropping metrics-core
ompermaier
wrote:
> I propose to fix https://issues.apache.org/jira/browse/FLINK-6103 before
> issue a release
>
> On Fri, Mar 17, 2017 at 8:12 AM, Ufuk Celebi wrote:
>
> > Cool! Thanks for taking care of this Gordon :-)
> >
> > On Fri, Mar 17, 2017 a
Welcome Theodore! Great to have you on board :-)
On March 21, 2017 at 4:35:35 PM, Robert Metzger (rmetz...@apache.org) wrote:
Hi everybody,
On behalf of the PMC I am delighted to announce Theodore Vasiloudis as a
new Flink committer!
Theo has been a community member for a very long time and
Tzu-Li (Gordon) Tai created FLINK-6139:
--
Summary: Documentation for building / preparing Flink for MapR
Key: FLINK-6139
URL: https://issues.apache.org/jira/browse/FLINK-6139
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-6109:
--
Summary: Add "consumer lag" report metric to FlinkKafkaConsumer
Key: FLINK-6109
URL: https://issues.apache.org/jira/browse/FLINK-6109
Proj
Dear Flink community,
Please vote on releasing the following candidate as Apache Flink version 1.1.5.
The commit to be voted on:
ed18e97 (http://git-wip-us.apache.org/repos/asf/flink/commit/ed18e97)
Branch:
release-1.1.5-rc1
(https://git1-us-west.apache.org/repos/asf/flink/repo?p=flink.git;
t;> Status: PR
> >>>>>>>
> >>>>>>>
> >>>>>>>> Am 14.03.2017 um 15:15 schrieb Till Rohrmann <
> trohrm...@apache.org
> >>>>> :
> >>>>>>>>
> >>&
annot retrieve the
>>>>>> completed checkpoint from the meta data state handle retrieved from
>>>>>> ZooKeeper. This can, for example, happen if the meta data is
>> deleted.
>>>>>> Checkpoints with unretrievable state handles are
Hi all!
I would like to start a discussion for the next bugfix release for 1.1.x and
1.2.x.
There’s been quite a few critical fixes for bugs in both the releases recently,
and I think they deserve a bugfix release soon.
Most of the bugs were reported by users.
I’m starting the discussion for bo
Tzu-Li (Gordon) Tai created FLINK-6038:
--
Summary: Add links to Apache Bahir Flink streaming connectors
Key: FLINK-6038
URL: https://issues.apache.org/jira/browse/FLINK-6038
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-6025:
--
Summary: User code ClassLoader not used when KryoSerializer
fallbacks to serialization for copying
Key: FLINK-6025
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-6006:
--
Summary: Kafka Consumer can lose state if queried partition list
is incomplete on restore
Key: FLINK-6006
URL: https://issues.apache.org/jira/browse/FLINK-6006
Tzu-Li (Gordon) Tai created FLINK-6004:
--
Summary: Allow FlinkKinesisConsumer to skip corrupted messages
Key: FLINK-6004
URL: https://issues.apache.org/jira/browse/FLINK-6004
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-5991:
--
Summary: Expose Broadcast Operator State through public APIs
Key: FLINK-5991
URL: https://issues.apache.org/jira/browse/FLINK-5991
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-5949:
--
Summary: Flink on YARN checks for Kerberos credentials for
non-Kerberos authentication methods
Key: FLINK-5949
URL: https://issues.apache.org/jira/browse/FLINK-5949
Tzu-Li (Gordon) Tai created FLINK-5939:
--
Summary: Wrong version in README.md for several Apache Flink
extensions
Key: FLINK-5939
URL: https://issues.apache.org/jira/browse/FLINK-5939
Project
Throwing in some thoughts:
When a source determines that no more data will come for a key (which
in itself is a bit of a tricky problem) then it should signal to downstream
operations to take the key out of watermark calculations, that is that we
can release some space.
I don’t think this is p
Tzu-Li (Gordon) Tai created FLINK-5849:
--
Summary: Kafka Consumer checkpointed state may contain undefined
offsets
Key: FLINK-5849
URL: https://issues.apache.org/jira/browse/FLINK-5849
Project
Hi Andrea!
Welcome to the Flink community! Very happy to see that you’re interested in
contributing.
Just let us know when you’ve came across an issue on JIRA you’d like to start
working on, and also your JIRA id.
We can assign you contributor permissions on JIRA so that you can assign issues
Hi Ozan,
From your description, it seems like your original huge job can be broken down
into smaller disconnected graphs, with only some of the graphs requiring
checkpointing / snapshots.
In general, it would be a good practice to split disconnected graphs of the
execution graph into multiple j
Great news! Welcome Stefan :-D
On February 10, 2017 at 11:36:14 PM, Aljoscha Krettek (aljos...@apache.org)
wrote:
Welcome! :-)
On Fri, 10 Feb 2017 at 16:10 Till Rohrmann wrote:
> Great to have you on board as a committer Stefan :-)
>
> On Fri, Feb 10, 2017 at 3:32 PM, Greg Hogan wro
Tzu-Li (Gordon) Tai created FLINK-5772:
--
Summary: Instability with embedded Elasticsearch node in
ElasticsearchSink test
Key: FLINK-5772
URL: https://issues.apache.org/jira/browse/FLINK-5772
Hi Kush!
The link is broken, thank you for reporting this.
This is the correct link:
https://ci.apache.org/projects/flink/flink-docs-release-1.2/setup/flink_on_windows.html
Cheers,
Gordon
On February 10, 2017 at 12:54:01 PM, kush batra (kush.ba...@gmail.com) wrote:
Hi,
In Quickstart section
Great news, congratulations!
Thank you Jark and Kostas for all your contribution to the Flink community so
far,
and really looking forward seeing it grow even more in the future with you
being aboard :-D
Cheers,
Gordon
On February 8, 2017 at 11:35:08 AM, Jark Wu (wuchong...@alibaba-inc.com) wr
Tzu-Li (Gordon) Tai created FLINK-5728:
--
Summary: FlinkKafkaProducer should flush on checkpoint by default
Key: FLINK-5728
URL: https://issues.apache.org/jira/browse/FLINK-5728
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-5719:
--
Summary: Let LatencyMarkers completely bypass operators / chains
Key: FLINK-5719
URL: https://issues.apache.org/jira/browse/FLINK-5719
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-5716:
--
Summary: Make streaming SourceContexts aware of source idleness
Key: FLINK-5716
URL: https://issues.apache.org/jira/browse/FLINK-5716
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-5704:
--
Summary: Deprecate FlinkKafkaConsumer constructors in favor of
improvements to decoupling from Kafka offset committing
Key: FLINK-5704
URL: https://issues.apache.org
Tzu-Li (Gordon) Tai created FLINK-5702:
--
Summary: Kafka Producer docs should warn if using
setLogFailuresOnly, at-least-once is compromised
Key: FLINK-5702
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-5701:
--
Summary: FlinkKafkaPrdocuer violates at-least-once by not handling
failed records
Key: FLINK-5701
URL: https://issues.apache.org/jira/browse/FLINK-5701
Tzu-Li (Gordon) Tai created FLINK-5697:
--
Summary: Add per-shard watermarks for FlinkKinesisConsumer
Key: FLINK-5697
URL: https://issues.apache.org/jira/browse/FLINK-5697
Project: Flink
+1 (non-binding)
- Tested TaskManager failures on Mesos / Standalone with exactly-once guarantees
- Above tests also done against Kafka 0.8 / 0.9 / 0.10, offsets committed
correctly back to ZK (manual check for 0.8 due to FLINK-4822)
- Tested Kafka 0.10 server-side timestamps
- Verified Async I/O
Hi Sree,
The expected Flink version for support for Elasticsearch 5 is Flink 1.3.0.
The release ETA for 1.3.0 is near the end of May 2017, based on the recently
announced timely-based release schedules.
The pull requests for Elasticsearch 5 support just needs to be reviewed before
they are merge
Tzu-Li (Gordon) Tai created FLINK-5581:
--
Summary: Improve Kerberos security related documentation
Key: FLINK-5581
URL: https://issues.apache.org/jira/browse/FLINK-5581
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-5580:
--
Summary: Kerberos keytabs not working for YARN deployment mode
Key: FLINK-5580
URL: https://issues.apache.org/jira/browse/FLINK-5580
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-5579:
--
Summary: Kerberos not working for Kafka connector using ticket
cache
Key: FLINK-5579
URL: https://issues.apache.org/jira/browse/FLINK-5579
Project: Flink
Hi Robert,
Thanks for bringing up the discussion. I like the proposal.
Regarding some of the downsides mentioned in the wiki:
1. Features that don’t make it in time with the feature freeze:
I think that’s ok, as long as we’re consistent with the schedules for the next
release. This way users wa
Tzu-Li (Gordon) Tai created FLINK-5512:
--
Summary: RabbitMQ documentation should inform that exactly-once
holds for RMQSource only when parallelism is 1
Key: FLINK-5512
URL: https://issues.apache.org/jira
Tzu-Li (Gordon) Tai created FLINK-5487:
--
Summary: Proper at-least-once support for ElasticsearchSink
Key: FLINK-5487
URL: https://issues.apache.org/jira/browse/FLINK-5487
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-5483:
--
Summary: Link to "linking modules not contained in binary
distribution" broken in all connector documentations
Key: FLINK-5483
URL: https://issues.apach
Tzu-Li (Gordon) Tai created FLINK-5479:
--
Summary: Per-partition watermarks in FlinkKafkaConsumer should
consider idle partitions
Key: FLINK-5479
URL: https://issues.apache.org/jira/browse/FLINK-5479
K-5353 should be
> > solved sooner or later...
> >
> > Best,
> > Flavio
> >
> > On 9 Jan 2017 12:24, "Tzu-Li (Gordon) Tai" wrote:
> >
> > > Thanks for starting the discussion Robert.
> > >
> > > I agree
Thanks for starting the discussion Robert.
I agree that we should try to treat the Elasticsearch connectors in a similar
fashion to the multiple Kafka connector versions.
+1 for flink-connector-elasticsearch-base
+1 to consolidating the documents
+1 for keeping the ES connector in Flink
I’d als
+1 (unbinding)
- Assured Kinesis connector works properly across different / older AWS EMR
versions with simple job (randomly tested in version 5.0.3, 4.8.2, 4.7.2, 4.5)
- Ran Java & Scala quickstart examples (in local IDE mode, cluster mode and
multi-node cluster)
On December 21, 2016 at 9:38
Tzu-Li (Gordon) Tai created FLINK-5128:
--
Summary: Get Kafka partitions in FlinkKafkaProducer only if a
partitioner is set
Key: FLINK-5128
URL: https://issues.apache.org/jira/browse/FLINK-5128
Tzu-Li (Gordon) Tai created FLINK-5075:
--
Summary: Kinesis consumer incorrectly determines shards as newly
discovered when tested against Kinesalite
Key: FLINK-5075
URL: https://issues.apache.org/jira/browse
+1 for cancelling RC1.
I would also like to merge FLINK-5013 (Kinesis connector not working on old EMR
versions) to be included in 1.1.4.
The PR (https://github.com/apache/flink/pull/2787) has been reviewed and can be
merged soon.
Best,
Gordon
On November 15, 2016 at 6:56:42 PM, Stefan Richte
Hi Mike,
I really like the idea! Especially that you pointed out we need a substantial
rework on the introduction
page to let users that are new to modern streaming frameworks understand the
space first.
With this content as a prelude, once the detailed Flink contents kick in, it
will definitel
Tzu-Li (Gordon) Tai created FLINK-5018:
--
Summary: User configurable source idle timeout to work with
WatermarkStatus emitting
Key: FLINK-5018
URL: https://issues.apache.org/jira/browse/FLINK-5018
Tzu-Li (Gordon) Tai created FLINK-5017:
--
Summary: Introduce WatermarkStatus stream element to allow for
temporarily idle streaming sources
Key: FLINK-5017
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-4821:
--
Summary: Implement rescalable non-partitioned state for Kinesis
Connector
Key: FLINK-4821
URL: https://issues.apache.org/jira/browse/FLINK-4821
Project
Tzu-Li (Gordon) Tai created FLINK-4753:
--
Summary: Kafka 0.8 connector's Periodic Offset Committer should
synchronize on checkpoint lock
Key: FLINK-4753
URL: https://issues.apache.org/jira/browse/FLINK
Sorry, correction to my last statements:
On the consumer side I think the instantiation was already removed from the
constructor in a recent commit.
On October 5, 2016 at 11:37:41 PM, Tzu-Li (Gordon) Tai (tzuli...@apache.org)
wrote:
This matters on the consumer side, yes. Moving the
fetching subtask the
partition list is identical?
On 05.10.2016 17:17, Tzu-Li (Gordon) Tai wrote:
> Hi Timo,
>
> I haven’t had the chance to look at the producer side too much yet, but after
> a look in the code,
> I think it’s reasonable to remove the instantiation fr
701 - 800 of 847 matches
Mail list logo
