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-2225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-2225.
Resolution: Fixed
Fixed via 5374ba97cd863af3062c9b6fa9f96c4b4ebe9a0a
> Erroneous scheduling of co-l
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: Flin
[
https://issues.apache.org/jira/browse/FLINK-2245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593385#comment-14593385
]
Theodore Vasiloudis commented on FLINK-2245:
Session management could resolve
[
https://issues.apache.org/jira/browse/FLINK-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593384#comment-14593384
]
Maximilian Michels commented on FLINK-2249:
---
My experience is that a lot of user
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593383#comment-14593383
]
ASF GitHub Bot commented on FLINK-1979:
---
Github user thvasilo commented on the pull
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 activit
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: Sub-task
[
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 cac
[
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 supp
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-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593376#comment-14593376
]
Theodore Vasiloudis edited comment on FLINK-2249 at 6/19/15 12:26 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593376#comment-14593376
]
Theodore Vasiloudis commented on FLINK-2249:
I had this problem appear as well
[
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 intermedi
[
https://issues.apache.org/jira/browse/FLINK-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593374#comment-14593374
]
Ufuk Celebi commented on FLINK-2249:
I've already seen a couple of users ask about thi
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
Proj
[
https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593351#comment-14593351
]
Fabian Hueske commented on FLINK-2246:
--
This is an expected behavior. There is no cha
[
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: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-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)
> Ad
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 cur
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593342#comment-14593342
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user andralungu commented on the pul
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 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
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
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-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
[
https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14593295#comment-14593295
]
Till Rohrmann commented on FLINK-2239:
--
I agree.
> print() on DataSet: stream result
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-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593241#comment-14593241
]
ASF GitHub Bot commented on FLINK-1520:
---
Github user shghatge commented on the pull
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 comm
[
https://issues.apache.org/jira/browse/FLINK-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593211#comment-14593211
]
Maximilian Michels commented on FLINK-2239:
---
I was thinking, if we already have
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 a
[
https://issues.apache.org/jira/browse/FLINK-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593202#comment-14593202
]
Maximilian Michels commented on FLINK-2235:
---
Yes, that would be smart :) Althoug
[
https://issues.apache.org/jira/browse/FLINK-2242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593198#comment-14593198
]
ASF GitHub Bot commented on FLINK-2242:
---
GitHub user mxm opened a pull request:
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
Alternative
[
https://issues.apache.org/jira/browse/FLINK-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593166#comment-14593166
]
Till Rohrmann commented on FLINK-2239:
--
Yes Johannes worked on using the {{BlobManage
[
https://issues.apache.org/jira/browse/FLINK-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593153#comment-14593153
]
Ufuk Celebi commented on FLINK-2239:
Someone (maybe [~trohrm...@apache.org] can give s
[
https://issues.apache.org/jira/browse/FLINK-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14593150#comment-14593150
]
Stephan Ewen commented on FLINK-2239:
-
There is code in contrib that collects data fro
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 project
42 matches
Mail list logo
