Matthias Pohl created FLINK-26175:
-
Summary: Make local cleanup being called in global cleanup
situations
Key: FLINK-26175
URL: https://issues.apache.org/jira/browse/FLINK-26175
Project: Flink
Yun Gao created FLINK-26174:
---
Summary: KinesisDataStreamsSink.restoreWriter failed due to
Architecture Violation
Key: FLINK-26174
URL: https://issues.apache.org/jira/browse/FLINK-26174
Project: Flink
Jingsong Lee created FLINK-26173:
Summary: Sink GlobalCommitter's behavior is not compatible
Key: FLINK-26173
URL: https://issues.apache.org/jira/browse/FLINK-26173
Project: Flink
Issue Type:
backspace created FLINK-26172:
-
Summary: some sql in `Table API&Sql` has syntax error
Key: FLINK-26172
URL: https://issues.apache.org/jira/browse/FLINK-26172
Project: Flink
Issue Type: Improvemen
Thanks for the explanation.
Given that it is unrelated with java version in Flink.
Starting with java11 for the flink-kubernetes-operator makes sense to me.
Best,
Yang
Thomas Weise 于2022年2月15日周二 23:57写道：
> Hi,
>
> At this point I see no reason to support Java 8 for a new project.
> Java 8 is b
Hi Gyula!
Alright! For clarity, the savepoint path and other savepoint related
configuration can be put into flinkConfiguration.
On the side, I think the automatic savepoint generation for instance should
be put into JobSpec along with other job options, and FlinkConfiguration
only configures what
Xuannan Su created FLINK-26171:
--
Summary: pyFlink -py options has issue with path that starts with
//
Key: FLINK-26171
URL: https://issues.apache.org/jira/browse/FLINK-26171
Project: Flink
Issu
zhangqw152 created FLINK-26170:
--
Summary: checkpoint time it too long
Key: FLINK-26170
URL: https://issues.apache.org/jira/browse/FLINK-26170
Project: Flink
Issue Type: Bug
Reporte
Echo Lee created FLINK-26169:
Summary: There is a typo in the annotation for the
WatermarkAlignmentParams class
Key: FLINK-26169
URL: https://issues.apache.org/jira/browse/FLINK-26169
Project: Flink
Lijie Wang created FLINK-26168:
--
Summary: The judgment of chainable ignores StreamExchangeMode when
partitioner is ForwardForConsecutiveHashPartitioner
Key: FLINK-26168
URL: https://issues.apache.org/jira/browse/FLIN
godfrey he created FLINK-26167:
--
Summary: Explicitly set the partitioner for the sql operators
whose shuffle and sort are removed
Key: FLINK-26167
URL: https://issues.apache.org/jira/browse/FLINK-26167
P
Gabor Somogyi created FLINK-26166:
-
Summary: flink-runtime-web fails to compile if newline is cr lf
Key: FLINK-26166
URL: https://issues.apache.org/jira/browse/FLINK-26166
Project: Flink
Issu
Roman Khachatryan created FLINK-26165:
-
Summary: SavepointFormatITCase fails on azure
Key: FLINK-26165
URL: https://issues.apache.org/jira/browse/FLINK-26165
Project: Flink
Issue Type: Bu
Hi,
At this point I see no reason to support Java 8 for a new project.
Java 8 is being phased out, we should start with 11.
Also, since the operator isn't a library but effectively just a docker
image, the ability to change the Java version isn't as critical as it
is for Flink core, which needs t
+1 (non-binding)
- signatures OK
- checksums OK
- tag OK
- all artifacts OK
- PR OK
run examples
--
Best regards,
Anton Kalashnikov
15.02.2022 09:30, Dawid Wysakowicz пишет:
+1 (binding)
- signatures OK
- checksums OK
- tag OK
- PR looks good
- built from sources
- run example
- checke
Dawid Wysakowicz created FLINK-26164:
Summary: Document watermark alignment
Key: FLINK-26164
URL: https://issues.apache.org/jira/browse/FLINK-26164
Project: Flink
Issue Type: Sub-task
Good catch, Yang Wang and Gyula on the Java version. I personally prefer
that we simply can not support Java 8 for the operator, since it is a net
new project we are better off starting support at Java 11 right away.
As Gyula outlined above, it is important to note that it only affects the
operato
Gyula Fora created FLINK-26163:
--
Summary: Refactor FlinkUtils#getEffectiveConfig into smaller pieces
Key: FLINK-26163
URL: https://issues.apache.org/jira/browse/FLINK-26163
Project: Flink
Issue
Daisy Tsang created FLINK-26162:
---
Summary: Revamp security section of the documentation
Key: FLINK-26162
URL: https://issues.apache.org/jira/browse/FLINK-26162
Project: Flink
Issue Type: Improv
Hi Devs,
Yang Wang discovered that the current prototype is not compatible with Java
8 but only 11 and upwards.
The reason for this is that the java operator SDK itself is not java 8
compatible unfortunately.
Given that Java 8 is on the road to deprecation and that the operator runs
as a contain
Yufei Zhang created FLINK-26161:
---
Summary: Pulsar Connector: edge case: splits should be added to
finishedSplits if was empty from beginning
Key: FLINK-26161
URL: https://issues.apache.org/jira/browse/FLINK-26161
Yufei Zhang created FLINK-26160:
---
Summary: Pulsar Connector: stopCursor description should be
changed. Connector only stop when auto discovery is disabled.
Key: FLINK-26160
URL: https://issues.apache.org/jira/browse
Yufei Zhang created FLINK-26159:
---
Summary: Pulsar Connector: should add description MAX_FETCH_RECORD
in doc to explain slow consumption
Key: FLINK-26159
URL: https://issues.apache.org/jira/browse/FLINK-26159
I also lean to not introduce the savepoint/checkpoint related fields to the
job spec, especially in the very beginning of flink-kubernetes-operator.
Best,
Yang
Gyula Fóra 于2022年2月15日周二 19:02写道：
> Hi Peng Yuan!
>
> While I do agree that savepoint path is a very important production
> configurat
Hi Peng Yuan!
While I do agree that savepoint path is a very important production
configuration there are a lot of other things that come to my mind:
- savepoint dir
- checkpoint dir
- checkpoint interval/timeout
- high availability settings (provider/storagedir etc)
just to name a few...
Wh
Till Rohrmann created FLINK-26158:
-
Summary: Update statefun-playground examples to use playground
ingress/egress
Key: FLINK-26158
URL: https://issues.apache.org/jira/browse/FLINK-26158
Project: Flink
Matyas Orhidi created FLINK-26157:
-
Summary: Containers Should Not Run As Root
Key: FLINK-26157
URL: https://issues.apache.org/jira/browse/FLINK-26157
Project: Flink
Issue Type: Sub-task
tao.yang03 created FLINK-26156:
--
Summary: Event Time Temporal Join Watermark lag
Key: FLINK-26156
URL: https://issues.apache.org/jira/browse/FLINK-26156
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-26155:
-
Summary: Add playground ingress/egress for cURL interaction
Key: FLINK-26155
URL: https://issues.apache.org/jira/browse/FLINK-26155
Project: Flink
Issue Ty
Roman Khachatryan created FLINK-26154:
-
Summary: SavepointFormatITCase fails on azure
Key: FLINK-26154
URL: https://issues.apache.org/jira/browse/FLINK-26154
Project: Flink
Issue Type: Bu
Till Rohrmann created FLINK-26153:
-
Summary: Add script to update README playground links for Statefun
Key: FLINK-26153
URL: https://issues.apache.org/jira/browse/FLINK-26153
Project: Flink
I
Hi Matyas!
Thanks for your reply!
For 1. and 3. scenarios，I couldn't agree more with the podTemplate solution
, i missed this part.
For savepoint related configuration, I think it's very important to be
specified in JobSpec, Because savepoint is a very common configuration for
upgrading a job, if
wenyibo created FLINK-26152:
---
Summary: Translate the page of SQL/queries/WITH clause
Key: FLINK-26152
URL: https://issues.apache.org/jira/browse/FLINK-26152
Project: Flink
Issue Type: Improvement
WangXiaoyong created FLINK-26151:
Summary: inprogressfileRecoverable not be clean up after restoring
the bucket
Key: FLINK-26151
URL: https://issues.apache.org/jira/browse/FLINK-26151
Project: Flink
Aiden Gong created FLINK-26150:
--
Summary: [pulsar] enable requestTimeoutMs configuration
Key: FLINK-26150
URL: https://issues.apache.org/jira/browse/FLINK-26150
Project: Flink
Issue Type: Improv
Jing Ge created FLINK-26149:
---
Summary: Build ArchUnit rule for connector reference
implementation after connector has been moved to the external repo
Key: FLINK-26149
URL: https://issues.apache.org/jira/browse/FLINK-26
Lijie Wang created FLINK-26148:
--
Summary: Change the format of adaptive batch scheduler config
option to "jobmanager.adaptive-batch-scheduler.XXX"
Key: FLINK-26148
URL: https://issues.apache.org/jira/browse/FLINK-261
jackylau created FLINK-26145:
Summary: k8s docs jobmanager-pod-template
artifacts-fetcher:latest image is not exist, we can use busybox to replace it
Key: FLINK-26145
URL: https://issues.apache.org/jira/browse/FLINK
Piotr Nowojski created FLINK-26147:
--
Summary: Deleting incremental savepoints directory in CLAIM mode
Key: FLINK-26147
URL: https://issues.apache.org/jira/browse/FLINK-26147
Project: Flink
I
Piotr Nowojski created FLINK-26146:
--
Summary: Add test coverage for native format flink upgrades (minor
versions)
Key: FLINK-26146
URL: https://issues.apache.org/jira/browse/FLINK-26146
Project: Flin
Roman Khachatryan created FLINK-26144:
-
Summary: SavepointFormatITCase did NOT fail with changelog.enabled
randomized
Key: FLINK-26144
URL: https://issues.apache.org/jira/browse/FLINK-26144
Proje
Hi Peng,
Thanks for your feedback. Regarding 1. and 3. scenarios, the podTemplate
functionality in the operator could cover both. We also need to be careful
about introducing proxy parameters in the CRD spec. The savepoint path is
usually accompanied with a bunch of other configurations for exampl
+1 (binding)
- signatures OK
- checksums OK
- tag OK
- PR looks good
- built from sources
- run example
- checked dependency version changes from 1.13.5 and notice files
Best,
Dawid
On 05/02/2022 21:06, Konstantin Knauf wrote:
Hi everyone,
Please review and vote on the release candidate
43 matches
Mail list logo
