[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129717#comment-15129717
]
ASF GitHub Bot commented on FLINK-3034:
---
GitHub user subhankarb opened a pull reques
GitHub user subhankarb opened a pull request:
https://github.com/apache/flink/pull/1580
[FLINK-3034][Streaming Connectors] Redis Sink Connector
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/subhankarb/flink FLINK-3034
Alternat
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1576#issuecomment-178965393
+1 This problem occasionally occurs in Amazon EMR 4.2.0.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-178836268
> I had some more comments concerning the failure case handling of stop
calls. The first problem is still the handling of exceptions when calling stop
on the Invokable in T
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129077#comment-15129077
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-3226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15129042#comment-15129042
]
ASF GitHub Bot commented on FLINK-3226:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/1579
[FLINK-3226] Add DataSet scan and conversion to DataSet[Row]
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fhueske/flink dataSetTrans
Altern
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1574#issuecomment-178823650
Thanks for the comments. @gumchum: Internally it is stored as a Java
`Iterator` and that is the reason why left it so, but it definitely make sense
to convert it to Sc
Github user gumchum commented on the pull request:
https://github.com/apache/flink/pull/1574#issuecomment-178783922
Looks good. It looks like collect is returning a Java iterator instead of a
Scala one. Is there a reason for this given that the code is for Scala users?
---
If your pr
[
https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128681#comment-15128681
]
Ufuk Celebi commented on FLINK-3310:
Sorry, I didn't see it. I would like to close it
[
https://issues.apache.org/jira/browse/FLINK-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128633#comment-15128633
]
ASF GitHub Bot commented on FLINK-3303:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128634#comment-15128634
]
ASF GitHub Bot commented on FLINK-3303:
---
Github user StephanEwen closed the pull req
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/1570
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1570#issuecomment-178705791
Manually merged in 21a715867d655bb61df9a9f7eef37e42b99e206a
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-3314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3314.
-
Resolution: Fixed
Fixed via 8fc7e7af2c7decb8e531b76e3edcc2601f73fe9d
> Early cancel calls can cau
[
https://issues.apache.org/jira/browse/FLINK-3314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3314.
---
> Early cancel calls can cause Tasks to not cancel properly
>
[
https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2348.
---
> IterateExampleITCase failing
>
>
> Key: FLINK-2348
>
[
https://issues.apache.org/jira/browse/FLINK-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3303.
-
Resolution: Done
Done in 21a715867d655bb61df9a9f7eef37e42b99e206a
> Move all non-batch specific c
[
https://issues.apache.org/jira/browse/FLINK-3303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3303.
---
> Move all non-batch specific classes in flink-java to flink-core
> --
[
https://issues.apache.org/jira/browse/FLINK-2348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2348.
-
Resolution: Fixed
Assignee: Stephan Ewen
Stabilized in bfff86c841f0b873f25367419db0b3dd504a1
[
https://issues.apache.org/jira/browse/FLINK-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-3049.
---
> Move "Either" type to package "org.apache.flink.types"
> ---
[
https://issues.apache.org/jira/browse/FLINK-3049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3049.
-
Resolution: Fixed
Fixed via 54743866e86cbe7689ae1dcf001deb559629747b
Sorry for the confusion...
[
https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128602#comment-15128602
]
ASF GitHub Bot commented on FLINK-3310:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1578
[FLINK-3310] [runtime, runtime-web] Add back pressure statistics
This PR introduces back pressure statistics to the web frontend.
The idea is that tasks, which are back pressured by the network
[
https://issues.apache.org/jira/browse/FLINK-2803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128580#comment-15128580
]
Lokesh Ravindranathan commented on FLINK-2803:
--
Hi Stephen,
Thanks so much
[
https://issues.apache.org/jira/browse/FLINK-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128559#comment-15128559
]
Maximilian Michels commented on FLINK-3310:
---
I also created an issue some time a
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128546#comment-15128546
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128549#comment-15128549
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1577#issuecomment-178685691
Thanks for the review. Will merge it once Travis gives green light.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1577#discussion_r51597662
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/LegacyFetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128536#comment-15128536
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1577#issuecomment-178683735
Good catch & fix!
+1 to merge asap (too many tests are failing on this one right now)
---
If your project is set up for it, you can reply to this email and have you
Github user cmonty commented on the pull request:
https://github.com/apache/flink/pull/1574#issuecomment-178683549
The Scala interface looks good to me and gets rid of the need to call
`getJavaStream` directly.
Thanks!
---
If your project is set up for it, you can reply to t
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128517#comment-15128517
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128515#comment-15128515
]
ASF GitHub Bot commented on FLINK-3313:
---
Github user uce commented on a diff in the
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1577#issuecomment-178680229
Good catch! :-)
---
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
en
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128513#comment-15128513
]
ASF GitHub Bot commented on FLINK-3313:
---
GitHub user tillrohrmann opened a pull requ
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1577#discussion_r51595056
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/LegacyFetcher.java
---
@@ -199
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/1577
[FLINK-3313] [kafka] Fix concurrent TypeInformationSerializationSchema
usage in LegacyFetcher
The LegacyFetcher used the given KeyedDeserializationSchema across multiple
threads even though
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1576
[hotfix][yarn] Shutdown JVM when Flink-on-yarn is shutting down
With this change, we call System.exit() when the YARN session is shutting
down.
On some Linux distributions, YARN is not abl
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-3313:
Assignee: Till Rohrmann
> Kafka08ITCase.testOneSourceMultiplePartitions fails with EOFExcep
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128491#comment-15128491
]
Till Rohrmann commented on FLINK-3313:
--
The problem ist that the {{TypeInformationSer
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1575
[FLINK-3207] [gelly] adds the vertex-centric iteration abstraction
As per the mailing list discussion, this PR adds the vertex-centric /
pregel iteration abstraction to gelly. In this model, superstep
[
https://issues.apache.org/jira/browse/FLINK-3207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128467#comment-15128467
]
ASF GitHub Bot commented on FLINK-3207:
---
GitHub user vasia opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-3322:
---
Fix Version/s: 1.0.0
> MemoryManager creates too much GC pressure with iterative jobs
> --
Gabor Gevay created FLINK-3322:
--
Summary: MemoryManager creates too much GC pressure with iterative
jobs
Key: FLINK-3322
URL: https://issues.apache.org/jira/browse/FLINK-3322
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3316.
--
Resolution: Fixed
Fixed via ffe31bf53ca28a842d4a352a568f288251d56490
> Links to Gelly and Flink
[
https://issues.apache.org/jira/browse/FLINK-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-3316:
Assignee: Till Rohrmann
> Links to Gelly and FlinkML libraries on main site broken
> --
[
https://issues.apache.org/jira/browse/FLINK-3316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128374#comment-15128374
]
Till Rohrmann commented on FLINK-3316:
--
In fact, all links in the first paragraph on
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128367#comment-15128367
]
Subhobrata Dey commented on FLINK-3035:
---
Hello [~mjsax],
Yes, I'm interested in the
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Subhobrata Dey reassigned FLINK-3035:
-
Assignee: Subhobrata Dey
> Redis as State Backend
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3287.
---
Resolution: Fixed
Fix Version/s: 1.0.0
http://git-wip-us.apache.org/repos/asf/flink/com
[
https://issues.apache.org/jira/browse/FLINK-3247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3247.
---
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/360f02b1
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1573
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128328#comment-15128328
]
ASF GitHub Bot commented on FLINK-3287:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-3321:
---
Labels: starter (was: )
> TupleSerializerBase.getLength should know the length when all fields know i
Gabor Gevay created FLINK-3321:
--
Summary: TupleSerializerBase.getLength should know the length when
all fields know it
Key: FLINK-3321
URL: https://issues.apache.org/jira/browse/FLINK-3321
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3217.
--
Resolution: Fixed
Fixed via 79058edb67095120558add534ba37304425fa602
> Implement NFA for patter
[
https://issues.apache.org/jira/browse/FLINK-3215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3215.
--
Resolution: Fixed
Initial version added via 79058edb67095120558add534ba37304425fa602
> Add CEP
[
https://issues.apache.org/jira/browse/FLINK-3216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-3216.
--
Resolution: Fixed
Fixed via 79058edb67095120558add534ba37304425fa602
> Define pattern specifica
[
https://issues.apache.org/jira/browse/FLINK-3216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-3216:
Assignee: Till Rohrmann
> Define pattern specification
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-3217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-3217:
Assignee: Till Rohrmann
> Implement NFA for pattern detection
> ---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1557
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-3216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128280#comment-15128280
]
ASF GitHub Bot commented on FLINK-3216:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128219#comment-15128219
]
Greg Hogan edited comment on FLINK-3291 at 2/2/16 2:05 PM:
---
Hi G
Till Rohrmann created FLINK-3320:
Summary: Add not operator to CEP's pattern API
Key: FLINK-3320
URL: https://issues.apache.org/jira/browse/FLINK-3320
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128270#comment-15128270
]
Robert Metzger commented on FLINK-3313:
---
Another instance:
https://s3.amazonaws.com
Till Rohrmann created FLINK-3319:
Summary: Add or operator to CEP's pattern API
Key: FLINK-3319
URL: https://issues.apache.org/jira/browse/FLINK-3319
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-3318:
Summary: Add support for quantifiers to CEP's pattern API
Key: FLINK-3318
URL: https://issues.apache.org/jira/browse/FLINK-3318
Project: Flink
Issue Type: Im
Till Rohrmann created FLINK-3317:
Summary: Add timeout handler to CEP operator
Key: FLINK-3317
URL: https://issues.apache.org/jira/browse/FLINK-3317
Project: Flink
Issue Type: Improvement
GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/1574
Scala DataStream&DataStreamUtils accessors fix
The PR contains two orthogonal approaches of fixing the access to
`DataStreamUtils.collect` for a scala environment. One or both of the
approaches ca
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128243#comment-15128243
]
Gabor Gevay commented on FLINK-3291:
> `ReduceDriver.run` owns two objects but is not
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128225#comment-15128225
]
Gabor Gevay commented on FLINK-3291:
I'm almost done with the fix, see here:
https://g
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128225#comment-15128225
]
Gabor Gevay edited comment on FLINK-3291 at 2/2/16 1:14 PM:
I'
[
https://issues.apache.org/jira/browse/FLINK-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128219#comment-15128219
]
Greg Hogan commented on FLINK-3291:
---
Hi Gabor, this looks to be a bug in some code I had
[
https://issues.apache.org/jira/browse/FLINK-2915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128214#comment-15128214
]
Robert Metzger commented on FLINK-2915:
---
Another instance:
{code}
Failed tests:
[
https://issues.apache.org/jira/browse/FLINK-3216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128206#comment-15128206
]
ASF GitHub Bot commented on FLINK-3216:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1557#issuecomment-178559057
Failing test case is unrelated to changes.
---
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 p
[
https://issues.apache.org/jira/browse/FLINK-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3175.
---
Resolution: Fixed
Fix Version/s: 1.0.0
http://git-wip-us.apache.org/repos/asf/flink/com
Theodore Vasiloudis created FLINK-3316:
--
Summary: Links to Gelly and FlinkML libraries on main site broken
Key: FLINK-3316
URL: https://issues.apache.org/jira/browse/FLINK-3316
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128133#comment-15128133
]
ASF GitHub Bot commented on FLINK-3287:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1573#issuecomment-178527480
There is one issue I need to figure out, then, I'll merge it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128123#comment-15128123
]
Andrea Sella commented on FLINK-3311:
-
Hi,
I am already working on to cassandra-connec
[
https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128109#comment-15128109
]
ASF GitHub Bot commented on FLINK-3187:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1470#discussion_r51557132
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128108#comment-15128108
]
ASF GitHub Bot commented on FLINK-3187:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1470#discussion_r51557088
--- Diff: docs/apis/fault_tolerance.md ---
@@ -193,73 +193,169 @@ state updates) of Flink coupled with bundled sinks:
[Back to top](#top)
[
https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128093#comment-15128093
]
ASF GitHub Bot commented on FLINK-3187:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1470#discussion_r51556358
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FixedDelayRestartStrategy.java
---
@@ -0,0 +1,113 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-3187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128092#comment-15128092
]
ASF GitHub Bot commented on FLINK-3187:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1470#discussion_r51556295
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---
@@ -237,53 +236,26 @@ public ExecutionConfig setParallelism(int
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128091#comment-15128091
]
ASF GitHub Bot commented on FLINK-3287:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1573#issuecomment-178518689
Thanks for fixing this, this was a critical issue.
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear
Aljoscha Krettek created FLINK-3315:
---
Summary: Fix Slot Sharing in Streaming API
Key: FLINK-3315
URL: https://issues.apache.org/jira/browse/FLINK-3315
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128086#comment-15128086
]
ASF GitHub Bot commented on FLINK-3287:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1573
[FLINK-3287][FLINK-3247] Fix curator shading for Kafka connector
Some maven versions are not properly evaluating star * excludes. Therefore,
I've manually listed our shaded artifacts in the
Stephan Ewen created FLINK-3314:
---
Summary: Early cancel calls can cause Tasks to not cancel properly
Key: FLINK-3314
URL: https://issues.apache.org/jira/browse/FLINK-3314
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-3216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15128080#comment-15128080
]
ASF GitHub Bot commented on FLINK-3216:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1557#issuecomment-178515178
The Scala problem seems to be related to missing suffixes in the pom file.
I fixed it. Once travis gives green light, I'll merge the PR.
---
If your project is set
1 - 100 of 128 matches
Mail list logo
