[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-32123:
--
Priority: Blocker (was: Major)
> Avro Confluent Schema Registry nightly end-to-end test faile
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-32123:
--
Summary: Avro Confluent Schema Registry nightly end-to-end test failed due
to timeout (was: F
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723806#comment-17723806
]
David Morávek commented on FLINK-32123:
---
[https://dev.azure.com/apache-flink/apach
[
https://issues.apache.org/jira/browse/FLINK-32121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek closed FLINK-32121.
-
Resolution: Duplicate
> Avro Confluent Schema Registry nightly end-to-end test failed due to tim
[
https://issues.apache.org/jira/browse/FLINK-32124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723801#comment-17723801
]
Zhanghao Chen commented on FLINK-32124:
---
Thanks [~gyfora]. I'll follow up there.
[
https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723800#comment-17723800
]
Zhanghao Chen commented on FLINK-32119:
---
+1 for "partition skew is probably worse
dawidwys commented on code in PR #22588:
URL: https://github.com/apache/flink/pull/22588#discussion_r1197439356
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,110 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-32127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723798#comment-17723798
]
Gyula Fora commented on FLINK-32127:
cc [~mxm]
> Source busy time is inaccurate in
[
https://issues.apache.org/jira/browse/FLINK-32124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723796#comment-17723796
]
Gyula Fora commented on FLINK-32124:
This is related to https://issues.apache.org/ji
dmvk commented on code in PR #22603:
URL: https://github.com/apache/flink/pull/22603#discussion_r1197426232
##
flink-end-to-end-tests/test-scripts/kafka-common.sh:
##
@@ -37,7 +37,7 @@ MAX_RETRY_SECONDS=120
function setup_kafka_dist {
# download Kafka
mkdir -p $TEST_DATA_
[
https://issues.apache.org/jira/browse/FLINK-32127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-32127:
--
Description:
We found that source busy time is inaccurate in many cases. The reason is that
s
[
https://issues.apache.org/jira/browse/FLINK-32127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-32127:
--
Description:
We found that source busy time is inaccurate in many cases. The reason is that
s
Zhanghao Chen created FLINK-32127:
-
Summary: Source busy time is inaccurate in many cases
Key: FLINK-32127
URL: https://issues.apache.org/jira/browse/FLINK-32127
Project: Flink
Issue Type: Im
pgaref commented on code in PR #22603:
URL: https://github.com/apache/flink/pull/22603#discussion_r1197420627
##
flink-end-to-end-tests/test-scripts/kafka-common.sh:
##
@@ -37,7 +37,7 @@ MAX_RETRY_SECONDS=120
function setup_kafka_dist {
# download Kafka
mkdir -p $TEST_DAT
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723793#comment-17723793
]
David Morávek commented on FLINK-32123:
---
I'm opening a ticket with INFRA; the prop
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723792#comment-17723792
]
David Morávek commented on FLINK-32123:
---
> Lets switch to [https://downloads.apac
Elkhan Dadashov created FLINK-32126:
---
Summary: When program arg contains two single quotes
org.apache.flink.configuration.StructuredOptionsSplitter.consumeInQuotes fails
Key: FLINK-32126
URL: https://issues.apac
melin created FLINK-32125:
-
Summary: Support Unified job submission API
Key: FLINK-32125
URL: https://issues.apache.org/jira/browse/FLINK-32125
Project: Flink
Issue Type: New Feature
Repo
reswqa commented on code in PR #22603:
URL: https://github.com/apache/flink/pull/22603#discussion_r1197414843
##
flink-end-to-end-tests/test-scripts/kafka-common.sh:
##
@@ -37,7 +37,7 @@ MAX_RETRY_SECONDS=120
function setup_kafka_dist {
# download Kafka
mkdir -p $TEST_DAT
Zhanghao Chen created FLINK-32124:
-
Summary: Add option to enable partition alignment for sources
Key: FLINK-32124
URL: https://issues.apache.org/jira/browse/FLINK-32124
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723790#comment-17723790
]
Panagiotis Garefalakis commented on FLINK-32123:
Thanks much [~tanyuxin]
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan reassigned FLINK-32123:
-
Assignee: Panagiotis Garefalakis
> Fix E2E kafka download timeout
> ---
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723789#comment-17723789
]
Yuxin Tan commented on FLINK-32123:
---
OK, The jira has something wrong and can not link
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan reassigned FLINK-32123:
-
Assignee: (was: Yuxin Tan)
> Fix E2E kafka download timeout
> -
[
https://issues.apache.org/jira/browse/FLINK-32112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723786#comment-17723786
]
Xianming Zhou commented on FLINK-32112:
---
Hi,[~Wencong Liu] . I'm very sorry for cl
flinkbot commented on PR #22605:
URL: https://github.com/apache/flink/pull/22605#issuecomment-1552414348
## CI report:
* ff630ae4422bfbf74d0e9b84a73fecd3cdf9afe8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xmzhou00 opened a new pull request, #22605:
URL: https://github.com/apache/flink/pull/22605
… Chinese document
## What is the purpose of the change
This PR Fix the deprecated state backend sample config in Chinese document
## Brief change log
update state b
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723780#comment-17723780
]
Panagiotis Garefalakis edited comment on FLINK-32123 at 5/18/23 3:50 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723780#comment-17723780
]
Panagiotis Garefalakis edited comment on FLINK-32123 at 5/18/23 3:50 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723780#comment-17723780
]
Panagiotis Garefalakis commented on FLINK-32123:
[~tanyuxin] the PR is
wanglijie95 commented on code in PR #22560:
URL: https://github.com/apache/flink/pull/22560#discussion_r1197319135
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -92,6 +92,17 @@ public class ExecutionOptions {
.withDe
[
https://issues.apache.org/jira/browse/FLINK-32121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32121:
--
Labels: test-stability (was: )
> Avro Confluent Schema Registry nightly end-to-end test failed due to
[
https://issues.apache.org/jira/browse/FLINK-32121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32121:
--
Component/s: Connectors / Kafka
> Avro Confluent Schema Registry nightly end-to-end test failed due to
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32123:
--
Component/s: Connectors / Kafka
> Fix E2E kafka download timeout
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32123:
--
Affects Version/s: 1.18.0
> Fix E2E kafka download timeout
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32123:
--
Labels: test-stability (was: )
> Fix E2E kafka download timeout
> --
>
>
flinkbot commented on PR #22604:
URL: https://github.com/apache/flink/pull/22604#issuecomment-1552330697
## CI report:
* 9e20d48936ca42ee9ffd9e3dad0448f48e4d8b81 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723775#comment-17723775
]
Yuxin Tan commented on FLINK-32121:
---
This looks like the duplicated issue with
https:
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan reassigned FLINK-32123:
-
Assignee: Yuxin Tan
> Fix E2E kafka download timeout
> --
>
>
TanYuxin-tyx opened a new pull request, #22604:
URL: https://github.com/apache/flink/pull/22604
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring th
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723774#comment-17723774
]
Yuxin Tan commented on FLINK-32123:
---
[~pgaref] Thanks for reporting this, I will take
xmzhou00 closed pull request #22596: [FLINK-32112][docs] Fix the deprecated
state backend sample config in Chinese document
URL: https://github.com/apache/flink/pull/22596
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-32123:
---
Description:
For the past few hours, E2E tests fail with: 'Avro Confluent Sc
YasuoStudyJava commented on code in PR #16540:
URL: https://github.com/apache/flink/pull/16540#discussion_r1197241554
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/TableSinkITCase.scala:
##
@@ -76,4 +81,22 @@ class TableSinkIT
luoyuxia commented on PR #22525:
URL: https://github.com/apache/flink/pull/22525#issuecomment-1552275854
Others also encounter the problem as reported in FLINK-32121. The reason is
shown as FLINK-32123.
--
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-32123:
---
Description:
For the past few hours, E2E tests fail with: 'Avro Confluent Sc
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-32123:
---
Description:
For the past few hours, E2E tests fail with: 'Avro Confluent Sc
flinkbot commented on PR #22603:
URL: https://github.com/apache/flink/pull/22603#issuecomment-1551947956
## CI report:
* 66a1e4729adf5ba5edd75e7a9bc9e7b90c430ea3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
pgaref opened a new pull request, #22603:
URL: https://github.com/apache/flink/pull/22603
https://issues.apache.org/jira/browse/FLINK-32123
For the past few hours, E2E tests fail with: `Avro Confluent Schema Registry
nightly end-to-end test failed after 9 minutes and 53 seconds! Test
Panagiotis Garefalakis created FLINK-32123:
--
Summary: Fix E2E kafka download timeout
Key: FLINK-32123
URL: https://issues.apache.org/jira/browse/FLINK-32123
Project: Flink
Issue Type
flinkbot commented on PR #22602:
URL: https://github.com/apache/flink/pull/22602#issuecomment-1551911927
## CI report:
* ef1b54cf2be377fcef6b282a6350f0635e8b054c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
bvarghese1 commented on code in PR #22588:
URL: https://github.com/apache/flink/pull/22588#discussion_r1196945904
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,79 @@
+/*
+ * Licensed to th
surendralilhore opened a new pull request, #22602:
URL: https://github.com/apache/flink/pull/22602
## What is the purpose of the change
Many users have reported on the mailing list that they are unable to
configure the ABFS filesystem as a checkpoint directory. This is often due to
C
Surendra Singh Lilhore created FLINK-32122:
--
Summary: Update the Azure Blob Storage document to assist in
configuring the MSI provider with a shaded class name
Key: FLINK-32122
URL: https://issues.apache.
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1196848796
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java:
##
@@ -0,0 +1,3
[
https://issues.apache.org/jira/browse/FLINK-31804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723543#comment-17723543
]
Aleksandr Pilipenko edited comment on FLINK-31804 at 5/17/23 5:09 PM:
[
https://issues.apache.org/jira/browse/FLINK-31804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723543#comment-17723543
]
Aleksandr Pilipenko commented on FLINK-31804:
-
Change in error message causi
[
https://issues.apache.org/jira/browse/FLINK-31946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723530#comment-17723530
]
Curtis Jensen commented on FLINK-31946:
---
GSI turns out to be problematic to implem
[
https://issues.apache.org/jira/browse/FLINK-31163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723514#comment-17723514
]
Sergey Nuyanzin edited comment on FLINK-31163 at 5/17/23 3:38 PM:
[
https://issues.apache.org/jira/browse/FLINK-31163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723514#comment-17723514
]
Sergey Nuyanzin edited comment on FLINK-31163 at 5/17/23 3:37 PM:
[
https://issues.apache.org/jira/browse/FLINK-31163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723514#comment-17723514
]
Sergey Nuyanzin commented on FLINK-31163:
-
Partially it fixed within CALCITE-491
zentol commented on code in PR #22384:
URL: https://github.com/apache/flink/pull/22384#discussion_r1196648554
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/AbstractLeaderElectionService.java:
##
@@ -0,0 +1,86 @@
+/*
+ * Licensed to the Apache Software Fo
LuoYunjun commented on PR #22597:
URL: https://github.com/apache/flink/pull/22597#issuecomment-1551557711
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1196579558
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/KinesisStreamProxy.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Lic
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1196578223
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/ShardAssignerFactory.java:
##
@@ -0,0 +1,41
[
https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723475#comment-17723475
]
Maximilian Michels commented on FLINK-32119:
True, partition skew is probabl
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1196574894
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/HashShardAssigner.java:
##
@@ -0,0 +1,38 @@
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1196564490
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java:
##
@@ -0,0 +1,3
LuoYunjun commented on PR #22597:
URL: https://github.com/apache/flink/pull/22597#issuecomment-1551418328
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
mbalassi commented on PR #596:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/596#issuecomment-1551406919
Hi @huaxk! Connecting to a cluster managed by the Kubernetes Operator is an
antipattern in its current form, because the operator will not be aware of the
jobs you submi
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1196519712
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java:
##
@@ -0,0 +1,3
mbalassi commented on PR #600:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/600#issuecomment-1551384965
Cool, thanks. I am merging as soon as the CI finishes.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1196497725
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java:
##
@@ -0,0 +1,3
[
https://issues.apache.org/jira/browse/FLINK-31822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723450#comment-17723450
]
Feng Jin commented on FLINK-31822:
--
[~fsk119] [~jark] Do you think this is a reasonab
[
https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32116:
--
Fix Version/s: aws-connector-4.2.0
> FlinkKinesisConsumer cannot stop-with-savepoint when conf
[
https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32116:
--
Affects Version/s: aws-connector-4.1.0
(was: 1.17.0)
> FlinkKinesis
[
https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-32116:
-
Assignee: Hong Liang Teoh
> FlinkKinesisConsumer cannot stop-with-savepoint when config
reswqa commented on PR #22596:
URL: https://github.com/apache/flink/pull/22596#issuecomment-1551315775
> There is a "." typo in the beginning of commit message.
+1, and there is another type: `docus` -> `docs`.
--
This is an automated message from the Apache Git Service.
To respond to
WencongLiu commented on PR #22596:
URL: https://github.com/apache/flink/pull/22596#issuecomment-1551301956
@xmzhou00
There is a "." typo in the beginning of commit message. Please fix it. Could
you please create a new PR to merge this commit to branch `1.17-release` ?
Don't forget to fo
[
https://issues.apache.org/jira/browse/FLINK-31782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-31782:
-
Assignee: Matthias Pohl
> Make DefaultLeaderElectionService implement
> MultipleCompon
[
https://issues.apache.org/jira/browse/FLINK-31781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-31781:
-
Assignee: Matthias Pohl
> Introduce contender ID into LeaderElectionService interface
>
[
https://issues.apache.org/jira/browse/FLINK-32121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723437#comment-17723437
]
Yuxin Tan commented on FLINK-32121:
---
https://dev.azure.com/apache-flink/apache-flink/_
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1196421503
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java:
##
@@ -0,0 +1,167 @@
+/*
+ * License
xmzhou00 commented on PR #22596:
URL: https://github.com/apache/flink/pull/22596#issuecomment-1551289735
> Thanks @xmzhou00 and @WencongLiu, approved.
Thanks 😄 @reswqa
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
[
https://issues.apache.org/jira/browse/FLINK-32121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wencong Liu updated FLINK-32121:
Environment: (was: !temp2.jpg!)
> Avro Confluent Schema Registry nightly end-to-end test faile
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1196419578
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java:
##
@@ -0,0 +1,167 @@
+/*
+ * License
Wencong Liu created FLINK-32121:
---
Summary: Avro Confluent Schema Registry nightly end-to-end test
failed due to timeout
Key: FLINK-32121
URL: https://issues.apache.org/jira/browse/FLINK-32121
Project: F
flinkbot commented on PR #22601:
URL: https://github.com/apache/flink/pull/22601#issuecomment-1551286906
## CI report:
* a3ac979e59096c7685322d1aaddcc298dbc6ece8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
XComp opened a new pull request, #22601:
URL: https://github.com/apache/flink/pull/22601
## What is the purpose of the change
The `contenderID` is something that shall be hidden from the contender by
providing the `LeaderElection` abstraction. The contender ID shall be specified
in t
gyfora merged PR #647:
URL: https://github.com/apache/flink-web/pull/647
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723432#comment-17723432
]
Gyula Fora commented on FLINK-32119:
If we disable this we can still have problems w
Maximilian Michels created FLINK-32120:
--
Summary: Add autoscaler config option to disable parallelism key
group alignment
Key: FLINK-32120
URL: https://issues.apache.org/jira/browse/FLINK-32120
P
[
https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-32119:
---
Description:
After choosing the target parallelism for a vertex, we choose a higher
Maximilian Michels created FLINK-32119:
--
Summary: Disable key group alignment for determining source
parallelism
Key: FLINK-32119
URL: https://issues.apache.org/jira/browse/FLINK-32119
Project: F
Fang Yong created FLINK-32118:
-
Summary: Support customized listener during task manager startup
Key: FLINK-32118
URL: https://issues.apache.org/jira/browse/FLINK-32118
Project: Flink
Issue Type:
hustonic commented on PR #22397:
URL: https://github.com/apache/flink/pull/22397#issuecomment-1551155362
@reswqa Hi, Can you help me merge this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
yangjf2019 commented on PR #601:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/601#issuecomment-1551147431
@mxm @gyfora Thank you for your patience, it gives me a lot of encouragement!
--
This is an automated message from the Apache Git Service.
To respond to the message,
dawidwys commented on code in PR #22588:
URL: https://github.com/apache/flink/pull/22588#discussion_r1196274099
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ArrayExceptFunction.java:
##
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the
flinkbot commented on PR #22600:
URL: https://github.com/apache/flink/pull/22600#issuecomment-1551113569
## CI report:
* 4bb367be180faf288027d32b618a486a40ea8818 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mxm commented on PR #601:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/601#issuecomment-1551110620
Thank you for contributing!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to th
1 - 100 of 138 matches
Mail list logo
