[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748784#comment-17748784
]
Gyula Fora commented on FLINK-32700:
Here it is:) https://issues.apache.org/jira/browse/FLINK-30529
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748783#comment-17748783
]
Gyula Fora commented on FLINK-32700:
Don’t get me wrong I think adding support for draining makes
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
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
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748759#comment-17748759
]
Talat Uyarer edited comment on FLINK-32700 at 7/29/23 1:36 AM:
---
[~gyfora]
[
https://issues.apache.org/jira/browse/FLINK-32700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748759#comment-17748759
]
Talat Uyarer commented on FLINK-32700:
--
[~gyfora] Currently there is an issue on Operator's delete.
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-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748687#comment-17748687
]
Venkata krishnan Sowrirajan commented on FLINK-20767:
-
I am currently looking into
[
https://issues.apache.org/jira/browse/FLINK-32710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748644#comment-17748644
]
Jiadong Lu commented on FLINK-32710:
Hi, Matthias. If i understand correctly , this ticket is
[
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-32711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748626#comment-17748626
]
Aitozi commented on FLINK-32711:
It's caused by the hard coded nullable result type of
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:
[
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)
>
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748609#comment-17748609
]
Matthias Pohl commented on FLINK-32681:
---
I'm linking FLINK-32345 as a cause because that failing
[
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-32662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748607#comment-17748607
]
Matthias Pohl commented on FLINK-32662:
---
[
https://issues.apache.org/jira/browse/FLINK-32681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748606#comment-17748606
]
Matthias Pohl commented on FLINK-32681:
---
twice in the same build:
*
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
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
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748584#comment-17748584
]
Matthias Pohl commented on FLINK-31168:
---
(y) I was able to reproduce this test failure using JDK17
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-32691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-32691.
Resolution: Fixed
Fixed in 3f63e03e83144e9857834f8db1895637d2aa218a
> Make it possible
[
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
>
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
[
https://issues.apache.org/jira/browse/FLINK-32672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748561#comment-17748561
]
Martijn Visser commented on FLINK-32672:
There is already FLINK-20628 and a PR
[
https://issues.apache.org/jira/browse/FLINK-32673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748559#comment-17748559
]
Martijn Visser commented on FLINK-32673:
There's two things imho:
1. I can restart the
[
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,
[
https://issues.apache.org/jira/browse/FLINK-32697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748557#comment-17748557
]
Martijn Visser commented on FLINK-32697:
[~sunyanyong] Do you want to fix it?
> When using JDBC
[
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,
[
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-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
[
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
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-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748537#comment-17748537
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 10:18 AM:
-
So
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748537#comment-17748537
]
Matthias Pohl commented on FLINK-31168:
---
So far, I wasn't able to reproduce it locally with up to
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748533#comment-17748533
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 9:49 AM:
It
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748533#comment-17748533
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 9:48 AM:
It
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748533#comment-17748533
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 9:48 AM:
It
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748533#comment-17748533
]
Matthias Pohl commented on FLINK-31168:
---
It appears that the leader election is not causing 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/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
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748491#comment-17748491
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 9:20 AM:
The
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748491#comment-17748491
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 9:20 AM:
The
[
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
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748491#comment-17748491
]
Matthias Pohl commented on FLINK-31168:
---
The most-recent failures seem to have been caused by the
[
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
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`
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`
[
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
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
[
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
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-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
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
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`
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
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748445#comment-17748445
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 8:03 AM:
For the
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748445#comment-17748445
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 7:37 AM:
For the
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748445#comment-17748445
]
Matthias Pohl commented on FLINK-31168:
---
For the record: The reported cases do not always have the
tisonkun commented on PR #56:
URL:
https://github.com/apache/flink-connector-pulsar/pull/56#issuecomment-1655131338
Support keybytes for now to minimize code change. Following work -
1. Add SQL client E2E test
2. Add upsert table factory
3. Revisit key serialization support. I
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748254#comment-17748254
]
Matthias Pohl edited comment on FLINK-31168 at 7/28/23 6:46 AM:
The
[
https://issues.apache.org/jira/browse/FLINK-31168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748436#comment-17748436
]
Matthias Pohl commented on FLINK-31168:
---
My suspicion doesn't seem to hold: I couldn't identify
[ https://issues.apache.org/jira/browse/FLINK-26541 ]
shizhengchao deleted comment on FLINK-26541:
--
was (Author: tinny):
Why do not use session mode？If application mode supports sql, then I think
there is no different whith session mode.
>
hanyuzheng7 closed pull request #23098: [FLINK-32262] Add MAP_ENTRIES support
URL: https://github.com/apache/flink/pull/23098
--
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.
flinkbot commented on PR #23098:
URL: https://github.com/apache/flink/pull/23098#issuecomment-1655074207
## CI report:
* 2a0667be43d20203ef1c1b05119c87c1efbd9030 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
70 matches
Mail list logo
