Arvid Heise created FLINK-37622:
---
Summary: Exactly once Kafka sink does not produce any records in
batch mode
Key: FLINK-37622
URL: https://issues.apache.org/jira/browse/FLINK-37622
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise reassigned FLINK-36648:
---
Assignee: Arvid Heise (was: Yanquan Lv)
> Release flink-connector-kafka v4.0.0 for Flink 2
MOBIN-F commented on PR #3980:
URL: https://github.com/apache/flink-cdc/pull/3980#issuecomment-2785142817
ci failed. I'll check again later
--
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 spe
ruanhang1993 commented on code in PR #3708:
URL: https://github.com/apache/flink-cdc/pull/3708#discussion_r2032439969
##
docs/content/docs/connectors/flink-sources/mysql-cdc.md:
##
@@ -426,6 +426,19 @@ During a snapshot operation, the connector will query each
included table to
github-actions[bot] commented on PR #25470:
URL: https://github.com/apache/flink/pull/25470#issuecomment-2785362064
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
github-actions[bot] commented on PR #25439:
URL: https://github.com/apache/flink/pull/25439#issuecomment-2785361786
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
github-actions[bot] commented on PR #25450:
URL: https://github.com/apache/flink/pull/25450#issuecomment-2785361905
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
github-actions[bot] commented on PR #25455:
URL: https://github.com/apache/flink/pull/25455#issuecomment-2785361975
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
Zakelly opened a new pull request, #26415:
URL: https://github.com/apache/flink/pull/26415
## What is the purpose of the change
There is a concurrency issue for reference counting in ForSt file cache,
which could lead to a read error in some special scenarios (e.g. extremely
frequent
beliefer opened a new pull request, #26417:
URL: https://github.com/apache/flink/pull/26417
## What is the purpose of the change
This PR aims to improve the readability of `DefaultAllocatedSlotPool`.
The original name `registeredSlots` can't tell developers any useful
information.
[
https://issues.apache.org/jira/browse/FLINK-37553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37553:
---
Labels: pull-request-available (was: )
> Make ForStKeyedStateBackend consider namespaceSeri
fredia commented on code in PR #26415:
URL: https://github.com/apache/flink/pull/26415#discussion_r2032341068
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataInputStream.java:
##
@@ -102,62 +102,81 @@ private FSDataI
mayuehappy opened a new pull request, #26416:
URL: https://github.com/apache/flink/pull/26416
…during restoring state
## What is the purpose of the change
Make ForStKeyedStateBackend update NamespaceSerializer during restoring state
## Brief change log
flinkbot commented on PR #26415:
URL: https://github.com/apache/flink/pull/26415#issuecomment-2785105538
## CI report:
* 7b963ba791e89acf37bb95e08dcfdc724dee6624 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-37458:
--
Assignee: Yanfei Lei
> Forbid enableAsyncState() for synchronous operators
>
[
https://issues.apache.org/jira/browse/FLINK-37458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941759#comment-17941759
]
Yanfei Lei commented on FLINK-37458:
Merged into release-2.0 via 14e85eced10e98bc758
MOBIN-F opened a new pull request, #3980:
URL: https://github.com/apache/flink-cdc/pull/3980
Code style verifier has been updated to JUnit 5
--
This is an automated message from the Apache Git
leonardBang commented on PR #3980:
URL: https://github.com/apache/flink-cdc/pull/3980#issuecomment-2785104152
Thanks @MOBIN-F for the quickfix
--
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
[
https://issues.apache.org/jira/browse/FLINK-37628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37628:
---
Labels: pull-request-available (was: )
> Wrong reference counting in ForSt file cache
> ---
flinkbot commented on PR #26416:
URL: https://github.com/apache/flink/pull/26416#issuecomment-2785176177
## CI report:
* 8f4cfd9ee17624cda10a40d69b8891bd1edd4593 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #26417:
URL: https://github.com/apache/flink/pull/26417#issuecomment-2785177001
## CI report:
* 7fd9bfbbd3106b4c43f3f14d69c056550fa66aff UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hql0312 commented on PR #3979:
URL: https://github.com/apache/flink-cdc/pull/3979#issuecomment-2785178413
> Please check the code style. @hql0312
ok，done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
beliefer opened a new pull request, #26418:
URL: https://github.com/apache/flink/pull/26418
## What is the purpose of the change
This PR aims to unify the name for the collection of `SlotOffer`.
Currently, there are two name of variable about collection of `SlotOffer`.
One is `slot
Zakelly commented on code in PR #26415:
URL: https://github.com/apache/flink/pull/26415#discussion_r2032354803
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/cache/CachedDataInputStream.java:
##
@@ -102,62 +102,81 @@ private FSData
[
https://issues.apache.org/jira/browse/FLINK-37623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-37623:
---
Assignee: Yanfei Lei (was: Zakelly Lan)
> Async state support for `process()` in Datastre
flinkbot commented on PR #26418:
URL: https://github.com/apache/flink/pull/26418#issuecomment-2785194374
## CI report:
* 43a54812fb035d279a21137de5f65d667500142d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
github-actions[bot] commented on PR #25486:
URL: https://github.com/apache/flink/pull/25486#issuecomment-2785362205
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
[
https://issues.apache.org/jira/browse/FLINK-36683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36683.
Resolution: Resolved
Resolved via master: 2e4abdb68ed960f09610cb8be332b770a07ba53e
> Support meta
tomncooper commented on code in PR #161:
URL:
https://github.com/apache/flink-connector-kafka/pull/161#discussion_r2030882248
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterFaultToleranceITCase.java:
##
@@ -40,7 +40,7 @@ public class Kaf
[
https://issues.apache.org/jira/browse/FLINK-37626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-37626:
---
Assignee: Zakelly Lan
> Flaky test: ForStFlinkFileSystemTest.testSstFileInCache
> -
flinkbot commented on PR #26412:
URL: https://github.com/apache/flink/pull/26412#issuecomment-2782507746
## CI report:
* f818133916a63feec3aba9361323b2c2231d0afd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
davidradl commented on code in PR #26412:
URL: https://github.com/apache/flink/pull/26412#discussion_r2030769398
##
docs/layouts/shortcodes/generated/forst_configuration.html:
##
@@ -116,6 +116,12 @@
String
The primary directory where ForSt puts its SST
pnowojski commented on code in PR #26388:
URL: https://github.com/apache/flink/pull/26388#discussion_r2030767818
##
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/InternalSourceSplitMetricGroup.java:
##
@@ -191,4 +191,17 @@ public Boolean isIdle() {
pub
flinkbot commented on PR #26413:
URL: https://github.com/apache/flink/pull/26413#issuecomment-2782943869
## CI report:
* 15cc4c070ca4a56aa1057071d421c0a95a10dd89 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
twalthr commented on PR #26396:
URL: https://github.com/apache/flink/pull/26396#issuecomment-2783419929
@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.
[
https://issues.apache.org/jira/browse/FLINK-36090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-36090:
--
Assignee: Maxim Vershinin
> Bug with IngestDB restore operation for priority queue st
akalash commented on code in PR #26320:
URL: https://github.com/apache/flink/pull/26320#discussion_r2031317302
##
docs/layouts/shortcodes/generated/rest_v1_dispatcher.html:
##
@@ -2879,7 +3009,72 @@
"properties" : {
"plan" : {
"type" : "object",
- "id" :
"ur
[
https://issues.apache.org/jira/browse/FLINK-36090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter resolved FLINK-36090.
Assignee: (was: Maxim Vershinin)
Resolution: Duplicate
Already fixed in FLINK-35
leonardBang merged PR #3705:
URL: https://github.com/apache/flink-cdc/pull/3705
--
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
prshnt commented on PR #135:
URL:
https://github.com/apache/flink-connector-kafka/pull/135#issuecomment-2782506369
@dependabot rebase
--
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
gguptp commented on code in PR #195:
URL:
https://github.com/apache/flink-connector-aws/pull/195#discussion_r2030973955
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling/PollingKinesisShardSplitReader.java:
darenwkt commented on code in PR #195:
URL:
https://github.com/apache/flink-connector-aws/pull/195#discussion_r2030971648
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling/PollingKinesisShardSplitReader.jav
juntaozhang commented on code in PR #26410:
URL: https://github.com/apache/flink/pull/26410#discussion_r2031022714
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeCasts.java:
##
@@ -538,6 +539,11 @@ private CastAvoidanceCheck
[
https://issues.apache.org/jira/browse/FLINK-35466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941590#comment-17941590
]
Lorenzo Affetti commented on FLINK-35466:
-
I would like to take this one
> Cann
[
https://issues.apache.org/jira/browse/FLINK-37621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941475#comment-17941475
]
Zakelly Lan commented on FLINK-37621:
-
Seems we lack support for `process()` with as
[
https://issues.apache.org/jira/browse/FLINK-37621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-37621:
---
Assignee: Zakelly Lan
> EnableAsyncState doesn't seem to do anything on DataStream API and
1996fanrui merged PR #26372:
URL: https://github.com/apache/flink/pull/26372
--
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.ap
Zakelly Lan created FLINK-37624:
---
Summary: Support enableAsyncState and switch operator after
datastream transformation
Key: FLINK-37624
URL: https://issues.apache.org/jira/browse/FLINK-37624
Project: F
Zakelly Lan created FLINK-37623:
---
Summary: Async state support for `process()` in Datastream API
Key: FLINK-37623
URL: https://issues.apache.org/jira/browse/FLINK-37623
Project: Flink
Issue Ty
1996fanrui merged PR #26367:
URL: https://github.com/apache/flink/pull/26367
--
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.ap
Zakelly commented on code in PR #26393:
URL: https://github.com/apache/flink/pull/26393#discussion_r2030677692
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/SavepointMetadataTableFunction.java:
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-37143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-37143.
-
Assignee: Yanquan Lv
Resolution: Fixed
> Update version of flink-connector-kafka to 4.0-SN
gaborgsomogyi commented on code in PR #26393:
URL: https://github.com/apache/flink/pull/26393#discussion_r2030693310
##
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/SavepointMetadataTableFunction.java:
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed
tomncooper commented on PR #161:
URL:
https://github.com/apache/flink-connector-kafka/pull/161#issuecomment-2782791845
> @tomncooper @MartijnVisser @AHeise I suggest we move to Kafka 4.0..0
client when we do Kafka connector v4 for Flink 2. WDYT? ( assuming we can sort
out the tests)
>
Zakelly commented on code in PR #26412:
URL: https://github.com/apache/flink/pull/26412#discussion_r2030928114
##
docs/content.zh/docs/ops/state/disaggregated_state.md:
##
@@ -150,6 +150,18 @@ state.backend.forst.primary-dir:
s3://your-bucket/forst-state
checkpoint and fast re
Zakelly opened a new pull request, #26413:
URL: https://github.com/apache/flink/pull/26413
(no comment)
--
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-ma
Gabor Somogyi created FLINK-37626:
-
Summary: Flaky test: ForStFlinkFileSystemTest.testSstFileInCache
Key: FLINK-37626
URL: https://issues.apache.org/jira/browse/FLINK-37626
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-37626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-37626:
--
Description:
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/re
fredia commented on PR #26412:
URL: https://github.com/apache/flink/pull/26412#issuecomment-2783112395
> Should we also use ResourceGuard like
[FLINK-37597](https://issues.apache.org/jira/browse/FLINK-37597) when using
sync mode to access remote storage ?
`ResourceGuard` is used to e
JNSimba commented on PR #3767:
URL: https://github.com/apache/flink-cdc/pull/3767#issuecomment-2783640913
> @JNSimba Could we provide this feature by `SupportsProjectionPushDown`?
`debezium.column.include.list` and `debezium.column.exclude.list` is hard for
users to understand and use. We c
leonardBang merged PR #3888:
URL: https://github.com/apache/flink-cdc/pull/3888
--
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
fapaul commented on code in PR #154:
URL:
https://github.com/apache/flink-connector-kafka/pull/154#discussion_r2031443184
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionOwnership.java:
##
@@ -0,0 +1,205 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-36611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36611:
--
Assignee: MOBIN
> Add schema info to output of Kafka sink
> ---
[
https://issues.apache.org/jira/browse/FLINK-36611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-36611.
Resolution: Implemented
Implemented via master: 3457a922b5da331243fb3a4a1bc26a1b58e81b36
> Add sc
leonardBang merged PR #3791:
URL: https://github.com/apache/flink-cdc/pull/3791
--
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
leonardBang merged PR #3848:
URL: https://github.com/apache/flink-cdc/pull/3848
--
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
leonardBang merged PR #3959:
URL: https://github.com/apache/flink-cdc/pull/3959
--
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
AHeise commented on code in PR #154:
URL:
https://github.com/apache/flink-connector-kafka/pull/154#discussion_r2031458928
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/TransactionOwnership.java:
##
@@ -0,0 +1,205 @@
+/*
+ * Licensed to th
FranMorilloAWS commented on PR #140:
URL:
https://github.com/apache/flink-connector-kafka/pull/140#issuecomment-2783947758
When is this releasing?
--
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
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031778448
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/ModelDescriptor.java:
##
@@ -0,0 +1,244 @@
+/*
+ * Licensed to the Apache Software Founda
leekeiabstraction commented on code in PR #195:
URL:
https://github.com/apache/flink-connector-aws/pull/195#discussion_r2031062113
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling/PollingKinesisShardSplitR
masteryhx commented on PR #26412:
URL: https://github.com/apache/flink/pull/26412#issuecomment-2783084846
Thanks for the PR.
Just an extra comment: Should we also use ResourceGuard like
[FLINK-37597](https://issues.apache.org/jira/browse/FLINK-37597) when using
sync mode to access remote
[
https://issues.apache.org/jira/browse/FLINK-37616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mika Naylor updated FLINK-37616:
Summary: PyFlink incorrectly unpickles Row fields within a Row (was:
PyFlink incorrectly unpickle
DanRoscigno commented on PR #25194:
URL: https://github.com/apache/flink/pull/25194#issuecomment-2783710846
Please can this be reviewed?
--
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 specif
Zakelly Lan created FLINK-37628:
---
Summary: Wrong reference counting in ForSt file cache
Key: FLINK-37628
URL: https://issues.apache.org/jira/browse/FLINK-37628
Project: Flink
Issue Type: Bug
gaborgsomogyi merged PR #26393:
URL: https://github.com/apache/flink/pull/26393
--
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
Keith Lee created FLINK-37627:
-
Summary: Restarting from a checkpoint/savepoint which coincides
with shard split causes data loss
Key: FLINK-37627
URL: https://issues.apache.org/jira/browse/FLINK-37627
Pr
autophagy opened a new pull request, #26414:
URL: https://github.com/apache/flink/pull/26414
## What is the purpose of the change
When creating a table using `TableEnvironment.from_elements`, the Table API
skips type validation on any Row elements that were created using positional
a
flinkbot commented on PR #26414:
URL: https://github.com/apache/flink/pull/26414#issuecomment-2783296378
## CI report:
* 92e7cc3e8e13c1c011ae107921c0b43b31cbc1d7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hlteoh37 merged PR #26387:
URL: https://github.com/apache/flink/pull/26387
--
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.apac
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031879610
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/ModelDescriptor.java:
##
@@ -0,0 +1,244 @@
+/*
+ * Licensed to the Apache Software Founda
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031900150
##
flink-python/pyflink/table/table_environment.py:
##
@@ -1071,6 +1128,88 @@ def create_view(self,
self._j_tenv.createView(view_path, table, ignore_if_exi
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031904769
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/CatalogManagerTest.java:
##
@@ -343,12 +343,14 @@ public void testModelModificationLi
[
https://issues.apache.org/jira/browse/FLINK-37627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941693#comment-17941693
]
Arun Lakshman edited comment on FLINK-37627 at 4/7/25 7:19 PM:
---
beliefer commented on PR #26372:
URL: https://github.com/apache/flink/pull/26372#issuecomment-2782469397
@1996fanrui @davidradl Thank you all!
--
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
[
https://issues.apache.org/jira/browse/FLINK-37620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37620:
---
Labels: pull-request-available (was: )
> ForSt Sync mode support remote storage and provide
[
https://issues.apache.org/jira/browse/FLINK-37585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941499#comment-17941499
]
Xin Gong commented on FLINK-37585:
--
You can see this discussion
[https://github.com/ap
davidradl commented on code in PR #26410:
URL: https://github.com/apache/flink/pull/26410#discussion_r2030762088
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeCasts.java:
##
@@ -538,6 +539,11 @@ private CastAvoidanceChecker
[
https://issues.apache.org/jira/browse/FLINK-25672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941577#comment-17941577
]
Nickel Fang commented on FLINK-25672:
-
We had the same issue (OOM in job manager) an
twalthr merged PR #26406:
URL: https://github.com/apache/flink/pull/26406
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-37607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941594#comment-17941594
]
Heart Zhou commented on FLINK-37607:
I would like to work on this issue.
> Blockli
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031795676
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -158,6 +167,121 @@ void testTableFromDescriptor() {
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031813534
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -158,6 +167,121 @@ void testTableFromDescriptor() {
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031798763
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -212,4 +336,39 @@ private static void
assertTemporaryCr
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031803406
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -212,4 +336,39 @@ private static void
assertTemporaryCr
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031821725
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -212,4 +336,39 @@ private static void
assertTemporaryCr
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031838881
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -564,6 +565,36 @@ public boolean createView(Str
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031786003
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -158,6 +167,121 @@ void testTableFromDescriptor() {
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031798763
##
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableEnvironmentTest.java:
##
@@ -212,4 +336,39 @@ private static void
assertTemporaryCr
snuyanzin commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2031827083
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1647,6 +1675,8 @@ private void execute(
1 - 100 of 107 matches
Mail list logo
