Hequn Cheng created FLINK-18966:
---
Summary: Support key_by() on ConnectedStreams for Python
DataStream API
Key: FLINK-18966
URL: https://issues.apache.org/jira/browse/FLINK-18966
Project: Flink
Dian Fu created FLINK-18965:
---
Summary: ExecutionContextTest.testCatalogs failed with
"ClassNotFoundException: org.apache.hadoop.fs.BlockStoragePolicySpi"
Key: FLINK-18965
URL: https://issues.apache.org/jira/browse/FLINK
Filesystems are supposed to be used as plugins (by putting the jars
under plugins/ instead of lib/), in which case they are loaded
separately from other classes, specifically user-code.
https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/plugins.html
On 14/08/2020 20:25, Satish Sa
What about filling in at least the most critical holes in the State
Processor API? As it stands now, many of its supposed benefits (e.g.,
migrate between state backends, change max parallelism) can't be realized
for applications that use windows.
https://issues.apache.org/jira/browse/FLINK-13095 -
What about the work of migrating some Flink sources to the new FLIP-27
source interface? They are not listed in the 1.12 release wiki page.
On Thu, Aug 13, 2020 at 6:51 PM Dian Fu wrote:
> Hi Rodrigo,
>
> Both FLIP-130 and FLIP-133 will be in the list of 1.12. Besides, there are
> also some othe
Hi team,
Was there a reason for not shading hadoop-common
https://github.com/apache/flink/commit/e1e7d7f7ecc080c850a264021bf1b20e3d27d373#diff-e7b798a682ee84ab804988165e99761cR38-R44
? This is leaking lots of classes such as guava and causing issues in our
flink application.
I see that hadoop-comm
weizihan created FLINK-18964:
Summary: package org.apache.flink.sql.parser.impl does not exist
Key: FLINK-18964
URL: https://issues.apache.org/jira/browse/FLINK-18964
Project: Flink
Issue Type: B
Matthias created FLINK-18963:
Summary: Added Copyright information to coding style guide
Key: FLINK-18963
URL: https://issues.apache.org/jira/browse/FLINK-18963
Project: Flink
Issue Type: Improve
Thanks Thomas for reporting the problem, analysing which commit has caused
and now for the verification that it was fixed :) Much appreciated.
Piotrek
czw., 13 sie 2020 o 18:18 Thomas Weise napisał(a):
> Hi Roman,
>
> Thanks for working on this! I deployed the change and it appears to be
> work
Nico Kruber created FLINK-18962:
---
Summary: Improve error message if checkpoint directory is not
writable
Key: FLINK-18962
URL: https://issues.apache.org/jira/browse/FLINK-18962
Project: Flink
Ryan created FLINK-18961:
Summary: In the case of FlatMap linking map, if map returns null,
an exception will be thrown in FlatMap
Key: FLINK-18961
URL: https://issues.apache.org/jira/browse/FLINK-18961
Proj
xiaohang.li created FLINK-18960:
---
Summary: flink sideoutput union
Key: FLINK-18960
URL: https://issues.apache.org/jira/browse/FLINK-18960
Project: Flink
Issue Type: Bug
Components: AP
Liu created FLINK-18959:
---
Summary: Fail to archiveExecutionGraph because job is not finished
when dispatcher close
Key: FLINK-18959
URL: https://issues.apache.org/jira/browse/FLINK-18959
Project: Flink
Shengkai Fang created FLINK-18958:
-
Summary: Lose column comment when create table
Key: FLINK-18958
URL: https://issues.apache.org/jira/browse/FLINK-18958
Project: Flink
Issue Type: Bug
Andrey Zagrebin created FLINK-18957:
---
Summary: Implement bulk fulfil-ability timeout tracking for shared
slots
Key: FLINK-18957
URL: https://issues.apache.org/jira/browse/FLINK-18957
Project: Flink
Dian Fu created FLINK-18956:
---
Summary: StreamTask.invoke should catch Throwable instead of
Exception
Key: FLINK-18956
URL: https://issues.apache.org/jira/browse/FLINK-18956
Project: Flink
Issue Ty
Nico Kruber created FLINK-18955:
---
Summary: Add snapshot path to job startup message
Key: FLINK-18955
URL: https://issues.apache.org/jira/browse/FLINK-18955
Project: Flink
Issue Type: Improvemen
Hequn Cheng created FLINK-18954:
---
Summary: Add documentation for Metrics in Python DataStream API.
Key: FLINK-18954
URL: https://issues.apache.org/jira/browse/FLINK-18954
Project: Flink
Issue T
Hequn Cheng created FLINK-18953:
---
Summary: Add documentation for DataTypes in Python DataStream API
Key: FLINK-18953
URL: https://issues.apache.org/jira/browse/FLINK-18953
Project: Flink
Issue
Hequn Cheng created FLINK-18952:
---
Summary: Add 10 minutes to DataStream API documentation
Key: FLINK-18952
URL: https://issues.apache.org/jira/browse/FLINK-18952
Project: Flink
Issue Type: Sub-
Shuiqiang Chen created FLINK-18950:
--
Summary: Add documentation for Operations in Python DataStream
API.
Key: FLINK-18950
URL: https://issues.apache.org/jira/browse/FLINK-18950
Project: Flink
Shuiqiang Chen created FLINK-18951:
--
Summary: Add documentation for Configurations in Python DataStream
API.
Key: FLINK-18951
URL: https://issues.apache.org/jira/browse/FLINK-18951
Project: Flink
Hequn Cheng created FLINK-18949:
---
Summary: Support Streaming File Sink for Python DataStream API
Key: FLINK-18949
URL: https://issues.apache.org/jira/browse/FLINK-18949
Project: Flink
Issue Typ
Hequn Cheng created FLINK-18948:
---
Summary: Add end to end test for Python DataStream API
Key: FLINK-18948
URL: https://issues.apache.org/jira/browse/FLINK-18948
Project: Flink
Issue Type: Sub-t
Hequn Cheng created FLINK-18947:
---
Summary: Support partitionCustom() operation for Python DataStream
API
Key: FLINK-18947
URL: https://issues.apache.org/jira/browse/FLINK-18947
Project: Flink
Shuiqiang Chen created FLINK-18946:
--
Summary: Support Cassandra connector for Python DataStream API
Key: FLINK-18946
URL: https://issues.apache.org/jira/browse/FLINK-18946
Project: Flink
Iss
Hequn Cheng created FLINK-18945:
---
Summary: Support key_by() on ConnectedStreams for Python
DataStream API
Key: FLINK-18945
URL: https://issues.apache.org/jira/browse/FLINK-18945
Project: Flink
Shuiqiang Chen created FLINK-18944:
--
Summary: Support JDBC connector for Python DataStream API
Key: FLINK-18944
URL: https://issues.apache.org/jira/browse/FLINK-18944
Project: Flink
Issue Ty
Hequn Cheng created FLINK-18943:
---
Summary: Support connect() operation for Python DataStream API
Key: FLINK-18943
URL: https://issues.apache.org/jira/browse/FLINK-18943
Project: Flink
Issue Typ
29 matches
Mail list logo
