Re:[jira] [Created] (FLINK-21685) Flink JobManager failed to restart in K8S HA setup

2021-03-08 Thread 戴林巍
Hello, looking at your error, it should be that the file could not be found, or there was a communication problem. Let me ask if your flink on k8s uses the StatefulSet mode? Or can you find the location of ck storage now? At 2021-03-09 15:23:00, "Peng Zhang (Jira)" wrote: >Peng

[jira] [Created] (FLINK-21685) Flink JobManager failed to restart in K8S HA setup

2021-03-08 Thread Peng Zhang (Jira)
Peng Zhang created FLINK-21685: -- Summary: Flink JobManager failed to restart in K8S HA setup Key: FLINK-21685 URL: https://issues.apache.org/jira/browse/FLINK-21685 Project: Flink Issue Type: Bu

Re: [DISCUSS] FLIP-162 follow-up discussion

2021-03-08 Thread Kurt Young
Hi Leonard, Thanks for this careful consideration. Given the fallback option will eventually change the behavior twice, which means potentially break user's job twice, I would also +1 to not introduce it. Best, Kurt On Fri, Mar 5, 2021 at 3:00 PM Leonard Xu wrote: > Hi, all > > As the FLIP-16

Re: [ANNOUNCE] Apache Flink 1.12.2 released

2021-03-08 Thread Leonard Xu
Well done! Thanks to Roman and Yuan, and everyone who contributed to the release. Best, Leonard > 在 2021年3月9日,11:39,Zhu Zhu 写道: > > Thanks Roman and Yuan for being the release managers! Thanks everyone who has > made this release possible! > > Cheers, > Zhu > > Piotr Nowojski mailto:pnowoj.

[jira] [Created] (FLINK-21684) Fix typo in StreamExecDeduplicate

2021-03-08 Thread wangpeibin (Jira)
wangpeibin created FLINK-21684: -- Summary: Fix typo in StreamExecDeduplicate Key: FLINK-21684 URL: https://issues.apache.org/jira/browse/FLINK-21684 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-21683) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader

2021-03-08 Thread ying zhang (Jira)
ying zhang created FLINK-21683: -- Summary: java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader Key: FLINK-21683 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-21682) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader

2021-03-08 Thread ying zhang (Jira)
ying zhang created FLINK-21682: -- Summary: java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader Key: FLINK-21682 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-21681) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader

2021-03-08 Thread ying zhang (Jira)
ying zhang created FLINK-21681: -- Summary: java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader Key: FLINK-21681 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-21680) Table Created with LIKE clause may get unexpected options "is_generic"

2021-03-08 Thread Xiaodong Chen (Jira)
Xiaodong Chen created FLINK-21680: - Summary: Table Created with LIKE clause may get unexpected options "is_generic" Key: FLINK-21680 URL: https://issues.apache.org/jira/browse/FLINK-21680 Project: Fli

[jira] [Created] (FLINK-21679) Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

2021-03-08 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-21679: - Summary: Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan Key: FLINK-21679 URL: https://issues.apache.org/jira/browse/FLIN

Re: [ANNOUNCE] Apache Flink 1.12.2 released

2021-03-08 Thread Zhu Zhu
Thanks Roman and Yuan for being the release managers! Thanks everyone who has made this release possible! Cheers, Zhu Piotr Nowojski 于2021年3月6日周六 上午12:38写道: > Thanks Roman and Yuan for your work and driving the release process :) > > pt., 5 mar 2021 o 15:53 Till Rohrmann napisał(a): > >> Great

Re: [VOTE] FLIP-165: Operator's Flame Graphs

2021-03-08 Thread Zhu Zhu
+1 (binding) Thanks, Zhu Piotr Nowojski 于2021年3月6日周六 上午12:22写道: > +1 (binding) > > pt., 5 mar 2021 o 17:20 Roman Khachatryan napisał(a): > > > +1 (binding) > > > > Regards, > > Roman > > > > On Fri, Mar 5, 2021 at 3:59 PM Till Rohrmann > wrote: > > > > > > +1 (binding) > > > > > > Cheers, > >

[jira] [Created] (FLINK-21678) Rename Expiration.expiresAfterReadOrWrite to Expiration.expiresAfterCall in StateFun

2021-03-08 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-21678: --- Summary: Rename Expiration.expiresAfterReadOrWrite to Expiration.expiresAfterCall in StateFun Key: FLINK-21678 URL: https://issues.apache.org/jira/browse/FLINK-21678

[jira] [Created] (FLINK-21677) org.apache.flink.test.state.operator.restore.unkeyed.ChainBreakTest hangs

2021-03-08 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-21677: - Summary: org.apache.flink.test.state.operator.restore.unkeyed.ChainBreakTest hangs Key: FLINK-21677 URL: https://issues.apache.org/jira/browse/FLINK-21677 Project: Flink

[jira] [Created] (FLINK-21676) Ensure that state names are valid identifiers in the StateFun Java SDK

2021-03-08 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-21676: --- Summary: Ensure that state names are valid identifiers in the StateFun Java SDK Key: FLINK-21676 URL: https://issues.apache.org/jira/browse/FLINK-21676

[jira] [Created] (FLINK-21675) Push filter into the scan when watermark assigner is the parent of the table scan

2021-03-08 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-21675: - Summary: Push filter into the scan when watermark assigner is the parent of the table scan Key: FLINK-21675 URL: https://issues.apache.org/jira/browse/FLINK-21675 P

[jira] [Created] (FLINK-21674) JDBC sink can't get valid connection after 5 minutes using Oracle JDBC driver

2021-03-08 Thread Fuyao (Jira)
Fuyao created FLINK-21674: - Summary: JDBC sink can't get valid connection after 5 minutes using Oracle JDBC driver Key: FLINK-21674 URL: https://issues.apache.org/jira/browse/FLINK-21674 Project: Flink

Re: [ANNOUCE][DISCUSS] Roadmap Update for Website

2021-03-08 Thread Stephan Ewen
Thanks, Robert! As far as I understand, the Reactive Mode is not yet released, that's why I didn't put it there. The radar should be updated after each release. What do you think? On Sat, Mar 6, 2021 at 3:41 PM Robert Metzger wrote: > Thanks a lot for updating the roadmap! > > I really like th

[jira] [Created] (FLINK-21673) Add extension points to heap backend to read/write incremental snapshots

2021-03-08 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-21673: - Summary: Add extension points to heap backend to read/write incremental snapshots Key: FLINK-21673 URL: https://issues.apache.org/jira/browse/FLINK-21673 Pr

[jira] [Created] (FLINK-21672) End to end tests (streaming) aren't Java vendor neutral (sun.management bean used)

2021-03-08 Thread Adam Roberts (Jira)
Adam Roberts created FLINK-21672: Summary: End to end tests (streaming) aren't Java vendor neutral (sun.management bean used) Key: FLINK-21672 URL: https://issues.apache.org/jira/browse/FLINK-21672 Pr

[jira] [Created] (FLINK-21671) some condition expressions can be simplified in org.apache.flink.yarn.YarnClusterDescriptor

2021-03-08 Thread zhangyongquan (Jira)
zhangyongquan created FLINK-21671: - Summary: some condition expressions can be simplified in org.apache.flink.yarn.YarnClusterDescriptor Key: FLINK-21671 URL: https://issues.apache.org/jira/browse/FLINK-21671

[jira] [Created] (FLINK-21670) Bump log4j version to 2.8.2

2021-03-08 Thread Adam Roberts (Jira)
Adam Roberts created FLINK-21670: Summary: Bump log4j version to 2.8.2 Key: FLINK-21670 URL: https://issues.apache.org/jira/browse/FLINK-21670 Project: Flink Issue Type: Bug Repor

[jira] [Created] (FLINK-21669) Support "table.dml-sync" option to execute DML statements synchronizely in TableEnvironment and SQL Client

2021-03-08 Thread Jark Wu (Jira)
Jark Wu created FLINK-21669: --- Summary: Support "table.dml-sync" option to execute DML statements synchronizely in TableEnvironment and SQL Client Key: FLINK-21669 URL: https://issues.apache.org/jira/browse/FLINK-21669

[jira] [Created] (FLINK-21668) A writing error in org.apache.flink.sql.parser.ddl.SqlCreateDatabase

2021-03-08 Thread humengyu (Jira)
humengyu created FLINK-21668: Summary: A writing error in org.apache.flink.sql.parser.ddl.SqlCreateDatabase Key: FLINK-21668 URL: https://issues.apache.org/jira/browse/FLINK-21668 Project: Flink

[jira] [Created] (FLINK-21667) Standby RM might remove resources from Kubernetes

2021-03-08 Thread Xintong Song (Jira)
Xintong Song created FLINK-21667: Summary: Standby RM might remove resources from Kubernetes Key: FLINK-21667 URL: https://issues.apache.org/jira/browse/FLINK-21667 Project: Flink Issue Type:

[jira] [Created] (FLINK-21666) Consistent documentation and recommendations regarding Stop vs Cancel with savepoint

2021-03-08 Thread Thomas Eckestad (Jira)
Thomas Eckestad created FLINK-21666: --- Summary: Consistent documentation and recommendations regarding Stop vs Cancel with savepoint Key: FLINK-21666 URL: https://issues.apache.org/jira/browse/FLINK-21666

[jira] [Created] (FLINK-21665) Create catalog statement should support [IF NOT EXIST] and [COMMENT]

2021-03-08 Thread humengyu (Jira)
humengyu created FLINK-21665: Summary: Create catalog statement should support [IF NOT EXIST] and [COMMENT] Key: FLINK-21665 URL: https://issues.apache.org/jira/browse/FLINK-21665 Project: Flink

[jira] [Created] (FLINK-21664) Support STATEMENT SET syntax in TableEnvironment

2021-03-08 Thread Jark Wu (Jira)
Jark Wu created FLINK-21664: --- Summary: Support STATEMENT SET syntax in TableEnvironment Key: FLINK-21664 URL: https://issues.apache.org/jira/browse/FLINK-21664 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21663) Reject duplicate StatefulFunction registrations under the same typename

2021-03-08 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-21663: --- Summary: Reject duplicate StatefulFunction registrations under the same typename Key: FLINK-21663 URL: https://issues.apache.org/jira/browse/FLINK-21663

Re: [DISCUSS]FLIP-150: Introduce Hybrid Source

2021-03-08 Thread Nicholas Jiang
Hi Kezhu, Thanks for your detailed points for the Hybrid Source. I follow your opinions and make a corresponding explanation as follows: 1.Would the Hybrid Source be possible to use this feature to switch/chain multiple homogeneous sources? "HybridSource" supports to switch/chain multiple homoge

[jira] [Created] (FLINK-21662) Reject duplicate ValueSpec registrations under the same state name

2021-03-08 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-21662: --- Summary: Reject duplicate ValueSpec registrations under the same state name Key: FLINK-21662 URL: https://issues.apache.org/jira/browse/FLINK-21662 Proj

[jira] [Created] (FLINK-21661) SHARD_GETRECORDS_INTERVAL_MILLIS wrong use?

2021-03-08 Thread jiamo (Jira)
jiamo created FLINK-21661: - Summary: SHARD_GETRECORDS_INTERVAL_MILLIS wrong use? Key: FLINK-21661 URL: https://issues.apache.org/jira/browse/FLINK-21661 Project: Flink Issue Type: Bug Comp

Re: [DISCUSS]FLIP-150: Introduce Hybrid Source

2021-03-08 Thread Nicholas Jiang
Hi Thomas, Thanks for your detailed reply for the design of Hybrid Source. I would reply to the questions you mentioned as follows: 1.Has there been related activity since the FLIP was created? Yes, the FLIP has the initial version of Hybrid Source implementation. You'd better refer to the reposit

[jira] [Created] (FLINK-21660) create table can not like with hive catalog table

2021-03-08 Thread liqiang.liu (Jira)
liqiang.liu created FLINK-21660: --- Summary: create table can not like with hive catalog table Key: FLINK-21660 URL: https://issues.apache.org/jira/browse/FLINK-21660 Project: Flink Issue Type: B