silence created FLINK-22707:
---
Summary: StatementSet support exectue(jobName)
Key: FLINK-22707
URL: https://issues.apache.org/jira/browse/FLINK-22707
Project: Flink
Issue Type: New Feature
Fuyao Li created FLINK-22706:
Summary: The NOTICE file of Flink repo should be updated
Key: FLINK-22706
URL: https://issues.apache.org/jira/browse/FLINK-22706
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22705:
-
Summary: SQL Client end-to-end test (Old planner) Elasticsearch
(v7.5.1) failed due to fail to download the tar
Key: FLINK-22705
URL: https://issues.apache.org/jira/browse/FLINK-22705
Guowei Ma created FLINK-22704:
-
Summary: ZooKeeperHaServicesTest.testCleanupJobData failed
Key: FLINK-22704
URL: https://issues.apache.org/jira/browse/FLINK-22704
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22703:
-
Summary:
SavepointITCase.testTriggerSavepointAndResumeWithFileBasedCheckpoints failed
Key: FLINK-22703
URL: https://issues.apache.org/jira/browse/FLINK-22703
Project:
Guowei Ma created FLINK-22702:
-
Summary: KafkaSourceITCase.testRedundantParallelism failed
Key: FLINK-22702
URL: https://issues.apache.org/jira/browse/FLINK-22702
Project: Flink
Issue Type: Bug
Update: opened an issue and a PR.
https://issues.apache.org/jira/browse/FLINK-22700
https://github.com/apache/flink/pull/15950
On Tue, May 18, 2021 at 10:03 AM Eron Wright
wrote:
> Thanks Arvid and David for sharing your ideas on this subject. I'm glad
> to hear that you're seeing use cases
Jinliang Guo created FLINK-22701:
Summary: "bin/flink savepoint -d :savepointpath" cannot locate
savepointpath arg
Key: FLINK-22701
URL: https://issues.apache.org/jira/browse/FLINK-22701
Project:
Eron Wright created FLINK-22700:
---
Summary: Propagate watermarks to Sink API
Key: FLINK-22700
URL: https://issues.apache.org/jira/browse/FLINK-22700
Project: Flink
Issue Type: Improvement
Nico Kruber created FLINK-22699:
---
Summary: Make ConstantArgumentCount public API
Key: FLINK-22699
URL: https://issues.apache.org/jira/browse/FLINK-22699
Project: Flink
Issue Type: Improvement
Austin Cawley-Edwards created FLINK-22698:
-
Summary: RabbitMQ source does not stop unless message arrives in
queue
Key: FLINK-22698
URL: https://issues.apache.org/jira/browse/FLINK-22698
Thanks Arvid and David for sharing your ideas on this subject. I'm glad to
hear that you're seeing use cases for watermark propagation via an enhanced
sink interface.
As you've guessed, my interest is in Pulsar and am exploring some options
for brokering watermarks across stream processing
Hi Konstantin,
Would it be possible to add FLINK-22646 [1] into the release? This is a
regression, that we need to workaround in order to support 1.13.x in Apache
Beam [2].
Best,
D.
[1] https://issues.apache.org/jira/browse/FLINK-22646
[2] https://github.com/apache/beam/pull/14719
On Tue, May
Timo Walther created FLINK-22697:
Summary: Clean up examples to not use legacy planner anymore
Key: FLINK-22697
URL: https://issues.apache.org/jira/browse/FLINK-22697
Project: Flink
Issue
Fabian Paul created FLINK-22696:
---
Summary: Enable Confluent Schema Registry Test on jdk 11
Key: FLINK-22696
URL: https://issues.apache.org/jira/browse/FLINK-22696
Project: Flink
Issue Type:
Hi Eron,
Thanks for starting this discussion. I've been thinking about this recently
as we've run into "watermark related" issues, when chaining multiple
pipelines together. My to cents to the discussion:
How I like to think about the problem, is that there should an invariant
that holds for any
Matthias created FLINK-22695:
Summary: Update Flink's Code Style and Quality Guide to match the
Google Java Format style introduced
Key: FLINK-22695
URL: https://issues.apache.org/jira/browse/FLINK-22695
Thanks for initiating this discussion, Konstantin. FLINK-22494 [1] (Avoid
discarding checkpoints in case of failure) is reviewed and backported. I
have FLINK-22688 [2] (exception history not working properly for unassigned
tasks) that came up recently. I provided a fix for it [3] already and hope
Shengkai Fang created FLINK-22694:
-
Summary: Refactor TPCH end to end tests
Key: FLINK-22694
URL: https://issues.apache.org/jira/browse/FLINK-22694
Project: Flink
Issue Type: Improvement
Hi Diogo,
the idea is that a savepoint operation can also fail. The status only
denotes whether the savepoint operation is still in-progress or completed
because it is an asynchronous operation. A savepoint operation can be
completed if it succeeded or if it failed. The failure cause should tell
sadf created FLINK-22693:
Summary: EXPLAIN cannot be used on Hbase table when useing ROW type
Key: FLINK-22693
URL: https://issues.apache.org/jira/browse/FLINK-22693
Project: Flink
Issue
Robert Metzger created FLINK-22692:
--
Summary: CheckpointStoreITCase.testRestartOnRecoveryFailure fails
with RuntimeException
Key: FLINK-22692
URL: https://issues.apache.org/jira/browse/FLINK-22692
Hi Eron,
I think this is a useful addition for storage systems that act as
pass-through for Flink to reduce recovery time. It is only useful if you
combine it with regional fail-over as only a small part of the pipeline is
restarted.
A couple of thoughts on the implications:
1. Watermarks are
23 matches
Mail list logo
