[
https://issues.apache.org/jira/browse/FLINK-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra reassigned FLINK-1612:
Assignee: Henry Saputra
> Add guidelines to avoid duplicate class names and more JavaDoc fo
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14346050#comment-14346050
]
ASF GitHub Bot commented on FLINK-1587:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/440#issuecomment-77068115
Hi,
I was about to merge this one, but I have two doubts:
- the tests print all execution output, including the exceptions, in
standard output. Is this OK or should w
[
https://issues.apache.org/jira/browse/FLINK-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-1640:
Assignee: Fabian Hueske
> FileOutputFormat writes to wrong path if path ends with '/'
> ---
[
https://issues.apache.org/jira/browse/FLINK-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345845#comment-14345845
]
ASF GitHub Bot commented on FLINK-1616:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/451
[FLINK-1616] [client] Overhaul of the client.
- Fix bugs with non-serializable messages
- Separate parser and action logic
- Clean up tests
- Vastly improve logging in CLI client
Fabian Hueske created FLINK-1640:
Summary: FileOutputFormat writes to wrong path if path ends with
'/'
Key: FLINK-1640
URL: https://issues.apache.org/jira/browse/FLINK-1640
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345849#comment-14345849
]
ASF GitHub Bot commented on FLINK-1633:
---
GitHub user andralungu opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-1631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1631.
-
Resolution: Fixed
Fixed via 94a66d570e4bb40824813911a4f1bb47a8bf8b90
> Port collisions in Process
GitHub user andralungu opened a pull request:
https://github.com/apache/flink/pull/452
[FLINK-1633][gelly] Added getTriplets() method and test
A convenience Gelly method that generates a DataSet of from the input graph.
You can merge this pull request into a Git repository by runni
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345709#comment-14345709
]
ASF GitHub Bot commented on FLINK-1637:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/450#issuecomment-77031055
Damn. The good news is, my test is working, the bad news is, that the
hadoop 2.6.0 version is causing an oversized uberjar:
> The number of files in the uberjar (
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345656#comment-14345656
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull reque
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-77025149
renamed, rebased, re...structured!
---
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
[
https://issues.apache.org/jira/browse/FLINK-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345637#comment-14345637
]
Henry Saputra commented on FLINK-1639:
--
Cool! Thanks [~ mbalassi], no good goes unpun
[
https://issues.apache.org/jira/browse/FLINK-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345637#comment-14345637
]
Henry Saputra edited comment on FLINK-1639 at 3/3/15 8:04 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345634#comment-14345634
]
Márton Balassi commented on FLINK-1639:
---
I do agree that a documentation is needed o
[
https://issues.apache.org/jira/browse/FLINK-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-1639:
-
Assignee: Márton Balassi
> Document the Flink deployment scripts to make sure others know
[
https://issues.apache.org/jira/browse/FLINK-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu reassigned FLINK-1633:
--
Assignee: Andra Lungu
> Add getTriplets() Gelly method
> --
>
>
Henry Saputra created FLINK-1639:
Summary: Document the Flink deployment scripts to make sure others
know how to make release
Key: FLINK-1639
URL: https://issues.apache.org/jira/browse/FLINK-1639
Proj
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345545#comment-14345545
]
ASF GitHub Bot commented on FLINK-1522:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/441#issuecomment-77013031
Hi @balidani! You're right, there is no way to check this without modifying
the library method. You can ignore my last bullet point for now :)
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345457#comment-14345457
]
Stephan Ewen commented on FLINK-1616:
-
There are a few issues with the CLI frontend.
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345455#comment-14345455
]
ASF GitHub Bot commented on FLINK-1587:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/440#issuecomment-77004964
perfect, thanks!
---
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
e
[
https://issues.apache.org/jira/browse/FLINK-1522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345412#comment-14345412
]
ASF GitHub Bot commented on FLINK-1522:
---
Github user balidani commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1637:
--
Component/s: Build System
> Flink uberjar does not work with Java 6
> --
Github user balidani commented on the pull request:
https://github.com/apache/flink/pull/441#issuecomment-76998835
Hi @vasia!
Thanks for the ideas! I tried to add more test cases that reflect them.
However, I'm not sure about the last bullet-point. Do you think my last
te
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/450
[FLINK-1637] Reduce number of files in uberjar for java 6
It seems that we've recently surpassed the magic number of 65536 files in
our YARN uberjar.
Java 6 is not able to read jar files with so
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345404#comment-14345404
]
ASF GitHub Bot commented on FLINK-1637:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345350#comment-14345350
]
Aljoscha Krettek commented on FLINK-1628:
-
[~fhueske] and I found the bug in the o
[
https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345353#comment-14345353
]
Aljoscha Krettek commented on FLINK-1628:
-
This is the fix, line 128 in AbstractJo
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345296#comment-14345296
]
ASF GitHub Bot commented on FLINK-377:
--
Github user aljoscha commented on the pull req
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-76981299
You could call it CoGroupRaw, just an idea...
Once that and the split into the python and generic part is done I vote for
merging this. The API looks good and oth
[
https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345300#comment-14345300
]
Robert Metzger commented on FLINK-1577:
---
Thank you!
> Misleading error messages whe
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345284#comment-14345284
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-1577.
Resolution: Fixed
Fixed in 9255594fb3b9b7c00d9088c3b630af9ecbdf22f4.
> Misleading error messages wh
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-76979731
yes they are implemented as they are for performance reasons. the python
cogroup grouping logic is actually a direct port of the
SortMergeCoGroupIterator.
it also
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/410#issuecomment-76978687
@rmetzger I don't see a reason why this should not go to master as well.
After all, it's optional and quite useful if you want to run a job on the full
cluster with as many av
[
https://issues.apache.org/jira/browse/FLINK-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345255#comment-14345255
]
ASF GitHub Bot commented on FLINK-1555:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/415
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1555.
---
Resolution: Fixed
Fix Version/s: 0.9
This has been resolved in
http://git-wip-us.apach
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/410#issuecomment-76974155
Ping ...
---
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
enable
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345245#comment-14345245
]
ASF GitHub Bot commented on FLINK-377:
--
Github user aljoscha commented on the pull req
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-76973194
Yes, this sounds good? Another thing: it has probably already come up but I
just want to make sure, you implement CoGroup and Reduce the way you do because
of performance
Github user uce closed the pull request at:
https://github.com/apache/flink/pull/356
---
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 enabled
[
https://issues.apache.org/jira/browse/FLINK-1350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345244#comment-14345244
]
ASF GitHub Bot commented on FLINK-1350:
---
Github user uce closed the pull request at:
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/449
Streaming cancellation + exception handling rework
This PR reworks the way runtime exceptions are handled in the streaming
runtime.
User code and other types of exceptions thrown during the i
[
https://issues.apache.org/jira/browse/FLINK-999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345203#comment-14345203
]
ASF GitHub Bot commented on FLINK-999:
--
GitHub user jkirsch opened a pull request:
GitHub user jkirsch opened a pull request:
https://github.com/apache/flink/pull/448
[FLINK-999] Configurability of LocalExecutor
Add also the global configuration to the minicluster.
This is an attempt to bring in the ability to pass configuration parameters
to the embedded
[
https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345169#comment-14345169
]
Robert Metzger commented on FLINK-1577:
---
Another user was affected by this.
Would be
Márton Balassi created FLINK-1638:
-
Summary: SimpleKafkaSource connector
Key: FLINK-1638
URL: https://issues.apache.org/jira/browse/FLINK-1638
Project: Flink
Issue Type: Improvement
Affec
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14345000#comment-14345000
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull reque
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-76935408
@aljoscha Im quite undecided on that one. What i would like the most is
having the language binding module remain where it is, with 2 submodules:
flink-generic and flink-py
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14344927#comment-14344927
]
Max Michels commented on FLINK-1637:
There are tools like ProGuard which can reduce th
[
https://issues.apache.org/jira/browse/FLINK-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14344918#comment-14344918
]
Robert Metzger commented on FLINK-1637:
---
The issue is that Java 6 can not load jar f
Robert Metzger created FLINK-1637:
-
Summary: Flink uberjar does not work with Java 6
Key: FLINK-1637
URL: https://issues.apache.org/jira/browse/FLINK-1637
Project: Flink
Issue Type: Bug
A
Ufuk Celebi created FLINK-1636:
--
Summary: Misleading exception during concurrent partition release
and remote request
Key: FLINK-1636
URL: https://issues.apache.org/jira/browse/FLINK-1636
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14344841#comment-14344841
]
Stephan Ewen commented on FLINK-1635:
-
I agree, let's remove this. The way that it cur
[
https://issues.apache.org/jira/browse/FLINK-1627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14344837#comment-14344837
]
Ufuk Celebi commented on FLINK-1627:
I couldn't yet reproduce the problem (I did 10 bu
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/440#issuecomment-76914047
The failure in TaskManagerFailsITCase should be unrelated to your PR. This
should be fixed once the proper shading is in place. So don't worry and go
ahead merg
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14344831#comment-14344831
]
ASF GitHub Bot commented on FLINK-1587:
---
Github user tillrohrmann commented on the p
Robert Metzger created FLINK-1635:
-
Summary: Remove Apache Thrift dependency from Flink
Key: FLINK-1635
URL: https://issues.apache.org/jira/browse/FLINK-1635
Project: Flink
Issue Type: Bug
63 matches
Mail list logo
