Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1477#issuecomment-169270202
Thanks @gallenvara.
Flink uses Jackson to handle JSON data. You can use it to parse the JSON
String.
Looking forward to your update :-)
---
If your
GitHub user ajaybhat opened a pull request:
https://github.com/apache/flink/pull/1486
[FLINK-2445] Add tests for HadoopOutputFormats
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ajaybhat/flink test-fix
Alternatively you can
[
https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085296#comment-15085296
]
ASF GitHub Bot commented on FLINK-2445:
---
GitHub user ajaybhat opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085382#comment-15085382
]
ASF GitHub Bot commented on FLINK-2445:
---
Github user ajaybhat commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omar Alvarez updated FLINK-3203:
Description:
When trying to execute the Python example without HDFS, the FlatMap fails with
the
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1465#issuecomment-169275924
Thanks for your feedback @fhueske. I will rework this PR during this week.
---
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-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085292#comment-15085292
]
ASF GitHub Bot commented on FLINK-3140:
---
Github user twalthr commented on the pull request:
Robert Metzger created FLINK-3204:
-
Summary: TaskManagers are not shutting down properly on YARN
Key: FLINK-3204
URL: https://issues.apache.org/jira/browse/FLINK-3204
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omar Alvarez updated FLINK-3203:
Labels: DistributedCache OGS (was: )
Component/s: Java API
Summary:
Github user ajaybhat commented on the pull request:
https://github.com/apache/flink/pull/1486#issuecomment-169292981
Hi @chiwanpark
> Could you re-implement DummyRecordWriter to make tests fast?
Its because I saw many tests creating temporary files that I used the same
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085210#comment-15085210
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on the pull request:
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1486#issuecomment-169283768
Hi @ajaybhat, thanks for opening pull request.
I read your pull request quickly and have a comment.
Currently, Flink has a lot of tests that create a
[
https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085363#comment-15085363
]
ASF GitHub Bot commented on FLINK-2445:
---
Github user chiwanpark commented on the pull request:
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-169267260
Just updated this. I did not add an additional YARN test, because I test
`GET` and `DELETE` in the REST test. About your last comment regarding
`Execution`: behavior of
[
https://issues.apache.org/jira/browse/FLINK-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085231#comment-15085231
]
ASF GitHub Bot commented on FLINK-3192:
---
Github user fhueske commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1432#issuecomment-169329884
I've quickly scrolled through the change. I'm wondering whether we should
change the development process for the Python API a bit.
It seems that you are currently
[
https://issues.apache.org/jira/browse/FLINK-3057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085559#comment-15085559
]
ASF GitHub Bot commented on FLINK-3057:
---
Github user rmetzger commented on the pull request:
GitHub user filipefigcorreia opened a pull request:
https://github.com/apache/flink/pull/1487
Added, to the DataStream API guide guide, an example of how to collect
results.
This is similar to what already exists for the DataSet API guide:
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085576#comment-15085576
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user rmetzger commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1427#issuecomment-169335005
Thanks a lot for looking into this!
In the `ExecutionConfig` I've made the following methods experimental:
- setAutoWatermarkInterval
- enableTimestamps
[
https://issues.apache.org/jira/browse/FLINK-3167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085539#comment-15085539
]
ASF GitHub Bot commented on FLINK-3167:
---
GitHub user rtudoran opened a pull request:
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/1488
[FLINK-3167] Improve documentation for window apply
Small correction and extension for the window apply example
You can merge this pull request into a Git repository by running:
$ git pull
Github user rtudoran closed the pull request at:
https://github.com/apache/flink/pull/1488
---
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 wishes so, or if the feature is
GitHub user rtudoran reopened a pull request:
https://github.com/apache/flink/pull/1488
[FLINK-3167] Improve documentation for window apply
Small correction and extension for the window apply example
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-3167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085542#comment-15085542
]
ASF GitHub Bot commented on FLINK-3167:
---
Github user rtudoran closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085543#comment-15085543
]
ASF GitHub Bot commented on FLINK-3167:
---
GitHub user rtudoran reopened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1489
[FLINK-3058] Add support for Kafka 0.9.0.0
For adding Kafka 0.9.0.0 support, this commit changes the following:
- Split up of the kafka connector into a
flink-connector-kafka-(base|0.9|0.8)
[
https://issues.apache.org/jira/browse/FLINK-3205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-3205.
-
Resolution: Duplicate
Fix Version/s: (was: 1.0.0)
Duplicate of FLINK-1712
> Remove
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/750#issuecomment-169344534
Travis failed with weird compilation error. I guess this is an caching
issue. It builds locally and on my personal Travis:
[
https://issues.apache.org/jira/browse/FLINK-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085608#comment-15085608
]
ASF GitHub Bot commented on FLINK-2111:
---
Github user mjsax commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085695#comment-15085695
]
ASF GitHub Bot commented on FLINK-3195:
---
Github user rmetzger commented on the pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1482#issuecomment-169362242
I'd like to finish the project restructure and I'll use this PR as a base.
I'll also address Fabian's comments.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-3167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085622#comment-15085622
]
ASF GitHub Bot commented on FLINK-3167:
---
Github user zentol commented on the pull request:
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1488#issuecomment-169346238
it appears that you used the wrong issue ID; it should be 31**76** but is
31**67**.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2833:
--
Issue Type: Sub-task (was: Task)
Parent: FLINK-3205
> Unstage Gelly and Module
[
https://issues.apache.org/jira/browse/FLINK-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2877:
--
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-3205
> Move Streaming API out of
Robert Metzger created FLINK-3205:
-
Summary: Remove the flink-staging module
Key: FLINK-3205
URL: https://issues.apache.org/jira/browse/FLINK-3205
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2877:
--
Parent Issue: FLINK-1712 (was: FLINK-3205)
> Move Streaming API out of Staging
>
[
https://issues.apache.org/jira/browse/FLINK-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-2833:
--
Parent Issue: FLINK-1712 (was: FLINK-3205)
> Unstage Gelly and Module refactoring
>
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1490
corrections in the javadoc examples of tumbling and sliding windows
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vasia/flink
[
https://issues.apache.org/jira/browse/FLINK-3207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3207:
Assignee: Vasia Kalavri
> Add a Pregel iteration abstraction to Gelly
>
Vasia Kalavri created FLINK-3207:
Summary: Add a Pregel iteration abstraction to Gelly
Key: FLINK-3207
URL: https://issues.apache.org/jira/browse/FLINK-3207
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3208:
Assignee: Vasia Kalavri
> Rename Gelly vertex-centric model to scatter-gather
>
Vasia Kalavri created FLINK-3208:
Summary: Rename Gelly vertex-centric model to scatter-gather
Key: FLINK-3208
URL: https://issues.apache.org/jira/browse/FLINK-3208
Project: Flink
Issue
Github user s1ck commented on the pull request:
https://github.com/apache/flink/pull/1471#issuecomment-169421134
Hi, sorry for the delay. I'll add the test asap.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15086070#comment-15086070
]
ASF GitHub Bot commented on FLINK-3118:
---
Github user s1ck commented on the pull request:
Greg Hogan created FLINK-3206:
-
Summary: Heap size for non-pre-allocated off-heap memory
Key: FLINK-3206
URL: https://issues.apache.org/jira/browse/FLINK-3206
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085791#comment-15085791
]
Stephan Ewen commented on FLINK-3206:
-
Are you running this on YARN?
I recently discovered this as a
[
https://issues.apache.org/jira/browse/FLINK-3206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15085839#comment-15085839
]
Greg Hogan commented on FLINK-3206:
---
No, running standalone.
> Heap size for non-pre-allocated off-heap
[
https://issues.apache.org/jira/browse/FLINK-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3197:
--
Description:
Here is related code:
{code}
FSDataInputStream fdis =
[
https://issues.apache.org/jira/browse/FLINK-3196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3196:
--
Description:
Here is related code:
{code}
InputStream propFile =
[
https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15086780#comment-15086780
]
ASF GitHub Bot commented on FLINK-2445:
---
Github user ajaybhat commented on the pull request:
Github user ajaybhat commented on the pull request:
https://github.com/apache/flink/pull/1486#issuecomment-169543630
The build has failed, but the failure seems unrelated to this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1477#issuecomment-169532718
@fhueske , codes has been finished. I have drop previous method of
plan-generator and rewrite a new parser named `PlanJsonParser` to parse the
existing JSON plan.
[
https://issues.apache.org/jira/browse/FLINK-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15086705#comment-15086705
]
ASF GitHub Bot commented on FLINK-3192:
---
Github user gallenvara commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15086217#comment-15086217
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user smarthi closed the pull request at:
Github user smarthi closed the pull request at:
https://github.com/apache/flink/pull/1479
---
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 wishes so, or if the feature is
Github user smarthi commented on the pull request:
https://github.com/apache/flink/pull/1479#issuecomment-169450577
Closing this PR, will replace with a newer PR.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15086216#comment-15086216
]
ASF GitHub Bot commented on FLINK-3115:
---
Github user smarthi commented on the pull request:
59 matches
Mail list logo
