Hi Xuefu,
Thanks for your feedback, and mention the compatibility issues.
You are right the change will result version incompatibility. And we my
plan it's will be released in the version of 1.8.x.
To be frank, we have considered the compatibility approach, which is to
retain the current TableEnv
Hi Jincheng,
thanks for the proposal. I totally agree with the problem of having 3
StreamTableEnvironments and 3 BatchTableEnvironments. We also identified
this problem when doing Flink trainings and introductions to the Table &
SQL API.
Actually, @Dawid and I were already discussing to remo
Paul Lin created FLINK-11126:
Summary: Filter out AMRMToken in the TaskManager credentials
Key: FLINK-11126
URL: https://issues.apache.org/jira/browse/FLINK-11126
Project: Flink
Issue Type: Impro
Hi Jincheng,
Thanks for bringing this up. It seems making good sense to me. However, one
concern I have is about backward compatibility. Could you clarify whether
existing user program will break with the proposed changes?
The answer to the question would largely determine when this can be intr
Another potential concern for semantic 3 is that. In the future, we may add
automatic caching to Flink. e.g. cache the intermediate results at the
shuffle boundary. If our semantic is that reference to the original table
means skipping cache, those users may not be able to benefit from the
implicit
Hequn Cheng created FLINK-11125:
---
Summary: Remove useless import
Key: FLINK-11125
URL: https://issues.apache.org/jira/browse/FLINK-11125
Project: Flink
Issue Type: Improvement
Compon
Hi Piotrek,
Thanks for the reply. Thought about it again, I might have misunderstood
your proposal in earlier emails. Returning a CachedTable might not be a bad
idea.
I was more concerned about the semantic and its intuitiveness when a
CachedTable is returned. i..e, if cache() returns CachedTable
Hequn Cheng created FLINK-11124:
---
Summary: Add private[flink] to TemporalTableFunction.create()
Key: FLINK-11124
URL: https://issues.apache.org/jira/browse/FLINK-11124
Project: Flink
Issue Type
sunjincheng created FLINK-11123:
---
Summary: Improve ml quick start doc
Key: FLINK-11123
URL: https://issues.apache.org/jira/browse/FLINK-11123
Project: Flink
Issue Type: Improvement
Co
Thanks Till and my belated +1 for a final patch release :)
On Mon, Dec 10, 2018 at 5:47 AM Till Rohrmann wrote:
> Thanks for the feedback! I conclude that the community is in favour of a
> last 1.5.6 release. I'll try to make the arrangements in the next two
> weeks.
>
> Cheers,
> Till
>
> On Mo
Gary Yao created FLINK-11122:
Summary: SafetyNetCloseableRegistryTest fails with
ClassCastException
Key: FLINK-11122
URL: https://issues.apache.org/jira/browse/FLINK-11122
Project: Flink
Issue T
Dear community,
this is the weekly community update thread #50. Please post any news and
updates you want to share with the community to this thread.
# Unified core API for streaming and batch
The community started to discuss how to bring streaming and batch closer
together by implementing a com
Hi Xianda,
thanks for sharing this detailed feedback. Do I understand you correctly
that flink-python and flink-streaming-python are not usable for the use
cases at Alibaba atm?
Could you share a bit more details about the Python UDFs for SQL? How do
you execute the Python code? Will it work with
Thanks for the feedback! I conclude that the community is in favour of a
last 1.5.6 release. I'll try to make the arrangements in the next two weeks.
Cheers,
Till
On Mon, Dec 10, 2018 at 2:40 AM jincheng sun
wrote:
> +1. There are incompatible improvements between 1.5.x and 1.6/1.7, so many
> 1
Stefan Richter created FLINK-11121:
--
Summary: Check and update licensing notes for Aliyun FS
[FLINK-10865]
Key: FLINK-11121
URL: https://issues.apache.org/jira/browse/FLINK-11121
Project: Flink
Hi Becket,
Sorry for not responding long time.
Regarding case1.
There wouldn’t be no “a.unCache()” method, but I would expect only
`cachedTableA1.dropCache()`. Dropping `cachedTableA1` wouldn’t affect
`cachedTableA2`. Just as in any other database dropping modifying one
independent table/mate
xuqianjin created FLINK-11120:
-
Summary: The bug of timestampadd handles time
Key: FLINK-11120
URL: https://issues.apache.org/jira/browse/FLINK-11120
Project: Flink
Issue Type: Sub-task
Hi All,
According to the feedback from users, the design of TableEnvironment is
very inconvenient for users, and often mistakenly imported by IDE,
especially for Java users, such as:
ExecutionEnvironment env = ...
BatchTableEnvironment tEnv = TableEnvironment.getTableEnvironment(env);
The user
Denys Fakhritdinov created FLINK-9:
--
Summary: Incorrect Scala example for Table Function
Key: FLINK-9
URL: https://issues.apache.org/jira/browse/FLINK-9
Project: Flink
Issue
vinoyang created FLINK-8:
Summary: Refactor and unify rowtime timestamp extractor interface
Key: FLINK-8
URL: https://issues.apache.org/jira/browse/FLINK-8
Project: Flink
Issue Type:
vinoyang created FLINK-7:
Summary: Migrate connector classes to flink-table-spi
Key: FLINK-7
URL: https://issues.apache.org/jira/browse/FLINK-7
Project: Flink
Issue Type: New Feature
Kostas Kloudas created FLINK-6:
--
Summary: Clean-up temporary files that upon recovery, they belong
to no checkpoint.
Key: FLINK-6
URL: https://issues.apache.org/jira/browse/FLINK-6
Projec
22 matches
Mail list logo
