I created a jira FLINK-26858
丛鹏 于2022年3月25日周五 10:24写道：
> fine,I'll create a jira issue
>
> 胡伟华 于2022年3月24日周四 19:59写道：
>
>> HI, congpeng
>>
>> Thanks for your report, I agree with you, we should be more explicit
>> about not finding the corresponding Factory for the specified target. Could
>> yo
丛鹏 created FLINK-26858:
--
Summary: When submitting a task, an error is reported and the
description is inaccurate, which will lead to misleading
Key: FLINK-26858
URL: https://issues.apache.org/jira/browse/FLINK-26858
Jane Chan created FLINK-26857:
-
Summary: Add ITCase for projection and filter predicate
Key: FLINK-26857
URL: https://issues.apache.org/jira/browse/FLINK-26857
Project: Flink
Issue Type: Sub-task
Jane Chan created FLINK-26856:
-
Summary: Add ITCase for compound primary key and multi-partition
Key: FLINK-26856
URL: https://issues.apache.org/jira/browse/FLINK-26856
Project: Flink
Issue Type:
Dian Fu created FLINK-26855:
---
Summary: ImportError: cannot import name 'environmentfilter' from
'jinja2'
Key: FLINK-26855
URL: https://issues.apache.org/jira/browse/FLINK-26855
Project: Flink
Issu
fine,I'll create a jira issue
胡伟华 于2022年3月24日周四 19:59写道：
> HI, congpeng
>
> Thanks for your report, I agree with you, we should be more explicit about
> not finding the corresponding Factory for the specified target. Could you
> create a jira issue for this?
>
>
> > 2022年3月24日 下午7:05，丛鹏 写道：
> >
liuminghao created FLINK-26854:
--
Summary: 重定向数据库无法写入
Key: FLINK-26854
URL: https://issues.apache.org/jira/browse/FLINK-26854
Project: Flink
Issue Type: Bug
Components: API / DataSet
Roman Khachatryan created FLINK-26853:
-
Summary: HeapStateBackend ignores metadata updates in certain cases
Key: FLINK-26853
URL: https://issues.apache.org/jira/browse/FLINK-26853
Project: Flink
Nico Kruber created FLINK-26852:
---
Summary: RocksDBMapState#clear not forwarding exceptions
Key: FLINK-26852
URL: https://issues.apache.org/jira/browse/FLINK-26852
Project: Flink
Issue Type: Bug
Chesnay Schepler created FLINK-26851:
Summary: Properly model reporter options as ConfigOptions
Key: FLINK-26851
URL: https://issues.apache.org/jira/browse/FLINK-26851
Project: Flink
Issu
Chesnay Schepler created FLINK-26850:
Summary: Add MetricType enum
Key: FLINK-26850
URL: https://issues.apache.org/jira/browse/FLINK-26850
Project: Flink
Issue Type: Improvement
Chesnay Schepler created FLINK-26849:
Summary: Deduplicate MetricRegistry code for (un)registering
metrics with reporters
Key: FLINK-26849
URL: https://issues.apache.org/jira/browse/FLINK-26849
Pr
hehuiyuan created FLINK-26848:
-
Summary: JDBC don't flush data when disable flush-max-rows and
flush-interval
Key: FLINK-26848
URL: https://issues.apache.org/jira/browse/FLINK-26848
Project: Flink
Dian Fu created FLINK-26847:
---
Summary: Unify the logic for the command line option -py and -pym
Key: FLINK-26847
URL: https://issues.apache.org/jira/browse/FLINK-26847
Project: Flink
Issue Type: Im
Dian Fu created FLINK-26846:
---
Summary: Gauge metrics doesn't work in PyFlink
Key: FLINK-26846
URL: https://issues.apache.org/jira/browse/FLINK-26846
Project: Flink
Issue Type: Bug
Compone
HI, congpeng
Thanks for your report, I agree with you, we should be more explicit about not
finding the corresponding Factory for the specified target. Could you create a
jira issue for this?
> 2022年3月24日 下午7:05，丛鹏 写道：
>
> Hi, I'm using flink1.12.2 a problem is found when submitting the task
Hi, I'm using flink1.12.2 a problem is found when submitting the task of
yarn application,
An example of the Flink official website submitting a task is
./bin/flink run-application -t yarn-application ./
examples/streaming/TopSpeedWindowing. jar
If some of them are misspelled, then yen application
Hi there,
Please use English on the dev@flink.apache.org mailing list.
Images/attachements don't work on these mailing lists. You would have to
host it somewhere else and link to it.
If this was a question about using Apache Flink user@ (Englisch) or user-zh@
(Chinese) would be the correct mailin
嗨，我这边在使用flink1.12.2提交yarn-application的任务时发现一个问题，
提交任务的flink官网的例子为
./bin/flink run-application -t yarn-application
./examples/streaming/TopSpeedWindowing.jar
如果其中有部分写错的话 yarn-application 写成了 yarn-appliation的话
就会报错
[image: image.png]
这里我看了代码是CliFrontend 封装的 213行的配置集合 effectiveConfiguration
有问题，导致Def
Salva created FLINK-26845:
-
Summary: Document testing guidelines
Key: FLINK-26845
URL: https://issues.apache.org/jira/browse/FLINK-26845
Project: Flink
Issue Type: Improvement
Components: S
Wenjun Ruan created FLINK-26844:
---
Summary: ConnectionUtilsTest run failed
Key: FLINK-26844
URL: https://issues.apache.org/jira/browse/FLINK-26844
Project: Flink
Issue Type: Bug
Compon
Timo Walther created FLINK-26843:
Summary: Cleanup code around TableConfig/ReadableConfig
Key: FLINK-26843
URL: https://issues.apache.org/jira/browse/FLINK-26843
Project: Flink
Issue Type: Su
Hi Ron,
thanks for opening this discussion and proposing a FLIP. This feature
has been requested multiple times before and it is definitely something
that the Flink community wants. However, we have to ensure that this
change fits into the overall architecture and doesn't break core
assumptio
Chesnay Schepler created FLINK-26842:
Summary: Remove flink-python Scala dependency
Key: FLINK-26842
URL: https://issues.apache.org/jira/browse/FLINK-26842
Project: Flink
Issue Type: Tech
thecai created FLINK-26841:
--
Summary: @param The The type parameter of the elements in the
second stream
Key: FLINK-26841
URL: https://issues.apache.org/jira/browse/FLINK-26841
Project: Flink
Issu
Hi Ron,
Thanks for creating the FLIP. You're talking about both local and remote
resources. With regards to remote resources, how do you see this work with
Flink's filesystem abstraction? I did read in the FLIP that Hadoop
dependencies are not packaged, but I would hope that we do that for all
fil
lincoln lee created FLINK-26840:
---
Summary: [minor refactor] Add a common
TopNBufferCacheRemovalListener for topN function
Key: FLINK-26840
URL: https://issues.apache.org/jira/browse/FLINK-26840
Project:
Yun Gao created FLINK-26839:
---
Summary:
SessionDispatcherLeaderProcessTest.recoverJobs_withJobIdRecoveryFailure_failsFatally
failed on azures
Key: FLINK-26839
URL: https://issues.apache.org/jira/browse/FLINK-26839
Yun Gao created FLINK-26838:
---
Summary: BatchingStateChangeUploadSchedulerTest.testRetryOnTimeout
failed on azure
Key: FLINK-26838
URL: https://issues.apache.org/jira/browse/FLINK-26838
Project: Flink
Yun Gao created FLINK-26837:
---
Summary: KafkaSinkE2ECase.testMetrics failed on azure
Key: FLINK-26837
URL: https://issues.apache.org/jira/browse/FLINK-26837
Project: Flink
Issue Type: Bug
Yang Wang created FLINK-26836:
-
Summary: Add sanity check for state.savepoints.dir when using
savepoint upgrade mode
Key: FLINK-26836
URL: https://issues.apache.org/jira/browse/FLINK-26836
Project: Flink
Yun Gao created FLINK-26835:
---
Summary: WordCountSubclassPOJOITCase failed on azure
Key: FLINK-26835
URL: https://issues.apache.org/jira/browse/FLINK-26835
Project: Flink
Issue Type: Bug
C
Hi everyone,
The RC0 for Apache Flink 1.15.0 has been created. This is still a
preview-only release candidate to facility the integrated testing since
there are still some ongoing efforts, thus no official votes will take place.
It has all the artifacts that we would typically have for a release
33 matches
Mail list logo
