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
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
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
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.
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
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
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
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
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
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
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
+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,
> >
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
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
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
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
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
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
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
34 matches
Mail list logo
