Haohui Mai created FLINK-24485:
--
Summary: COUNT(DISTINCT) should support binary field
Key: FLINK-24485
URL: https://issues.apache.org/jira/browse/FLINK-24485
Project: Flink
Issue Type
Haohui Mai created FLINK-24456:
--
Summary: Support bounded offset in the Kafka table connector
Key: FLINK-24456
URL: https://issues.apache.org/jira/browse/FLINK-24456
Project: Flink
Issue Type
gt; On behalf of the PMC I am delighted to announce Haohui Mai as a new Flink
> > committer!
> >
> > Haohui has been an active member of our community for several months.
> > Among other things, he made major contributions in ideas and code to the
> > SQL and Table
Haohui Mai created FLINK-7787:
-
Summary: Remove guava dependency in the cassandra connector
Key: FLINK-7787
URL: https://issues.apache.org/jira/browse/FLINK-7787
Project: Flink
Issue Type: Bug
Haohui Mai created FLINK-7743:
-
Summary: Remove the restriction of minimum memory of JM
Key: FLINK-7743
URL: https://issues.apache.org/jira/browse/FLINK-7743
Project: Flink
Issue Type: Bug
You can definitely use absolute URIs to access two clusters. The
configuration just has to be the union of multiple HDFS clusters
(e.g., the NameNode lists)
Accessing both secure and non-secure clusters are fairly tricky but it
can be done.
AFAIK Isolating the Hadoop configuration will require a
Haohui Mai created FLINK-7392:
-
Summary: Enable more predicate push-down in joins
Key: FLINK-7392
URL: https://issues.apache.org/jira/browse/FLINK-7392
Project: Flink
Issue Type: Improvement
Haohui Mai created FLINK-7344:
-
Summary: Migrate usage of joda-time to the Java 8 DateTime API
Key: FLINK-7344
URL: https://issues.apache.org/jira/browse/FLINK-7344
Project: Flink
Issue Type
Haohui Mai created FLINK-7237:
-
Summary: Remove DateTimeUtils from Flink once Calcite is upgraded
to 1.14
Key: FLINK-7237
URL: https://issues.apache.org/jira/browse/FLINK-7237
Project: Flink
Haohui Mai created FLINK-7236:
-
Summary: Bump up the Calcite version to 1.14
Key: FLINK-7236
URL: https://issues.apache.org/jira/browse/FLINK-7236
Project: Flink
Issue Type: Bug
Haohui Mai created FLINK-7235:
-
Summary: Backport CALCITE-1884 to the Flink repository before
Calcite 1.14
Key: FLINK-7235
URL: https://issues.apache.org/jira/browse/FLINK-7235
Project: Flink
Haohui Mai created FLINK-7159:
-
Summary: Semantics of OVERLAPS in Table API diverge from the SQL
standard
Key: FLINK-7159
URL: https://issues.apache.org/jira/browse/FLINK-7159
Project: Flink
Congrats!
On Mon, Jul 10, 2017 at 11:17 PM Dawid Wysakowicz <
wysakowicz.da...@gmail.com> wrote:
> Congrats, Gordon!
>
Congrats!
On Mon, Jul 10, 2017 at 11:33 PM Shaoxuan Wang wrote:
> Congratulations, Jincheng!
>
>
> On Tue, Jul 11, 2017 at 2:01 PM, Zhuoluo Yang >
> wrote:
>
> > Congrats, Jincheng!
> >
> > Thanks,
> >
> > Zhuoluo 😀
> >
> >
> >
> >
> >
> > 在 2017年7月11日，上午9:51，Jark 写道：
> >
> > Welcome on board
PR which should be included in the next bug fix release
> for the Table API:
> >> https://issues.apache.org/jira/browse/FLINK-7005
> >>
> >> Timo
> >>
> >> Am 23.06.17 um 14:09 schrieb Robert Metzger:
> >>> Thanks Haohui.
> >>>
>
Hi,
Release management is though, I'm happy to help. Are there any timelines
you have in mind?
Haohui
On Fri, Jun 23, 2017 at 12:01 AM Robert Metzger wrote:
> Hi all,
>
> with the 1.3.1 release on the way, we can start thinking about the 1.3.2
> release.
>
> We have already one issue that shoul
Congrats!
On Thu, Jun 22, 2017 at 9:58 AM SHI Xiaogang wrote:
> Congrats, Shaoxuan
>
> Regards,
> Xiaogang
>
> 2017-06-22 9:08 GMT+08:00 jincheng sun :
>
> > Congratulations Shaoxuan.
> >
> >
> > 2017-06-22 8:56 GMT+08:00 Zhangrucong :
> >
> > > Congrats Shaoxuan!
> > >
> > > -邮件原件-
> > >
Congrats!
On Thu, Jun 22, 2017 at 5:51 AM Stavros Kontopoulos <
st.kontopou...@gmail.com> wrote:
> Congratulations Dawid!
>
> On Tue, Jun 20, 2017 at 12:06 PM, Vasudevan, Ramkrishna S <
> ramkrishna.s.vasude...@intel.com> wrote:
>
> > Congratulations !!
> >
> > -Original Message-
> > From:
Hi,
We are interested in building the simplest case of stream-table joins --
essentially calling stream.map(x => (x, table.get(x)). It solves the use
cases of augmenting the streams with the information of the database. The
operation itself can be batched for better performance.
We are happy to c
+1
There are several high impacts security vulnerabilities in JDK 7 and will
not be addressed.
As a result we completely moved away from JDK 7.
+1 on separating the tasks of supporting Scala 2.12 and JDK 8 in two steps.
On Thu, Jun 8, 2017 at 9:53 AM Greg Hogan wrote:
> Is this not two diffe
Hi,
We have discovered https://issues.apache.org/jira/browse/FLINK-6780 which
effectively makes external catalogs in the table API very difficult to use.
It may not be a show stopper but in my opinion it is worth a fix before the
release.
Regards,
Haohui
On Tue, May 30, 2017 at 11:22 AM Till Ro
Haohui Mai created FLINK-6780:
-
Summary: ExternalTableSource fails to add the processing time and
the event time attribute in the row type
Key: FLINK-6780
URL: https://issues.apache.org/jira/browse/FLINK-6780
Haohui Mai created FLINK-6693:
-
Summary: Support DATE_FORMAT function in the SQL API
Key: FLINK-6693
URL: https://issues.apache.org/jira/browse/FLINK-6693
Project: Flink
Issue Type: New Feature
Haohui Mai created FLINK-6692:
-
Summary: The flink-dist jar contains unshaded nettyjar
Key: FLINK-6692
URL: https://issues.apache.org/jira/browse/FLINK-6692
Project: Flink
Issue Type: Bug
+1
The Table / SQL component has made significant progress in the last few
months (kudos to all contributors).
It is a good time to have a documentation to reflect all the changes in the
Table / SQL side.
On Thu, May 18, 2017 at 8:12 AM Robert Metzger wrote:
> Thank you Fabian for working on
Haohui Mai created FLINK-6605:
-
Summary: Allow users to specify a default name for processing time
Key: FLINK-6605
URL: https://issues.apache.org/jira/browse/FLINK-6605
Project: Flink
Issue Type
Haohui Mai created FLINK-6595:
-
Summary: Nested SQL queries do not expose proctime / rowtime
attributes
Key: FLINK-6595
URL: https://issues.apache.org/jira/browse/FLINK-6595
Project: Flink
Haohui Mai created FLINK-6574:
-
Summary: External catalog should support a single level catalog
Key: FLINK-6574
URL: https://issues.apache.org/jira/browse/FLINK-6574
Project: Flink
Issue Type
Hi,
Just curious -- do we have anything to track the blockers on the table /
SQL side? For example, it seems to me that FLINK-6563 is a blocker because
all group windows in SQL will not work without it. I think that Fabian /
Timo might want to get several jiras into 1.3.
Regards,
Haohui
On Thu,
Haohui Mai created FLINK-6563:
-
Summary: Expose time indicator attributes in the KafkaTableSource
Key: FLINK-6563
URL: https://issues.apache.org/jira/browse/FLINK-6563
Project: Flink
Issue Type
Haohui Mai created FLINK-6562:
-
Summary: Support implicit table references for nested fields in SQL
Key: FLINK-6562
URL: https://issues.apache.org/jira/browse/FLINK-6562
Project: Flink
Issue
Hello,
Thanks for starting this thread. It would be great to see the following
features available in Flink 1.3:
* Support for complex schema: FLINK-6033, FLINK-6377
* Various improvements on SQL over group windows: FLINK-6335, FLINK-6373
* StreamTableSink for JDBC and Cassandra: FLINK-6281, FLINK
Haohui Mai created FLINK-6377:
-
Summary: Support map types in the Table / SQL API
Key: FLINK-6377
URL: https://issues.apache.org/jira/browse/FLINK-6377
Project: Flink
Issue Type: New Feature
Haohui Mai created FLINK-6373:
-
Summary: Add runtime support for distinct aggregation over grouped
windows
Key: FLINK-6373
URL: https://issues.apache.org/jira/browse/FLINK-6373
Project: Flink
Haohui Mai created FLINK-6335:
-
Summary: Support DISTINCT over grouped window in stream SQL
Key: FLINK-6335
URL: https://issues.apache.org/jira/browse/FLINK-6335
Project: Flink
Issue Type: Bug
Haohui Mai created FLINK-6281:
-
Summary: Create TableSink for JDBC
Key: FLINK-6281
URL: https://issues.apache.org/jira/browse/FLINK-6281
Project: Flink
Issue Type: Improvement
Haohui Mai created FLINK-6217:
-
Summary: ContaineredTaskManagerParameters sets off heap memory
size incorrectly
Key: FLINK-6217
URL: https://issues.apache.org/jira/browse/FLINK-6217
Project: Flink
-1 (non-binding)
We recently found out that all jobs submitted via UI will have a
parallelism of 1, potentially due to FLINK-5808.
Filed FLINK-6209 to track it.
~Haohui
On Mon, Mar 27, 2017 at 2:59 AM Chesnay Schepler wrote:
> If possible I would like to include FLINK-6183 & FLINK-6184 as wel
Haohui Mai created FLINK-6209:
-
Summary: StreamPlanEnvironment always has a parallelism of 1
Key: FLINK-6209
URL: https://issues.apache.org/jira/browse/FLINK-6209
Project: Flink
Issue Type: Bug
Congrats!
On Tue, Mar 21, 2017 at 11:01 AM Matthias J. Sax wrote:
> -BEGIN PGP SIGNED MESSAGE-
> Hash: SHA512
>
> Congrats!
>
> On 3/21/17 8:59 AM, Greg Hogan wrote:
> > Welcome, Theo, and great to have you onboard with Flink and ML!
> >
> >
> >> On Mar 21, 2017, at 4:35 AM, Robert Metzg
Haohui Mai created FLINK-6033:
-
Summary: Support UNNEST query in the stream SQL api
Key: FLINK-6033
URL: https://issues.apache.org/jira/browse/FLINK-6033
Project: Flink
Issue Type: Improvement
Haohui Mai created FLINK-6012:
-
Summary: Support WindowStart / WindowEnd functions in stream SQL
Key: FLINK-6012
URL: https://issues.apache.org/jira/browse/FLINK-6012
Project: Flink
Issue Type
Haohui Mai created FLINK-6011:
-
Summary: Support TUMBLE, HOP, SESSION window in streaming SQL
Key: FLINK-6011
URL: https://issues.apache.org/jira/browse/FLINK-6011
Project: Flink
Issue Type: Sub
Haohui Mai created FLINK-5954:
-
Summary: Always assign names to the window in the Stream SQL APi
Key: FLINK-5954
URL: https://issues.apache.org/jira/browse/FLINK-5954
Project: Flink
Issue Type
Haohui Mai created FLINK-5931:
-
Summary: Make Flink highly available even if defaultFS is
unavailable
Key: FLINK-5931
URL: https://issues.apache.org/jira/browse/FLINK-5931
Project: Flink
Issue
Hi,
Thanks for starting the discussion. I can see there are multiple trade-offs
in these two approaches. One question I have is that to which extent Flink
wants to open its APIs to allow users to access both processing and event
time.
Before we talk about joins, my understanding for the two appro
Congrats!
On Fri, Feb 10, 2017 at 8:08 AM Henry Saputra
wrote:
> Congrats and welcome!
>
> On Fri, Feb 10, 2017 at 7:45 AM, Tzu-Li (Gordon) Tai
> wrote:
>
> > Great news! Welcome Stefan :-D
> >
> >
> > On February 10, 2017 at 11:36:14 PM, Aljoscha Krettek (
> aljos...@apache.org)
> > wrote:
> >
Congratulations!
On Tue, Feb 7, 2017 at 12:17 PM Fabian Hueske wrote:
> Hi everybody,
>
> I'm very happy to announce that Jark Wu and Kostas Kloudas accepted the
> invitation of the Flink PMC to become committers of the Apache Flink
> project.
>
> Jark and Kostas are longtime members of the Flin
Haohui Mai created FLINK-5725:
-
Summary: Support JOIN between two streams in the SQL API
Key: FLINK-5725
URL: https://issues.apache.org/jira/browse/FLINK-5725
Project: Flink
Issue Type: New
+1. Nice to be pinged if required, but relying on specific people to review
simply does not scale.
Popping up one level, occasionally the fact that people tag other people is
because the PRs are left unreviewed for a while (or they believe the PRs
will not be reviewed unless they explicitly ping o
Haohui Mai created FLINK-5631:
-
Summary: [yarn] Support downloading additional jars from non-HDFS
paths
Key: FLINK-5631
URL: https://issues.apache.org/jira/browse/FLINK-5631
Project: Flink
that the Calcite / Azure Stream Analytics have introduced a
new construct (TUMBLE / TUMBLINGWINDOW) to address this issue.
Do you think it is a good idea to follow the same conventions? Your ideas
are appreciated.
Regards,
Haohui
On Mon, Jan 23, 2017 at 1:02 PM Haohui Mai wrote:
> +1
&g
+1
We are also quite interested in these features and would love to
participate and contribute.
~Haohui
On Mon, Jan 23, 2017 at 7:31 AM Fabian Hueske wrote:
> Hi everybody,
>
> it seems that currently several contributors are working on new features
> for the streaming Table API / SQL around r
Hi,
Usually this problem can be well addressed by growing the community. We
Just wondering whether there is a wiki to describe how non-committers can
help on reviewing the patches?
I'm glad to help out on reviewing patches.
Regards,
Haohui
On Fri, Jan 20, 2017 at 7:42 AM Stephan Ewen wrote:
>
Haohui Mai created FLINK-5583:
-
Summary: Support flexible error handling in the Kafka consumer
Key: FLINK-5583
URL: https://issues.apache.org/jira/browse/FLINK-5583
Project: Flink
Issue Type
Hi,
I'm interested in contributing to Flink. I wonder, is it possible that
someone can add me as a contributor in the Flink project so that I can
assign jiras to myself? Your help is highly appreciated.
Regards,
Haohui
Haohui Mai created FLINK-5489:
-
Summary: maven release:prepare fails due to invalid JDOM comments
in pom.xml
Key: FLINK-5489
URL: https://issues.apache.org/jira/browse/FLINK-5489
Project: Flink
me know if you have any questions.
>
> Cheers, Fabian
>
> [1] http://flink.apache.org/news/2016/05/24/stream-sql.html
> [2]
>
> http://www.slideshare.net/FlinkForward/fabian-hueske-taking-a-look-under-the-hood-of-apache-flinks-relational-apis
> [3]
>
> https://docs.googl
Hi,
We are currently exploring on building a streaming SQL solution on top of
Flink. We think that Flink is a good fit for the problem.
I'm curious about what is the status on the Flink-Calcite integration right
now? Is it being actively developed and on the road map?
We are also very open to co
59 matches
Mail list logo
