[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507333#comment-14507333
]
Till Rohrmann commented on FLINK-1745:
--
Hi Raghav,
if I understood it correctly,
[
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-1865:
--
Comment: was deleted
(was: Go ahead.)
Unstable test KafkaITCase
-
[
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-1865:
--
Comment: was deleted
(was: Go ahead.)
Unstable test KafkaITCase
-
Till Rohrmann created FLINK-1931:
Summary: Add ADMM to optimization framework
Key: FLINK-1931
URL: https://issues.apache.org/jira/browse/FLINK-1931
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-1931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1931:
-
Labels: ML (was: )
Add ADMM to optimization framework
--
[
https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507004#comment-14507004
]
ASF GitHub Bot commented on FLINK-1909:
---
Github user gyfora commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507058#comment-14507058
]
Robert Metzger commented on FLINK-1865:
---
The issue still persists (this is a build
[
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507069#comment-14507069
]
Robert Metzger commented on FLINK-1865:
---
I have written to the Kafka Mailing list to
[
https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507012#comment-14507012
]
ASF GitHub Bot commented on FLINK-1909:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507361#comment-14507361
]
Márton Balassi commented on FLINK-1865:
---
Go ahead.
Unstable test KafkaITCase
[
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507359#comment-14507359
]
Márton Balassi commented on FLINK-1865:
---
Go ahead.
Unstable test KafkaITCase
[
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507360#comment-14507360
]
Márton Balassi commented on FLINK-1865:
---
Go ahead.
Unstable test KafkaITCase
Till Rohrmann created FLINK-1932:
Summary: Add L-BFGS to the optimization framework
Key: FLINK-1932
URL: https://issues.apache.org/jira/browse/FLINK-1932
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-1422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507190#comment-14507190
]
ASF GitHub Bot commented on FLINK-1422:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507189#comment-14507189
]
Vasia Kalavri commented on FLINK-1930:
--
Hi [~rmetzger]! No, I'm not sure what's the
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/350
---
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 gyfora commented on the pull request:
https://github.com/apache/flink/pull/614#issuecomment-95157387
The current stream reduces only keep 1 element as their state, the problem
is that if you run it in parallel, each node will keep a partial reduce.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507002#comment-14507002
]
ASF GitHub Bot commented on FLINK-1909:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/610#discussion_r28868831
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
---
@@
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/617#issuecomment-95173776
No, I would not add a dependency there. Maybe a comment that we've managed
a transitive dependency of hbase.
---
If your project is set up for it, you can reply to this
Github user gyfora closed the pull request at:
https://github.com/apache/flink/pull/610
---
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
[
https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507131#comment-14507131
]
ASF GitHub Bot commented on FLINK-1909:
---
Github user gyfora closed the pull request
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/350#issuecomment-95206967
Thanks, Chesnay! I've added the constructor parametrization, fixed the code
examples, and rebased on the lastest master.
Going to merge it.
---
If your project is
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/617
[runtime] Bump Netty version to 4.27.Final and add javassist
@rmetzger, javassist is set in the root POM. Is it OK to leave it in
flink-runtime as I have it now w/o version?
You can merge this pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/604
---
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
[
https://issues.apache.org/jira/browse/FLINK-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507080#comment-14507080
]
ASF GitHub Bot commented on FLINK-1875:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/606
---
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 gyfora commented on the pull request:
https://github.com/apache/flink/pull/521#issuecomment-95199623
Hey Peti,
I added a refactor commit that reworked the way types are handled in the
sources a little bit.
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507148#comment-14507148
]
ASF GitHub Bot commented on FLINK-1687:
---
Github user gyfora commented on the pull
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/571#discussion_r28869610
--- Diff: flink-staging/flink-hbase/pom.xml ---
@@ -112,6 +112,12 @@ under the License.
/exclusion
[
https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507025#comment-14507025
]
ASF GitHub Bot commented on FLINK-1828:
---
Github user fpompermaier commented on a
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/610#discussion_r28868234
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
---
@@
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/617#issuecomment-95163295
Ah .. we didn't change the javaassist version ;)
---
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
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/617#issuecomment-95169398
Yap. I've just seen that there is no reference to javassist in the
flink-hbase pom. Is that intentional? Shouldn't we also add a dependency there
w/o the version?
---
If
Github user gyfora commented on a diff in the pull request:
https://github.com/apache/flink/pull/610#discussion_r28868351
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
---
@@
Robert Metzger created FLINK-1929:
-
Summary: Add code to cleanly stop a running streaming topology
Key: FLINK-1929
URL: https://issues.apache.org/jira/browse/FLINK-1929
Project: Flink
Issue
Github user ktzoumas commented on the pull request:
https://github.com/apache/flink/pull/606#issuecomment-95174641
Good to merge
---
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
[
https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1909.
---
Resolution: Fixed
https://github.com/apache/flink/commit/6df1dd2cc848d0a691a98309a3bb760f9a998673
[
https://issues.apache.org/jira/browse/FLINK-1422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507163#comment-14507163
]
ASF GitHub Bot commented on FLINK-1422:
---
Github user uce commented on the pull
Vasia Kalavri created FLINK-1930:
Summary: NullPointerException in vertex-centric iteration
Key: FLINK-1930
URL: https://issues.apache.org/jira/browse/FLINK-1930
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507179#comment-14507179
]
Robert Metzger commented on FLINK-1930:
---
I've seen this issue also recently in a
[
https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507306#comment-14507306
]
Nikolaas Steenbergen commented on FLINK-1907:
-
I've added a class to start up
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/617#issuecomment-95218150
OK, then this is good to merge?
---
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
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/615#issuecomment-95223394
+1
LGTM
---
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
[
https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507290#comment-14507290
]
Stephan Ewen commented on FLINK-1930:
-
I have a bit of code pending that may help to
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507556#comment-14507556
]
Chiwan Park commented on FLINK-1745:
Hi.
About the model, I think that grouping the
[
https://issues.apache.org/jira/browse/FLINK-1687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14507675#comment-14507675
]
ASF GitHub Bot commented on FLINK-1687:
---
Github user szape commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra closed FLINK-1653.
Resolution: Fixed
With increase Travis capacity for ASF lets close this one for now.
Setting up
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14508420#comment-14508420
]
Chiwan Park commented on FLINK-1745:
Okay, thanks [~raghav.chalapa...@gmail.com] for
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/614
---
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
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14508143#comment-14508143
]
Raghav Chalapathy commented on FLINK-1745:
--
Hi
I agree we with the idea to
GitHub user hsaputra opened a pull request:
https://github.com/apache/flink/pull/618
Add DEPRECATED annotations in Spargel APIs and update the doc to refer to
Gelly for Flink graph processing.
Mark all user-facing from the Spargel API as deprecated and add a comment
in the docs
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/618#issuecomment-95337327
CC @vasia
---
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
Chiwan Park created FLINK-1933:
--
Summary: Add distance measure interface and basic implementation
to machine learning library
Key: FLINK-1933
URL: https://issues.apache.org/jira/browse/FLINK-1933
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/617#issuecomment-95162838
Are we sure that HBase is still working?
I think there are no automated tests for Hbase ;)
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1875.
---
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/db608332
Robert Metzger created FLINK-1923:
-
Summary: Replace asynchronous logging in JobManager with regular
slf4j logging
Key: FLINK-1923
URL: https://issues.apache.org/jira/browse/FLINK-1923
Project: Flink
Till Rohrmann created FLINK-1925:
Summary: Split SubmitTask method up into two phases: Receive TDD
and instantiation of TDD
Key: FLINK-1925
URL: https://issues.apache.org/jira/browse/FLINK-1925
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/616
[FLINK-1924] Minor Refactoring
This PR resolves a few minor issues, including
formatting
simpler python process initialization
renaming of the python connection following the switch to tcp
[
https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506778#comment-14506778
]
ASF GitHub Bot commented on FLINK-1924:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1925:
-
Description:
A user reported that a job times out while submitting tasks to the TaskManager.
The
[
https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-1924:
Affects Version/s: (was: 0.8.2)
0.9
Fix Version/s:
[
https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-1924:
Affects Version/s: (was: 0.8.1)
0.8.2
Fix Version/s:
[
https://issues.apache.org/jira/browse/FLINK-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-1926:
Summary: [Py] Sync Python API with other API's (was: [Py] Sync Python API
with otehr
Chesnay Schepler created FLINK-1926:
---
Summary: [Py] Sync Python API with otehr API's
Key: FLINK-1926
URL: https://issues.apache.org/jira/browse/FLINK-1926
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-1927:
---
Summary: [Py] Rework operator distribution
Key: FLINK-1927
URL: https://issues.apache.org/jira/browse/FLINK-1927
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506732#comment-14506732
]
Stefan Bunk commented on FLINK-1916:
Isn't the code I linked already quite minimal?
Robert Metzger created FLINK-1922:
-
Summary: Failed task deployment causes NPE on input split
assignment
Key: FLINK-1922
URL: https://issues.apache.org/jira/browse/FLINK-1922
Project: Flink
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/601
---
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
[
https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506825#comment-14506825
]
ASF GitHub Bot commented on FLINK-1891:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/572
---
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
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506826#comment-14506826
]
ASF GitHub Bot commented on FLINK-703:
--
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-703:
Fix Version/s: (was: pre-apache)
0.9
Use complete element as join key.
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-703.
-
Resolution: Implemented
Implemented with 45e680c2b6c9c2f64ce55423b755a13d402ff8ba
Use complete
[
https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1891.
--
Resolution: Fixed
Fix Version/s: 0.9
Fixed with a0147c493cf210a0914c35200ebfacd47515374d
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/372
---
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
[
https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506913#comment-14506913
]
ASF GitHub Bot commented on FLINK-1486:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506691#comment-14506691
]
Robert Metzger commented on FLINK-1804:
---
I didn't see them lately. I'll close the
[
https://issues.apache.org/jira/browse/FLINK-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1804.
---
Resolution: Invalid
flink-quickstart-scala tests fail on scala-2.11 build profile on travis
Robert Metzger created FLINK-1920:
-
Summary: Passing -D akka.ask.timeout=5 min to yarn client does not
work
Key: FLINK-1920
URL: https://issues.apache.org/jira/browse/FLINK-1920
Project: Flink
Robert Metzger created FLINK-1921:
-
Summary: Rework parallelism/slots handling for per-job YARN
sessions
Key: FLINK-1921
URL: https://issues.apache.org/jira/browse/FLINK-1921
Project: Flink
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/372#issuecomment-95153627
I think you are right. If there's only one sink active, there is no need
for a sink identifier.
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506968#comment-14506968
]
ASF GitHub Bot commented on FLINK-1486:
---
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506978#comment-14506978
]
Stephan Ewen commented on FLINK-1878:
-
Complemented in
[
https://issues.apache.org/jira/browse/FLINK-1918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1918.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Stephan Ewen
Fixed via
[
https://issues.apache.org/jira/browse/FLINK-1918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1918.
---
NullPointerException at org.apache.flink.client.program.Client's constructor
while using
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/614#issuecomment-95156797
LGTM, really nice feature. Maybe we should also discourage or even diasble
the current full stream reduces where the state might grow infinite now that we
have this
[
https://issues.apache.org/jira/browse/FLINK-1918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506983#comment-14506983
]
Stephan Ewen commented on FLINK-1918:
-
[~Ehnalis] It should be fixed in the the latest
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/610#issuecomment-95157189
LGTM.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14506986#comment-14506986
]
ASF GitHub Bot commented on FLINK-1909:
---
Github user mbalassi commented on the pull
90 matches
Mail list logo
