[GitHub] flink pull request: Fix nested generics scala

Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/293#issuecomment-69378698 This should go into the 0.8.0 since it fixes a very critical bug. Time is of the essence here. :D --- If your project is set up for it, you can reply to this ema

[GitHub] flink pull request: Fix nested generics scala

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/293 Fix nested generics scala You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink fix-nested-generics-scala Alternatively you can review

[jira] [Commented] (FLINK-986) Add intermediate results to distributed runtime

[ https://issues.apache.org/jira/browse/FLINK-986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271646#comment-14271646 ] ASF GitHub Bot commented on FLINK-986: -- Github user rmetzger commented on the pull req

[GitHub] flink pull request: [FLINK-986] [FLINK-25] [Distributed runtime] A...

Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/254#issuecomment-69375283 +1 --- 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

[GitHub] flink pull request: [FLINK-986] [FLINK-25] [Distributed runtime] A...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/254#issuecomment-69373922 Nice. +1 to merge this now! --- 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 do

[jira] [Commented] (FLINK-986) Add intermediate results to distributed runtime

[ https://issues.apache.org/jira/browse/FLINK-986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271631#comment-14271631 ] ASF GitHub Bot commented on FLINK-986: -- Github user StephanEwen commented on the pull

[jira] [Created] (FLINK-1383) Move the hadoopcompatibility package name to just haddop

Henry Saputra created FLINK-1383: Summary: Move the hadoopcompatibility package name to just haddop Key: FLINK-1383 URL: https://issues.apache.org/jira/browse/FLINK-1383 Project: Flink Issue

[jira] [Commented] (FLINK-1377) Bring Team page up to date

[ https://issues.apache.org/jira/browse/FLINK-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271578#comment-14271578 ] Henry Saputra commented on FLINK-1377: -- Ah thanks! I maybe hit some mirror that has n

[jira] [Commented] (FLINK-1377) Bring Team page up to date

[ https://issues.apache.org/jira/browse/FLINK-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271549#comment-14271549 ] Kostas Tzoumas commented on FLINK-1377: --- yes, I pushed the changes to the website. W

[GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/290#issuecomment-69361811 @rmetzger I added some documentation for the config parameter. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271519#comment-14271519 ] ASF GitHub Bot commented on FLINK-1320: --- Github user mxm commented on the pull reque

[jira] [Created] (FLINK-1382) Void is not added to TypeInfoParser

Felix Neutatz created FLINK-1382: Summary: Void is not added to TypeInfoParser Key: FLINK-1382 URL: https://issues.apache.org/jira/browse/FLINK-1382 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-1360) Automatic type extraction for Void is missing

[ https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Felix Neutatz closed FLINK-1360. Resolution: Not a Problem Please use i.e. TypeExtractor.getForClass() in these cases > Automatic ty

[jira] [Resolved] (FLINK-1197) Special page on website that describes issues that occur together with types

[ https://issues.apache.org/jira/browse/FLINK-1197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-1197. - Resolution: Fixed Fix Version/s: 0.9 Assignee: Stephan Ewen (was: Timo Walther) W

[jira] [Commented] (FLINK-1360) Automatic type extraction for Void is missing

[ https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271491#comment-14271491 ] Stephan Ewen commented on FLINK-1360: - There is no other issue for that. Can you close

[jira] [Commented] (FLINK-1271) Extend HadoopOutputFormat and HadoopInputFormat to handle Void.class

[ https://issues.apache.org/jira/browse/FLINK-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271488#comment-14271488 ] ASF GitHub Bot commented on FLINK-1271: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1271] Remove writable limitation

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/287#issuecomment-69358588 Yes, that would be nice. The test looks good. A bit of style cleanup and some commit squashing and this is good to merge in my opinion. --- If your project i

[jira] [Commented] (FLINK-1229) Synchronize WebClient arguments with command line arguments

[ https://issues.apache.org/jira/browse/FLINK-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271485#comment-14271485 ] ASF GitHub Bot commented on FLINK-1229: --- Github user StephanEwen commented on the pu

[jira] [Commented] (FLINK-1229) Synchronize WebClient arguments with command line arguments

[ https://issues.apache.org/jira/browse/FLINK-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271484#comment-14271484 ] ASF GitHub Bot commented on FLINK-1229: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-1229][FLINK-1206] Synchronize webclient...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/291#issuecomment-69358452 Good idea. Two comments inline, but otherwise looks good. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[GitHub] flink pull request: [FLINK-1229][FLINK-1206] Synchronize webclient...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/291#discussion_r22725429 --- Diff: flink-clients/src/main/java/org/apache/flink/client/web/JobSubmissionServlet.java --- @@ -146,10 +146,22 @@ protected void doGet(HttpServletRequ

[jira] [Commented] (FLINK-1377) Bring Team page up to date

[ https://issues.apache.org/jira/browse/FLINK-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271482#comment-14271482 ] Henry Saputra commented on FLINK-1377: -- Hi [~ktzoumas], why is this closed? Has the c

[jira] [Commented] (FLINK-1229) Synchronize WebClient arguments with command line arguments

[ https://issues.apache.org/jira/browse/FLINK-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271481#comment-14271481 ] ASF GitHub Bot commented on FLINK-1229: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request: [FLINK-1229][FLINK-1206] Synchronize webclient...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/291#discussion_r22725368 --- Diff: flink-clients/src/main/java/org/apache/flink/client/web/JobSubmissionServlet.java --- @@ -146,10 +146,22 @@ protected void doGet(HttpServletRequ

[jira] [Commented] (FLINK-1360) Automatic type extraction for Void is missing

[ https://issues.apache.org/jira/browse/FLINK-1360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271479#comment-14271479 ] Felix Neutatz commented on FLINK-1360: -- Have you already fixed the TypeInfoParser bug

[jira] [Commented] (FLINK-1295) Add option to Flink client to start a YARN session per job

[ https://issues.apache.org/jira/browse/FLINK-1295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271472#comment-14271472 ] ASF GitHub Bot commented on FLINK-1295: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-1295][FLINK-883] Allow to deploy 'job o...

GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/292 [FLINK-1295][FLINK-883] Allow to deploy 'job only' YARN cluster. Add tests to YARN - users can now also deploy Flink on YARN for executing a single job. - the flink-yarn project has been moved o

[jira] [Created] (FLINK-1381) Only one output splitter supported per operator

Gyula Fora created FLINK-1381: - Summary: Only one output splitter supported per operator Key: FLINK-1381 URL: https://issues.apache.org/jira/browse/FLINK-1381 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-1377) Bring Team page up to date

[ https://issues.apache.org/jira/browse/FLINK-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Tzoumas resolved FLINK-1377. --- Resolution: Fixed > Bring Team page up to date > -- > >

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271099#comment-14271099 ] ASF GitHub Bot commented on FLINK-1320: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/290#issuecomment-69345274 After running several integration tests, I discovered some issues with the off-heap memory allocation. I'm not completely sure what is causing the issue but I'm looking into i

[GitHub] flink pull request: [FLINK-986] [FLINK-25] [Distributed runtime] A...

Github user aalexandrov commented on the pull request: https://github.com/apache/flink/pull/254#issuecomment-69343812 I am excited! --- 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 featur

[jira] [Commented] (FLINK-986) Add intermediate results to distributed runtime

[ https://issues.apache.org/jira/browse/FLINK-986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271086#comment-14271086 ] ASF GitHub Bot commented on FLINK-986: -- Github user aalexandrov commented on the pull

[GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/290#issuecomment-69341391 @StephanEwen Thanks for pointing that out. This should probably go into a separate issue. --- If your project is set up for it, you can reply to this email and have your repl

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271077#comment-14271077 ] ASF GitHub Bot commented on FLINK-1320: --- Github user mxm commented on the pull reque

[jira] [Commented] (FLINK-1378) could not find implicit value for evidence parameter of type TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-1378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271057#comment-14271057 ] Aljoscha Krettek commented on FLINK-1378: - I'm looking into it. > could not find

[jira] [Commented] (FLINK-1379) add RSS feed for the blog

[ https://issues.apache.org/jira/browse/FLINK-1379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271056#comment-14271056 ] Robert Metzger commented on FLINK-1379: --- Yes, we once had a feed. This is roughly h

[jira] [Created] (FLINK-1380) Update SplitDataStream to extend DataStream

Gyula Fora created FLINK-1380: - Summary: Update SplitDataStream to extend DataStream Key: FLINK-1380 URL: https://issues.apache.org/jira/browse/FLINK-1380 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-1379) add RSS feed for the blog

Max Michels created FLINK-1379: -- Summary: add RSS feed for the blog Key: FLINK-1379 URL: https://issues.apache.org/jira/browse/FLINK-1379 Project: Flink Issue Type: Improvement Compone

[jira] [Resolved] (FLINK-1367) Add field aggregations to Streaming Scala api

[ https://issues.apache.org/jira/browse/FLINK-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-1367. --- Resolution: Fixed https://github.com/apache/flink/commit/06503c8fd3506fb83bd09392856c465f8d095736 > A

[jira] [Resolved] (FLINK-1109) Add IntelliJ/Eclipe setup guide for developers

[ https://issues.apache.org/jira/browse/FLINK-1109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1109. Resolution: Fixed Fixed in 7f659f6 and 7e08fa1. > Add IntelliJ/Eclipe setup guide for developers >

[jira] [Updated] (FLINK-1373) Add documentation for intermediate results and network stack to internals

[ https://issues.apache.org/jira/browse/FLINK-1373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-1373: --- Summary: Add documentation for intermediate results and network stack to internals (was: Add document

[jira] [Assigned] (FLINK-1377) Bring Team page up to date

[ https://issues.apache.org/jira/browse/FLINK-1377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Tzoumas reassigned FLINK-1377: - Assignee: Kostas Tzoumas > Bring Team page up to date > -- > >

[jira] [Created] (FLINK-1378) could not find implicit value for evidence parameter of type TypeInformation

John Sandiford created FLINK-1378: - Summary: could not find implicit value for evidence parameter of type TypeInformation Key: FLINK-1378 URL: https://issues.apache.org/jira/browse/FLINK-1378 Project:

[jira] [Closed] (FLINK-1334) Please create a DOAP file for your TLP

[ https://issues.apache.org/jira/browse/FLINK-1334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1334. - Resolution: Fixed Apache Flink shows up in the projects list. Closing the issue... > Please crea

[jira] [Commented] (FLINK-986) Add intermediate results to distributed runtime

[ https://issues.apache.org/jira/browse/FLINK-986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271027#comment-14271027 ] ASF GitHub Bot commented on FLINK-986: -- Github user uce commented on the pull request:

[GitHub] flink pull request: [FLINK-986] [FLINK-25] [Distributed runtime] A...

Github user uce commented on the pull request: https://github.com/apache/flink/pull/254#issuecomment-69335730 Just rebased on the current master again. Locally, all tests pass. Let's see what Travis says. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-1229) Synchronize WebClient arguments with command line arguments

[ https://issues.apache.org/jira/browse/FLINK-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14270922#comment-14270922 ] ASF GitHub Bot commented on FLINK-1229: --- GitHub user qmlmoon opened a pull request:

[GitHub] flink pull request: [FLINK-1229][FLINK-1206] Synchronize webclient...

GitHub user qmlmoon opened a pull request: https://github.com/apache/flink/pull/291 [FLINK-1229][FLINK-1206] Synchronize webclient arguments with command line and add default parallelism option You can merge this pull request into a Git repository by running: $ git pull https

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14270885#comment-14270885 ] ASF GitHub Bot commented on FLINK-1320: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/290#issuecomment-69321520 I just realized that the whole code of Flink actually runs only on architectures that support unaligned memory accesses, i.e., where you can fetch a `long` from an add

[GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/290#discussion_r22710693 --- Diff: flink-core/src/main/java/org/apache/flink/core/memory/DirectMemorySegment.java --- @@ -0,0 +1,560 @@ +/* + * Licensed to the Apache Soft

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14270877#comment-14270877 ] ASF GitHub Bot commented on FLINK-1320: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14270868#comment-14270868 ] ASF GitHub Bot commented on FLINK-1320: --- Github user StephanEwen commented on the pu

[GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma...

Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/290#issuecomment-69320368 I actually like the idea that tests (when starting the mini cluster) randomly select one of the two implementations. We can add that after including this, thou

[jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory

[ https://issues.apache.org/jira/browse/FLINK-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14270865#comment-14270865 ] ASF GitHub Bot commented on FLINK-1320: --- Github user mxm commented on the pull reque

[GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma...

Github user mxm commented on the pull request: https://github.com/apache/flink/pull/290#issuecomment-69320016 @uce To achieve optimal test coverage, we could modify all tests which use the HeapMemorySegment to run with the DirectMemorySegment as well. Another approach would be to rand

[jira] [Created] (FLINK-1377) Bring Team page up to date

Stephan Ewen created FLINK-1377: --- Summary: Bring Team page up to date Key: FLINK-1377 URL: https://issues.apache.org/jira/browse/FLINK-1377 Project: Flink Issue Type: Task Components:

[jira] [Commented] (FLINK-1375) Remove incubator references & rename to new project urls

[ https://issues.apache.org/jira/browse/FLINK-1375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14270843#comment-14270843 ] Stephan Ewen commented on FLINK-1375: - I updated the readme and some internal docs in

[jira] [Commented] (FLINK-1228) Add REST Interface to JobManager

[ https://issues.apache.org/jira/browse/FLINK-1228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14270772#comment-14270772 ] Arvid Heise commented on FLINK-1228: My original intent with this ticket was indeed si