Congxian Qiu(klion26) created FLINK-15661:
-
Summary:
JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure failed
because of Could not find Flink job
Key: FLINK-15661
URL: https://issues.
Canbin Zheng created FLINK-15662:
Summary: Make K8s client timeouts configurable
Key: FLINK-15662
URL: https://issues.apache.org/jira/browse/FLINK-15662
Project: Flink
Issue Type: Improvement
Canbin Zheng created FLINK-15663:
Summary: Kerberos Support in Kubernetes Deploy Mode
Key: FLINK-15663
URL: https://issues.apache.org/jira/browse/FLINK-15663
Project: Flink
Issue Type: New Fe
Yun Gao created FLINK-15664:
---
Summary: Flink plan visualizer does not show operators information
completely when there are line wrap
Key: FLINK-15664
URL: https://issues.apache.org/jira/browse/FLINK-15664
P
Canbin Zheng created FLINK-15665:
Summary: External shuffle service support in Kubernetes mode
Key: FLINK-15665
URL: https://issues.apache.org/jira/browse/FLINK-15665
Project: Flink
Issue Typ
Canbin Zheng created FLINK-15666:
Summary: GPU scheduling support in Kubernetes mode
Key: FLINK-15666
URL: https://issues.apache.org/jira/browse/FLINK-15666
Project: Flink
Issue Type: New Fea
Hi everyone,
Currently Flink supports the resource management system YARN and Mesos.
However, they were not
designed for fast moving cloud native architectures, and they could not
support mixed workloads (e.g. batch,
streaming, deep learning, web services, etc.) relatively well. At the same
time
Canbin Zheng created FLINK-15667:
Summary: Hadoop Configurations Mount Support
Key: FLINK-15667
URL: https://issues.apache.org/jira/browse/FLINK-15667
Project: Flink
Issue Type: New Feature
Zhu Zhu created FLINK-15668:
---
Summary: Remove AlsoRunWithLegacyScheduler
Key: FLINK-15668
URL: https://issues.apache.org/jira/browse/FLINK-15668
Project: Flink
Issue Type: Sub-task
Compon
Hi Canbin Zheng,
I have found that you created some tickets about Flink on Kubernetes. We
just have the same requirements.
Maybe we could have more discussion about the use cases and implementation
details. I have created
a slack channel[1], please join in if you want.
Any dev users if you have s
Hi Yang Wang,
Thanks for your effort on this topic and inviting me, I am glad to join the
future work on native Kubernetes integration, will try to join the slack
channel latter.
Yang Wang 于2020年1月19日周日 下午6:04写道：
> Hi Canbin Zheng,
>
> I have found that you created some tickets about Flink on K
Hi community，
now I have a flink sql job, and I set the flink sql sate retention
time, there are three dir in flink checkpoint dir :
1. chk -xx dir
2. shared dir
3. taskowned dir
I find the shared dir store the last year checkpoint state,the only reason
I thought is that the latest
checkpo
godfrey he created FLINK-15669:
--
Summary: SQL client can't cancel flink job
Key: FLINK-15669
URL: https://issues.apache.org/jira/browse/FLINK-15669
Project: Flink
Issue Type: Bug
Compo
Dear community,
happy to share this week's weekly community digest with a release candidate
for Flink 1.10, a Pulsar Catalog for Flink, a 50% discount code for Flink
Forward SF and bit more.
Flink Development
==
* [releases] The first (preview)* release candidate for Flink 1.10* has
Ok thanks for the pointer, I wasn't awareof that!
Il Dom 19 Gen 2020, 03:00 godfrey he ha scritto:
> hi Flavio, TableEnvironment.getCompletionHints maybe already meet the
> requirement.
>
> Flavio Pompermaier 于2020年1月18日周六 下午3:39写道：
>
> > Why not adding also a suggest() method (also unimplement
Dear My Worshippers, I want to contribute to Apache Flink. Would you please
give me the permission as a contributor? My JIRA ID is forward.
Hi Lake
A more suitable place for this mail should be in user-mail list.
There are three reasons why this could happen:
1. This file is orphan file e.g. file uploaded during one checkpoint but
task manager exited unexpectedly leave that checkpoint not completed.
2. This file should be rem
Stephan Ewen created FLINK-15670:
Summary: Provide a Kafka Source/Sink pair that aligns Kafka's
Partitions and Flink's KeyGroups
Key: FLINK-15670
URL: https://issues.apache.org/jira/browse/FLINK-15670
Stephan Ewen created FLINK-15671:
Summary: Provide one place for Docker Images with all supported
cluster modes
Key: FLINK-15671
URL: https://issues.apache.org/jira/browse/FLINK-15671
Project: Flink
Stephan Ewen created FLINK-15672:
Summary: Switch to Log4j 2 by default
Key: FLINK-15672
URL: https://issues.apache.org/jira/browse/FLINK-15672
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-15673:
Summary: Shepherd FLIP-75 (Various Web UI fixes)
Key: FLINK-15673
URL: https://issues.apache.org/jira/browse/FLINK-15673
Project: Flink
Issue Type: Improveme
Stephan Ewen created FLINK-15674:
Summary: Let Java and Scala Type Extraction go through the same
stack
Key: FLINK-15674
URL: https://issues.apache.org/jira/browse/FLINK-15674
Project: Flink
Hequn Cheng created FLINK-15675:
---
Summary: Add documentation that Python UDF is not supported for
Flink Planner under batch mode
Key: FLINK-15675
URL: https://issues.apache.org/jira/browse/FLINK-15675
P
Hi
Welcome to the Flink community
You no longer need contributor permissions. You can simply create a JIRA
ticket and ask to be assigned to it in order to start working. Please also
take a look at the Flink's contribution guidelines [1] for more information.
[1] https://flink.apache.org/contribu
Hi
Thank you very much for your apply.
-- --
??: "Benchao Li"https://flink.apache.org/contributing/how-to-contribute.html
273339930 <273339...@qq.com> ??2020??1??19?? 11:24??
> Dear My Worshippers, I want to contribute to Apache Flink
hailong wang created FLINK-15676:
Summary: Improve test code of JDBCUpsertTableSinkITCase and
JDBCLookupFunctionITCase
Key: FLINK-15676
URL: https://issues.apache.org/jira/browse/FLINK-15676
Project:
hailong wang created FLINK-15677:
Summary: TableSource#explainSource should return the field names
from getProducedDataType instead of getTableSchema
Key: FLINK-15677
URL: https://issues.apache.org/jira/browse/FLI
>>What I understand from you, one operator has two watermarks? If so, one
operator's output watermark would be an input watermark of the next
operator? Does it sounds redundant?
There are no two watermarks for an operator. What I want to say is
"watermark metrics".
>>Or do you mean the Web UI only
Jingsong Lee created FLINK-15678:
Summary: Optimize producing primary key without row number in
special Top 1
Key: FLINK-15678
URL: https://issues.apache.org/jira/browse/FLINK-15678
Project: Flink
Yangze Guo created FLINK-15679:
--
Summary: Improve Flink's ID system
Key: FLINK-15679
URL: https://issues.apache.org/jira/browse/FLINK-15679
Project: Flink
Issue Type: Improvement
Rep
Hi everyone,
Thanks for the discussion and votes.
So far the email[1] wants to make AppendingState#add refuse to add null
element, received 3 approving votes, and there is no -1 votes:
* Aljoscha
* Yu Li
* Yun Tang
Therefore, I'm happy to announce that we'll apply this change and make
Appending
31 matches
Mail list logo
