[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748445#comment-17748445
]
Matthias Pohl commented on FLINK-31168:
---
For the record: The reported cases do not
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748445#comment-17748445
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 7:37 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748445#comment-17748445
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 8:03 AM:
--
whhe commented on PR #17:
URL:
https://github.com/apache/flink-connector-hbase/pull/17#issuecomment-1655247084
> @whhe The connector actually shouldn't rely on `flink-shaded` at all.
It will not depend on 'flink-shaded', this modification is to add netty
packages other than 'netty-al
flinkbot commented on PR #23099:
URL: https://github.com/apache/flink/pull/23099#issuecomment-1655250466
## CI report:
* eb0bbb685ade3539ddf1ad08755b2db9be306ec3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
LadyForest closed pull request #23065: [FLINK-32656][table] Deprecate
ManagedTable related APIs
URL: https://github.com/apache/flink/pull/23065
--
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 sp
[
https://issues.apache.org/jira/browse/FLINK-32709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-32709:
--
Summary: Improve memory utilization for Hybrid Shuffle (was: Modify
segment size to improve memory ut
WencongLiu opened a new pull request, #23100:
URL: https://github.com/apache/flink/pull/23100
## What is the purpose of the change
*Fix the write logic in remote tier of hybrid shuffle.*
## Brief change log
- *Fix the write logic in remote tier of hybrid shuffle.*
[
https://issues.apache.org/jira/browse/FLINK-32708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32708:
---
Labels: pull-request-available (was: )
> Fix the write logic in remote tier of hybrid shuff
FangYongs opened a new pull request, #23101:
URL: https://github.com/apache/flink/pull/23101
## What is the purpose of the change
This PR aims to not save job which without restart strategy to job writer
and store.
In olap scenario, jobs always has no restart strategy. It will incr
[
https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32667:
---
Labels: pull-request-available (was: )
> Use standalone store and embedding writer for jobs
flinkbot commented on PR #23100:
URL: https://github.com/apache/flink/pull/23100#issuecomment-1655282000
## CI report:
* 30bae68215a49365875c956eadde2a36929f0aea UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23101:
URL: https://github.com/apache/flink/pull/23101#issuecomment-1655290894
## CI report:
* 9e88a35aafee8645ebbabb3225b24fa8052b4bcd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reassigned FLINK-32667:
-
Assignee: Fang Yong
> Use standalone store and embedding writer for jobs with no-restart-strate
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748491#comment-17748491
]
Matthias Pohl commented on FLINK-31168:
---
The most-recent failures seem to have bee
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31168:
--
Fix Version/s: 1.18.0
> JobManagerHAProcessFailureRecoveryITCase failed due to job not being f
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31168:
--
Priority: Blocker (was: Major)
> JobManagerHAProcessFailureRecoveryITCase failed due to job n
MartijnVisser commented on PR #17:
URL:
https://github.com/apache/flink-connector-hbase/pull/17#issuecomment-1655299963
> this modification is to add netty packages other than 'netty-all', such as
'netty-transport' here, to the sql jar.
Ah sorry, I misread. I'll try to have a look la
[
https://issues.apache.org/jira/browse/FLINK-32708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wencong Liu updated FLINK-32708:
Summary: Fix the write logic in remote tier of Hybrid Shuffle (was: Fix
the write logic in remote
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748491#comment-17748491
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 9:20 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748491#comment-17748491
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 9:20 AM:
--
1996fanrui commented on PR #23094:
URL: https://github.com/apache/flink/pull/23094#issuecomment-1655369644
The actual CI passed, and the uploading log and caching docker image failed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/FLINK-32710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32710:
--
Labels: starter (was: )
> The LeaderElection component IDs for running is only the JobID whic
[
https://issues.apache.org/jira/browse/FLINK-32710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32710:
--
Issue Type: Improvement (was: Bug)
> The LeaderElection component IDs for running is only the
Matthias Pohl created FLINK-32710:
-
Summary: The LeaderElection component IDs for running is only the
JobID which might be confusing in the log output
Key: FLINK-32710
URL: https://issues.apache.org/jira/browse/FL
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748533#comment-17748533
]
Matthias Pohl commented on FLINK-31168:
---
It appears that the leader election is no
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748533#comment-17748533
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 9:48 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748533#comment-17748533
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 9:48 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748533#comment-17748533
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 9:49 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748537#comment-17748537
]
Matthias Pohl commented on FLINK-31168:
---
So far, I wasn't able to reproduce it loc
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748537#comment-17748537
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 10:18 AM:
-
yunfengzhou-hub commented on code in PR #22931:
URL: https://github.com/apache/flink/pull/22931#discussion_r1277383109
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java:
##
@@ -183,6 +189,15 @@ public class CheckpointCoordinator {
[
https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov reassigned FLINK-32694:
-
Assignee: Alexander Fedulov
> Cascade deprecation to classes that implement Par
[
https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32694:
--
Summary: Migrate classes that implement ParallelSourceFunction to Source V2
API (was:
[
https://issues.apache.org/jira/browse/FLINK-32670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32670:
--
Summary: Cascade deprecation to classes that implement SourceFunction
(was: Annotate
[
https://issues.apache.org/jira/browse/FLINK-32697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32697:
---
Priority: Major (was: Blocker)
> When using JDBC to insert data into the oracle database, a
[
https://issues.apache.org/jira/browse/FLINK-32697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748557#comment-17748557
]
Martijn Visser commented on FLINK-32697:
[~sunyanyong] Do you want to fix it?
>
[
https://issues.apache.org/jira/browse/FLINK-32670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-32670:
--
Description: (was: Â ParallelSourceFunction, RichParallelSourceFunction,
Externally
[
https://issues.apache.org/jira/browse/FLINK-32673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748559#comment-17748559
]
Martijn Visser commented on FLINK-32673:
There's two things imho:
1. I can rest
[
https://issues.apache.org/jira/browse/FLINK-32672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748561#comment-17748561
]
Martijn Visser commented on FLINK-32672:
There is already FLINK-20628 and a PR
MartijnVisser commented on PR #1:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/1#issuecomment-1655509560
> I am working for it now.
Any update to report from your end on this @RocMarshal ?
--
This is an automated message from the Apache Git Service.
To respond to th
[
https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32650:
---
Fix Version/s: (was: 1.18.0)
> Added the ability to split flink-protobuf codegen code
>
[
https://issues.apache.org/jira/browse/FLINK-32691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-32691.
Resolution: Fixed
Fixed in 3f63e03e83144e9857834f8db1895637d2aa218a
> Make it possible to
luoyuxia commented on code in PR #23060:
URL: https://github.com/apache/flink/pull/23060#discussion_r1277438779
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -557,6 +558,59 @@ INSERT INTO my_ctas_table SELECT id, name, age FROM
source_table WHERE mod(id, 1
{{< top >}}
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748584#comment-17748584
]
Matthias Pohl commented on FLINK-31168:
---
(y) I was able to reproduce this test fai
Tartarus0zm commented on PR #23060:
URL: https://github.com/apache/flink/pull/23060#issuecomment-1655600364
@luoyuxia thanks for your review! PTAL
--
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
luoyuxia commented on code in PR #23013:
URL: https://github.com/apache/flink/pull/23013#discussion_r1277459386
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/v2/DiscardingSink.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748606#comment-17748606
]
Matthias Pohl commented on FLINK-32681:
---
twice in the same build:
*
https://dev.a
[
https://issues.apache.org/jira/browse/FLINK-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748607#comment-17748607
]
Matthias Pohl commented on FLINK-32662:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32681:
--
Priority: Critical (was: Major)
> RocksDBStateDownloaderTest.testMultiThreadCleanupOnFailure
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748609#comment-17748609
]
Matthias Pohl commented on FLINK-32681:
---
I'm linking FLINK-32345 as a cause becaus
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-32681:
--
Issue Type: Bug (was: Technical Debt)
> RocksDBStateDownloaderTest.testMultiThreadCleanupOnFa
Aitozi created FLINK-32711:
--
Summary: Type mismatch when proctime function used as parameter
Key: FLINK-32711
URL: https://issues.apache.org/jira/browse/FLINK-32711
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-32711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748626#comment-17748626
]
Aitozi commented on FLINK-32711:
It's caused by the hard coded nullable result type of P
[
https://issues.apache.org/jira/browse/FLINK-32711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-32711:
---
Issue Type: Bug (was: Improvement)
> Type mismatch when proctime function used as parameter
> -
[
https://issues.apache.org/jira/browse/FLINK-32710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748644#comment-17748644
]
Jiadong Lu commented on FLINK-32710:
Hi, Matthias. If i understand correctly , this
[
https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748687#comment-17748687
]
Venkata krishnan Sowrirajan commented on FLINK-20767:
-
I am currentl
netvl commented on PR #22854:
URL: https://github.com/apache/flink/pull/22854#issuecomment-1656406321
@1996fanrui sorry for the delay! I fixed the checkstyle issues (`mvn
checkstyle:check` now passes locally), and I fixed the picture and the
description of the PR. Please review, thanks!)
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748759#comment-17748759
]
Talat Uyarer commented on FLINK-32700:
--
[~gyfora] Currently there is an issue on Op
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748759#comment-17748759
]
Talat Uyarer edited comment on FLINK-32700 at 7/29/23 1:36 AM:
---
RocMarshal commented on PR #20990:
URL: https://github.com/apache/flink/pull/20990#issuecomment-1656535485
Hi, @1996fanrui Would you mind helping review this PR If you have free time ?
Thanks you very much~
--
This is an automated message from the Apache Git Service.
To respond to the m
RocMarshal commented on PR #1:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/1#issuecomment-1656547551
> > I am working for it now.
>
> Any update to report from your end on this @RocMarshal ?
Hi, @MartijnVisser Still in doing. I'll update in the end of this week
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748783#comment-17748783
]
Gyula Fora commented on FLINK-32700:
Don’t get me wrong I think adding support for d
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748784#comment-17748784
]
Gyula Fora commented on FLINK-32700:
Here it is:) https://issues.apache.org/jira/bro
64 matches
Mail list logo
