Rui Li created FLINK-21808:
--
Summary: Support DQL in HiveParser
Key: FLINK-21808
URL: https://issues.apache.org/jira/browse/FLINK-21808
Project: Flink
Issue Type: Sub-task
Components:
Yang Wang created FLINK-21807:
-
Summary: Make ApplicationDeployer interface public
Key: FLINK-21807
URL: https://issues.apache.org/jira/browse/FLINK-21807
Project: Flink
Issue Type: Improvement
Kezhu Wang created FLINK-21806:
--
Summary: ContinuousEventTimeTrigger should register its first
timer base on current watermark
Key: FLINK-21806
URL: https://issues.apache.org/jira/browse/FLINK-21806
Hi Xingbo,
Thanks a lot for bringing up this discussion. Actually the size limit already
becomes an issue during releasing 1.11.3 and 1.12.1. It blocks us to publish
PyFlink packages to PyPI during the release as there is no enough space left
(PS: already published the packages after
Wenlong Lyu created FLINK-21805:
---
Summary: Support StreamExecRank and StreamExecSortLimit Json ser/de
Key: FLINK-21805
URL: https://issues.apache.org/jira/browse/FLINK-21805
Project: Flink
*Hi Apache Flink community, *
*We want to invite you to Beam College, a fee training program focused
on Apache Beam. *
*
**
The demand for people with data analytics skills is growing. Partnered
with Google Cloud and the Apache Beam Open Source community, Beam
College provides free
Roman Khachatryan created FLINK-21804:
-
Summary: Load Changelog implementation via PluginManager
Key: FLINK-21804
URL: https://issues.apache.org/jira/browse/FLINK-21804
Project: Flink
I created a Pull Request for the roadmap update:
https://github.com/apache/flink-web/pull/426
Happy to take reviews!
Best,
Stephan
On Wed, Mar 10, 2021 at 1:55 PM Stephan Ewen wrote:
> Thanks for the positive feedback. Will convert this to a pull request then
> in the next days.
>
> Still
Craig Smoothey created FLINK-21803:
--
Summary: Tumbling / Sliding windows are unaware of daylight
savings time
Key: FLINK-21803
URL: https://issues.apache.org/jira/browse/FLINK-21803
Project: Flink
Hi all,
I run many flink jobs that contains sql, they reports the metrics to infuxdb. I
find many strange measurements in metrics database of influxdb, e.g. "from
table1".
Does sql produce those measurements ? What is the meanings of those
measurements ?
--
tim yu
Terry Wang created FLINK-21802:
--
Summary: LogicalTypeJsonDeserializer/Serializer custom
RowType/MapType/ArrayType/MultisetType
Key: FLINK-21802
URL: https://issues.apache.org/jira/browse/FLINK-21802
Timo Walther created FLINK-21801:
Summary: Update use new schema in Table, TableResult,
TableOperation
Key: FLINK-21801
URL: https://issues.apache.org/jira/browse/FLINK-21801
Project: Flink
Xintong Song created FLINK-21800:
Summary: Guard MemorySegment against concurrent frees.
Key: FLINK-21800
URL: https://issues.apache.org/jira/browse/FLINK-21800
Project: Flink
Issue Type:
Xintong Song created FLINK-21799:
Summary: Detect and fail explicitly on managed memory leaking
Key: FLINK-21799
URL: https://issues.apache.org/jira/browse/FLINK-21799
Project: Flink
Issue
Xintong Song created FLINK-21798:
Summary: Guard MemorySegment against multiple frees.
Key: FLINK-21798
URL: https://issues.apache.org/jira/browse/FLINK-21798
Project: Flink
Issue Type:
Arvid Heise created FLINK-21797:
---
Summary: Performance regression on 03/11/21
Key: FLINK-21797
URL: https://issues.apache.org/jira/browse/FLINK-21797
Project: Flink
Issue Type: Improvement
Dawid Wysakowicz created FLINK-21796:
Summary:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=14665=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=ff888d9b-cd34-53cc-d90f-3e446d355529
Key: FLINK-21796
+1 for moving Flink ML to a separate repository. Thanks for driving this
discussion and effort Dong!
Cheers,
Till
On Fri, Mar 12, 2021 at 1:19 PM Becket Qin wrote:
> Thanks for raising the discussion, Dong. +1 on moving the Flink ML to a
> separate repository.
>
> Machine learning is a big
Xintong Song created FLINK-21795:
Summary: Support retrieving slot details via rest api
Key: FLINK-21795
URL: https://issues.apache.org/jira/browse/FLINK-21795
Project: Flink
Issue Type:
Xintong Song created FLINK-21794:
Summary: Support retrieving slot details via rest api
Key: FLINK-21794
URL: https://issues.apache.org/jira/browse/FLINK-21794
Project: Flink
Issue Type:
Xintong Song created FLINK-21793:
Summary: Native K8s does not respect TM memory setups decided by RM
Key: FLINK-21793
URL: https://issues.apache.org/jira/browse/FLINK-21793
Project: Flink
Wei Zhong created FLINK-21792:
-
Summary: Add a PythonFunctionRunnerDescriptor and unify the
creation of all the PythonFunctionRunner
Key: FLINK-21792
URL: https://issues.apache.org/jira/browse/FLINK-21792
godfrey he created FLINK-21791:
--
Summary: Support StreamExecLocalGroupAggregate and
StreamExecGlobalGroupAggregate json serialization/deserialization
Key: FLINK-21791
URL:
Yingjie Cao created FLINK-21790:
---
Summary: Shuffle data directories to make data directory section
of different TaskManagers fairer
Key: FLINK-21790
URL: https://issues.apache.org/jira/browse/FLINK-21790
Yingjie Cao created FLINK-21789:
---
Summary: Make FileChannelManagerImpl#getNextPathNum select data
directory fairly
Key: FLINK-21789
URL: https://issues.apache.org/jira/browse/FLINK-21789
Project: Flink
Yingjie Cao created FLINK-21788:
---
Summary: Throw PartitionNotFoundException if the partition file
has been lost for blocking shuffle
Key: FLINK-21788
URL: https://issues.apache.org/jira/browse/FLINK-21788
wangbin created FLINK-21787:
---
Summary: The method $(String) is undefined for the type
TableExample
Key: FLINK-21787
URL: https://issues.apache.org/jira/browse/FLINK-21787
Project: Flink
Issue
27 matches
Mail list logo
