Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4240
@aljoscha It is also a problem for 1.3. It's even worse since it still uses
the scala.binary.version property, which thus may try to fetch a 2.11 version
of quasiquotes which just doesn't exist.
[
https://issues.apache.org/jira/browse/FLINK-7178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089864#comment-16089864
]
ASF GitHub Bot commented on FLINK-7178:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4326
@zentol What's the plan for merging this? (Asking because it's one of the
remaining blockers for `1.3.2`)
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089852#comment-16089852
]
ASF GitHub Bot commented on FLINK-7058:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4240
This is not relevant for the `release-1.3` branch? (I'm asking because that
one still has some issues)
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089829#comment-16089829
]
ASF GitHub Bot commented on FLINK-7213:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4353#discussion_r127709120
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java
---
@@ -18,20 +18,40 @@
package
[
https://issues.apache.org/jira/browse/FLINK-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089828#comment-16089828
]
ASF GitHub Bot commented on FLINK-7213:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4353#discussion_r127708906
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java
---
@@ -18,20 +18,40 @@
package
[
https://issues.apache.org/jira/browse/FLINK-7212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089811#comment-16089811
]
ASF GitHub Bot commented on FLINK-7212:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4354
+1.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
[
https://issues.apache.org/jira/browse/FLINK-7212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089803#comment-16089803
]
ASF GitHub Bot commented on FLINK-7212:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/4354
[FLINK-7212][tests] re-enable JobManagerLeaderSessionIDITCase
This test was previously named JobManagerLeaderSessionIDITSuite and has not
been executed for a while by maven because of it having
[
https://issues.apache.org/jira/browse/FLINK-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089800#comment-16089800
]
ASF GitHub Bot commented on FLINK-7213:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4353
CC @StephanEwen @zentol
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and
[
https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089799#comment-16089799
]
Fabian Hueske commented on FLINK-7205:
--
The spatial uniqueness could be obtained from the id of the
[
https://issues.apache.org/jira/browse/FLINK-7213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089798#comment-16089798
]
ASF GitHub Bot commented on FLINK-7213:
---
GitHub user StefanRRichter opened a pull request:
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4353
[FLINK-7213] Introduce state management by OperatorID in TaskManager
Flink-5892 introduced the job manager / checkpoint coordinator part of
managing state on the operator level instead of
Stefan Richter created FLINK-7213:
-
Summary: Introduce state management by OperatorID in TaskManager
Key: FLINK-7213
URL: https://issues.apache.org/jira/browse/FLINK-7213
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089763#comment-16089763
]
ASF GitHub Bot commented on FLINK-6075:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4263
Hi @rtudoran, you are right, I said we will need retraction for OFFSET and
FETCH. However, it is only required for the general case and the special case
of `ORDER BY *time ASC` without updates
Nico Kruber created FLINK-7212:
--
Summary: JobManagerLeaderSessionIDITSuite not executed
Key: FLINK-7212
URL: https://issues.apache.org/jira/browse/FLINK-7212
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089733#comment-16089733
]
ASF GitHub Bot commented on FLINK-6725:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3993
No worries. Thanks for the update!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
[
https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089732#comment-16089732
]
Fabian Hueske commented on FLINK-7194:
--
In what sense is {{ScalarFunction.getResultType()}} different
[
https://issues.apache.org/jira/browse/FLINK-7058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089712#comment-16089712
]
ASF GitHub Bot commented on FLINK-7058:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4240
LGTM, +1.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
[
https://issues.apache.org/jira/browse/FLINK-7203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089700#comment-16089700
]
Aljoscha Krettek commented on FLINK-7203:
-
How do you mean? I still see {{AvroInputFormat}} and
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-7151:
Assignee: yuemeng
> FLINK SQL support create temporary function and table
>
[
https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089680#comment-16089680
]
Fabian Hueske commented on FLINK-7151:
--
Sure
Can you briefly describe how you are planning to address
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4350
Hi @greghogan, I think this is definitely a valuable improvement.
However, I looked at the plan of a query with a `ReduceFunction` with
`CombineHint.None` and found that it still has a combine
[
https://issues.apache.org/jira/browse/FLINK-7204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089678#comment-16089678
]
ASF GitHub Bot commented on FLINK-7204:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089646#comment-16089646
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4324
Hi @hongyuhong, thanks for your feedback!
I agree, passing good error messages to users is important. However, this
is very difficult in the optimizer because the optimizer is exploring different
[
https://issues.apache.org/jira/browse/FLINK-7101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089625#comment-16089625
]
Fabian Hueske commented on FLINK-7101:
--
Hi [~sunjincheng121], is [PR
[
https://issues.apache.org/jira/browse/FLINK-7101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089622#comment-16089622
]
ASF GitHub Bot commented on FLINK-7101:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4348#discussion_r127677326
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunction.scala
---
@@ -131,7 +131,8 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089603#comment-16089603
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3829
Thanks for the reply @lincoln-lil.
I agree, it is possible that a `TableSink` defines its schema when it is
created instead of when it is configured by the optimizer. However, I think
[
https://issues.apache.org/jira/browse/FLINK-6887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-6887.
--
Resolution: Fixed
Fixed in 527e7499c5807be138d1ba0a278917190a7d4cf1
> Split up CodeGenerator into several
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4171
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-6887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089590#comment-16089590
]
ASF GitHub Bot commented on FLINK-6887:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089566#comment-16089566
]
ASF GitHub Bot commented on FLINK-7175:
---
Github user pnowojski commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089567#comment-16089567
]
ASF GitHub Bot commented on FLINK-7175:
---
Github user pnowojski closed the pull request at:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4323
Closing this PR. Benchmarks will be in separate repository.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
Github user pnowojski closed the pull request at:
https://github.com/apache/flink/pull/4323
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-7211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089544#comment-16089544
]
ASF GitHub Bot commented on FLINK-7211:
---
GitHub user greghogan opened a pull request:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/4352
[FLINK-7211] [build] Exclude Gelly javadoc jar from release
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
Greg Hogan created FLINK-7211:
-
Summary: Exclude Gelly javadoc jar from release
Key: FLINK-7211
URL: https://issues.apache.org/jira/browse/FLINK-7211
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
[
https://issues.apache.org/jira/browse/FLINK-5775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089534#comment-16089534
]
Aljoscha Krettek commented on FLINK-5775:
-
Please re-open if there's more information.
>
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
[
https://issues.apache.org/jira/browse/FLINK-5775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5775.
---
Resolution: Cannot Reproduce
> NullReferenceException when running job on local cluster
>
[
https://issues.apache.org/jira/browse/FLINK-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-7209:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-6544
> Support DataView in Java and
[
https://issues.apache.org/jira/browse/FLINK-7207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-7207:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-6544
> Support getAccumulatorType when
[
https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-7208:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-6544
> Refactor build-in
[
https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-7206:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-6544
> Implementation of DataView to
Kaibo Zhou created FLINK-7209:
-
Summary: Support DataView in Java and Scala Tuples and case
classes or as the accumulator of AggregateFunction itself
Key: FLINK-7209
URL:
[
https://issues.apache.org/jira/browse/FLINK-6887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089495#comment-16089495
]
ASF GitHub Bot commented on FLINK-6887:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/4171
@fhueske thanks for reviewing. I had fixed the code style issue.
I will merge this once the CI pass.
---
If your project is set up for it, you can reply to this email and have your
reply
Kaibo Zhou created FLINK-7208:
-
Summary: Refactor build-in agg(MaxWithRetractAccumulator and
MinWithRetractAccumulator) using the DataView
Key: FLINK-7208
URL: https://issues.apache.org/jira/browse/FLINK-7208
Kaibo Zhou created FLINK-7207:
-
Summary: Support getAccumulatorType when use DataView
Key: FLINK-7207
URL: https://issues.apache.org/jira/browse/FLINK-7207
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-7206:
--
Description: Implementation of MapView and ListView to support state access
for UDAGG.
>
[
https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-7206:
--
Environment: (was: Implementation of MapView and ListView to support
state access for UDAGG.)
>
Kaibo Zhou created FLINK-7206:
-
Summary: Implementation of DataView to support state access for
UDAGG
Key: FLINK-7206
URL: https://issues.apache.org/jira/browse/FLINK-7206
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089489#comment-16089489
]
Kaibo Zhou commented on FLINK-6544:
---
Hi all, as discussed in the documentation, I will create some
[
https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kaibo Zhou updated FLINK-6544:
--
Description:
Currently UDAGG users can not access state, it's necessary to provide users
with a
Github user kaibozhou closed the pull request at:
https://github.com/apache/flink/pull/4351
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089475#comment-16089475
]
ASF GitHub Bot commented on FLINK-6544:
---
Github user kaibozhou closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089482#comment-16089482
]
ASF GitHub Bot commented on FLINK-6075:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/4263
@rtudoran "SELECT x FROM stream ORDER BY *time FETCH 2" do not need
retraction. Because it is order by ascending time. The query will only emit the
first 2 rows and after that drop all rows. We
[
https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089436#comment-16089436
]
ASF GitHub Bot commented on FLINK-6075:
---
Github user rtudoran commented on the issue:
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/4263
@fhueske You were the one that argue that retraction support is needed for
offset and fetch. When we were discussing this i was not into having the
retraction. I think finally it depends on what
[
https://issues.apache.org/jira/browse/FLINK-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-6725.
Resolution: Won't Fix
> make requiresOver as a contracted method in udagg
>
[
https://issues.apache.org/jira/browse/FLINK-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089427#comment-16089427
]
ASF GitHub Bot commented on FLINK-6725:
---
Github user shaoxuan-wang commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089428#comment-16089428
]
ASF GitHub Bot commented on FLINK-6725:
---
Github user shaoxuan-wang closed the pull request at:
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3993
@fhueske @sunjincheng121 @wuchong, thanks for the valuable inputs. We
talked offline and get an agreement that we'd better to put
`getAccumulatorType()`, `getResultType()` etc. in
Github user shaoxuan-wang closed the pull request at:
https://github.com/apache/flink/pull/3993
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
[
https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089419#comment-16089419
]
Ruidong Li commented on FLINK-7194:
---
[~fhueske]I agree to your suggestion, but the {{getResultType()}}
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/3672#discussion_r127641370
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java
---
@@ -20,6 +20,7 @@
import
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/3672#discussion_r127641519
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -949,8 +949,6 @@ public void run() {
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/3672#discussion_r127641085
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointStateRestoreTest.java
---
@@ -66,10 +66,19 @@
public void
[
https://issues.apache.org/jira/browse/FLINK-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089387#comment-16089387
]
ASF GitHub Bot commented on FLINK-6923:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4149
+1 agree with @aljoscha here.
The main problem with this change is that there is no usages of it in other
parts of the codebase, and can very easily be removed "accidentally" in the
future.
[
https://issues.apache.org/jira/browse/FLINK-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang updated FLINK-5878:
-
Summary: Add stream-stream inner/left-out join (was: Add stream-stream
inner join on TableAPI)
[
https://issues.apache.org/jira/browse/FLINK-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang reassigned FLINK-5878:
Assignee: Hequn Cheng (was: Shaoxuan Wang)
> Add stream-stream inner/left-out join
>
[
https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089359#comment-16089359
]
ASF GitHub Bot commented on FLINK-6998:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089358#comment-16089358
]
ASF GitHub Bot commented on FLINK-6998:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089356#comment-16089356
]
ASF GitHub Bot commented on FLINK-6998:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16089357#comment-16089357
]
ASF GitHub Bot commented on FLINK-6998:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4187#discussion_r127636481
--- Diff:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4187#discussion_r127636725
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@ -505,6
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4187#discussion_r127636859
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaCommitCallback.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4187#discussion_r127636523
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@ -185,6
101 - 194 of 194 matches
Mail list logo
