Márton Balassi created FLINK-2007:
-
Summary: Initial data point in Delta function needs to be
serializable
Key: FLINK-2007
URL: https://issues.apache.org/jira/browse/FLINK-2007
Project: Flink
Robert Metzger created FLINK-2008:
-
Summary: PersistentKafkaSource is sometimes emitting tuples
multiple times
Key: FLINK-2008
URL: https://issues.apache.org/jira/browse/FLINK-2008
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541668#comment-14541668
]
Márton Balassi commented on FLINK-2007:
---
I have a working prototype, the API needs
[
https://issues.apache.org/jira/browse/FLINK-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1857.
---
Flakey SimpleRecoveryITCase#testRestartMultipleTimes test
[
https://issues.apache.org/jira/browse/FLINK-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1857.
-
Resolution: Done
Fix Version/s: 0.9
Flakey SimpleRecoveryITCase#testRestartMultipleTimes
[
https://issues.apache.org/jira/browse/FLINK-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541682#comment-14541682
]
Stephan Ewen commented on FLINK-1857:
-
I think this has been fixed by the combination
[
https://issues.apache.org/jira/browse/FLINK-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1784.
-
Resolution: Not A Problem
KafkaITCase
---
Key: FLINK-1784
[
https://issues.apache.org/jira/browse/FLINK-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541689#comment-14541689
]
Stephan Ewen commented on FLINK-1784:
-
Subsumed by FLINK-2008
KafkaITCase
[
https://issues.apache.org/jira/browse/FLINK-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541692#comment-14541692
]
Stephan Ewen commented on FLINK-1690:
-
I think this one is stable by now...
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/667#issuecomment-101617351
For some reason it doesn't like the keywork2Parser when you use String
Interpolation. If you replace the line with:
```
((i?)\Q + kw.key + \E).r
```
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541624#comment-14541624
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user mxm commented on the pull
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-101579496
Do you want to allow empty keys like in `-- value` or even `--`? I think
the parser should throw an exception in this case.
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541684#comment-14541684
]
Stephan Ewen commented on FLINK-1865:
-
With the rewrite of the PersistentKafkaSource,
[
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1865.
---
Resolution: Not A Problem
Unstable test KafkaITCase
-
[
https://issues.apache.org/jira/browse/FLINK-1661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-1661.
--
Resolution: Not A Problem
Fix Version/s: 0.9
The method was removed by
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/671#issuecomment-101653784
It would mean the state with which that operator instance is started.
It is just a personal preference - just keep it as it is if you want...
---
If your project
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/671#issuecomment-101652722
But what does restoreInitialState mean? What is the initial state? The
state when the operator was first created?
---
If your project is set up for it, you can reply
Stephan Ewen created FLINK-2011:
---
Summary: Improve error message when user-defined serialization
logic is wrong
Key: FLINK-2011
URL: https://issues.apache.org/jira/browse/FLINK-2011
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541908#comment-14541908
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user aljoscha commented on the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/671#issuecomment-101651301
Looks good
I actually liked the function name `restoreInitialState`. This makes it
very clear that this method sets only the initial state, not any state
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541827#comment-14541827
]
Aljoscha Krettek commented on FLINK-1962:
-
Sorry, your comment did not appear yet
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/659#issuecomment-101663155
I rebased this PR on top of the latest work on the checkpointing. What are
the opinions on merging this?
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541810#comment-14541810
]
Aljoscha Krettek commented on FLINK-1962:
-
I'm sorry. It seems that the Graph API
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541818#comment-14541818
]
Peter Schrott commented on FLINK-1731:
--
As discussed with [~aalexandrov] The initial
[
https://issues.apache.org/jira/browse/FLINK-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1595.
-
Resolution: Implemented
Fix Version/s: 0.9
Implemented via 4786b56 and 48e21a1.
Add a
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541783#comment-14541783
]
PJ Van Aeken commented on FLINK-1962:
-
So the line I mentioned is definitely the
Stephan Ewen created FLINK-2010:
---
Summary: Add test that verifies that chained tasks are properly
checkpointed
Key: FLINK-2010
URL: https://issues.apache.org/jira/browse/FLINK-2010
Project: Flink
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/671#issuecomment-101654445
Nah, you can change it of course. :smile_cat:
---
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-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541940#comment-14541940
]
ASF GitHub Bot commented on FLINK-1595:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/520
---
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-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14542011#comment-14542011
]
ASF GitHub Bot commented on FLINK-1990:
---
Github user chhao01 commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541985#comment-14541985
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user mbalassi commented on the pull
Github user chhao01 commented on the pull request:
https://github.com/apache/flink/pull/667#issuecomment-101688740
Thank you @aljoscha, eventually I got the IDE works with unit test, and I
update the code, let's see what travis will say.
---
If your project is set up for it, you can
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/659#issuecomment-101684152
I'll do another pass tomorrow.
---
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-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14542129#comment-14542129
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14542134#comment-14542134
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/659#issuecomment-101721428
I will also try to have a closer look later today or tomorrow.
First rough glance looks good!
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14542108#comment-14542108
]
ASF GitHub Bot commented on FLINK-1990:
---
Github user chhao01 commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14542183#comment-14542183
]
Theodore Vasiloudis commented on FLINK-2003:
As a note, in my case this was
[
https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543112#comment-14543112
]
ASF GitHub Bot commented on FLINK-1711:
---
GitHub user lokeshrajaram opened a pull
GitHub user lokeshrajaram opened a pull request:
https://github.com/apache/flink/pull/673
[FLINK-1711] - Converted all usages of Commons Validate to Guava Checks(for
Java classes), Scala predef require(for Scala classes)
[FLINK-1711] - Converted all usages of Commons Validate to
[
https://issues.apache.org/jira/browse/FLINK-1932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Theodore Vasiloudis reassigned FLINK-1932:
--
Assignee: Theodore Vasiloudis
Add L-BFGS to the optimization framework
GitHub user nikste opened a pull request:
https://github.com/apache/flink/pull/672
[FLINK-1907] Scala shell
implementation of Scala Shell, for Scala versions 2.10 and 2.11.
Also includes change to eager print()
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-2006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2006.
---
TaskManagerTest.testRunJobWithForwardChannel:432 expected:FINISHED but
was:FAILED
[
https://issues.apache.org/jira/browse/FLINK-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2011.
---
Improve error message when user-defined serialization logic is wrong
[
https://issues.apache.org/jira/browse/FLINK-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2011.
-
Resolution: Pending Closed
Fixed in 113b20b7f8717b12c5f0dfa691da582d426fbae0
Improve error
[
https://issues.apache.org/jira/browse/FLINK-2006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2006.
-
Resolution: Pending Closed
Fix Version/s: 0.9
Assignee: Stephan Ewen
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14542326#comment-14542326
]
ASF GitHub Bot commented on FLINK-1907:
---
GitHub user nikste opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541516#comment-14541516
]
Peter Schrott edited comment on FLINK-1731 at 5/13/15 7:29 AM:
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541505#comment-14541505
]
ASF GitHub Bot commented on FLINK-1990:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/667#issuecomment-101544907
I'll check it out.
---
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-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541516#comment-14541516
]
Peter Schrott edited comment on FLINK-1731 at 5/13/15 7:30 AM:
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541516#comment-14541516
]
Peter Schrott edited comment on FLINK-1731 at 5/13/15 7:33 AM:
Robert Metzger created FLINK-2006:
-
Summary: TaskManagerTest.testRunJobWithForwardChannel:432
expected:FINISHED but was:FAILED
Key: FLINK-2006
URL: https://issues.apache.org/jira/browse/FLINK-2006
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14541570#comment-14541570
]
Alexander Alexandrov commented on FLINK-1731:
-
I suggest to try and add the
55 matches
Mail list logo
