[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438529#comment-15438529
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2305
Hi @StephanEwen @aljoscha , I have updated this PR with the `with(...)`
approach , could you have a look at it?
And log FLINK-4503 JIRA for Flink 2.0 breaking changes.
---
If your project i
Jark Wu created FLINK-4503:
--
Summary: Remove with method from CoGroupedStream and JoinedStream,
and change apply method return type
Key: FLINK-4503
URL: https://issues.apache.org/jira/browse/FLINK-4503
Proje
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438519#comment-15438519
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r76367829
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -35,27 +79,634 @@
*/
public class
[
https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-4459:
-
Assignee: Kurt Young
> Introduce SlotProvider for Scheduler
> ---
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438437#comment-15438437
]
zhangjing edited comment on FLINK-4478 at 8/26/16 4:04 AM:
---
Hi [
[
https://issues.apache.org/jira/browse/FLINK-4478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438437#comment-15438437
]
zhangjing commented on FLINK-4478:
--
Good abstraction.
> Implement heartbeat logic
>
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438412#comment-15438412
]
ramkrishna.s.vasudevan commented on FLINK-3322:
---
[~StephanEwen]
I thought of
[
https://issues.apache.org/jira/browse/FLINK-4462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15438402#comment-15438402
]
ASF GitHub Bot commented on FLINK-4462:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2412
@StephanEwen
I meant the library only. I did not mean it is added in code. Am not sure
what are the APIs in that library to make use.
---
If your project is set up for it, you can reply to t
Elias Levy created FLINK-4502:
-
Summary: Cassandra connector documentation has misleading
consistency guarantees
Key: FLINK-4502
URL: https://issues.apache.org/jira/browse/FLINK-4502
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy closed FLINK-4501.
-
Resolution: Duplicate
HTTP connection got reset and was submitted twice.
> Cassandra sink can lose messag
Elias Levy created FLINK-4500:
-
Summary: Cassandra sink can lose messages
Key: FLINK-4500
URL: https://issues.apache.org/jira/browse/FLINK-4500
Project: Flink
Issue Type: Bug
Components
Elias Levy created FLINK-4501:
-
Summary: Cassandra sink can lose messages
Key: FLINK-4501
URL: https://issues.apache.org/jira/browse/FLINK-4501
Project: Flink
Issue Type: Bug
Components
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437818#comment-15437818
]
ASF GitHub Bot commented on FLINK-4499:
---
Github user smarthi commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437815#comment-15437815
]
ASF GitHub Bot commented on FLINK-4499:
---
GitHub user smarthi opened a pull request:
Github user smarthi commented on the issue:
https://github.com/apache/flink/pull/2422
Setup a default findbugs-exclude.xml, please feel free to customize as u
deem fit for Flink.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
GitHub user smarthi opened a pull request:
https://github.com/apache/flink/pull/2422
FLINK-4499: Introduce findbugs maven plugin
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes t
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437693#comment-15437693
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2374
@zentol I've updated Meter's interface. Could you give this PR another
review?
Sorry for the force push, I had to rebase on top of `master` to resolve
merge conflict.
---
If your project is s
[
https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437533#comment-15437533
]
Greg Hogan commented on FLINK-4440:
---
I think it is good to be explicit when assigning th
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437475#comment-15437475
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user delding commented on the issue:
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2332
Hi, I have updated the PR based on @ramkrish86 's comments.
1. rename MutationActionList to MutationActions which has a public method
createMutations that
return HBase Mutations
2. ma
[
https://issues.apache.org/jira/browse/FLINK-4459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437459#comment-15437459
]
Stephan Ewen commented on FLINK-4459:
-
Yes, this is needed.
In the master branch, the
[
https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3679:
--
Component/s: Kafka Connector
> DeserializationSchema should handle zero or more outputs for ever
[
https://issues.apache.org/jira/browse/FLINK-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437453#comment-15437453
]
Stephan Ewen commented on FLINK-4490:
-
For the FLIP-6 work, we need that agreed.
Here
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437410#comment-15437410
]
Gabor Gevay commented on FLINK-3322:
Yes, I volunteer to help :)
> MemoryManager crea
[
https://issues.apache.org/jira/browse/FLINK-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437396#comment-15437396
]
ASF GitHub Bot commented on FLINK-4278:
---
Github user nssalian commented on the issue
Github user nssalian closed the pull request at:
https://github.com/apache/flink/pull/2403
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437395#comment-15437395
]
ASF GitHub Bot commented on FLINK-4278:
---
Github user nssalian closed the pull reques
Github user nssalian commented on the issue:
https://github.com/apache/flink/pull/2403
@StephanEwen, let me close this and open a new one after some testing. Will
post an new PR this week.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-4100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437392#comment-15437392
]
Neelesh Srinivas Salian commented on FLINK-4100:
Sounds good. Thanks [~alj
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437391#comment-15437391
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2418
Looks like we could just pop the variables map into constructor and get the
key names for free, that's neat.
I wouldn't worry too much about disregarding the naming scheme; in contrast
to oth
[
https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437383#comment-15437383
]
ASF GitHub Bot commented on FLINK-4482:
---
GitHub user tedyu opened a pull request:
GitHub user tedyu opened a pull request:
https://github.com/apache/flink/pull/2421
FLINK-4482 numUnsuccessfulCheckpointsTriggers is accessed without holding
triggerLock
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437322#comment-15437322
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2244
Hey @fhueske
I've renamed tests as you suggested.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437314#comment-15437314
]
Stephan Ewen commented on FLINK-3322:
-
Would you volunteer to help with this?
If yes,
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437310#comment-15437310
]
Stephan Ewen commented on FLINK-3030:
-
Thanks, that is a great issue to solve!
> Enha
[
https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437307#comment-15437307
]
Vasia Kalavri commented on FLINK-4440:
--
I don't have a strong opinion against adding
Ted Yu created FLINK-4499:
-
Summary: Introduce findbugs maven plugin
Key: FLINK-4499
URL: https://issues.apache.org/jira/browse/FLINK-4499
Project: Flink
Issue Type: Improvement
Reporter:
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2002#discussion_r76288290
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/compression/InflaterInputStreamFactory.java
---
@@ -23,13 +23,12 @@
import java.io
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2294
This is okay to merge from my side. Definitely seems easier than the
`Delegate` trick.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-4265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437279#comment-15437279
]
ASF GitHub Bot commented on FLINK-4265:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437274#comment-15437274
]
Stephan Ewen commented on FLINK-4482:
-
I think the statements can be adjusted to be pr
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437243#comment-15437243
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2244
Thank you for helping with this PR @fhueske
It's ok, I'll update the PR in an hour or so.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437238#comment-15437238
]
ASF GitHub Bot commented on FLINK-4437:
---
Github user tedyu closed the pull request a
Github user tedyu closed the pull request at:
https://github.com/apache/flink/pull/2409
---
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 enabl
Github user haoch commented on the issue:
https://github.com/apache/flink/pull/2420
@fhueske sure and thanks for the comment.
---
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
enab
Github user haoch closed the pull request at:
https://github.com/apache/flink/pull/2420
---
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 enabl
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2369
Thanks Robert for addressing my comments :)
Overall, I like the new hybrid producer approach. However, I'm still
curious whether or not it is possible / reasonable to drop the
`FlinkKafkaPr
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437224#comment-15437224
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437223#comment-15437223
]
ASF GitHub Bot commented on FLINK-4437:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2409
@tedyu Should we close this pull request?
---
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 featur
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2420
Thanks for the fix @haoch! However, @smarthi opened #2416 to fix the issue
as well.
Would you mind closing your PR?
There are certainly more things the documentation that can be improved
[
https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy updated FLINK-4498:
--
Description:
The Cassandra sink documentation is somewhat muddled and could be improved.
For instance,
Elias Levy created FLINK-4498:
-
Summary: Better Cassandra sink documentation
Key: FLINK-4498
URL: https://issues.apache.org/jira/browse/FLINK-4498
Project: Flink
Issue Type: Improvement
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2418
I think that works to expose the names. I was wondering, though, if we can
have a more JMX-natural integration.
The JMX `ObjectName` has the constructor `ObjectName(String domain,
Hashta
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437183#comment-15437183
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user StephanEwen commented on the is
GitHub user haoch opened a pull request:
https://github.com/apache/flink/pull/2420
[hotfix] Fix invalid elasticsearch url link in documentation
Fix invalid elasticsearch url link from `http://elastic.com` to
`http://elastic.co` in documentation
You can merge this pull request into
[
https://issues.apache.org/jira/browse/FLINK-4479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437181#comment-15437181
]
Robert Metzger commented on FLINK-4479:
---
PR open: https://github.com/apache/flink-we
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2244
Looks good to merge @mushketyk :-)
The only thing that I'd change would be to rename
`Kafka08JsonTableSinkTest` to `Kafka08JsonTableSinkITCase` (same for Kafka09*),
since these are long running i
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437179#comment-15437179
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on the issue:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r76277062
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcherTimestampsTest
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437170#comment-15437170
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437160#comment-15437160
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437159#comment-15437159
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r76275879
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r76275805
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/SimpleConsumerThread.java
---
Elias Levy created FLINK-4497:
-
Summary: Add support for Scala tuples and case classes to
Cassandra sink
Key: FLINK-4497
URL: https://issues.apache.org/jira/browse/FLINK-4497
Project: Flink
Issu
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2400#discussion_r76274362
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java
---
@@ -35,27 +79,634 @@
*/
public class TaskExecuto
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu reopened FLINK-4437:
---
Assignee: (was: Ted Yu)
> Lock evasion around lastTriggeredCheckpoint may lead to lost updates to
> rel
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-4437.
---
Resolution: Fixed
> Lock evasion around lastTriggeredCheckpoint may lead to lost updates to
> related fields
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437151#comment-15437151
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r76274826
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437148#comment-15437148
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437141#comment-15437141
]
Alexander Chermenin commented on FLINK-2608:
This is a bug in ArraysAsListSeri
[
https://issues.apache.org/jira/browse/FLINK-4480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437136#comment-15437136
]
ASF GitHub Bot commented on FLINK-4480:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2416
Merging this...
---
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, o
[
https://issues.apache.org/jira/browse/FLINK-4462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437134#comment-15437134
]
ASF GitHub Bot commented on FLINK-4462:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2412
The `japicmp` is a maven plugin that is added to projects like
`flink-core`. It is not part of any code.
---
If your project is set up for it, you can reply to this email and have your
reply app
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437131#comment-15437131
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2315
There are some compilation issues in the build logs:
```
[ERROR] COMPILATION ERROR :
[INFO] -
[ERROR]
/home/jenkins/jenkin
[
https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4433:
--
Issue Type: Improvement (was: Bug)
> Refactor the StreamSource.
> --
>
[
https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4433:
--
Component/s: DataStream API
> Refactor the StreamSource.
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-4433:
-
Assignee: Kostas Kloudas
> Refactor the StreamSource.
> --
>
>
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/commit/444315a12ca2b1d3de44ea50dda9b8bb5a36bb9e#commitcomment-18778263
Mh, I stumbled across the broken log upload when I tried fixing that issue
... so I thought the commit is related to my efforts fi
[
https://issues.apache.org/jira/browse/FLINK-3761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437116#comment-15437116
]
ASF GitHub Bot commented on FLINK-3761:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/1988
I think this is subsumed by #2376
Should we close this Pull Request?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
[
https://issues.apache.org/jira/browse/FLINK-4488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437113#comment-15437113
]
ASF GitHub Bot commented on FLINK-4488:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2419
That makes sense, +1 to merge this for 1.1.2 and 1.2
Wondering if we can guard this via a test, so that the FLIP-6 refactoring
does not re-introduce the bug.
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-4418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437100#comment-15437100
]
ASF GitHub Bot commented on FLINK-4418:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-4437.
---
Resolution: Fixed
> Lock evasion around lastTriggeredCheckpoint may lead to lost updates to
> related fields
[
https://issues.apache.org/jira/browse/FLINK-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu reopened FLINK-4437:
---
Assignee: Ted Yu
> Lock evasion around lastTriggeredCheckpoint may lead to lost updates to
> related fields
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r76268687
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15437096#comment-15437096
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2383
Merging this...
---
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, o
1 - 100 of 243 matches
Mail list logo
