Github user sahitya-pavurala commented on the pull request:
https://github.com/apache/flink/pull/850#issuecomment-113630618
either way, it should be one of either getClass or instanceOf , it is
inconsistent right now
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593150#comment-14593150
]
Stephan Ewen commented on FLINK-2239:
-
There is code in contrib that collects data
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/747#issuecomment-113406359
I still get these random KafkaITCase failures on travis. This might be a
timeout issue of some sort, @rmetzger do you have any tips on debugging that?
---
If your
[
https://issues.apache.org/jira/browse/FLINK-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593153#comment-14593153
]
Ufuk Celebi commented on FLINK-2239:
Someone (maybe [~trohrm...@apache.org] can give
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/852
[FLINK-2242] deprecate RemoteCollector interface and implementation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink FLINK-2242
[
https://issues.apache.org/jira/browse/FLINK-2242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593198#comment-14593198
]
ASF GitHub Bot commented on FLINK-2242:
---
GitHub user mxm opened a pull request:
Ufuk Celebi created FLINK-2246:
--
Summary: Combiner not chained
Key: FLINK-2246
URL: https://issues.apache.org/jira/browse/FLINK-2246
Project: Flink
Issue Type: Bug
Components: Core
[
https://issues.apache.org/jira/browse/FLINK-1404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-1404:
-
Assignee: Maximilian Michels (was: Ufuk Celebi)
Add support to cache
[
https://issues.apache.org/jira/browse/FLINK-1404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-1404:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-2250
Add support to
Theodore Vasiloudis created FLINK-2245:
--
Summary: Programs that contain collect() reported as multiple jobs
in the Web frontend
Key: FLINK-2245
URL: https://issues.apache.org/jira/browse/FLINK-2245
Theodore Vasiloudis created FLINK-2248:
--
Summary: Allow disabling of sdtout logging output
Key: FLINK-2248
URL: https://issues.apache.org/jira/browse/FLINK-2248
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2246:
-
Summary: Add chained combine driver strategy for ReduceFunction (was:
Combiner not chained)
Maximilian Michels created FLINK-2249:
-
Summary: ExecutionEnvironment: Ignore calls to execute() if no
data sinks defined
Key: FLINK-2249
URL: https://issues.apache.org/jira/browse/FLINK-2249
Maximilian Michels created FLINK-2250:
-
Summary: Backtracking of intermediate results
Key: FLINK-2250
URL: https://issues.apache.org/jira/browse/FLINK-2250
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593385#comment-14593385
]
Theodore Vasiloudis commented on FLINK-2245:
Session management could resolve
Theodore Vasiloudis created FLINK-2244:
--
Summary: Add ability to start and stop persistent IaaS cluster
Key: FLINK-2244
URL: https://issues.apache.org/jira/browse/FLINK-2244
Project: Flink
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/847#issuecomment-113483077
Mea culpa. No the mapper test is fine;
For the examples comment, I meant to go through the classes in the example
folder and to modify the way the graph is
[
https://issues.apache.org/jira/browse/FLINK-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593376#comment-14593376
]
Theodore Vasiloudis commented on FLINK-2249:
I had this problem appear as
[
https://issues.apache.org/jira/browse/FLINK-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593376#comment-14593376
]
Theodore Vasiloudis edited comment on FLINK-2249 at 6/19/15 12:26 PM:
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593383#comment-14593383
]
ASF GitHub Bot commented on FLINK-1979:
---
Github user thvasilo commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593384#comment-14593384
]
Maximilian Michels commented on FLINK-2249:
---
My experience is that a lot of
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/656#issuecomment-113504786
Hello, this PR needs to be rebase since so that it's mergeable with the
latest master.
I think it's fair to say that we can close it in a week if no more
[
https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2246:
-
Issue Type: Improvement (was: Bug)
Add chained combine driver strategy for ReduceFunction
[
https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593351#comment-14593351
]
Fabian Hueske commented on FLINK-2246:
--
This is an expected behavior. There is no
[
https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2246:
-
Component/s: (was: Core)
Local Runtime
Add chained combine driver strategy
[
https://issues.apache.org/jira/browse/FLINK-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593374#comment-14593374
]
Ufuk Celebi commented on FLINK-2249:
I've already seen a couple of users ask about
[
https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Theodore Vasiloudis updated FLINK-2186:
---
Summary: Rework CSV import to support very wide files (was: Rework SVM
import to
Maximilian Michels created FLINK-2251:
-
Summary: Implement job session management
Key: FLINK-2251
URL: https://issues.apache.org/jira/browse/FLINK-2251
Project: Flink
Issue Type:
Theodore Vasiloudis created FLINK-2247:
--
Summary: Improve the way memory is reported in the web frontend
Key: FLINK-2247
URL: https://issues.apache.org/jira/browse/FLINK-2247
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593342#comment-14593342
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on the
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/747#discussion_r32804056
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SuccessfulCheckpoint.java
---
@@ -64,6 +73,22 @@ public long getTimestamp() {
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/747#discussion_r32804068
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/state/StatefulOperatorTest.java
---
@@ -0,0 +1,195
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/747#issuecomment-113389891
Thats's a good point Stephan, I fixed it.
---
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
[
https://issues.apache.org/jira/browse/FLINK-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593211#comment-14593211
]
Maximilian Michels commented on FLINK-2239:
---
I was thinking, if we already have
Github user shghatge commented on the pull request:
https://github.com/apache/flink/pull/847#issuecomment-113439469
Hello @Andra
There is one test for fromCsv with mapper in
GraphCreationWithMapperITCase.java
Should I add more tests for that?
Also for the examples
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593241#comment-14593241
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user shghatge commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593297#comment-14593297
]
ASF GitHub Bot commented on FLINK-2124:
---
Github user mbalassi commented on a diff in
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/848#discussion_r32817766
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593166#comment-14593166
]
Till Rohrmann commented on FLINK-2239:
--
Yes Johannes worked on using the
[
https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593202#comment-14593202
]
Maximilian Michels commented on FLINK-2235:
---
Yes, that would be smart :)
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/764#issuecomment-113435843
Thanks. :) Cool that people are interested. Missing features are in the
pipeline already. Stay tuned ;)
---
If your project is set up for it, you can reply to this email
Péter Szabó created FLINK-2243:
--
Summary: Add finite spout functionality to Storm compatibility
layer
Key: FLINK-2243
URL: https://issues.apache.org/jira/browse/FLINK-2243
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593295#comment-14593295
]
Till Rohrmann commented on FLINK-2239:
--
I agree.
print() on DataSet: stream results
Till Rohrmann created FLINK-2253:
Summary: ALS fails if the data flow is split up and the input is
non-deterministic
Key: FLINK-2253
URL: https://issues.apache.org/jira/browse/FLINK-2253
Project:
[
https://issues.apache.org/jira/browse/FLINK-2225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-2225.
Resolution: Fixed
Fixed via 5374ba97cd863af3062c9b6fa9f96c4b4ebe9a0a
Erroneous scheduling of
45 matches
Mail list logo
