Jingsong Lee created FLINK-15006:
Summary: Add option to close shuffle when dynamic partition
inserting
Key: FLINK-15006
URL: https://issues.apache.org/jira/browse/FLINK-15006
Project: Flink
Aljoscha Krettek created FLINK-15007:
Summary: Flink on YARN does not request required TaskExecutors in
some cases
Key: FLINK-15007
URL: https://issues.apache.org/jira/browse/FLINK-15007
Project:
Hi Jingsong,
Thanks a lot for your comments. Please see my reply inlined below.
> 在 2019年12月2日，下午3:47，Jingsong Lee 写道：
>
> Hi Dian:
>
>
> Thanks for your driving. I have some questions:
>
>
> - Where should these configurations belong? You have mentioned tableApi/SQL,
> so should in TableCo
Hi Jingsong,
It's fine. :) Appreciated the comments!
I have replied you in the discussion thread as I also think it's better to
discuss these in the discussion thread.
Thanks,
Dian
> 在 2019年12月2日，下午3:47，Jingsong Li 写道：
>
> Sorry for bothering your voting.
> Let's discuss in discussion thre
Would security@f.a.o work as any other private ML?
Contrary to what Becket said in the discussion thread,
secur...@apache.org is not just "another hop"; it provides guiding
material, the security team checks for activity and can be pinged easily
as they are cc'd in the initial report.
I vast
Hi Dian:
Thanks for you explanation.
If you can update the document to add explanation for the changes to the
table layer,
it might be better. (it's just a suggestion, it depends on you)
About forwardedInputQueue in AbstractPythonScalarFunctionOperator,
Will this queue take up a lot of memory?
C
Gary Yao created FLINK-15008:
Summary: Tests in flink-yarn-tests fail with
ClassNotFoundException (JDK11)
Key: FLINK-15008
URL: https://issues.apache.org/jira/browse/FLINK-15008
Project: Flink
I
Timo Walther created FLINK-15009:
Summary: Add a utility for creating type inference logic via
reflection
Key: FLINK-15009
URL: https://issues.apache.org/jira/browse/FLINK-15009
Project: Flink
Nico Kruber created FLINK-15010:
---
Summary: Temp directories flink-netty-shuffle-* are not cleaned up
Key: FLINK-15010
URL: https://issues.apache.org/jira/browse/FLINK-15010
Project: Flink
Issue
Nico Kruber created FLINK-15011:
---
Summary: RocksDB temp directory not cleaned up
Key: FLINK-15011
URL: https://issues.apache.org/jira/browse/FLINK-15011
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-15012:
---
Summary: Checkpoint directory not cleaned up
Key: FLINK-15012
URL: https://issues.apache.org/jira/browse/FLINK-15012
Project: Flink
Issue Type: Improvement
Aljoscha Krettek created FLINK-15013:
Summary: Flink (on YARN) sometimes needs too many slots
Key: FLINK-15013
URL: https://issues.apache.org/jira/browse/FLINK-15013
Project: Flink
Issue
Seth Wiesman created FLINK-15014:
Summary: Refactor KeyedStateInputFormat to support multiple types
of user functions
Key: FLINK-15014
URL: https://issues.apache.org/jira/browse/FLINK-15014
Project: F
Hi all,
I'd like to discuss dropping vendor-specific deployment documentation from
Flink's official docs. To be clear, I am *NOT* suggesting we drop any of
the filesystem documentation, but the following three pages.
AWS:
https://ci.apache.org/projects/flink/flink-docs-master/ops/deployment/aws.h
+1 from my side to drop.
On Mon, Dec 2, 2019 at 6:34 PM Seth Wiesman wrote:
> Hi all,
>
> I'd like to discuss dropping vendor-specific deployment documentation from
> Flink's official docs. To be clear, I am *NOT* suggesting we drop any of
> the filesystem documentation, but the following three
Bowen Li created FLINK-15015:
Summary: add documentation for using orc reader in hive connector
Key: FLINK-15015
URL: https://issues.apache.org/jira/browse/FLINK-15015
Project: Flink
Issue Type:
César Soto Valero created FLINK-15016:
-
Summary: Remove unused dependency
Key: FLINK-15016
URL: https://issues.apache.org/jira/browse/FLINK-15016
Project: Flink
Issue Type: Improvement
Bowen Li created FLINK-15017:
Summary: add a thrift jdbc/odbc server for Flink
Key: FLINK-15017
URL: https://issues.apache.org/jira/browse/FLINK-15017
Project: Flink
Issue Type: New Feature
Seth Wiesman created FLINK-15018:
Summary: Add event time page to Concepts
Key: FLINK-15018
URL: https://issues.apache.org/jira/browse/FLINK-15018
Project: Flink
Issue Type: Improvement
Bowen Li created FLINK-15019:
Summary: publish blog and document Flink-Hive benchmark v.s. Hive
on MR/Tez
Key: FLINK-15019
URL: https://issues.apache.org/jira/browse/FLINK-15019
Project: Flink
I
Jingsong Lee created FLINK-15020:
Summary: Support timestamp type in hive
Key: FLINK-15020
URL: https://issues.apache.org/jira/browse/FLINK-15020
Project: Flink
Issue Type: Sub-task
Hi everyone,
Please review and vote on the release candidate #2 for the version 1.8.3,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
*
zhijiang created FLINK-15021:
Summary: Refactor to remove channelWritabilityChanged from
PartitionRequestQueue
Key: FLINK-15021
URL: https://issues.apache.org/jira/browse/FLINK-15021
Project: Flink
Danny Chen created FLINK-15022:
--
Summary: E2E View support in FLINK SQL
Key: FLINK-15022
URL: https://issues.apache.org/jira/browse/FLINK-15022
Project: Flink
Issue Type: Improvement
C
Sorry, I just realized that I've send my feedbacks to Jingsong's email
address, instead of the dev / user mailing list.
Please find my comments below.
Thank you~
Xintong Song
On Wed, Nov 27, 2019 at 4:32 PM Xintong Song wrote:
> As a participant of the discussion yesterday, I'm +1 for the pr
Xintong Song created FLINK-15023:
Summary: Remove on-heap managed memory
Key: FLINK-15023
URL: https://issues.apache.org/jira/browse/FLINK-15023
Project: Flink
Issue Type: Sub-task
Yingjie Cao created FLINK-15024:
---
Summary: System classloader memory leak after loading too many
codegen classes.
Key: FLINK-15024
URL: https://issues.apache.org/jira/browse/FLINK-15024
Project: Flink
Dian Fu created FLINK-15025:
---
Summary: The license and notice is not correct for the
flink-python module
Key: FLINK-15025
URL: https://issues.apache.org/jira/browse/FLINK-15025
Project: Flink
Issu
Hi Hequn,
+1 (non-binding) Thank you for driving this.
- Verified signatures and checksums
- Maven build from source skip tests (Scala 2.11 and Scala 2.12)
- Start local cluster and web ui is accessible (Scala 2.11 and Scala 2.12)
- Submit WordCount example of both batch and streaming, good (Scal
Danny Chen created FLINK-15026:
--
Summary: Support database DDLs in SQL CLI
Key: FLINK-15026
URL: https://issues.apache.org/jira/browse/FLINK-15026
Project: Flink
Issue Type: Sub-task
C
Danny Chen created FLINK-15027:
--
Summary: Support alter table DDLs in SQL CLI
Key: FLINK-15027
URL: https://issues.apache.org/jira/browse/FLINK-15027
Project: Flink
Issue Type: Sub-task
Yu Li created FLINK-15028:
-
Summary: YARNSessionFIFOSecuredITCase test failed with java11 on
travis
Key: FLINK-15028
URL: https://issues.apache.org/jira/browse/FLINK-15028
Project: Flink
Issue Type:
Yu Li created FLINK-15029:
-
Summary: Dependency shading of table modules test failed on travis
Key: FLINK-15029
URL: https://issues.apache.org/jira/browse/FLINK-15029
Project: Flink
Issue Type: Bug
Yingjie Cao created FLINK-15030:
---
Summary: Potential deadlock for bounded blocking ResultPartition.
Key: FLINK-15030
URL: https://issues.apache.org/jira/browse/FLINK-15030
Project: Flink
Issue
Zhu Zhu created FLINK-15031:
---
Summary: Calculate required shuffle memory cases before allocating
slots in resources specified
Key: FLINK-15031
URL: https://issues.apache.org/jira/browse/FLINK-15031
Project:
Guowei Ma created FLINK-15032:
-
Summary: Remove the eagerly serialization from
`RemoteRpcInvocation`
Key: FLINK-15032
URL: https://issues.apache.org/jira/browse/FLINK-15032
Project: Flink
Issue
36 matches
Mail list logo
