xiaogang zhou created FLINK-22059:
-
Summary: add a new option is rocksdb statebackend to enable job
threads setting
Key: FLINK-22059
URL: https://issues.apache.org/jira/browse/FLINK-22059
Project:
Dian Fu created FLINK-22058:
---
Summary: Support FLIP-27 based NumberSequenceSource connector in
PyFlink DataStream API
Key: FLINK-22058
URL: https://issues.apache.org/jira/browse/FLINK-22058
Project: Flink
Bhagi created FLINK-22057:
-
Summary: Flink client submitting Flink job remotely to Flink
cluster through Loadbalancer rest service
Key: FLINK-22057
URL: https://issues.apache.org/jira/browse/FLINK-22057
Guowei Ma created FLINK-22056:
-
Summary: FlinkKafkaProducerITCase failed because of "producer
leak".
Key: FLINK-22056
URL: https://issues.apache.org/jira/browse/FLINK-22056
Project: Flink
Issue
Xintong Song created FLINK-22055:
Summary: RPC main thread executor may schedule commands with wrong
time unit of delay
Key: FLINK-22055
URL: https://issues.apache.org/jira/browse/FLINK-22055
Yi Tang created FLINK-22054:
---
Summary: Using a shared watcher for ConfigMap watching
Key: FLINK-22054
URL: https://issues.apache.org/jira/browse/FLINK-22054
Project: Flink
Issue Type: Improvement
lindong28 commented on pull request #2:
URL: https://github.com/apache/flink-ml/pull/2#issuecomment-810706284
@becketqin Could you review this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
lindong28 opened a new pull request #2:
URL: https://github.com/apache/flink-ml/pull/2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service,
link fix pr here https://github.com/apache/flink/pull/15442
we might need someone help review and merge meanwhile.
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
Arvid Heise created FLINK-22053:
---
Summary: Recovery of a completed split in NumberSequenceSource
causes fatal exception.
Key: FLINK-22053
URL: https://issues.apache.org/jira/browse/FLINK-22053
Project:
Seth Wiesman created FLINK-22052:
Summary: Add FLIP-142 changes to PyFlink
Key: FLINK-22052
URL: https://issues.apache.org/jira/browse/FLINK-22052
Project: Flink
Issue Type: Sub-task
Hi Till,
We did some investigation and found this memory usage point to
rocksdbstatebackend running on managed memory. So far we have seen this bug
in rocksdbstatebackend on managed memory. we followed suggestion [1] and
disabled managed memory management so far not seeing issue.
I felt this
Hi,
FYI: I just submitted the small PR to support this:
https://github.com/apache/flink/pull/15436
Best
Etienne
On 29/03/2021 20:05, Arvid Heise wrote:
Hi Etienne,
In general, any small PR on this subject is very welcome. I don't think
that the community as a whole will invest much into
Till Rohrmann created FLINK-22051:
-
Summary: Better document the distinction between
stop-with-savepoint and stop-with-savepoint-with-drain
Key: FLINK-22051
URL: https://issues.apache.org/jira/browse/FLINK-22051
Roman Khachatryan created FLINK-22050:
-
Summary: Failed to release input gate
(IllegalReferenceCountException)
Key: FLINK-22050
URL: https://issues.apache.org/jira/browse/FLINK-22050
Project:
ZhangWei created FLINK-22049:
Summary: Simplify calculating the starting index of the local
key-group range in InternalTimerServiceImpl constructor.
Key: FLINK-22049
URL:
Till Rohrmann created FLINK-22048:
-
Summary: Remove unnecessary akka.transport.* configuration options
Key: FLINK-22048
URL: https://issues.apache.org/jira/browse/FLINK-22048
Project: Flink
hayden zhou created FLINK-22047:
---
Summary: Could not find FLINSHED Flink job and can't submit job
Key: FLINK-22047
URL: https://issues.apache.org/jira/browse/FLINK-22047
Project: Flink
Issue
shiqihao created FLINK-22046:
Summary: org.apache.flink.cep.nfa.State#toString() may has a
abnormal format
Key: FLINK-22046
URL: https://issues.apache.org/jira/browse/FLINK-22046
Project: Flink
Matthias created FLINK-22045:
Summary: Set log level for shaded zookeeper logger
Key: FLINK-22045
URL: https://issues.apache.org/jira/browse/FLINK-22045
Project: Flink
Issue Type: Bug
Bhagi created FLINK-22044:
-
Summary: running job from Flink client(cli) from outside Flink
jobmanager pod
Key: FLINK-22044
URL: https://issues.apache.org/jira/browse/FLINK-22044
Project: Flink
jinfeng created FLINK-22043:
---
Summary: Introduce thrift format to (de)serialize thrift message
only with table
Key: FLINK-22043
URL: https://issues.apache.org/jira/browse/FLINK-22043
Project: Flink
@Konstantin Knauf
Yes, we'll make sure that migration docs are added before finalizing the
release.
I've proceeded to create RC1 for StateFun 3.0.0. Voting is happening on a
separate thread.
On Tue, Mar 30, 2021 at 3:06 AM Robert Metzger wrote:
> Wow, the feature list sounds really exciting!
Hi everyone,
Please review and vote on the release candidate #1 for the version 3.0.0 of
Apache Flink Stateful Functions, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
**Testing Guideline**
You can find here [1] a page in the
jingzi created FLINK-22042:
--
Summary: Fix reading bigint(20) UNSIGNED type field cannot be cast
Key: FLINK-22042
URL: https://issues.apache.org/jira/browse/FLINK-22042
Project: Flink
Issue Type:
Till Rohrmann created FLINK-22041:
-
Summary: Configure DataStreamAllroundTest via Configuration
instead of ParameterTool
Key: FLINK-22041
URL: https://issues.apache.org/jira/browse/FLINK-22041
Robert Metzger created FLINK-22040:
--
Summary: Maven: Entry has not been leased from this pool / fix for
e2e tests
Key: FLINK-22040
URL: https://issues.apache.org/jira/browse/FLINK-22040
Project:
Andy created FLINK-22038:
Summary: Update TopN node to be without rowNumber if rowNumber
field is projected out after TopN
Key: FLINK-22038
URL: https://issues.apache.org/jira/browse/FLINK-22038
Project:
Zhilong Hong created FLINK-22037:
Summary: Remove the redundant blocking queue from
DeployingTasksBenchmarkBase
Key: FLINK-22037
URL: https://issues.apache.org/jira/browse/FLINK-22037
Project: Flink
Konstantin Knauf created FLINK-22036:
Summary: Document Jira Bot in Flink Confluence
Key: FLINK-22036
URL: https://issues.apache.org/jira/browse/FLINK-22036
Project: Flink
Issue Type:
Konstantin Knauf created FLINK-22034:
Summary: Add Rule 1
Key: FLINK-22034
URL: https://issues.apache.org/jira/browse/FLINK-22034
Project: Flink
Issue Type: Sub-task
Konstantin Knauf created FLINK-22035:
Summary: Run Jira Bot periodically with Github Actions
Key: FLINK-22035
URL: https://issues.apache.org/jira/browse/FLINK-22035
Project: Flink
Issue
Konstantin Knauf created FLINK-22033:
Summary: Add Rule 2
Key: FLINK-22033
URL: https://issues.apache.org/jira/browse/FLINK-22033
Project: Flink
Issue Type: Sub-task
Konstantin Knauf created FLINK-22032:
Summary: Implement Rule 3 First (Simplest Rule)
Key: FLINK-22032
URL: https://issues.apache.org/jira/browse/FLINK-22032
Project: Flink
Issue Type:
Konstantin Knauf created FLINK-22030:
Summary: Add Technical Debt Issue Type
Key: FLINK-22030
URL: https://issues.apache.org/jira/browse/FLINK-22030
Project: Flink
Issue Type: Sub-task
Konstantin Knauf created FLINK-22029:
Summary: Remove "Task", "Wish" and "Test" Issue Types
Key: FLINK-22029
URL: https://issues.apache.org/jira/browse/FLINK-22029
Project: Flink
Issue
Konstantin Knauf created FLINK-22028:
Summary: Remove "Trivial" Ticket Priority
Key: FLINK-22028
URL: https://issues.apache.org/jira/browse/FLINK-22028
Project: Flink
Issue Type:
Konstantin Knauf created FLINK-22027:
Summary: Create separate repository for Jira Bot
Key: FLINK-22027
URL: https://issues.apache.org/jira/browse/FLINK-22027
Project: Flink
Issue Type:
Konstantin Knauf created FLINK-22026:
Summary: Improved Jira Process & Bot
Key: FLINK-22026
URL: https://issues.apache.org/jira/browse/FLINK-22026
Project: Flink
Issue Type: Improvement
Matthias created FLINK-22025:
Summary: SurefireBooterForkException: ExecutionException Error
occurred in starting fork
Key: FLINK-22025
URL: https://issues.apache.org/jira/browse/FLINK-22025
Project:
Matthias created FLINK-22024:
Summary: Maven: Entry has not been leased from this pool
Key: FLINK-22024
URL: https://issues.apache.org/jira/browse/FLINK-22024
Project: Flink
Issue Type: Bug
Tzu-Li (Gordon) Tai created FLINK-22023:
---
Summary: Remove outdated StateFun quickstart archetype
Key: FLINK-22023
URL: https://issues.apache.org/jira/browse/FLINK-22023
Project: Flink
42 matches
Mail list logo