Dawid Wysakowicz created FLINK-23080:
Summary: Add finish method to the SinkFunction
Key: FLINK-23080
URL: https://issues.apache.org/jira/browse/FLINK-23080
Project: Flink
Issue Type: Sub
JING ZHANG created FLINK-23079:
--
Summary: HiveTableSinkITCase fails
Key: FLINK-23079
URL: https://issues.apache.org/jira/browse/FLINK-23079
Project: Flink
Issue Type: Bug
Components: C
Thanks for the comment, Xintong.
I used to wonder if it was reasonable or worthwhile to introduce a
configuration like "table.exec.shuffle-mode" for DataStream API.
Narrow down the scope of effect sounds good to me.
Best,
Yangze Guo
On Tue, Jun 22, 2021 at 2:08 PM Xintong Song wrote:
>
> I seco
Piotr Nowojski created FLINK-23078:
--
Summary: Scheduler Benchmarks not compiling
Key: FLINK-23078
URL: https://issues.apache.org/jira/browse/FLINK-23078
Project: Flink
Issue Type: Bug
I second Zhu and Till's opinion.
Failing with an exception that also includes how to resolve the problem
sounds better, in terms of making it explicit to users that pipelined edges
are replaced with blocking edges.
Concerning absence of knobs tuning the edge types, we can introduce a
configuratio
xiaojin.wy created FLINK-23077:
--
Summary: Running nexmark q5 with 1.13.1 of
pipeline.object-reuse=true, the taskmanager will be killed and produce failover.
Key: FLINK-23077
URL: https://issues.apache.org/jira/browse
Xintong Song created FLINK-23076:
Summary: DispatcherTest.testWaitingForJobMasterLeadership fails on
azure
Key: FLINK-23076
URL: https://issues.apache.org/jira/browse/FLINK-23076
Project: Flink
Thanks Dawid for starting the discussion, and thanks Yun, Godfrey and
Jingsong for volunteering as release managers.
+1 for the releases, and +1 for the release managers.
Thank you~
Xintong Song
On Tue, Jun 22, 2021 at 10:15 AM Jingsong Li wrote:
> +1 to the release.
>
> Thanks Dawid for
Zakelly Lan created FLINK-23075:
---
Summary: Python API for enabling ChangelogStateBackend
Key: FLINK-23075
URL: https://issues.apache.org/jira/browse/FLINK-23075
Project: Flink
Issue Type: Impro
Ada Wong created FLINK-23074:
Summary: There is a class conflict between flink-connector-hive
and flink-parquet
Key: FLINK-23074
URL: https://issues.apache.org/jira/browse/FLINK-23074
Project: Flink
Thanks David for taking care of this. I will take a look at this issue.
Regards,
Dian
> 2021年6月22日 上午4:06，David Anderson 写道：
>
> I've been trying to upgrade the pyflink-walkthrough to Flink 1.13.1, but
> without any success.
>
> Unless I give it a lot of resources the data generator times out
+1
Thanks Ingo for picking up this FLIP.
Best,
Leonard
> 在 2021年6月22日，10:16，JING ZHANG 写道：
>
> +1 (binding)
>
> Best regards,
> JING ZHANG
>
> Jingsong Li 于2021年6月22日周二 上午10:11写道：
>
>> +1 (binding)
>>
>> Thanks for driving.
>>
>> Best,
>> Jingsong
>>
>> On Tue, Jun 22, 2021 at 12:07 AM
+1 (binding)
Best regards,
JING ZHANG
Jingsong Li 于2021年6月22日周二 上午10:11写道：
> +1 (binding)
>
> Thanks for driving.
>
> Best,
> Jingsong
>
> On Tue, Jun 22, 2021 at 12:07 AM Jark Wu wrote:
>
> > +1 (binding)
> >
> > Best,
> > Jark
> >
> > On Mon, 21 Jun 2021 at 22:51, Timo Walther wrote:
> >
>
+1 (binding)
Thanks for driving.
Best,
Jingsong
On Tue, Jun 22, 2021 at 12:07 AM Jark Wu wrote:
> +1 (binding)
>
> Best,
> Jark
>
> On Mon, 21 Jun 2021 at 22:51, Timo Walther wrote:
>
> > +1 (binding)
> >
> > Thanks for driving this.
> >
> > Regards,
> > Timo
> >
> > On 21.06.21 13:24, Ingo B
+1 to the release.
Thanks Dawid for driving this discussion.
I am willing to volunteer as the release manager too.
Best,
Jingsong
On Tue, Jun 22, 2021 at 9:58 AM godfrey he wrote:
> Thanks for driving this, Dawid. +1 to the release.
> I would also like to volunteer as the release manager for
Thanks for driving this, Dawid. +1 to the release.
I would also like to volunteer as the release manager for these versions.
Best
Godfrey
Seth Wiesman 于2021年6月22日周二 上午8:39写道：
> +1 to the release.
>
> It would be great if we could get FLINK-23073 into 1.13.2. There's already
> an open PR and it
+1 to the release.
It would be great if we could get FLINK-23073 into 1.13.2. There's already
an open PR and it unblocks upgrading the table API walkthrough in
apache/flink-playgrounds to 1.13.
Seth
On Mon, Jun 21, 2021 at 6:28 AM Yun Tang wrote:
> Hi Dawid,
>
> Thanks for driving this discuss
Hi Gabor + Marton,
I don't believe that the issue with this proposal is the specific mechanism
proposed (Kerberos), but rather that it is not the level to implement it at
(Flink). I'm just one voice, so please take this with a grain of salt.
In the other solutions previously noted there is no nee
Hi Eron,
I will check it tomorrow. Sorry for the delay. If someone beats me to that,
please go ahead.
On Mon, Jun 21, 2021 at 8:18 PM Eron Wright
wrote:
> Would someone be willing and able to review the PR which adds watermarks to
> the sink API?
>
> https://github.com/apache/flink/pull/15950
>
I've been trying to upgrade the pyflink-walkthrough to Flink 1.13.1, but
without any success.
Unless I give it a lot of resources the data generator times out trying to
connect to Kafka. If I give it 6 cores and 11GB (which is about all I can
offer it) it does manage to connect, but then fails try
Here is a summary of where we are at with the PR:
* Added capability to construct sources at switch time through a
factory interface. This can support all previously discussed
scenarios. The simple case (sources with fixed start position) is
still simple, but for scenarios that require deferred in
Seth Wiesman created FLINK-23073:
Summary: Fix space handling in CSV timestamp parser
Key: FLINK-23073
URL: https://issues.apache.org/jira/browse/FLINK-23073
Project: Flink
Issue Type: Bug
Would someone be willing and able to review the PR which adds watermarks to
the sink API?
https://github.com/apache/flink/pull/15950
Thanks!
Eron
Hi team,
Thank you for your input. Based on this discussion I agree with G that
selecting and standardizing on a specific strong authentication mechanism
is more challenging than the whole rest of the scope of this authentication
story. :-) I suggest that G and I go back to the drawing board and c
+1 (binding)
Best,
Jark
On Mon, 21 Jun 2021 at 22:51, Timo Walther wrote:
> +1 (binding)
>
> Thanks for driving this.
>
> Regards,
> Timo
>
> On 21.06.21 13:24, Ingo Bürk wrote:
> > Hi everyone,
> >
> > thanks for all the feedback so far. Based on the discussion[1] we seem to
> > have consensus
+1 (binding)
Thanks for driving this.
Regards,
Timo
On 21.06.21 13:24, Ingo Bürk wrote:
Hi everyone,
thanks for all the feedback so far. Based on the discussion[1] we seem to
have consensus, so I would like to start a vote on FLIP-129 for which the
FLIP has now also been updated[2].
The vote
Hi All,
We see that adding any kind of specific authentication raises more
questions than answers.
What would be if a generic API would be added without any real
authentication logic?
That way every provider can add its own protocol implementation as
additional jar.
BR,
G
On Thu, Jun 17, 2021 a
Timo Walther created FLINK-23072:
Summary: Add benchmarks for SQL internal and external serializers
Key: FLINK-23072
URL: https://issues.apache.org/jira/browse/FLINK-23072
Project: Flink
Issu
Thanks for the feedback, Till!
Actually, we cannot give user any resolution for this issue as there
is no API for DataStream users to influence the edge types at the
moment. The edge types are currently fixed based on the jobs' mode
(batch or streaming).
a) I think it might not confuse the user a
Hi,
Thanks Steffen for the explanations. I think it makes sense to me.
Re Arvid/Steffen:
- Keep in mind that even if we choose to provide a non blocking API using
the `isAvailable()`/`getAvailableFuture()` method, we would still need to
support blocking inside the sinks. For example at the very
Hi everyone,
thanks for all the feedback so far. Based on the discussion[1] we seem to
have consensus, so I would like to start a vote on FLIP-129 for which the
FLIP has now also been updated[2].
The vote will last for at least 72 hours (Thu, Jun 24th 12:00 GMT) unless
there is an objection or in
Hi Dawid,
Thanks for driving this discussion, I am willing to volunteer as the release
manager for these versions.
Best
Yun Tang
From: Konstantin Knauf
Sent: Friday, June 18, 2021 22:35
To: dev
Subject: Re: [DISCUSS] Releasing Flink 1.11.4, 1.12.5, 1.13.2
Hi
Ingo Bürk created FLINK-23071:
-
Summary: Implement StatementSet#addInsert(TableDescriptor, Table)
Key: FLINK-23071
URL: https://issues.apache.org/jira/browse/FLINK-23071
Project: Flink
Issue Type
Ingo Bürk created FLINK-23065:
-
Summary: Implement TableEnvironment#createTemporaryTable
Key: FLINK-23065
URL: https://issues.apache.org/jira/browse/FLINK-23065
Project: Flink
Issue Type: Sub-tas
Ingo Bürk created FLINK-23070:
-
Summary: Implement TableEnvironment#createTable
Key: FLINK-23070
URL: https://issues.apache.org/jira/browse/FLINK-23070
Project: Flink
Issue Type: Sub-task
Ingo Bürk created FLINK-23069:
-
Summary: Support schema-less #executeInsert(TableDescriptor)
Key: FLINK-23069
URL: https://issues.apache.org/jira/browse/FLINK-23069
Project: Flink
Issue Type: Sub
Ingo Bürk created FLINK-23068:
-
Summary: Support LIKE in TableDescriptor
Key: FLINK-23068
URL: https://issues.apache.org/jira/browse/FLINK-23068
Project: Flink
Issue Type: Sub-task
Comp
Ingo Bürk created FLINK-23067:
-
Summary: Implement Table#executeInsert(TableDescriptor)
Key: FLINK-23067
URL: https://issues.apache.org/jira/browse/FLINK-23067
Project: Flink
Issue Type: Sub-task
Ingo Bürk created FLINK-23066:
-
Summary: Implement TableEnvironment#from
Key: FLINK-23066
URL: https://issues.apache.org/jira/browse/FLINK-23066
Project: Flink
Issue Type: Sub-task
Comp
Ingo Bürk created FLINK-23064:
-
Summary: Centralize connector options
Key: FLINK-23064
URL: https://issues.apache.org/jira/browse/FLINK-23064
Project: Flink
Issue Type: Sub-task
Compone
Ingo Bürk created FLINK-23063:
-
Summary: Remove TableEnvironment#connect
Key: FLINK-23063
URL: https://issues.apache.org/jira/browse/FLINK-23063
Project: Flink
Issue Type: Sub-task
Comp
Ingo Bürk created FLINK-23062:
-
Summary: FLIP-129: Register sources/sinks in Table API
Key: FLINK-23062
URL: https://issues.apache.org/jira/browse/FLINK-23062
Project: Flink
Issue Type: New Featu
Chesnay Schepler created FLINK-23061:
Summary: Split BootstrapTools
Key: FLINK-23061
URL: https://issues.apache.org/jira/browse/FLINK-23061
Project: Flink
Issue Type: Sub-task
C
Chesnay Schepler created FLINK-23060:
Summary: Move FutureUtils.toJava into separate class
Key: FLINK-23060
URL: https://issues.apache.org/jira/browse/FLINK-23060
Project: Flink
Issue Typ
Hi Piotr,
to pick up this discussion thread again:
- This FLIP is about providing some base implementation for FLIP-143 sinks
that make adding new implementations easier, similar to the
SourceReaderBase.
- The whole availability topic will most likely be a separate FLIP. The
basic issue just poppe
I would be more in favor of what Zhu Zhu proposed to throw an exception
with a meaningful and understandable explanation that also includes how to
resolve this problem. I do understand the reasoning behind automatically
switching the edge types in order to make things easier to use but a) this
can
Thanks for starting this discussion Dawid. We have collected a couple of
fixes for the different releases:
#fixes:
1.11.4: 72
1.12.5: 35
1.13.2: 49
which in my opinion warrants new bugfix releases. Note that we intend to do
another 1.11 release because of the seriousness of the FLINK-22815 [1]
wh
David Anderson created FLINK-23059:
--
Summary: Update playgrounds for Flink 1.13
Key: FLINK-23059
URL: https://issues.apache.org/jira/browse/FLINK-23059
Project: Flink
Issue Type: Improvement
Thanks for bringing this to the dev ML Etienne. Could you maybe update the
release notes for Flink 1.13 [1] to include this change? That way it might
be a bit more prominent. I think the change needs to go into the
release-1.13 and master branch.
[1]
https://github.com/apache/flink/blob/master/doc
yandufeng created FLINK-23058:
-
Summary: flink-elasticsearch-6 not work
Key: FLINK-23058
URL: https://issues.apache.org/jira/browse/FLINK-23058
Project: Flink
Issue Type: Bug
Components
LIU Xiao created FLINK-23057:
Summary: flink-console.sh doesn't do variable expansion for
FLINK_ENV_JAVA_OPTS like flink-daemon.sh
Key: FLINK-23057
URL: https://issues.apache.org/jira/browse/FLINK-23057
P
Junhan Yang created FLINK-23056:
---
Summary: flink docs sql builtin functions out of date
Key: FLINK-23056
URL: https://issues.apache.org/jira/browse/FLINK-23056
Project: Flink
Issue Type: Bug
JING ZHANG created FLINK-23055:
--
Summary: Add document for Window TVF offset
Key: FLINK-23055
URL: https://issues.apache.org/jira/browse/FLINK-23055
Project: Flink
Issue Type: Sub-task
According to the latest comment of Zhu Zhu[1], I append the potential
resource deadlock in batch jobs as a known limitation to this FLIP.
Thus, I'd extend the voting period for another 72h.
[1]
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-169-DataStream-API-for-Fine
Thanks, I append it to the known limitations of this FLIP.
Best,
Yangze Guo
On Mon, Jun 21, 2021 at 3:20 PM Zhu Zhu wrote:
>
> Thanks for the quick response Yangze.
> The proposal sounds good to me.
>
> Thanks,
> Zhu
>
> Yangze Guo 于2021年6月21日周一 下午3:01写道：
>>
>> Thanks for the comments, Zhu!
>>
Jingsong Lee created FLINK-23054:
Summary: Correct upsert optimization by upsert keys
Key: FLINK-23054
URL: https://issues.apache.org/jira/browse/FLINK-23054
Project: Flink
Issue Type: Bug
Thanks for the quick response Yangze.
The proposal sounds good to me.
Thanks,
Zhu
Yangze Guo 于2021年6月21日周一 下午3:01写道：
> Thanks for the comments, Zhu!
>
> Yes, it is a known limitation for fine-grained resource management. We
> also have filed this issue in FLINK-20865 when we proposed FLIP-156.
Thanks for the comments, Zhu!
Yes, it is a known limitation for fine-grained resource management. We
also have filed this issue in FLINK-20865 when we proposed FLIP-156.
As a first step, I agree that we can mark batch jobs with PIPELINED
edges as an invalid case for this feature. However, just th
59 matches
Mail list logo
