Dian Fu created FLINK-32131:
---
Summary: Support specifying hadoop config dir for Python
HiveCatalog
Key: FLINK-32131
URL: https://issues.apache.org/jira/browse/FLINK-32131
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-31743.
Resolution: Fixed
> Avoid relocating the RocksDB's log failure when filename exceeds 255
>
[
https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31743:
---
Fix Version/s: 1.16.2
1.17.1
(was: 1.16.3)
[
https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31743:
---
Fix Version/s: 1.16.3
1.17.2
(was: 1.16.2)
[
https://issues.apache.org/jira/browse/FLINK-31654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31654:
---
Fix Version/s: 1.16.3
1.17.2
(was: 1.16.2)
[
https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31139:
---
Fix Version/s: 1.16.3
1.17.2
(was: 1.16.2)
[
https://issues.apache.org/jira/browse/FLINK-30821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30821:
---
Fix Version/s: 1.17.2
> The optimized exec plan generated by
>
[
https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30959:
---
Fix Version/s: 1.16.3
1.17.2
(was: 1.16.2)
> Improve the
[
https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29459:
---
Fix Version/s: 1.17.2
> Sink v2 has bugs in supporting legacy v1 implementations with global
[
https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29459:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
(was: 1.15.5)
>
[
https://issues.apache.org/jira/browse/FLINK-30112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30112:
---
Fix Version/s: 1.16.3
1.17.2
(was: 1.16.2)
[
https://issues.apache.org/jira/browse/FLINK-30821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30821:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> The optimized exec plan generated by
[
https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27954:
---
Fix Version/s: 1.17.2
(was: 1.15.5)
> JobVertexFlameGraphHandler does not
[
https://issues.apache.org/jira/browse/FLINK-27082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27082:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> Disable tests relying on non-writable
[
https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29370:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> Protobuf in flink-sql-protobuf is not
[
https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27954:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> JobVertexFlameGraphHandler does not
[
https://issues.apache.org/jira/browse/FLINK-32124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen closed FLINK-32124.
-
Resolution: Invalid
> Add option to enable partition alignment for sources
>
[
https://issues.apache.org/jira/browse/FLINK-32124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724125#comment-17724125
]
Zhanghao Chen commented on FLINK-32124:
---
Hi [~gyfora]. I confirmed that operator actually aligns
[
https://issues.apache.org/jira/browse/FLINK-32127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724124#comment-17724124
]
Zhanghao Chen commented on FLINK-32127:
---
Hi [~Wencong Liu]. I think the key problem here is that
[
https://issues.apache.org/jira/browse/FLINK-27079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27079:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> Setup cron jobs
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-27080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27080:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> Enable builds for pull requests
>
[
https://issues.apache.org/jira/browse/FLINK-31875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31875:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> OSS throwns NoClassDefFoundError due
[
https://issues.apache.org/jira/browse/FLINK-27075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27075:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> Migrate CI from Azure to Github
[
https://issues.apache.org/jira/browse/FLINK-27077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-27077:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> Setup per-commit builds
>
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724113#comment-17724113
]
Weijie Guo commented on FLINK-31963:
It seems that all pull request has been merged but this ticket
[
https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-31963.
Resolution: Fixed
master(1.18) via 354c0f455b92c083299d8028f161f0dd113ab614.
release-1.17 via
[
https://issues.apache.org/jira/browse/FLINK-30596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30596:
---
Fix Version/s: 1.17.2
(was: 1.17.1)
> Multiple POST /jars/:jarid/run
[
https://issues.apache.org/jira/browse/FLINK-30596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30596:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> Multiple POST /jars/:jarid/run
[
https://issues.apache.org/jira/browse/FLINK-29530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29530:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> CommittableMessageTypeInfo#toString
[
https://issues.apache.org/jira/browse/FLINK-30219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30219:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> Fetch results api in sql gateway
[
https://issues.apache.org/jira/browse/FLINK-31981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31981:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> Enabling waiting on the Flink
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-28440:
---
Fix Version/s: 1.16.3
(was: 1.16.2)
> EventTimeWindowCheckpointingITCase
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724093#comment-17724093
]
Jiang Xin edited comment on FLINK-28386 at 5/19/23 3:38 AM:
Hi [~pnowojski],
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724093#comment-17724093
]
Jiang Xin commented on FLINK-28386:
---
Hi [~pnowojski], I'm working on this. I agree with you that only
[
https://issues.apache.org/jira/browse/FLINK-32068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724088#comment-17724088
]
leishuiyu commented on FLINK-32068:
---
the PR is
jiaoqingbo commented on PR #20986:
URL: https://github.com/apache/flink/pull/20986#issuecomment-1553936952
@wanglijie95 would you mind sparing some time to review it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
flinkbot commented on PR #22606:
URL: https://github.com/apache/flink/pull/22606#issuecomment-1553933931
## CI report:
* b45384cee0d1fa6c3d591e0560db62478901e7c9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feifan Wang updated FLINK-32130:
Description:
Currently, _SharedStateRegistryImpl_ will discard old one while register new
state
[
https://issues.apache.org/jira/browse/FLINK-32127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724083#comment-17724083
]
Wencong Liu commented on FLINK-32127:
-
Hi [~Zhanghao Chen] , Thanks for the proposal! I guess the
Feifan Wang created FLINK-32130:
---
Summary: previous checkpoint will be broke by the subsequent
incremental checkpoint
Key: FLINK-32130
URL: https://issues.apache.org/jira/browse/FLINK-32130
Project:
Fang Yong created FLINK-32129:
-
Summary: Filesystem connector is not compatible with option
'pipeline.generic-types'
Key: FLINK-32129
URL: https://issues.apache.org/jira/browse/FLINK-32129
Project: Flink
godfreyhe commented on code in PR #22593:
URL: https://github.com/apache/flink/pull/22593#discussion_r1198483617
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecJoin.java:
##
@@ -119,12 +139,14 @@ public
huaxk closed pull request #596: fix: flink account cannot get resource
"services" in API group
URL: https://github.com/apache/flink-kubernetes-operator/pull/596
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
TanYuxin-tyx commented on PR #22573:
URL: https://github.com/apache/flink/pull/22573#issuecomment-1553894900
@snuyanzin @reswqa I have addressed the comments. Could you please take a
look again?
--
This is an automated message from the Apache Git Service.
To respond to the message,
luoyuxia commented on PR #22600:
URL: https://github.com/apache/flink/pull/22600#issuecomment-1553885719
@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.
huaxk commented on PR #596:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/596#issuecomment-1553868545
Yes, I see.
--
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
pgaref commented on code in PR #22506:
URL: https://github.com/apache/flink/pull/22506#discussion_r1198145131
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/exceptionhistory/RootExceptionHistoryEntry.java:
##
@@ -107,26 +121,33 @@ public static
pgaref commented on code in PR #22506:
URL: https://github.com/apache/flink/pull/22506#discussion_r1198148957
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/ExecutionFailureHandler.java:
##
@@ -51,22 +58,39 @@ public class
[
https://issues.apache.org/jira/browse/FLINK-32114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-32114:
---
Description:
On task failures, context would be nice to include extra
pgaref commented on code in PR #22506:
URL: https://github.com/apache/flink/pull/22506#discussion_r1198145131
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/exceptionhistory/RootExceptionHistoryEntry.java:
##
@@ -107,26 +121,33 @@ public static
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723992#comment-17723992
]
Gyula Fora commented on FLINK-32041:
done :)
> flink-kubernetes-operator RoleBinding for Leases
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-32041:
--
Assignee: Thomas Chin (was: Andrew Otto)
> flink-kubernetes-operator RoleBinding for Leases
[
https://issues.apache.org/jira/browse/FLINK-32041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723990#comment-17723990
]
Andrew Otto commented on FLINK-32041:
-
[~tchin] Is going to submit a PR for this, can you assign
boring-cyborg[bot] commented on PR #49:
URL:
https://github.com/apache/flink-connector-jdbc/pull/49#issuecomment-1553268136
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
wanglijie95 merged PR #22450:
URL: https://github.com/apache/flink/pull/22450
--
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:
xmzhou00 commented on PR #22605:
URL: https://github.com/apache/flink/pull/22605#issuecomment-1553083514
Hi @WencongLiu . Hi @reswqa . I created a new PR to merge this commit to
branch 1.17-release. Please review it. Thanks .
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-31971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek resolved FLINK-31971.
---
Resolution: Fixed
> Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest
>
[
https://issues.apache.org/jira/browse/FLINK-31971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723914#comment-17723914
]
David Morávek commented on FLINK-31971:
---
master: 777ae5cb2aaafce9c534565412d6e350846aadc7
> Drop
dmvk merged PR #22504:
URL: https://github.com/apache/flink/pull/22504
--
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:
dmvk commented on PR #22551:
URL: https://github.com/apache/flink/pull/22551#issuecomment-1553060234
Can we have a regression test for this?
--
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
dmvk commented on PR #22591:
URL: https://github.com/apache/flink/pull/22591#issuecomment-1553052416
> The test usually runs in milliseconds but occasionally runs into the
1000ms limit.
Can we simply increase the timeouts to a really high number (~ 1h-ish)?
--
This is an automated
dmvk commented on code in PR #22506:
URL: https://github.com/apache/flink/pull/22506#discussion_r1197813929
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/exceptionhistory/RootExceptionHistoryEntry.java:
##
@@ -107,26 +121,33 @@ public static
[ https://issues.apache.org/jira/browse/FLINK-32128 ]
Seungchul Lee deleted comment on FLINK-32128:
---
was (Author: JIRAUSER300406):
Can I get a ticket for this?
> Unmodifiable implementation for getter method in test function
>
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723886#comment-17723886
]
David Morávek commented on FLINK-32123:
---
master: 8c3637b47f3dd906694857cd1b808139599126fa
The
tamirsagi commented on PR #603:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/603#issuecomment-1552842225
> Please run `mvn clean install` locally before you push to avoid the need
to run the CI again and again. There is still a spotless formatting issue
Hey Gyula,
[
https://issues.apache.org/jira/browse/FLINK-29179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723877#comment-17723877
]
wangliang commented on FLINK-29179:
---
Hi, I want to translate this doc. May you assign it to me?
[
https://issues.apache.org/jira/browse/FLINK-31855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723876#comment-17723876
]
Gyula Fora commented on FLINK-31855:
You can set the spec.job.state = SUSPENDED to cancel the job.
[
https://issues.apache.org/jira/browse/FLINK-32128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seungchul Lee updated FLINK-32128:
--
Description:
While using the Flink in our company, I would like to share a small suggestion
[
https://issues.apache.org/jira/browse/FLINK-32128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seungchul Lee updated FLINK-32128:
--
Fix Version/s: (was: 1.18.0)
> Unmodifiable implementation for getter method in test
[
https://issues.apache.org/jira/browse/FLINK-32128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723871#comment-17723871
]
Seungchul Lee commented on FLINK-32128:
---
Can I get a ticket for this?
> Unmodifiable
[
https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-32116:
-
Assignee: Aleksandr Pilipenko (was: Hong Liang Teoh)
> FlinkKinesisConsumer cannot
zhuzhurk commented on code in PR #22506:
URL: https://github.com/apache/flink/pull/22506#discussion_r1197562013
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/exceptionhistory/RootExceptionHistoryEntry.java:
##
@@ -107,26 +121,33 @@ public static
zhuzhurk commented on code in PR #22506:
URL: https://github.com/apache/flink/pull/22506#discussion_r1197573074
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/ExecutionFailureHandler.java:
##
@@ -51,22 +58,39 @@ public class
wanglijie95 commented on code in PR #22413:
URL: https://github.com/apache/flink/pull/22413#discussion_r1197529186
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/benchmark/e2e/RestartStreamingJobBenchmark.java:
##
@@ -0,0 +1,96 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-31910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723841#comment-17723841
]
Jiang Xin commented on FLINK-31910:
---
>From the demo, I'm not sure if the
WencongLiu commented on PR #22572:
URL: https://github.com/apache/flink/pull/22572#issuecomment-1552702594
@XComp The commit message has been corrected.
--
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
[
https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723826#comment-17723826
]
padavan commented on FLINK-31967:
-
[~fsk119] [~pyro]
This looks like basic functionality that is often
[
https://issues.apache.org/jira/browse/FLINK-32128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seungchul Lee updated FLINK-32128:
--
Description:
While using the Flink in our company, I would like to share a small suggestion
dannycranmer commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1197508069
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java:
##
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-32124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723821#comment-17723821
]
Gyula Fora commented on FLINK-32124:
[~Zhanghao Chen] can you please confirm that the current
hlteoh37 commented on code in PR #49:
URL:
https://github.com/apache/flink-connector-aws/pull/49#discussion_r1197502360
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/KinesisStreamsRecordEmitter.java:
##
@@ -0,0 +1,56 @@
[
https://issues.apache.org/jira/browse/FLINK-32124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723820#comment-17723820
]
Gyula Fora commented on FLINK-32124:
My bad, this is what I meant:
Seungchul Lee created FLINK-32128:
-
Summary: Unmodifiable implementation for getter method in test
function
Key: FLINK-32128
URL: https://issues.apache.org/jira/browse/FLINK-32128
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723819#comment-17723819
]
Fang Yong commented on FLINK-32124:
---
[~gyfora]Is the link
[
https://issues.apache.org/jira/browse/FLINK-29577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cai Liuyang closed FLINK-29577.
---
Resolution: Fixed
> Disable rocksdb wal when restore from full snapshot
>
TanYuxin-tyx closed pull request #22604: [FLINK-32123][kafka] Fix E2E kafka
packages download timeout
URL: https://github.com/apache/flink/pull/22604
--
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
[
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
[
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:
[
https://issues.apache.org/jira/browse/FLINK-32123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723806#comment-17723806
]
David Morávek commented on FLINK-32123:
---
[
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
[
https://issues.apache.org/jira/browse/FLINK-32124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723801#comment-17723801
]
Zhanghao Chen commented on FLINK-32124:
---
Thanks [~gyfora]. I'll follow up there.
> Add option to
[
https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723800#comment-17723800
]
Zhanghao Chen commented on FLINK-32119:
---
+1 for "partition skew is probably worse than key group
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
[
https://issues.apache.org/jira/browse/FLINK-32127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723798#comment-17723798
]
Gyula Fora commented on FLINK-32127:
cc [~mxm]
> Source busy time is inaccurate in many cases
>
[
https://issues.apache.org/jira/browse/FLINK-32124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723796#comment-17723796
]
Gyula Fora commented on FLINK-32124:
This is related to
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
[
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
[
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
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:
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
1 - 100 of 106 matches
Mail list logo
