>From my point of view, I also prefer "sql-client.dml-sync",
because the behavior of this configuration is very clear.
Even if we introduce a new config in the future, e.g. `table.dml-sync`,
we can also deprecate the sql-client one.
Introducing a "table." configuration without any implementation
Hi,
Thanks guys for the comments !
I did not know it was legacy. I will give the new sources a try.
Jingsong, when you say "migrate ParquetInputFormat to the new BulkFormat
interface", do you mean that the new ParquetColumnarRowInputFormat is
not fully functional yet?
In the meantime, if
ranqiqiang created FLINK-21476:
--
Summary: How to appoint jobname
Key: FLINK-21476
URL: https://issues.apache.org/jira/browse/FLINK-21476
Project: Flink
Issue Type: Improvement
Thank you all for your congratulations! It's really an honor for me.
Best,
Wei
Xingbo Huang 于2021年2月24日周三 上午9:54写道：
> Thank you everyone! I really don't know what to say. I'm truly honoured.
>
> Best,
> Xingbo
>
> Guowei Ma 于2021年2月24日周三 上午9:29写道：
>
> > Congratulations Wei and Xingbo!
> >
>
Robert Metzger created FLINK-21475:
--
Summary: StateWithExecutionGraph.suspend fails with
IllegalStateException
Key: FLINK-21475
URL: https://issues.apache.org/jira/browse/FLINK-21475
Project: Flink
Zhenqiu Huang created FLINK-21474:
-
Summary: Migrate FileSystemTableSource to DynamicTable Source
Interface
Key: FLINK-21474
URL: https://issues.apache.org/jira/browse/FLINK-21474
Project: Flink
Zhenqiu Huang created FLINK-21473:
-
Summary: Migrate ParquetInputFormat to BulkFormat interface
Key: FLINK-21473
URL: https://issues.apache.org/jira/browse/FLINK-21473
Project: Flink
Issue
Hi Jingsong,
Thanks for pointing this out. Actually, I planned to work on changing
interfaces ParquetTableSource and ParquetInputFormat.
After refactoring the code, I may also help to fix the issue in
https://issues.apache.org/jira/browse/FLINK-21468.
Best Regards
Peter Huang
On Tue, Feb 23,
Hi Etienne,
Thanks for your reporting.
There are indeed many problems. There is no doubt that we need to improve
our current format implementation.
But ParquetTableSource and ParquetInputFormat are legacy implementations
with legacy interfaces. We have introduced new interfaces for execution
If we all agree the option should only be handled by sql client, then why
don't we
just call it `sql-client.dml-sync`? As you said, calling it
`table.dml-sync` but has no
affection in `TableEnv.executeSql("INSERT INTO")` will also cause a big
confusion for
users.
The only concern I saw is if we
hayden zhou created FLINK-21472:
---
Summary: encingTokenException: Fencing token mismatch
Key: FLINK-21472
URL: https://issues.apache.org/jira/browse/FLINK-21472
Project: Flink
Issue Type: Bug
kangTwang created FLINK-21471:
-
Summary: jobmanger, taskmanager, and job hang abnormally, and the
blobstore directory is not deleted
Key: FLINK-21471
URL: https://issues.apache.org/jira/browse/FLINK-21471
Thank you everyone! I really don't know what to say. I'm truly honoured.
Best,
Xingbo
Guowei Ma 于2021年2月24日周三 上午9:29写道：
> Congratulations Wei and Xingbo!
>
> Best,
> Guowei
>
>
> On Wed, Feb 24, 2021 at 9:21 AM Zhu Zhu wrote:
>
> > Congratulations Wei and Xingbo!
> >
> > Thanks,
> > Zhu
> >
>
Congratulations Wei and Xingbo!
Best,
Guowei
On Wed, Feb 24, 2021 at 9:21 AM Zhu Zhu wrote:
> Congratulations Wei and Xingbo!
>
> Thanks,
> Zhu
>
> Zhijiang 于2021年2月23日周二 上午10:59写道：
>
> > Congratulations Wei and Xingbo!
> >
> >
> > Best,
> > Zhijiang
> >
> >
> >
Congratulations Wei and Xingbo!
Thanks,
Zhu
Zhijiang 于2021年2月23日周二 上午10:59写道：
> Congratulations Wei and Xingbo!
>
>
> Best,
> Zhijiang
>
>
> --
> From:Yun Tang
> Send Time:2021年2月23日(星期二) 10:58
> To:Roman Khachatryan ; dev
>
Guowei Ma created FLINK-21470:
-
Summary: testSafetyNetClose fail
Key: FLINK-21470
URL: https://issues.apache.org/jira/browse/FLINK-21470
Project: Flink
Issue Type: Bug
Components: API
The artifacts removed.
Thanks everybody for taking part in the verification.
Regards,
Roman
On Tue, Feb 23, 2021 at 12:21 PM Roman Khachatryan wrote:
> Thanks Piotr,
>
> The RC-1 is therefore cancelled.
> I'll remove the artifacts and create a new RC once the issue is resolved.
>
> Regards,
>
Piotr Nowojski created FLINK-21469:
--
Summary: stop-with-savepoint --drain doesn't advance watermark for
sources chained to MultipleInputStreamTask
Key: FLINK-21469
URL:
Hi all,
I've been playing with Parquet with SQL and Avro lately. I've found some
bugs:
1. https://issues.apache.org/jira/browse/FLINK-21388 : I already
submitted a PR on this one (https://github.com/apache/flink/pull/14961)
2. https://issues.apache.org/jira/browse/FLINK-21389
3.
Etienne Chauchot created FLINK-21468:
Summary: ParquetTableSource: where clause on integer does not work
Key: FLINK-21468
URL: https://issues.apache.org/jira/browse/FLINK-21468
Project: Flink
Hi Kurt,
we can also shorten it to `table.dml-sync` if that would help. Then it
would confuse users that do a regular `.executeSql("INSERT INTO")` in a
notebook session.
In any case users will need to learn the semantics of this option.
`table.multi-dml-sync` should be described as "If a
Kezhu Wang created FLINK-21467:
--
Summary: Document possible recommended usage of
Bounded{One/Multi}Input.endInput and emphasize that they could be called
multiple times
Key: FLINK-21467
URL:
Thanks Piotr,
The RC-1 is therefore cancelled.
I'll remove the artifacts and create a new RC once the issue is resolved.
Regards,
Roman
On Tue, Feb 23, 2021 at 11:57 AM Piotr Nowojski
wrote:
> Ops, sorry I've linked the wrong issue in the previous email. This is the
> correct one:
>
Ops, sorry I've linked the wrong issue in the previous email. This is the
correct one:
https://issues.apache.org/jira/browse/FLINK-21453
Piotrek
wt., 23 lut 2021 o 11:56 Piotr Nowojski
napisał(a):
> -1
>
> I need to unfortunately change my vote to -1 because of the bug that was
> introduced in
-1
I need to unfortunately change my vote to -1 because of the bug that was
introduced in 1.12.2:
https://issues.apache.org/jira/browse/FLINK-19462
Luckily this seems to be an easy fix.
Piotrek
sob., 20 lut 2021 o 15:42 Yang Wang napisał(a):
> +1 (non-binding)
>
> * build from source
> *
Shengkai Fang created FLINK-21466:
-
Summary: Simplify the command to start the sql client
Key: FLINK-21466
URL: https://issues.apache.org/jira/browse/FLINK-21466
Project: Flink
Issue Type:
Shengkai Fang created FLINK-21465:
-
Summary: Extend explain syntax
Key: FLINK-21465
URL: https://issues.apache.org/jira/browse/FLINK-21465
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-21464:
-
Summary: Support ADD JAR command in sql client
Key: FLINK-21464
URL: https://issues.apache.org/jira/browse/FLINK-21464
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-21463:
-
Summary: Refactor client parser
Key: FLINK-21463
URL: https://issues.apache.org/jira/browse/FLINK-21463
Project: Flink
Issue Type: Sub-task
Shengkai Fang created FLINK-21462:
-
Summary: Use `table.planner`, `execution.runtime-mode` to create
TableEnvironment in sql client
Key: FLINK-21462
URL: https://issues.apache.org/jira/browse/FLINK-21462
zhuxiaoshang created FLINK-21461:
Summary: FileNotFoundException when sink to hive
Key: FLINK-21461
URL: https://issues.apache.org/jira/browse/FLINK-21461
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-21460:
-
Summary: Introduce option `table.planner`, `execution.runtime-mode`
Key: FLINK-21460
URL: https://issues.apache.org/jira/browse/FLINK-21460
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-21459:
---
Summary: Implement remote Java SDK for Stateful Functions
Key: FLINK-21459
URL: https://issues.apache.org/jira/browse/FLINK-21459
Project: Flink
Chesnay Schepler created FLINK-21458:
Summary: Add numRestarts metric
Key: FLINK-21458
URL: https://issues.apache.org/jira/browse/FLINK-21458
Project: Flink
Issue Type: Sub-task
Igal Shilman created FLINK-21457:
Summary: Add support to differentiate a zero length value bytes
and non existing value.
Key: FLINK-21457
URL: https://issues.apache.org/jira/browse/FLINK-21457
Jark Wu created FLINK-21456:
---
Summary: TableResult#print() should correctly stringify values of
TIMESTAMP type in SQL format
Key: FLINK-21456
URL: https://issues.apache.org/jira/browse/FLINK-21456
Project:
Yi Tang created FLINK-21455:
---
Summary: Deploy history server on kubernetes
Key: FLINK-21455
URL: https://issues.apache.org/jira/browse/FLINK-21455
Project: Flink
Issue Type: New Feature
Shengkai Fang created FLINK-21454:
-
Summary: FLIP-163: SQL Client Improvements
Key: FLINK-21454
URL: https://issues.apache.org/jira/browse/FLINK-21454
Project: Flink
Issue Type: New Feature
Thanks for the explanation Yun and Guowei. I have to admit that I do not
fully understand why this is strictly required but I think that we are
touching two very important aspects which might have far fetching
consequences for how Flink works:
1) Do we want to allow that multiple checkpoints are
Piotr Nowojski created FLINK-21453:
--
Summary: BoundedOneInput.endInput is NOT called when doing stop
with savepoint WITH drain
Key: FLINK-21453
URL: https://issues.apache.org/jira/browse/FLINK-21453
Sorry for the late reply, but I'm confused by `table.multi-dml-sync`.
IIUC this config will take effect with 2 use cases:
1. SQL client, either interactive mode or executing multiple statements via
-f. In most cases,
there will be only one INSERT INTO statement but we are controlling the
Arvid Heise created FLINK-21452:
---
Summary: FLIP-27 sources cannot reliably downscale
Key: FLINK-21452
URL: https://issues.apache.org/jira/browse/FLINK-21452
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-21451:
Summary: Remove TaskExecutionState#jobID
Key: FLINK-21451
URL: https://issues.apache.org/jira/browse/FLINK-21451
Project: Flink
Issue Type:
43 matches
Mail list logo
