Hi Ken,
yes, that’s exactly how it work in Flink as well.
The object reuse move dues not affect how chaining is done.
Best, Fabian
Von: Ken Krugler
Gesendet: Freitag, 4. März 2016 01:54
An: dev@flink.apache.org
Betreff: RE: Guarantees for object reuse modes and documentation
Hi Gábor,
When
Ted Yu created FLINK-3576:
-
Summary: Upgrade Snappy Java to 1.1.2.1
Key: FLINK-3576
URL: https://issues.apache.org/jira/browse/FLINK-3576
Project: Flink
Issue Type: Improvement
Reporter:
Hi All,
I've created 2 docker containers on my local machine, one running
JM(192.168.99.104) and other running TM. I was expecting to see TM in the
JM UI but it did not happen. On looking into the TM logs I see following
lines
01:29:50,862 DEBUG org.apache.flink.runtime.taskmanager.TaskManager
Hi Gábor,
When object re-use is enabled, what happens when maps are chained?
In Cascading, when running in local mode, the tuple that one map operation
outputs is immediately used as the input for the next map.
The upstream map isn't called with another input tuple until the pipelining is
done
+1
Checked that the sources don't contain binaries
Tested cluster execution with flink/run and web client job submission
Run all examples via FliRTT
Tested Kafka 0.9
Verified that quickstarts work with Eclipse and IntelliJ
Run example with RemoteEnvironment
Verified SBT quickstarts
On Thu, Mar 3,
Aljoscha Krettek created FLINK-3575:
---
Summary: Update Working With State Section in Doc
Key: FLINK-3575
URL: https://issues.apache.org/jira/browse/FLINK-3575
Project: Flink
Issue Type: Impr
Timo Walther created FLINK-3574:
---
Summary: Implement math functions for Table API
Key: FLINK-3574
URL: https://issues.apache.org/jira/browse/FLINK-3574
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-3573:
---
Summary: Implement more String functions for Table API
Key: FLINK-3573
URL: https://issues.apache.org/jira/browse/FLINK-3573
Project: Flink
Issue Type: Sub-tas
Till Rohrmann created FLINK-3572:
Summary: SourceStreamTaskTest.testCheckpointing fails on Travis
Key: FLINK-3572
URL: https://issues.apache.org/jira/browse/FLINK-3572
Project: Flink
Issue Ty
+1
I think we have a winner. :D
The “boring” tests from the checklist should still hold for this RC and I now
ran a custom windowing job with state on RocksDB on Hadoop 2.7 with Scala 2.11.
I used the Yarn HA mode and shot down both JobManagers and TaskManagers and the
job restarted successful
Till Rohrmann created FLINK-3571:
Summary: SavepointITCase.testRestoreFailure fails on Travis
Key: FLINK-3571
URL: https://issues.apache.org/jira/browse/FLINK-3571
Project: Flink
Issue Type:
Apparently I was not careful enough when writing the email.
The release branch is "release-1.0.0-rc5" and its the fifth RC.
On Thu, Mar 3, 2016 at 2:01 PM, Robert Metzger wrote:
> Dear Flink community,
>
> Please vote on releasing the following candidate as Apache Flink version
> 1.0.0.
>
> This
Till Rohrmann created FLINK-3570:
Summary: Replace random NIC selection heuristic by
InetAddress.getLocalHost
Key: FLINK-3570
URL: https://issues.apache.org/jira/browse/FLINK-3570
Project: Flink
Dear Flink community,
Please vote on releasing the following candidate as Apache Flink version 1.0
.0.
This is the fourth RC.
Here is a document to report on the testing and release verification:
https://docs.google.com/document/d/1hoQ5k4WQteNj2OoPwpQPD4ZVHrCwM1pTlUVww8ld7oY/edit#heading=h.2v6zy5
Maximilian Michels created FLINK-3569:
-
Summary: Test cases fail due to Maven Shade plugin
Key: FLINK-3569
URL: https://issues.apache.org/jira/browse/FLINK-3569
Project: Flink
Issue Type:
Sebastian Neef created FLINK-3568:
-
Summary: Hadoop's Bzip decompression is not thread safe
Key: FLINK-3568
URL: https://issues.apache.org/jira/browse/FLINK-3568
Project: Flink
Issue Type: Bu
Timo Walther created FLINK-3567:
---
Summary: Rework selection when grouping in Table API
Key: FLINK-3567
URL: https://issues.apache.org/jira/browse/FLINK-3567
Project: Flink
Issue Type: Bug
Hi everyone,
Asterios told me that you in the meantime might already have started
planning/implementing incremental checkpoints and that it might be too
late for me to chose it as a topic for my diploma thesis. Is that the
case? If yes, is there a similar topic that I could work on?
Yours,
Marius
Thanks Ufuk! I'll add the Gelly-related breaking changes.
-Vasia.
On 3 March 2016 at 10:55, Márton Balassi wrote:
> Thanks for initiating this Ufuk. Updated the streaming hashing mention -
> whether it is api breaking is questionable, so I would place it last in the
> list. But definitely good
Thanks for initiating this Ufuk. Updated the streaming hashing mention -
whether it is api breaking is questionable, so I would place it last in the
list. But definitely good to mention it there.
On Thu, Mar 3, 2016 at 10:48 AM, Ufuk Celebi wrote:
> Hey all,
>
> let's make sure that we have a go
Hey all,
let's make sure that we have a good migration guide for the 1.0
release with the announcement.
Can you please add relevant changes that you are aware of to this document:
https://docs.google.com/document/d/13RqZ-_7_w1pYCi4cm_94XfaxwyTS1R_9KYUmD7jmGV8
I've created two sections, one for
21 matches
Mail list logo
