[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15849048#comment-15849048
]
Haohui Mai commented on FLINK-5668:
---
Please allow me to fill in some of the contexts here.
The request
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855478#comment-15855478
]
Haohui Mai commented on FLINK-5583:
---
The interface looks good to me. It looks like that you want to have
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855424#comment-15855424
]
Haohui Mai commented on FLINK-5583:
---
The pseudo-code looks like the following:
{code}
void invoke() {
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15853088#comment-15853088
]
Haohui Mai commented on FLINK-5624:
---
Support group by via rowtime makes sense. From a semantic point of
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855986#comment-15855986
]
Haohui Mai edited comment on FLINK-5710 at 2/7/17 1:47 PM:
---
Can you please
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15855986#comment-15855986
]
Haohui Mai commented on FLINK-5710:
---
Can you please elaborate a little bit more, particularly how the
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15854944#comment-15854944
]
Haohui Mai commented on FLINK-5583:
---
In general (1) sounds good to me. Taking a closer look it seems
[
https://issues.apache.org/jira/browse/FLINK-5631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15858619#comment-15858619
]
Haohui Mai commented on FLINK-5631:
---
[~StephanEwen] can you please take another look?
> [yarn] Support
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15854818#comment-15854818
]
Haohui Mai commented on FLINK-5624:
---
Thanks for the explanation.
I took a closer look at the built-in
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
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-5725:
-
Assignee: radu (was: Haohui Mai)
> Support JOIN between two streams in the SQL API
>
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15857608#comment-15857608
]
Haohui Mai commented on FLINK-5725:
---
Sorry I missed the thread. :-(
Yes supporting {{JOIN}} in general
[
https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15843627#comment-15843627
]
Haohui Mai commented on FLINK-4679:
---
There are two aspects here: (1) translating the over clause using
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
[
https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872506#comment-15872506
]
Haohui Mai commented on FLINK-3679:
---
[~tzulitai] -- would you mind taking a look?
>
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-5624:
--
Issue Type: Improvement (was: Bug)
> Support tumbling window on streaming tables in the SQL API
>
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860036#comment-15860036
]
Haohui Mai commented on FLINK-5710:
---
Just FYI: FLINK-5624 implements the {{rowTime()}} function. The
[
https://issues.apache.org/jira/browse/FLINK-5731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860217#comment-15860217
]
Haohui Mai commented on FLINK-5731:
---
One related but off-topic questions: Are there any reasons to
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15860047#comment-15860047
]
Haohui Mai commented on FLINK-5654:
---
I may not fully get the question -- Is it possible to do something
[
https://issues.apache.org/jira/browse/FLINK-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867369#comment-15867369
]
Haohui Mai commented on FLINK-5655:
---
I'm particularly interested in the part that compiles the sliding
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15867288#comment-15867288
]
Haohui Mai commented on FLINK-5570:
---
We are interested in this feature as well. Just curious about the
[
https://issues.apache.org/jira/browse/FLINK-5414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15870558#comment-15870558
]
Haohui Mai commented on FLINK-5414:
---
[~jark], are there any progresses on this jira? We are interested
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:
[
https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-3679:
-
Assignee: Haohui Mai
> DeserializationSchema should handle zero or more outputs for every input
[
https://issues.apache.org/jira/browse/FLINK-5921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887417#comment-15887417
]
Haohui Mai commented on FLINK-5921:
---
My understanding is that there should be no need for code
[
https://issues.apache.org/jira/browse/FLINK-5931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886438#comment-15886438
]
Haohui Mai commented on FLINK-5931:
---
I have confirmed with [~gtCarrera9] (a YARN committer and Hadoop
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886342#comment-15886342
]
Haohui Mai edited comment on FLINK-5668 at 2/27/17 7:37 PM:
[~rmetzger] --
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886342#comment-15886342
]
Haohui Mai edited comment on FLINK-5668 at 2/27/17 7:37 PM:
[~rmetzger] --
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
[
https://issues.apache.org/jira/browse/FLINK-5931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-5931:
--
Description:
In order to use Flink in mission-critical environments, Flink must be available
even if
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886404#comment-15886404
]
Haohui Mai commented on FLINK-5668:
---
[~bill.liu8904] I believe that the title of the jira is confusing.
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886342#comment-15886342
]
Haohui Mai commented on FLINK-5668:
---
[~rmetzger] -- just want to clarify FLINK-5631 here.
YARN
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886524#comment-15886524
]
Haohui Mai commented on FLINK-5570:
---
Thanks [~fhueske] for the pointer. Just took a very quick skim --
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
[
https://issues.apache.org/jira/browse/FLINK-5489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-5489:
-
Assignee: Haohui Mai
> maven release:prepare fails due to invalid JDOM comments in pom.xml
>
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15939344#comment-15939344
]
Haohui Mai commented on FLINK-5570:
---
I think the APIs of the PR looks good to me overall.
One question
[
https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15943938#comment-15943938
]
Haohui Mai commented on FLINK-5829:
---
Unfortunately it seems that it is infeasible to inherit and forward
[
https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15941637#comment-15941637
]
Haohui Mai commented on FLINK-5829:
---
I just pushed a PR. The migration process is relatively
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
[
https://issues.apache.org/jira/browse/FLINK-6209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946043#comment-15946043
]
Haohui Mai commented on FLINK-6209:
---
We found that FLINK-5808 removes this snippet of code that causes
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
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15946785#comment-15946785
]
Haohui Mai commented on FLINK-5668:
---
Sorry for the delayed response.
Our main requirement is to allow
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15951280#comment-15951280
]
Haohui Mai commented on FLINK-5998:
---
All failed tests passed locally. :-|
[~rmetzger], is it possible
[
https://issues.apache.org/jira/browse/FLINK-6102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934151#comment-15934151
]
Haohui Mai commented on FLINK-6102:
---
I would recommend keeping it as is. The problem is that the whole
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934054#comment-15934054
]
Haohui Mai commented on FLINK-5998:
---
Sorry for the delay I'm just busy on other issues -- I'll take care
[
https://issues.apache.org/jira/browse/FLINK-5570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15928975#comment-15928975
]
Haohui Mai commented on FLINK-5570:
---
Thanks for the ping, [~fhueske]. Please allow me for a day or two
[
https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15956108#comment-15956108
]
Haohui Mai commented on FLINK-6261:
---
[~fhueske], I am interested in contributing this feature. If you
[
https://issues.apache.org/jira/browse/FLINK-6261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15956510#comment-15956510
]
Haohui Mai commented on FLINK-6261:
---
That's even better -- looking forward to the PR :-)
> Add support
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-6012:
--
Summary: Support WindowStart / WindowEnd functions in streaming SQL (was:
Support WindowStart /
[
https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976845#comment-15976845
]
Haohui Mai commented on FLINK-6335:
---
The scope of this jira is about supporting the DISTINCT keyword
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
[
https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-5829:
-
Assignee: Haohui Mai
> Bump Calcite version to 1.12 once available
>
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:
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:
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-5998:
-
Assignee: Haohui Mai
> Un-fat Hadoop from Flink fat jar
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-6033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15922923#comment-15922923
]
Haohui Mai commented on FLINK-6033:
---
Discussed offline with [~fhueske] -- the proposed approach is to
[
https://issues.apache.org/jira/browse/FLINK-6033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-6033:
--
Summary: Support UNNEST query in the stream SQL API (was: Support UNNEST
query in the stream SQL api)
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
[
https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-3679:
--
Summary: Allow Kafka consumer to skip corrupted messages (was:
DeserializationSchema should handle
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:
[
https://issues.apache.org/jira/browse/FLINK-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-5954:
--
Summary: Always assign names to the window in the Stream SQL API (was:
Always assign names to the
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6225:
-
Assignee: Haohui Mai
> Support Row Stream for CassandraSink
>
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958592#comment-15958592
]
Haohui Mai commented on FLINK-6012:
---
I'm okay with either way, but I think we have a decent chance to
[
https://issues.apache.org/jira/browse/FLINK-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai closed FLINK-5622.
-
Resolution: Duplicate
> Support tumbling window on batch tables in the SQL API
>
[
https://issues.apache.org/jira/browse/FLINK-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15961476#comment-15961476
]
Haohui Mai commented on FLINK-5622:
---
I think so. Thanks for the reminder. I'll close this jira.
>
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
[
https://issues.apache.org/jira/browse/FLINK-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-6335:
--
Summary: Parse DISTINCT over grouped window in stream SQL (was: Support
DISTINCT over grouped window
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:
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-7357:
-
Assignee: Haohui Mai
> HOP_START() HOP_END() does not work when using HAVING clause with GROUP
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121265#comment-16121265
]
Haohui Mai commented on FLINK-7398:
---
Putting in a companion object is an viable option. My worry,
[
https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16125856#comment-16125856
]
Haohui Mai commented on FLINK-6692:
---
Sounds good. Thanks for the effort!
> The flink-dist jar contains
[
https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai resolved FLINK-6692.
---
Resolution: Fixed
> The flink-dist jar contains unshaded netty jar
>
[
https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081820#comment-16081820
]
Haohui Mai commented on FLINK-6429:
---
I have a patch and will upload it shortly.
> Bump up Calcite
[
https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091283#comment-16091283
]
Haohui Mai commented on FLINK-6429:
---
Sorry for the delay. There are several issues that need to be
[
https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6429:
-
Assignee: Haohui Mai (was: Timo Walther)
> Bump up Calcite version to 1.13
>
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
[
https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16083277#comment-16083277
]
Haohui Mai commented on FLINK-6429:
---
[~twalthr] that would be great. I found a few issues and I'm adding
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
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-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-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-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
[
https://issues.apache.org/jira/browse/FLINK-7159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai resolved FLINK-7159.
---
Resolution: Fixed
This has been resolved as a part of FLINK-6429.
> Semantics of OVERLAPS in Table
[
https://issues.apache.org/jira/browse/FLINK-7051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-7051:
-
Assignee: Haohui Mai
> Bump up Calcite version to 1.14
> ---
>
>
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
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120511#comment-16120511
]
Haohui Mai commented on FLINK-7357:
---
I haven't started yet. Please go ahead.
> HOP_START() HOP_END()
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-7398:
-
Assignee: Haohui Mai
> Table API operators/UDFs must not store Logger
>
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120536#comment-16120536
]
Haohui Mai commented on FLINK-7398:
---
Good catch!
I think we can fix it for once but I'm more worried
[
https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117500#comment-16117500
]
Haohui Mai commented on FLINK-6429:
---
bq. In order to change the default behavior of the rule, the only
[
https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117328#comment-16117328
]
Haohui Mai commented on FLINK-6429:
---
It's difficult to say this is a pure Calcite bug. Technically SQL
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:
[
https://issues.apache.org/jira/browse/FLINK-6563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-6563:
--
Priority: Critical (was: Major)
Component/s: Table API & SQL
> Expose time indicator attributes
[
https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008891#comment-16008891
]
Haohui Mai commented on FLINK-6529:
---
Will do. Thanks!
> Rework the shading model in Flink
>
[
https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008821#comment-16008821
]
Haohui Mai commented on FLINK-6568:
---
Hit the same issue multiple times when testing out 1.3. Are we good
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:
[
https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6569:
-
Assignee: Haohui Mai
> flink-table KafkaJsonTableSource example doesn't work
>
[
https://issues.apache.org/jira/browse/FLINK-6568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6568:
-
Assignee: Haohui Mai
> flink-table doesn't work without flink-streaming-scala dependency
>
[
https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6529:
-
Assignee: Haohui Mai
> Rework the shading model in Flink
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16005350#comment-16005350
]
Haohui Mai commented on FLINK-6529:
---
That makes sense as we are being hit by this problem quite hard
[
https://issues.apache.org/jira/browse/FLINK-6595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai updated FLINK-6595:
--
Component/s: Table API & SQL
> Nested SQL queries do not expose proctime / rowtime attributes
>
1 - 100 of 144 matches
Mail list logo
