[
https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136131#comment-15136131
]
ASF GitHub Bot commented on FLINK-2131:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/757#issuecomment-180943918
Thanks for the review. I will push a fix soon.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136075#comment-15136075
]
Subhobrata Dey commented on FLINK-3035:
---
Hello [~mjsax], I had a look into the rocks
Gyula Fora created FLINK-3355:
-
Summary: Allow passing RocksDB Option to RocksDBStateBackend
Key: FLINK-3355
URL: https://issues.apache.org/jira/browse/FLINK-3355
Project: Flink
Issue Type: Impro
Gyula Fora created FLINK-3354:
-
Summary: RocksDB should compute checkpoint size based on backup
file size
Key: FLINK-3354
URL: https://issues.apache.org/jira/browse/FLINK-3354
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-3353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136027#comment-15136027
]
ASF GitHub Bot commented on FLINK-3353:
---
GitHub user stefanobaghino opened a pull re
GitHub user stefanobaghino opened a pull request:
https://github.com/apache/flink/pull/1598
[FLINK-3353] CSV-related tests may fail depending on locale
As the results are hard-coded, it makes sense to explicitly pass the US
locale to render the results as strings. Should close
[FLI
Stefano Baghino created FLINK-3353:
--
Summary: CSV-related tests may fail depending on locale
Key: FLINK-3353
URL: https://issues.apache.org/jira/browse/FLINK-3353
Project: Flink
Issue Type:
Gyula Fora created FLINK-3352:
-
Summary: RocksDB Backend cannot determine correct hdfs path
Key: FLINK-3352
URL: https://issues.apache.org/jira/browse/FLINK-3352
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefano Baghino reassigned FLINK-2021:
--
Assignee: Stefano Baghino
> Rework examples to use ParameterTool
>
Gyula Fora created FLINK-3351:
-
Summary: RocksDB Backend cannot determine correct local db path
Key: FLINK-3351
URL: https://issues.apache.org/jira/browse/FLINK-3351
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135974#comment-15135974
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user kl0u commented on the pull requ
Github user kl0u commented on the pull request:
https://github.com/apache/flink/pull/1588#issuecomment-180847040
Thanks a lot for the comments @rmetzger and @StephanEwen .
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. I
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1594#issuecomment-180842858
LGTM
---
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-3339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135960#comment-15135960
]
ASF GitHub Bot commented on FLINK-3339:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135951#comment-15135951
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/1588#discussion_r52106077
--- Diff: docs/setup/config.md ---
@@ -211,6 +211,8 @@ The parameters define the behavior of tasks that create
result files.
yarn.application-ma
[
https://issues.apache.org/jira/browse/FLINK-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135852#comment-15135852
]
ASF GitHub Bot commented on FLINK-3128:
---
Github user f-sander commented on the pull
Github user f-sander commented on the pull request:
https://github.com/apache/flink/pull/1565#issuecomment-180798486
Sorry for the long delay. I still don't really have time for this, but I
wan't to describe it anyways. That's why the writing and formatting is pretty
sloppy in this. S
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135818#comment-15135818
]
ASF GitHub Bot commented on FLINK-3341:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1597#issuecomment-180790019
Good fix, pretty important to get this into 1.0
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If yo
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135815#comment-15135815
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1588#issuecomment-180789530
The fallback behavior here is now different than the original behavior.
I think it would be good to make the fallback the same as before, meaning
to use the numbe
Stephan Ewen created FLINK-3350:
---
Summary: Increase timeouts on Travis Builds
Key: FLINK-3350
URL: https://issues.apache.org/jira/browse/FLINK-3350
Project: Flink
Issue Type: Bug
Comp
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/21a715867d655bb61df9a9f7eef37e42b99e206a#commitcomment-15932805
In the current master, the `DataStream` class imports the correct
`o.a.f.api.common.operators.Keys`.
https://github.c
[
https://issues.apache.org/jira/browse/FLINK-3337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135792#comment-15135792
]
ASF GitHub Bot commented on FLINK-3337:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1596#issuecomment-180775810
Seems to work. The test failures are unreleated.
---
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-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-3210.
---
Resolution: Later
> Unnecessary call to deserializer#deserialize() in
> LegacyFetcher#SimpleConsumerThread#ru
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135764#comment-15135764
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1591#issuecomment-180765494
Looks like the meta data is now completely available :). +1 for merging
this.
---
If your project is set up for it, you can reply to this email and have your
reply appear o
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135763#comment-15135763
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1591#discussion_r52102118
--- Diff:
flink-contrib/flink-storm-examples/src/test/java/org/apache/flink/storm/tests/operators/VerifyMetaDataBolt.java
---
@@ -0,0 +1,65 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135762#comment-15135762
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1591#discussion_r52102060
--- Diff:
flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/api/FlinkTopology.java
---
@@ -229,9 +229,24 @@ private void translateTopology() {
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1591#discussion_r52102056
--- Diff:
flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/SpoutCollectorTest.java
---
@@ -75,12 +75,71 @@ public void testSpoutStormColle
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135760#comment-15135760
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1591#discussion_r52102057
--- Diff:
flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/SpoutCollectorTest.java
---
@@ -75,12 +75,71 @@ public void testSpoutStormColle
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135761#comment-15135761
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135758#comment-15135758
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on a diff in the
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/1591#discussion_r52102026
--- Diff:
flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/StormTuple.java
---
@@ -41,55 +39,61 @@
*/
public class StormTuple i
[
https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135756#comment-15135756
]
Farouk Salem commented on FLINK-3343:
-
Sorry, I checked an old version of kafka docume
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1588#issuecomment-180753220
I hope its a coincidence that the YARN tests failed in this PR. If they
fail after your next push again, we have to check if your changes caused the
failure
---
If yo
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135752#comment-15135752
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1588#issuecomment-180753150
I didn't test this myself, but this diff could be sufficient for testing
your change:
```diff
diff --git
a/flink-yarn-tests/src/main/java/org/apache/flink/
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135751#comment-15135751
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135750#comment-15135750
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1588#discussion_r52101633
--- Diff: docs/setup/config.md ---
@@ -211,6 +211,8 @@ The parameters define the behavior of tasks that create
result files.
yarn.applicatio
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135749#comment-15135749
]
ASF GitHub Bot commented on FLINK-3341:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1597
[FLINK-3341] Make 'auto.offset.reset' compatible with Kafka 0.8 and 0.9
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink334
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135747#comment-15135747
]
Robert Metzger commented on FLINK-3341:
---
I think I've took "latest" because the new
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3341:
-
Assignee: Robert Metzger
> Kafka connector's 'auto.offset.reset' inconsistent with Kafka
[
https://issues.apache.org/jira/browse/FLINK-3349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3349.
---
Resolution: Fixed
Great. I'm closing the JIRA then.
> PlanVisualizer doesn't work
> -
[
https://issues.apache.org/jira/browse/FLINK-3349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135744#comment-15135744
]
Riccardo Diomedi commented on FLINK-3349:
-
If you download Flink source from this
[
https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135743#comment-15135743
]
Robert Metzger commented on FLINK-3343:
---
Where did you see that the default value is
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135739#comment-15135739
]
ASF GitHub Bot commented on FLINK-3034:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1580#issuecomment-180746275
How do you want to implement this? I'm asking because I don't see an
obvious way to expose this to the user.
---
If your project is set up for it, you can reply to thi
[
https://issues.apache.org/jira/browse/FLINK-3349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135738#comment-15135738
]
Robert Metzger commented on FLINK-3349:
---
So the issue has been resolved?
> PlanVisu
[
https://issues.apache.org/jira/browse/FLINK-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135732#comment-15135732
]
Márton Balassi commented on FLINK-3297:
---
Hey [~mohitsethi], we used to have a ZeroMQ
Github user alexeyegorov commented on the pull request:
https://github.com/apache/flink/commit/21a715867d655bb61df9a9f7eef37e42b99e206a#commitcomment-15932065
@uce yes, I've already added _2.10 to my dependencies that are scala
dependent... but I still get the build problem.
---
If
[
https://issues.apache.org/jira/browse/FLINK-3349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135714#comment-15135714
]
Riccardo Diomedi commented on FLINK-3349:
-
I now realize that i don't have neither
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1585#discussion_r52099968
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/operator/SortPartitionTest.java
---
@@ -169,6 +169,72 @@ public void testSortPartitionWithExpres
[
https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135695#comment-15135695
]
ASF GitHub Bot commented on FLINK-3234:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15135692#comment-15135692
]
ASF GitHub Bot commented on FLINK-3234:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1585#discussion_r52099909
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/SortPartitionOperator.java
---
@@ -79,16 +112,33 @@ public SortPartitionOperator(DataS
64 matches
Mail list logo
