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 Gua
[
https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14543112#comment-14543112
]
ASF GitHub Bot commented on FLINK-1711:
---
GitHub user lokeshrajaram opened a pull req
[
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 9da2
[
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 mess
[
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: but
> was:
> ---
[
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-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542326#comment-14542326
]
ASF GitHub Bot commented on FLINK-1907:
---
GitHub user nikste opened a pull request:
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-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
>
[
https://issues.apache.org/jira/browse/FLINK-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542183#comment-14542183
]
Theodore Vasiloudis commented on FLINK-2003:
As a note, in my case this was ca
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542134#comment-14542134
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user StephanEwen commented on the pu
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 an
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/664#issuecomment-101720728
Good catch, thank you.
I added test cases that validate we're throwing an exception for `-` and
`--` inputs.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542129#comment-14542129
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542108#comment-14542108
]
ASF GitHub Bot commented on FLINK-1990:
---
Github user chhao01 commented on the pull r
Github user chhao01 commented on the pull request:
https://github.com/apache/flink/pull/667#issuecomment-101719363
Failed in `flink-streaming-connectors` with java 8, does that related to
this change?
---
If your project is set up for it, you can reply to this email and have your
rep
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14542011#comment-14542011
]
ASF GitHub Bot commented on FLINK-1990:
---
Github user chhao01 commented on the pull r
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 h
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541985#comment-14541985
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user mbalassi commented on the pull
[
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 co
[
https://issues.apache.org/jira/browse/FLINK-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541908#comment-14541908
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user aljoscha commented on the pull
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 ema
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 pr
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 projec
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
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-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 to
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
whe
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/671
Clean up naming of State/Checkpoint Interfaces
The interfaces are used on StreamTask (for now) but were called
*Operator.
Also, the methods on operator were suggesting that it is only us
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541827#comment-14541827
]
Aljoscha Krettek commented on FLINK-1962:
-
Sorry, your comment did not appear yet
Aljoscha Krettek created FLINK-2009:
---
Summary: Time-Based Windows fail with Chaining Disabled
Key: FLINK-2009
URL: https://issues.apache.org/jira/browse/FLINK-2009
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541818#comment-14541818
]
Peter Schrott commented on FLINK-1731:
--
As discussed with [~aalexandrov] The initial
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-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 http://github.com/
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541783#comment-14541783
]
PJ Van Aeken commented on FLINK-1962:
-
So the line I mentioned is definitely the probl
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541701#comment-14541701
]
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-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-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541700#comment-14541700
]
Maximilian Michels commented on FLINK-1610:
---
No, the problem persists on the lat
[
https://issues.apache.org/jira/browse/FLINK-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541692#comment-14541692
]
Stephan Ewen commented on FLINK-1690:
-
I think this one is stable by now...
> Process
[
https://issues.apache.org/jira/browse/FLINK-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541693#comment-14541693
]
Stephan Ewen commented on FLINK-1610:
-
Any updates, has this been fixed?
> Java docs
[
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-tabpanel&focusedCommentId=14541689#comment-14541689
]
Stephan Ewen commented on FLINK-1784:
-
Subsumed by FLINK-2008
> KafkaITCase
> ---
[
https://issues.apache.org/jira/browse/FLINK-1784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-1784.
---
> KafkaITCase
> ---
>
> Key: FLINK-1784
> URL: https://issues.apac
[
https://issues.apache.org/jira/browse/FLINK-1865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-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-tabpanel&focusedCommentId=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-2007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541668#comment-14541668
]
Márton Balassi commented on FLINK-2007:
---
I have a working prototype, the API needs c
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541635#comment-14541635
]
PJ Van Aeken commented on FLINK-1962:
-
I suspect the casting in this line does not cha
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
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 rep
[
https://issues.apache.org/jira/browse/FLINK-1525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541624#comment-14541624
]
ASF GitHub Bot commented on FLINK-1525:
---
Github user mxm commented on the pull reque
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
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541570#comment-14541570
]
Alexander Alexandrov commented on FLINK-1731:
-
I suggest to try and add the in
Robert Metzger created FLINK-2006:
-
Summary: TaskManagerTest.testRunJobWithForwardChannel:432
expected: but was:
Key: FLINK-2006
URL: https://issues.apache.org/jira/browse/FLINK-2006
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541516#comment-14541516
]
Peter Schrott edited comment on FLINK-1731 at 5/13/15 7:33 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14541516#comment-14541516
]
Peter Schrott edited comment on FLINK-1731 at 5/13/15 7:29 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541516#comment-14541516
]
Peter Schrott commented on FLINK-1731:
--
Hi [~chiwanpark],
the thing is, to fit the m
[
https://issues.apache.org/jira/browse/FLINK-1990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 fea
65 matches
Mail list logo
