[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649614#comment-17649614
]
Matthias Pohl commented on FLINK-29427:
---
[
https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649613#comment-17649613
]
Matthias Pohl commented on FLINK-29859:
---
[
https://issues.apache.org/jira/browse/FLINK-29664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-29664.
--
Resolution: Done
> Collect subpartition sizes of BLOCKING result partitions
>
[
https://issues.apache.org/jira/browse/FLINK-29664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649603#comment-17649603
]
Lijie Wang commented on FLINK-29664:
Done via 96795ae5bf0b6d6c8b1fa793be742a7c1af3
> Collect
wanglijie95 closed pull request #2: [FLINK-29664][runtime] Collect
subpartition sizes of blocking result partitions
URL: https://github.com/apache/flink/pull/2
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-30456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-30456:
--
Assignee: James Busche
> OLM Bundle Description Version Problems
>
jbusche commented on PR #491:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/491#issuecomment-1358917278
I tested my PR briefly on OpenShift 4.10, will do some more thorough testing
tomorrow and post the results here. I think @tedhtchang might test on his
server(s) too.
[
https://issues.apache.org/jira/browse/FLINK-30453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30453:
---
Labels: pull-request-available (was: )
> Fix 'can't find CatalogFactory' error when using
yuzelin opened a new pull request, #442:
URL: https://github.com/apache/flink-table-store/pull/442
Main Change:
- Allow passing ClassLoader parameter when creating catalog;
- Pass ClassLoader from context when creating `FlinkCatalog`.
--
This is an automated message from the Apache
huwh commented on PR #21496:
URL: https://github.com/apache/flink/pull/21496#issuecomment-1358905082
Thanks for your comment, @xintongsong, I made the changes
1. delete UnwantedWorker and UnwantedWorkerWithResourceProfile. Make the
unwanted workers as hint.
2. add
[
https://issues.apache.org/jira/browse/FLINK-30260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649592#comment-17649592
]
SwathiChandrashekar commented on FLINK-30260:
-
Hi [~mxm] , [~gyfora] , I would like to
[
https://issues.apache.org/jira/browse/FLINK-30435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649587#comment-17649587
]
Yubin Li commented on FLINK-30435:
--
Hi [~lzljs3620320], After FLINK-29679 merged, just need to modify a
[
https://issues.apache.org/jira/browse/FLINK-30445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-30445:
-
Description:
# Web3 is very hot. But you could search GitHub open source blockchain
explorer, the most
[
https://issues.apache.org/jira/browse/FLINK-30445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649558#comment-17649558
]
Junyao Huang commented on FLINK-30445:
--
[https://lists.apache.org/list.html?d...@flink.apache.org]
[
https://issues.apache.org/jira/browse/FLINK-30445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649553#comment-17649553
]
Junyao Huang commented on FLINK-30445:
--
Is it this one?
ramkrish86 commented on code in PR #21508:
URL: https://github.com/apache/flink/pull/21508#discussion_r1052900496
##
flink-filesystems/flink-azure-fs-hadoop/pom.xml:
##
@@ -185,13 +185,6 @@ under the License.
ramkrish86 commented on code in PR #21508:
URL: https://github.com/apache/flink/pull/21508#discussion_r1052900374
##
flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AzureBlobFsRecoverableDataOutputStream.java:
##
@@ -0,0 +1,299 @@
+/*
+ *
Yun Tang created FLINK-30457:
Summary: Introduce period compaction to FRocksDB
Key: FLINK-30457
URL: https://issues.apache.org/jira/browse/FLINK-30457
Project: Flink
Issue Type: Improvement
yangjunhan commented on code in PR #21483:
URL: https://github.com/apache/flink/pull/21483#discussion_r1052849668
##
flink-runtime-web/web-dashboard/src/app/pages/job/exceptions/job-exceptions.component.ts:
##
@@ -151,4 +153,10 @@ export class JobExceptionsComponent implements
yangjunhan commented on code in PR #21483:
URL: https://github.com/apache/flink/pull/21483#discussion_r1052849595
##
flink-runtime-web/web-dashboard/src/app/pages/job/exceptions/job-exceptions.component.ts:
##
@@ -151,4 +153,10 @@ export class JobExceptionsComponent implements
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-24932:
-
Priority: Major (was: Minor)
> Frocksdb cannot run on Apple M1
> ---
>
>
jbusche commented on PR #491:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/491#issuecomment-1358748799
Yes @morhidi it took me awhile to fill out completely
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
morhidi commented on PR #491:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/491#issuecomment-1358742932
@jbusche please fill out the PR template properly
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-30456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30456:
---
Labels: pull-request-available (was: )
> OLM Bundle Description Version Problems
>
zjureel closed pull request #441: [FLINK-30423] Introduce codegen for
CastExecutor
URL: https://github.com/apache/flink-table-store/pull/441
--
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
jbusche opened a new pull request, #491:
URL: https://github.com/apache/flink-kubernetes-operator/pull/491
Signed-off-by: James Busche
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain
xintongsong commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-1358726442
> Mainly 2 TODOs. One is the 2MB buffer and next is the flush support. I
think for now it should be good. But I can raise TODO JIRAs and work on it
later. Is that ok ?
I'm
xintongsong commented on code in PR #21508:
URL: https://github.com/apache/flink/pull/21508#discussion_r1052787197
##
flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AzureBlobFsRecoverableDataOutputStream.java:
##
@@ -0,0 +1,299 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-30456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
James Busche updated FLINK-30456:
-
Description:
OLM is working great with OperatorHub, but noticed a few items that need fixing.
James Busche created FLINK-30456:
Summary: OLM Bundle Description Version Problems
Key: FLINK-30456
URL: https://issues.apache.org/jira/browse/FLINK-30456
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-30406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30406:
---
Labels: pull-request-available (was: )
> Jobmanager Deployment error without HA metadata
gyfora opened a new pull request, #489:
URL: https://github.com/apache/flink-kubernetes-operator/pull/489
## What is the purpose of the change
The purpose of this PR is to fix the long standing annoying case where the
job was stuck after a non-upgradable state after
[
https://issues.apache.org/jira/browse/FLINK-30260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30260.
--
Fix Version/s: kubernetes-operator-1.4.0
Resolution: Fixed
> FLIP-271: Add initial Autoscaling
[
https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-30437:
---
Fix Version/s: kubernetes-operator-1.4.0
> State incompatibility issue might cause state loss
>
[
https://issues.apache.org/jira/browse/FLINK-30408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30408.
--
Resolution: Fixed
merged to main c4e76402f02f05932c6446d97bdc3d60861b9b27
> Add unit test for HA
[
https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30437.
--
Resolution: Fixed
merged to main c4e76402f02f05932c6446d97bdc3d60861b9b27
> State incompatibility
gyfora merged PR #488:
URL: https://github.com/apache/flink-kubernetes-operator/pull/488
--
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:
[
https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649470#comment-17649470
]
Gyula Fora commented on FLINK-30444:
I think the JobManager shutting down is inconsistent with the
gyfora merged PR #484:
URL: https://github.com/apache/flink-kubernetes-operator/pull/484
--
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:
MartijnVisser commented on PR #21529:
URL: https://github.com/apache/flink/pull/21529#issuecomment-1358263883
@luoyuxia I could use your help with this. This is a PR to validate that
after the update of Hadoop from 2.8.5 to 2.10.2 everything would still work. As
part of the upgrade for
[
https://issues.apache.org/jira/browse/FLINK-30232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649454#comment-17649454
]
Martijn Visser commented on FLINK-30232:
[~cthomson] Have you heard anything? Else I can take a
MartijnVisser commented on PR #21529:
URL: https://github.com/apache/flink/pull/21529#issuecomment-1358137678
@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
[
https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649416#comment-17649416
]
David Morávek commented on FLINK-30444:
---
This is a deeper issue with how the savepoints are
pnowojski commented on code in PR #20151:
URL: https://github.com/apache/flink/pull/20151#discussion_r1052418421
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java:
##
@@ -51,27 +66,40 @@ class
flinkbot commented on PR #21532:
URL: https://github.com/apache/flink/pull/21532#issuecomment-1357891772
## CI report:
* 5cb42cb1d6c5850906ac77e54d1943182097474d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gunnarmorling commented on PR #21531:
URL: https://github.com/apache/flink/pull/21531#issuecomment-1357888979
// CC @rmetzger
--
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
[
https://issues.apache.org/jira/browse/FLINK-30455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649387#comment-17649387
]
Gunnar Morling commented on FLINK-30455:
Sent PR [https://github.com/apache/flink/pull/21532,]
[
https://issues.apache.org/jira/browse/FLINK-30455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30455:
---
Labels: pull-request-available (was: )
> Avoid "cleaning" of java.lang.String in
gunnarmorling opened a new pull request, #21532:
URL: https://github.com/apache/flink/pull/21532
https://issues.apache.org/jira/browse/FLINK-30455
## What is the purpose of the change
Avoiding reflective access to java.lang.String which fails on Java 17 and
beyond.
##
flinkbot commented on PR #21531:
URL: https://github.com/apache/flink/pull/21531#issuecomment-1357877649
## CI report:
* b64e541cca8bfe43c5d0ec84918bbb2bd0851d24 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30455:
--
Assignee: Gunnar Morling
> Avoid "cleaning" of java.lang.String in ClosureCleaner
>
[
https://issues.apache.org/jira/browse/FLINK-30454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649383#comment-17649383
]
Gunnar Morling edited comment on FLINK-30454 at 12/19/22 3:51 PM:
--
Ok,
[
https://issues.apache.org/jira/browse/FLINK-30454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649383#comment-17649383
]
Gunnar Morling commented on FLINK-30454:
Ok, cool. Logged
[
https://issues.apache.org/jira/browse/FLINK-30454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30454:
---
Labels: pull-request-available (was: )
> Inconsistent class hierarchy in TaskIOMetricGroup
gunnarmorling opened a new pull request, #21531:
URL: https://github.com/apache/flink/pull/21531
## What is the purpose of the change
Making sure the runtime module can be compiled with ecj. I encountered two
locations which seem inconsistent with the JLS but were still accepted by
[
https://issues.apache.org/jira/browse/FLINK-30455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649371#comment-17649371
]
Gunnar Morling commented on FLINK-30455:
[~rmetzger] et al., if you think this makes sense,
Gunnar Morling created FLINK-30455:
--
Summary: Avoid "cleaning" of java.lang.String in ClosureCleaner
Key: FLINK-30455
URL: https://issues.apache.org/jira/browse/FLINK-30455
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649365#comment-17649365
]
Robert Metzger commented on FLINK-30454:
I'm pretty sure these are not public classes. We use
pnowojski commented on code in PR #20151:
URL: https://github.com/apache/flink/pull/20151#discussion_r1052319366
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java:
##
@@ -286,27 +277,32 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-30450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649364#comment-17649364
]
Anton Ippolitov commented on FLINK-30450:
-
I am mostly interested in the checkpoint / savepoint
[
https://issues.apache.org/jira/browse/FLINK-15786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-15786:
---
Priority: Major (was: Not a Priority)
> Load connector code with separate classloader
>
[
https://issues.apache.org/jira/browse/FLINK-30450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649362#comment-17649362
]
Martijn Visser commented on FLINK-30450:
With regards to this request, are you looking at
pnowojski commented on code in PR #20151:
URL: https://github.com/apache/flink/pull/20151#discussion_r1052295272
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java:
##
@@ -18,280 +18,265 @@
package
Aitozi commented on PR #21441:
URL: https://github.com/apache/flink/pull/21441#issuecomment-1357774211
Hi @twalthr could help take a look at this simple cleanup?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek reassigned FLINK-30444:
-
Assignee: David Morávek
> State recovery error not handled correctly and always causes
[
https://issues.apache.org/jira/browse/FLINK-30450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649357#comment-17649357
]
Anton Ippolitov commented on FLINK-30450:
-
Thank you for creating this ticket! To expand on what
flinkbot commented on PR #21530:
URL: https://github.com/apache/flink/pull/21530#issuecomment-1357765946
## CI report:
* c139c227d20dd5e3406ac080d3efcc0e1c106e9d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30376:
---
Labels: pull-request-available (was: )
> Introduce a new flink busy join reorder rule
swuferhong opened a new pull request, #21530:
URL: https://github.com/apache/flink/pull/21530
## What is the purpose of the change
Introducing a new Flink busy join reorder strategy which based on the greedy
algorithm. The old join reorder rule will also be the default join
ramkrish86 commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-1357757731
@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
Aitozi commented on PR #15137:
URL: https://github.com/apache/flink/pull/15137#issuecomment-1357750969
Thanks @twalthr for your input. Because the `TableEnvironment#getCatalog`
leak the internal `Catalog` to the user's face, it's not compatible to enforce
the Catalog to interact with
[
https://issues.apache.org/jira/browse/FLINK-30454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gunnar Morling updated FLINK-30454:
---
Description:
I noticed an interesting issue when trying to compile the flink-runtime module
[
https://issues.apache.org/jira/browse/FLINK-30454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649345#comment-17649345
]
Gunnar Morling edited comment on FLINK-30454 at 12/19/22 2:16 PM:
--
Gunnar Morling created FLINK-30454:
--
Summary: Inconsistent class hierarchy in TaskIOMetricGroup
Key: FLINK-30454
URL: https://issues.apache.org/jira/browse/FLINK-30454
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-30454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649345#comment-17649345
]
Gunnar Morling commented on FLINK-30454:
[~rmetzger] , curious about your thoughts on that
[
https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649343#comment-17649343
]
Gyula Fora commented on FLINK-28875:
merged to release-1.3 69f7e94808cbded27f2238bf3039b9d693009f4a
[
https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-28875:
---
Fix Version/s: kubernetes-operator-1.3.1
> Add FlinkSessionJobControllerTest
>
gyfora merged PR #486:
URL: https://github.com/apache/flink-kubernetes-operator/pull/486
--
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:
ramkrish86 commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-1357728930
Pushed the changes. We will update here once the other tests are done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1052217885
##
flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/converter/MongoConvertersTest.java:
##
@@ -146,28 +146,31 @@ public
[
https://issues.apache.org/jira/browse/FLINK-30355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-30355.
--
Fix Version/s: 1.17.0
Resolution: Fixed
Fixed in master:
MartijnVisser merged PR #21520:
URL: https://github.com/apache/flink/pull/21520
--
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:
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1052209447
##
flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/converter/MongoConvertersTest.java:
##
@@ -146,28 +146,31 @@ public
MartijnVisser commented on PR #21128:
URL: https://github.com/apache/flink/pull/21128#issuecomment-1357654602
@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
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1052185934
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java:
##
@@ -151,16 +146,11 @@ public
twalthr commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1052181728
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java:
##
@@ -151,16 +146,11 @@ public
[
https://issues.apache.org/jira/browse/FLINK-27177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot updated FLINK-27177:
-
Description: Following the plan in
wangyang0918 commented on PR #21527:
URL: https://github.com/apache/flink/pull/21527#issuecomment-1357635178
We need to add a test to guard this behavior.
--
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
flinkbot commented on PR #21529:
URL: https://github.com/apache/flink/pull/21529#issuecomment-1357633959
## CI report:
* d56fcee002d98d3a9b70818c0243cbb4856b3874 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-27925:
-
Assignee: ouyangwulin
> Avoid to create watcher without the resourceVersion
>
[
https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649317#comment-17649317
]
Yang Wang commented on FLINK-27925:
---
Thanks [~ouyangwuli] for sharing the investigation. +1 for adding
MartijnVisser opened a new pull request, #21529:
URL: https://github.com/apache/flink/pull/21529
This PR is only to validate if https://github.com/apache/flink/pull/21128
compiles with the Hadoop 3 profile
--
This is an automated message from the Apache Git Service.
To respond to the
boring-cyborg[bot] commented on PR #41:
URL:
https://github.com/apache/flink-connector-aws/pull/41#issuecomment-1357608490
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is an
astamur opened a new pull request, #41:
URL: https://github.com/apache/flink-connector-aws/pull/41
## What is the purpose of the change
[FLINK-30224](https://issues.apache.org/jira/projects/FLINK/issues/FLINK-30224)
- An IT test was added which ensures that the issue with a slow KDS
[
https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649232#comment-17649232
]
ouyangwulin edited comment on FLINK-27925 at 12/19/22 12:31 PM:
In the
[
https://issues.apache.org/jira/browse/FLINK-30423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30423:
---
Labels: pull-request-available (was: )
> Introduce cast executor codegen for column type
zjureel opened a new pull request, #441:
URL: https://github.com/apache/flink-table-store/pull/441
This PR aims to introduce codegen for `CastExecutor`, the main codes are
copied from flink `CastRule` and related class
--
This is an automated message from the Apache Git Service.
To
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1052145855
##
flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/converter/MongoConvertersTest.java:
##
@@ -146,28 +146,31 @@ public
[
https://issues.apache.org/jira/browse/FLINK-29996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-29996.
--
Resolution: Fixed
merged in master: 3c043cfd68fd52135175d4ae3d65a1e1909af133
> Link to the task
Myasuka merged PR #21465:
URL: https://github.com/apache/flink/pull/21465
--
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:
1 - 100 of 150 matches
Mail list logo
