Forward Xu created FLINK-15356:
--
Summary: Add applicationId to existing flink metrics running on
yarn
Key: FLINK-15356
URL: https://issues.apache.org/jira/browse/FLINK-15356
Project: Flink
Issu
Arvid Heise created FLINK-15355:
---
Summary: Nightly streaming file sink fails with unshaded hadoop
Key: FLINK-15355
URL: https://issues.apache.org/jira/browse/FLINK-15355
Project: Flink
Issue Ty
Yang Wang created FLINK-15354:
-
Summary: Start and stop minikube only in kubernetes related e2e
tests
Key: FLINK-15354
URL: https://issues.apache.org/jira/browse/FLINK-15354
Project: Flink
Issue
Hi Jark，
Thanks for your help. I convert it into FLIP wiki already.
Best,
Forward
Jark Wu 于2019年12月20日周五 下午11:09写道：
> Hi Forward,
>
> Thanks for updating the documentation. I think the design doc looks good to
> me now. I think you can convert it into FLIP wiki and start a vote then.
>
> Best,
Hi everybody,
I'd like to kick off a discussion on FLIP-90: Support SQL 2016-2017 JSON
functions in Flink SQL.
Implement Support SQL 2016-2017 JSON functions in Flink SQL[1].
Would love to hear your thoughts.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-90%3A+Support+SQL+2016
Hi everybody,
I'd like to kick off a discussion on FLIP-90: Support SQL 2016-2017 JSON
functions in Flink SQL.
Implement Support SQL 2016-2017 JSON functions in Flink SQL[1].
Would love to hear your thoughts.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-90%3A+Support+SQL+2016
Bowen Li created FLINK-15351:
Summary: develop PostgresJDBCCatalog
Key: FLINK-15351
URL: https://issues.apache.org/jira/browse/FLINK-15351
Project: Flink
Issue Type: Sub-task
Components
Bowen Li created FLINK-15353:
Summary: develop AbstractJDBCCatalog
Key: FLINK-15353
URL: https://issues.apache.org/jira/browse/FLINK-15353
Project: Flink
Issue Type: Sub-task
Components
Bowen Li created FLINK-15352:
Summary: develop MySQLJDBCCatalog
Key: FLINK-15352
URL: https://issues.apache.org/jira/browse/FLINK-15352
Project: Flink
Issue Type: Sub-task
Components: C
Bowen Li created FLINK-15350:
Summary: develop JDBCCatalog to connect to relational databases
Key: FLINK-15350
URL: https://issues.apache.org/jira/browse/FLINK-15350
Project: Flink
Issue Type: Ne
Bowen Li created FLINK-15349:
Summary: add Catalog DDL support in FLIP-69
Key: FLINK-15349
URL: https://issues.apache.org/jira/browse/FLINK-15349
Project: Flink
Issue Type: New Feature
Bowen Li created FLINK-15348:
Summary: Fix orc optimization for version less than 2.3 by
introducing orc shim
Key: FLINK-15348
URL: https://issues.apache.org/jira/browse/FLINK-15348
Project: Flink
Thanks for the feedback and good discussion everyone. I left some comments
inline.
On Fri, Dec 20, 2019 at 1:59 PM Stephan Ewen wrote:
> +1 to not have more options for off-heap memory, that would get confusing
> fast. We can keep the name "off-heap" for both task and framework, as long
> as the
Till Rohrmann created FLINK-15347:
-
Summary:
ZooKeeperDefaultDispatcherRunnerTest.testResourceCleanupUnderLeadershipChange
failed on Travis
Key: FLINK-15347
URL: https://issues.apache.org/jira/browse/FLINK-15347
Hi Forward,
Thanks for updating the documentation. I think the design doc looks good to
me now. I think you can convert it into FLIP wiki and start a vote then.
Best,Jark
Jark Wu 于2019年12月20日 周五23:07写道：
> Hi Forward,
>
> Thanks for updating the documentation. I think it is
>
> On Mon, 2 Dec 201
Hi Forward,
Thanks for updating the documentation. I think it is
On Mon, 2 Dec 2019 at 14:21, Forward Xu wrote:
> Hi Jark,
> Thank you very much，I will improve this document as soon as possible.
> My confluence username is ForwardXu.
>
> Best,
> Forward
>
> Jark Wu 于2019年12月2日周一 上午11:56写道：
>
>
Thanks Robert.
Bowen, in the spirit of remaining neutral, I decided to put them in
alphabetical order.
Seth
> On Dec 20, 2019, at 3:34 AM, Robert Metzger wrote:
>
> I've assigned you to the ticket.
> You've convinced me that the "Deployment Model" thing was not a good idea.
>
>> On Fri, De
+1 to not have more options for off-heap memory, that would get confusing
fast. We can keep the name "off-heap" for both task and framework, as long
as they mean the same thing: native plus direct, and fully counted into
MaxDirectMemory. I would suggest to update the config descriptions then to
ref
Regarding the framework/task direct/native memory options, I tend to think
it differently. I'm in favor of keep the "*.off-heap.size" for the config
option keys.
- It's not necessary IMO to expose the difference concepts of direct /
native memory to the users.
- I would avoid introducing
Hi Stephan and Xintong,
Thanks for the further FLIP-49 feedbacks.
> - "taskmanager.memory.size" (old main config option) is replaced by
> "taskmanager.memory.total-process.size" which has a different meaning in
> standalone setups. The old option did not subtract metaspace and other
> overhe
Hi tison,
I think we have the same direction that running user program on jobmanager
side.
Maybe i could called it cluster deploy-mode for per-job.
The separation of deployment and submission is exactly what we need to do.
After
separation, we could choose where to run the user program. For examp
Okay, I understand. I'm okay with removing the profile.
On Thu, Dec 19, 2019 at 11:34 AM Till Rohrmann wrote:
> The profiles make bumping ZooKeeper's version a bit more cumbersome. I
> would be interested for this reason to get rid of them, too.
>
> Cheers,
> Till
>
> On Wed, Dec 18, 2019 at 5:3
I've assigned you to the ticket.
You've convinced me that the "Deployment Model" thing was not a good idea.
On Fri, Dec 20, 2019 at 5:35 AM Bowen Li wrote:
> Really cool. I especially like the list of tags on "Ververica Platform"!
>
> BTW, why is "Ververica Platform" placed at the last? I won't
Big +1 for this effort.
It is really exciting we have started this great work. More and more
companies start to
use Flink in container environment(docker, Kubernetes, Mesos, even
Yarn-3.x). So it is
very important that we could have unified official image building and
releasing process.
The ima
Hi Xintong!
Please find my answers inline:
> - "taskmanager.memory.size" (old main config option) is replaced by
>> "taskmanager.memory.total-process.size" which has a different meaning in
>> standalone setups. The old option did not subtract metaspace and other
>> overhead, while the new optio
xiaojin.wy created FLINK-15346:
--
Summary: OldCsvValidator has no property of "emptyColumnAsNull".
Key: FLINK-15346
URL: https://issues.apache.org/jira/browse/FLINK-15346
Project: Flink
Issue Typ
lining created FLINK-15345:
--
Summary: CurrentExecution and priorExecutions are inconsistent in
the test case
Key: FLINK-15345
URL: https://issues.apache.org/jira/browse/FLINK-15345
Project: Flink
I
Jingsong Lee created FLINK-15344:
Summary: Update limitations in hive udf document
Key: FLINK-15344
URL: https://issues.apache.org/jira/browse/FLINK-15344
Project: Flink
Issue Type: Sub-task
jocean.shi created FLINK-15343:
--
Summary: Add Watermarks options for TwoInputStreamOperator
Key: FLINK-15343
URL: https://issues.apache.org/jira/browse/FLINK-15343
Project: Flink
Issue Type: New
29 matches
Mail list logo
