I'm happy to announce that we have unanimously approved this release.
These are the 4 approving votes, 3 of which are binding:
* Gordong (binding)
* Piotr (non-binding)
* Timo (binding)
* Chesnay (binding)
Thanks everyone!
On 06.06.2018 08:56, Chesnay Schepler wrote:
Nice catch, but I wouldn't
Nice catch, but I wouldn't cancel the vote because of it. The release
process is documented in the Wiki and refers to the correct scripts.
On 05.06.2018 16:50, Timo Walther wrote:
+1
- Checked the commits that went into this release
- Build from source
I found one minor thing. There are two "
SUBRAMANYA SURESH created FLINK-9536:
Summary: Rolling logs using log4j.properties, prevents them from
showing on the UI.
Key: FLINK-9536
URL: https://issues.apache.org/jira/browse/FLINK-9536
Pro
SUBRAMANYA SURESH created FLINK-9535:
Summary: log4j.properties specified in env.java.options doesn't
get picked.
Key: FLINK-9535
URL: https://issues.apache.org/jira/browse/FLINK-9535
Project: Fl
aitozi created FLINK-9534:
-
Summary: CEP
Key: FLINK-9534
URL: https://issues.apache.org/jira/browse/FLINK-9534
Project: Flink
Issue Type: Bug
Reporter: aitozi
--
This message was se
aitozi created FLINK-9533:
-
Summary: CEP
Key: FLINK-9533
URL: https://issues.apache.org/jira/browse/FLINK-9533
Project: Flink
Issue Type: Bug
Reporter: aitozi
--
This message was se
Hi, thanks for bringing up this discussion.
I agree to unify the UniqueKeyExtractor and DataStreamRetractionRules,
however I am not sure if it is a good idea to implement it
with RelShuttle. Theoretically, retraction rules and other rules may depend
on each other. So, by using a RelShuttle instead
Abdul Qadeer created FLINK-9532:
---
Summary: Flink Overview of Jobs Documentation Incorrect
Key: FLINK-9532
URL: https://issues.apache.org/jira/browse/FLINK-9532
Project: Flink
Issue Type: Bug
Hi, Stephan:
Yes that's what I mean. In fact the most import thing is to share the
dispatcher so that we can have *a centralized gateway for flink job
management and submission. The problem with per job cluster is that we
can't have a centralized gateway.*
I didn't realize that job manager also n
Along these lines, it would help to add a sitemap (and the robots.txt required
to reference it) for flink.apache.org and ci.apache.org (for /projects/flink)
You can see what Tomcat did along these lines -
http://tomcat.apache.org/robots.txt references
http://tomcat.apache.org/sitemap.xml, which
+1
On Tue, Jun 5, 2018 at 9:46 AM, Stephan Ewen wrote:
> Big +1 to this!
>
> I would like to contribute to this effort and help strengthen the way Flink
> presents itself.
>
>
> On Tue, Jun 5, 2018 at 11:56 AM, Fabian Hueske wrote:
>
> > Hi everybody,
> >
> > I've opened a PR [1] that reworks p
Big +1 to this!
I would like to contribute to this effort and help strengthen the way Flink
presents itself.
On Tue, Jun 5, 2018 at 11:56 AM, Fabian Hueske wrote:
> Hi everybody,
>
> I've opened a PR [1] that reworks parts of the Flink website (
> flink.apache.org).
>
> My goal is to improve t
+1 on the refactoring.
I spent some time a while back trying to get a better understanding on the
several rules mentioned here.
Correct me if I were wrong by I was under the impression that the reason
why the rules are split was because AccMode and UpdateMode are the ones
that we care about and th
Timo Walther created FLINK-9531:
---
Summary: Improve logging during type extraction of the Row type
Key: FLINK-9531
URL: https://issues.apache.org/jira/browse/FLINK-9531
Project: Flink
Issue Type
Hi Renjie,
When you suggest to have TaskManager isolation in session mode, do you mean
to have a shared JobManager / Dispatcher, but job-specific TaskManagers?
If this mainly to reduce the overhead of the per-job JobManager?
One assumption so far was that if TaskManager isolation is required,
Job
+1
- Checked the commits that went into this release
- Build from source
I found one minor thing. There are two "create_release_branch.sh"
scripts in the tools directory.
Regards,
Timo
Am 01.06.18 um 08:32 schrieb Tzu-Li (Gordon) Tai:
+1
- Checked signatures and hashes
- Source builds succ
Hi, Till:
1. Does the community has any plan to add task manager isolation into
the session mode?
2. Is there any issues to track this feature? I want to help contribute.
3. Thanks for the knowledge but it can't help if task manager isolation
is not present.
On Tue, Jun 5, 2018 a
Chesnay Schepler created FLINK-9530:
---
Summary: Task numRecords metrics broken for chains
Key: FLINK-9530
URL: https://issues.apache.org/jira/browse/FLINK-9530
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-9529:
Summary: Do not expose keyed methods on ProcessFunction.Context
Key: FLINK-9529
URL: https://issues.apache.org/jira/browse/FLINK-9529
Project: Flink
Issue Ty
Hi Renjie,
1) you're right that the Flink session mode does not give you proper job
isolation. It is the same as with Flink 1.4 session mode. If this is a
strong requirement for you, then I recommend using the per job mode.
2) At the moment it is also not possible to define per job resource
requi
Please ask a more specific question. What have you tried so far, where
exactly are you stuck etc. .
Note that the existing connectors are always a good source for
inspiration: https://github.com/apache/flink/tree/master/flink-connectors
On 05.06.2018 10:58, Amol S - iProgrammer wrote:
Hello
Hello Ezmlm,
I have gone through flink documentation and found it quit interesting but I
am stuck in one task i.e. mongodb streaming oplog using flink. Can you help
me to figure out this?
---
*Amol Suryawanshi*
Java Developer
am...@iprogrammer.com
*iP
Hi everybody,
I've opened a PR [1] that reworks parts of the Flink website (
flink.apache.org).
My goal is to improve the structure of the website and provide more
valuable information about the project and the community.
A visitor (who doesn't know Flink yet) should be able to easily find
answe
Hi,
I think the proposed refactoring is a good idea.
It should simplify the logic to determine which update mode to use.
We could also try to make some of the method and field names more intuitive
and extend the internal documentation a bit.
@Hequn, It would be good to get your thoughts on this i
Fabian Hueske created FLINK-9528:
Summary: Incorrect results: Filter does not treat Upsert messages
correctly.
Key: FLINK-9528
URL: https://issues.apache.org/jira/browse/FLINK-9528
Project: Flink
Chesnay Schepler created FLINK-9527:
---
Summary: Paths initialize with URI are not normalized
Key: FLINK-9527
URL: https://issues.apache.org/jira/browse/FLINK-9527
Project: Flink
Issue Type:
We could also offer a feature that users can request classloaders with
additional jars.
This could work as follows:
1) Users register jar files in the ExecutionEnvironment (similar to cached
files) with a name, e.g., env.registerJarFile("~/myJar.jar", "myName");
2) In a function, the user can requ
@Shuyi: Yes, a more advanced table example would be helpful anyway and
combining it with Kafka/Avro end-to-end would be even better.
@Will: I totally agree that the current connector ecosystem could be
improved. This is also on mid-term roadmap. Contributors that could help
here are very welco
Chesnay Schepler created FLINK-9526:
---
Summary: BucketingSink end-to-end test failed on Travis
Key: FLINK-9526
URL: https://issues.apache.org/jira/browse/FLINK-9526
Project: Flink
Issue Type
29 matches
Mail list logo
