Matthias Schwalbe created FLINK-23509:
-
Summary: FlinkKafkaInternalProducer overrides static final
ProducerIdAndEpoch#NONE during transaction recovery (fails)
Key: FLINK-23509
URL: https://issues.apache.org/ji
john created FLINK-23508:
Summary: HA mode cannot coexist with history server
Key: FLINK-23508
URL: https://issues.apache.org/jira/browse/FLINK-23508
Project: Flink
Issue Type: Bug
Report
Hi everyone,
Please review and vote on the release candidate #3 for the version 1.12.5,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
*
john created FLINK-23507:
Summary: The node IP obtained in NodePort mode is a VIP
Key: FLINK-23507
URL: https://issues.apache.org/jira/browse/FLINK-23507
Project: Flink
Issue Type: Bug
Comp
zhanghw created FLINK-23506:
---
Summary: word_count.py 执行错误
Key: FLINK-23506
URL: https://issues.apache.org/jira/browse/FLINK-23506
Project: Flink
Issue Type: Bug
Components: API / Python
Hi!
Window aggregations will only output results when the watermark rises above
the end of window. Let's say the end of window is at 00:01, only
when recvdTime is larger or equal than 00:06 will this window emit (because
there is a 5 minutes out of orderness).
If it is not the case then it indeed
Hi Arvid,
Thanks for the patient discussion.
To explain a bit more on the metric being a global variable, I think in
general there are two ways to pass a value from one code block to another.
The first way is direct passing. That means the variable is explicitly
passed from one code block to anot
Kexin Hui created FLINK-23505:
-
Summary: Trim down kafka-client dependency from AWS Glue module
Key: FLINK-23505
URL: https://issues.apache.org/jira/browse/FLINK-23505
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-23504:
Summary: Rework TestingRpcService to not depend on akka
Key: FLINK-23504
URL: https://issues.apache.org/jira/browse/FLINK-23504
Project: Flink
Issue
Hi everyone,
I am happy to finish voting for FLIP-183 [1] with approving. The vote [2] is
now closed.
There was no veto and three +1 votes all of which were binding:
- Piotr Nowojski (binding)
- Yuan Mei (binding)
- Till Rohrmann (binding)
Thank everyone for participating!
[1]https://cwiki
Hi everyone,
Please review and vote on the release candidate #1 for the version 1.11.4,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
*
陈磊 created FLINK-23503:
--
Summary: csv格式数据带双引号反序列化失败
Key: FLINK-23503
URL: https://issues.apache.org/jira/browse/FLINK-23503
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
A
Chesnay Schepler created FLINK-23502:
Summary: Benchmarks use outdated flink-shaded-netty-dynamic version
Key: FLINK-23502
URL: https://issues.apache.org/jira/browse/FLINK-23502
Project: Flink
Hi Team,
I am trying to upgrade from 1.7 to 1.13
Code in 1.7
Schema schema = new Schema();
schema.rowtime(new Rowtime()
.timestampsFromField("eventTime")
.watermarksPeriodicBounded(3000)
);
Code in 1.13
tableEnv.executeSql("CREATE TABLE ORDERS ( " +
"`sid` BIGINT, " +
Brachi Packter created FLINK-23501:
--
Summary: [GCP PubSub] Support add table source API for GCP PubSub
Key: FLINK-23501
URL: https://issues.apache.org/jira/browse/FLINK-23501
Project: Flink
Chesnay Schepler created FLINK-23500:
Summary: AkkaRpcSystemLoader fails if tmp directory does not exist
Key: FLINK-23500
URL: https://issues.apache.org/jira/browse/FLINK-23500
Project: Flink
Hi,
I would recommend having a look at the headers of the original email [1].
In those headers, there will be a value for 'Return-Path' with an email
address. If you send an email to that address, it will unsubscribe you.
Best regards,
Martijn
[1] https://support.google.com/mail/answer/29436?hl
Chesnay Schepler created FLINK-23499:
Summary: ConfigurationUtils#splitPaths may split scheme from path
Key: FLINK-23499
URL: https://issues.apache.org/jira/browse/FLINK-23499
Project: Flink
Timo Walther created FLINK-23498:
Summary: Use a layered configuration in Executor and Planner
Key: FLINK-23498
URL: https://issues.apache.org/jira/browse/FLINK-23498
Project: Flink
Issue Typ
Chesnay Schepler created FLINK-23497:
Summary: flink-table-planner does not compile on scala 2.12
Key: FLINK-23497
URL: https://issues.apache.org/jira/browse/FLINK-23497
Project: Flink
Is
Hi Jing,
I already sent emails to the mentioned email ids... the reply I got was, my
email I’d is not available...
Not sure why I am still receiving these emails
On Mon, 26 Jul 2021 at 9:42 AM, JING ZHANG wrote:
> Hi Bhagi,
> To unsubscribe emails from Flink JIRA activities, send an email to
>
Hi Konstantin!
Thanks for raising this up. From my point of view it is a reasonable
change. But I think it would be better to handle different types of tickets
respectively. For example, for bugs a default major seems to be better,
while for others the default shall be minor.
Konstantin Knauf 于2
Chesnay Schepler created FLINK-23496:
Summary: Maven snapshot build does not use MAVEN_GLOBAL_OPTIONS
Key: FLINK-23496
URL: https://issues.apache.org/jira/browse/FLINK-23496
Project: Flink
Brachi Packter created FLINK-23495:
--
Summary: [GCP PubSub] Make checkpoint optional for preview/staging
mode
Key: FLINK-23495
URL: https://issues.apache.org/jira/browse/FLINK-23495
Project: Flink
Hi everyone,
In [1] I proposed to change the default priority of our Jira project to
"Minor". Most tickets are opened with the default priority. Arguably the
majority of these tickets fall into the "Minor" category instead of "Major"
according to the definition in [3] (and the implementation of th
25 matches
Mail list logo
