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
[
https://issues.apache.org/jira/browse/FLINK-3353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136027#comment-15136027
]
ASF GitHub Bot commented on FLINK-3353:
---
GitHub user stefanobaghino opened a pull request:
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.
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135974#comment-15135974
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user kl0u commented on the pull request:
[
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-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
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:
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-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
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:
[
https://issues.apache.org/jira/browse/FLINK-3035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136075#comment-15136075
]
Subhobrata Dey commented on FLINK-3035:
---
Hello [~mjsax], I had a look into the rocksdb state backend
[
https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135743#comment-15135743
]
Robert Metzger commented on FLINK-3343:
---
Where did you see that the default value is 200 ?
The
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
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135951#comment-15135951
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user kl0u commented on a diff in the pull request:
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=15135960#comment-15135960
]
ASF GitHub Bot commented on FLINK-3339:
---
Github user mbalassi commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135815#comment-15135815
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user StephanEwen commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135818#comment-15135818
]
ASF GitHub Bot commented on FLINK-3341:
---
Github user StephanEwen commented on the pull request:
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
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.
[
https://issues.apache.org/jira/browse/FLINK-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135852#comment-15135852
]
ASF GitHub Bot commented on FLINK-3128:
---
Github user f-sander commented on the pull request:
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.
[
https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15136131#comment-15136131
]
ASF GitHub Bot commented on FLINK-2131:
---
Github user sachingoel0101 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135744#comment-15135744
]
Riccardo Diomedi commented on FLINK-3349:
-
If you download Flink source from this site:
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135762#comment-15135762
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on a diff in the pull request:
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://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135750#comment-15135750
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user rmetzger commented on a diff in the pull
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.
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
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135752#comment-15135752
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user rmetzger commented on the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-3349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135738#comment-15135738
]
Robert Metzger commented on FLINK-3349:
---
So the issue has been resolved?
> PlanVisualizer doesn't
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135751#comment-15135751
]
ASF GitHub Bot commented on FLINK-2213:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135761#comment-15135761
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135760#comment-15135760
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on a diff in the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135758#comment-15135758
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135714#comment-15135714
]
Riccardo Diomedi commented on FLINK-3349:
-
I now realize that i don't have neither .css files nor
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-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135732#comment-15135732
]
Márton Balassi commented on FLINK-3297:
---
Hey [~mohitsethi], we used to have a ZeroMQ connector back
[
https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135739#comment-15135739
]
ASF GitHub Bot commented on FLINK-3034:
---
Github user rmetzger commented on the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135764#comment-15135764
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135695#comment-15135695
]
ASF GitHub Bot commented on FLINK-3234:
---
Github user fhueske commented on a diff in the pull
[
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
>
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
[
https://issues.apache.org/jira/browse/FLINK-3341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135749#comment-15135749
]
ASF GitHub Bot commented on FLINK-3341:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135763#comment-15135763
]
ASF GitHub Bot commented on FLINK-2721:
---
Github user mxm commented on a diff in the pull request:
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 @@
+/*
+ *
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135692#comment-15135692
]
ASF GitHub Bot commented on FLINK-3234:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135756#comment-15135756
]
Farouk Salem commented on FLINK-3343:
-
Sorry, I checked an old version of kafka documentation (Kafka
[
https://issues.apache.org/jira/browse/FLINK-3337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15135792#comment-15135792
]
ASF GitHub Bot commented on FLINK-3337:
---
Github user StephanEwen commented on the pull request:
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
61 matches
Mail list logo
