didiaode18 created FLINK-23521:
--
Summary: flinksql
Key: FLINK-23521
URL: https://issues.apache.org/jira/browse/FLINK-23521
Project: Flink
Issue Type: Improvement
Components: API /
Seth Wiesman created FLINK-23520:
Summary: Improve StateFun <-> DataStream Interop
Key: FLINK-23520
URL: https://issues.apache.org/jira/browse/FLINK-23520
Project: Flink
Issue Type:
Hi Sandeep,
In general I'd say it will be tricky to read Beam state this way as it
doesn't use Flink primitives, but it's writing state in custom binary
format (it can be de-serialized, but it's not easy to put all of the pieces
together).
Can you please share an example code of how you're
Mason Chen created FLINK-23519:
--
Summary: Aggregate State Backend Latency by State Level
Key: FLINK-23519
URL: https://issues.apache.org/jira/browse/FLINK-23519
Project: Flink
Issue Type:
Hi,
We have a simple Beam application like a work count running with Flink
runner (Beam 2.26 and Flink 1.9). We are using Beam’s value state. I am trying
to read the state from savepoint using Flink's State Processor API but getting
a NullPointerException. Converted the whole code into
Dawid Wysakowicz created FLINK-23518:
Summary: ZooKeeperLeaderElectionConnectionHandlingTest hangs on
Azure
Key: FLINK-23518
URL: https://issues.apache.org/jira/browse/FLINK-23518
Project: Flink
Hi,
I would introduce a new priority between Major and Minor. I think there's
still value for having a Minor priority, especially for tickets where
something is being reported but there's a workable workaround available.
With regards to Yun's comment, I think that's a follow-up question on what
Hi Konstantin,
How about rename "Major" to "Normal"? We already have higher critical and
blocker priorities, and I personally usually treat current "major" as "normal"
priority.
Best,
Yun Tang
From: Konstantin Knauf
Sent: Tuesday, July 27, 2021 18:03
To: dev
Quick Question to Martijn, Jingsong: do you propose to rename "Minor" to
"Normal" or would you like to introduce a new priority between Major and
Minor?
On Tue, Jul 27, 2021 at 11:44 AM Jingsong Li wrote:
> I agree with Martijn.
>
> My problem is just minor, which will make me a little
Chesnay Schepler created FLINK-23517:
Summary: Add messages to bannedDependencies enforcer rules
Key: FLINK-23517
URL: https://issues.apache.org/jira/browse/FLINK-23517
Project: Flink
I agree with Martijn.
My problem is just minor, which will make me a little disappointed.
Best,
Jingsong
On Tue, Jul 27, 2021 at 5:32 PM Martijn Visser
wrote:
> Hi,
>
> I personally would prefer to use "Normal" as a default priority because I
> think a lot of people's first reaction is that
Hi,
I personally would prefer to use "Normal" as a default priority because I
think a lot of people's first reaction is that their reported problem is
bigger than a minor loss of function [1], resulting in them choosing the
next priority which is currently "Major".
Best regards,
Martijn
[1]
李伟高 created FLINK-23516:
---
Summary: I try to specify savepoint dir in my app. However, the
startup task reports an error, java.lang.unsupported operationexception: the
configuration is unmodifiable; its contents cannot be changed.
Key:
李伟高 created FLINK-23515:
---
Summary: I try to specify savepoint dir in my app. However, the
startup task reports an error, java.lang.unsupported operationexception: the
configuration is unmodifiable; its contents cannot be changed.
Key:
ighack created FLINK-23514:
--
Summary: foreach exec SQL
Key: FLINK-23514
URL: https://issues.apache.org/jira/browse/FLINK-23514
Project: Flink
Issue Type: Improvement
Components: Table SQL
Ingo Bürk created FLINK-23513:
-
Summary: Remove old connectors and formats
Key: FLINK-23513
URL: https://issues.apache.org/jira/browse/FLINK-23513
Project: Flink
Issue Type: Sub-task
Yun Gao created FLINK-23512:
---
Summary: Check for illegal modifications of JobGraph with
partially finished operators
Key: FLINK-23512
URL: https://issues.apache.org/jira/browse/FLINK-23512
Project: Flink
zoucao created FLINK-23511:
--
Summary: Fix the location error in metric page.
Key: FLINK-23511
URL: https://issues.apache.org/jira/browse/FLINK-23511
Project: Flink
Issue Type: Improvement
zoucao created FLINK-23510:
--
Summary: add a new metric to show the max usage of
inputExclusiveBuffer for each inputChannel
Key: FLINK-23510
URL: https://issues.apache.org/jira/browse/FLINK-23510
Project:
Matthias Schwalbe created FLINK-23509:
-
Summary: FlinkKafkaInternalProducer overrides static final
ProducerIdAndEpoch#NONE during transaction recovery (fails)
Key: FLINK-23509
URL:
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
21 matches
Mail list logo
