Dear community!
After careful testing and three release candidates, I take a chance and
hereby start a vote.
Please vote on releasing the following candidate as Apache Flink version
0.9.0.
-
The commit to be voted on:
e4643d248350c5c272
I merged the legal and scheduler PR.
On Tue, Jun 16, 2015 at 11:17 PM Márton Balassi
wrote:
> @Max: The PR is good to go on my side. Does the job, could be a bit nicer
> though. Added to the document.
>
> On Tue, Jun 16, 2015 at 10:54 PM, Aljoscha Krettek
> wrote:
>
> > I added the two relevant
@Max: The PR is good to go on my side. Does the job, could be a bit nicer
though. Added to the document.
On Tue, Jun 16, 2015 at 10:54 PM, Aljoscha Krettek
wrote:
> I added the two relevant Table API commits to the release doc.
>
> On Tue, 16 Jun 2015 at 21:49 Maximilian Michels wrote:
>
> > +1
I added the two relevant Table API commits to the release doc.
On Tue, 16 Jun 2015 at 21:49 Maximilian Michels wrote:
> +1 for adding the Table API fixes.
>
> @Till: It seems like you fixed the bug in the scheduler. Is
> https://github.com/apache/flink/pull/843 fixing it?
>
> @Marton: What's the
+1 for adding the Table API fixes.
@Till: It seems like you fixed the bug in the scheduler. Is
https://github.com/apache/flink/pull/843 fixing it?
@Marton: What's the state of your pull request to solve the license issue
of the shaded dependencies? https://github.com/apache/flink/pull/837
I'm as
Important fixes, IMO. +1 for adding.
2015-06-16 18:50 GMT+02:00 Aljoscha Krettek :
> I would like to include the fixes for the Table API: RowSerializer supports
> null values, Aggregations properly deal with null values.
>
> What do you think?
>
> On Mon, 15 Jun 2015 at 17:31 Aljoscha Krettek wr
I would like to include the fixes for the Table API: RowSerializer supports
null values, Aggregations properly deal with null values.
What do you think?
On Mon, 15 Jun 2015 at 17:31 Aljoscha Krettek wrote:
> I created this to help with release testing:
> https://github.com/aljoscha/FliRTT
>
> Y
Aljoscha Krettek created FLINK-2234:
---
Summary: CoStreamWindow is Dependent on Input Ordering
Key: FLINK-2234
URL: https://issues.apache.org/jira/browse/FLINK-2234
Project: Flink
Issue Type:
Ufuk Celebi created FLINK-2233:
--
Summary: InputFormat nextRecord Javadocs out of sync
Key: FLINK-2233
URL: https://issues.apache.org/jira/browse/FLINK-2233
Project: Flink
Issue Type: Bug
But the sources stay inside they run() method the whole execution time, per
design. That's why another thread needs to call cancel() on the source to
break it out of this (in most cases) infinite loop.
On Tue, 16 Jun 2015 at 14:13 Matthias J. Sax
wrote:
> Hi,
>
> I just encountered, that the (ne
Hi,
I just encountered, that the (new streaming API) SourceFunction
interface method cancel() states in the JavaDoc, that one might have a
"volatile field 'isRunning'". Why should this member be volatile? I do
not see why different thread should access this field (I would claim, it
will be impleme
We could replace the placeholder "error" with something more meaningful
though...
On Tue, Jun 16, 2015 at 1:27 PM, Márton Balassi
wrote:
> Ok, never mind. I got it: it is decided later dependent on the hadoop
> profile. Makes sense.
>
> On Tue, Jun 16, 2015 at 1:24 PM, Márton Balassi
> wrote:
>
Ok, never mind. I got it: it is decided later dependent on the hadoop
profile. Makes sense.
On Tue, Jun 16, 2015 at 1:24 PM, Márton Balassi
wrote:
> Hey,
>
> While reading through the flink-parent pom I have stumbled upon this. [1]
>
> error
>
> I am just curious why do we use this. :)
>
> [1] h
Hey,
While reading through the flink-parent pom I have stumbled upon this. [1]
error
I am just curious why do we use this. :)
[1] https://github.com/apache/flink/blob/master/pom.xml#L72
Hi,
Thank you for your help. It was actually an issue between the Flink
version I used to build my quickstart jar and the Flink version on the
cluster.
Cheers,
Thomas
Le 16/06/15 10:10, Till Rohrmann a écrit :
I also tested your code with an additional sink and it is executed on a
cluster w
Thanks Ted for writing Marvin. I think this clarifies things for the
LICENSE and NOTICE files.
Since we have to parse anyways the NOTICE files of all direct and
transitive ALv2 dependencies for the binary distribution, it probably does
not make a big difference in terms of maintenance whether we l
Ufuk Celebi created FLINK-2232:
--
Summary: StormWordCountLocalITCase fails
Key: FLINK-2232
URL: https://issues.apache.org/jira/browse/FLINK-2232
Project: Flink
Issue Type: Bug
Component
I also tested your code with an additional sink and it is executed on a
cluster without problems.
Cheers,
Till
On Tue, Jun 16, 2015 at 10:00 AM Chiwan Park wrote:
> Hi. What flink version is running now in cluster?
> I copied your code and packaging with flink quickstart archetype. There is
> a
Hi. What flink version is running now in cluster?
I copied your code and packaging with flink quickstart archetype. There is
another error because you don’t add any data sink in the program.
Regards,
Chiwan Park
> On Jun 16, 2015, at 4:17 PM, Thomas Peel wrote:
>
>
>
> Hi guys,
>
> I am hav
Hi guys,
I am having troubles with a portion of code that throws an exception
when executed on a cluster (through the web interface) but not when
executed localy.
The code :
object DorotheaLassoRegression {
def main(args: Array[String]): Unit = {
val env = ExecutionEnvironment.getExecutionE
Stephan Ewen created FLINK-2231:
---
Summary: Create a Serializer for Scala Enumerations
Key: FLINK-2231
URL: https://issues.apache.org/jira/browse/FLINK-2231
Project: Flink
Issue Type: Improvemen
21 matches
Mail list logo
