[
https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732378#comment-17732378
]
Michael Hempel-Jørgensen commented on FLINK-31856:
--
[~reta] yes, I think your
hanyuzheng7 commented on PR #22717:
URL: https://github.com/apache/flink/pull/22717#issuecomment-1590501036
Hi, @snuyanzin. Thank you for your comments.
Do you think this is ok now?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
macdoor615 created FLINK-32333:
--
Summary: The same SQL statement, sql-client and sql-gateway give
different execution plans
Key: FLINK-32333
URL: https://issues.apache.org/jira/browse/FLINK-32333
huwh commented on PR #22686:
URL: https://github.com/apache/flink/pull/22686#issuecomment-1590441961
Thanks a lot, comments addressed and fixup commit squashed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
xintongsong commented on code in PR #22733:
URL: https://github.com/apache/flink/pull/22733#discussion_r1228923781
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/memory/MemoryTierConsumerAgent.java:
##
@@ -0,0 +1,71 @@
+/*
+ *
wanglijie95 commented on code in PR #22686:
URL: https://github.com/apache/flink/pull/22686#discussion_r1228936755
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraphBuilder.java:
##
@@ -118,36 +118,44 @@ public static
TanYuxin-tyx commented on PR #22728:
URL: https://github.com/apache/flink/pull/22728#issuecomment-1590374279
Thanks @xintongsong and @reswqa for helping review the code.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
huwh commented on PR #22686:
URL: https://github.com/apache/flink/pull/22686#issuecomment-1590369528
Thanks for your review, @wanglijie95 . comments addressed. Please take a
look.
Since only "BlobWriter.serializeAndTryOffload" will throw an IOException,
I'd like to remove the try
[
https://issues.apache.org/jira/browse/FLINK-31641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31641.
--
Fix Version/s: 1.18.0
Resolution: Fixed
master(1.18) via
reswqa merged PR #22728:
URL: https://github.com/apache/flink/pull/22728
--
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:
reswqa commented on PR #17867:
URL: https://github.com/apache/flink/pull/17867#issuecomment-1590359837
Thanks for Inviting me, this change looks good to me. But I'm not familiar
with Table / SQL related codes, it's best to wait for @fsk119 to take a look.
--
This is an automated message
Fang Yong created FLINK-32332:
-
Summary: Jar files for catalog function are not listed correctly
Key: FLINK-32332
URL: https://issues.apache.org/jira/browse/FLINK-32332
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31916:
---
Labels: pull-request-available (was: )
> Python API only respects deprecated env.java.opts
hanyuzheng7 commented on code in PR #22717:
URL: https://github.com/apache/flink/pull/22717#discussion_r1228736983
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -479,4 +480,82 @@ private Stream
hanyuzheng7 commented on code in PR #22717:
URL: https://github.com/apache/flink/pull/22717#discussion_r1228736983
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -479,4 +480,82 @@ private Stream
flinkbot commented on PR #22775:
URL: https://github.com/apache/flink/pull/22775#issuecomment-1589940884
## CI report:
* c8b5a3ac0ad29fd4173fc7edd68e27762a59d6a4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32150.
Resolution: Duplicate
> ThreadDumpInfoTest crashed with exit code 239 on AZP
[
https://issues.apache.org/jira/browse/FLINK-32200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32200.
Resolution: Duplicate
> OrcFileSystemITCase cashed with exit code 239
[
https://issues.apache.org/jira/browse/FLINK-30153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30153.
Resolution: Duplicate
> YARNSessionCapacitySchedulerITCase fails with
[
https://issues.apache.org/jira/browse/FLINK-32192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32192.
Resolution: Duplicate
> JsonBatchFileSystemITCase fail due to Process Exit Code: 239
>
[
https://issues.apache.org/jira/browse/FLINK-32189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32189.
Resolution: Fixed
> Integration tests fail due to Process Exit Code: 239 and
[
https://issues.apache.org/jira/browse/FLINK-30299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30299.
Resolution: Duplicate
> TaskManagerRunnerTest fails with 239 exit code (i.e.
>
[
https://issues.apache.org/jira/browse/FLINK-32314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32314.
Resolution: Fixed
master: 09df45a88a3c95fd8211a5051572b470d31063b1
> Ignore
[
https://issues.apache.org/jira/browse/FLINK-31669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-31669.
Resolution: Duplicate
> DynamicFilteringITCase failed fataly because of
zentol merged PR #22764:
URL: https://github.com/apache/flink/pull/22764
--
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-31919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-31919.
Resolution: Fixed
master: 50f069ce5b1203df8acd724d804afc33eda8a9d4
> Skip ClosureCleaner
zentol merged PR #22551:
URL: https://github.com/apache/flink/pull/22551
--
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:
snuyanzin commented on code in PR #22717:
URL: https://github.com/apache/flink/pull/22717#discussion_r1228696955
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -479,4 +480,82 @@ private Stream
snuyanzin commented on code in PR #22717:
URL: https://github.com/apache/flink/pull/22717#discussion_r1228696955
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CollectionFunctionsITCase.java:
##
@@ -479,4 +480,82 @@ private Stream
[
https://issues.apache.org/jira/browse/FLINK-25000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-25000:
Assignee: Chesnay Schepler
> Scala 2.12.7 doesn't compile on Java 17
>
flinkbot commented on PR #22776:
URL: https://github.com/apache/flink/pull/22776#issuecomment-1590003206
## CI report:
* 3447babaef48cf9e019348fdd3ae47609d09c835 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
zentol opened a new pull request, #22776:
URL: https://github.com/apache/flink/pull/22776
(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,
[
https://issues.apache.org/jira/browse/FLINK-31916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-31916:
Assignee: Chesnay Schepler
> Python API only respects deprecated env.java.opts
[
https://issues.apache.org/jira/browse/FLINK-17224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-17224:
---
Assignee: Sergey Nuyanzin
> Precision of TIME type does not work correctly
>
[
https://issues.apache.org/jira/browse/FLINK-17224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732242#comment-17732242
]
Sergey Nuyanzin commented on FLINK-17224:
-
I would take
> Precision of TIME type does not work
[
https://issues.apache.org/jira/browse/FLINK-17224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17224:
---
Labels: auto-unassigned pull-request-available (was: auto-unassigned)
> Precision of TIME
snuyanzin opened a new pull request, #22775:
URL: https://github.com/apache/flink/pull/22775
## What is the purpose of the change
The PR makes support of `TIME` precision (0-3 - currently only this range,
I'm going to submit support for micros and nanos in the next PR) including
[
https://issues.apache.org/jira/browse/FLINK-32297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32297.
Resolution: Fixed
master: f83c6e0cc9dec2ec563c5ad65aa87622c47f7462
> Use Temurin image
zentol merged PR #22747:
URL: https://github.com/apache/flink/pull/22747
--
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:
hanyuzheng7 commented on PR #22717:
URL: https://github.com/apache/flink/pull/22717#issuecomment-1589833404
@snuyanzin
Thank you for your suggestions.
Do you think this is ok?
--
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-32331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32331:
---
Labels: pull-request-available (was: )
> Print JVM thread dumps when Github Actions
Martijn Visser created FLINK-32331:
--
Summary: Print JVM thread dumps when Github Actions workflow gets
cancelled/times out
Key: FLINK-32331
URL: https://issues.apache.org/jira/browse/FLINK-32331
zentol commented on code in PR #22774:
URL: https://github.com/apache/flink/pull/22774#discussion_r1228496348
##
flink-end-to-end-tests/test-scripts/test_ha_datastream.sh:
##
@@ -45,7 +45,8 @@ function run_ha_test() {
# change the pid dir to start log files always from 0,
[
https://issues.apache.org/jira/browse/FLINK-32304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732198#comment-17732198
]
Chesnay Schepler edited comment on FLINK-32304 at 6/13/23 5:49 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-32304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32304:
-
Fix Version/s: 1.17.2
> Reduce rpc-akka jar size
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-32304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32304:
-
Fix Version/s: (was: 1.17.2)
> Reduce rpc-akka jar size
>
[
https://issues.apache.org/jira/browse/FLINK-32304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32304.
Resolution: Fixed
master: f145341bd6085d003922cba0a157693bd56338b0
> Reduce rpc-akka jar
[
https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-31856:
Fix Version/s: opensearch-1.0.2
> Add support for Opensearch Connector REST client
[
https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732197#comment-17732197
]
Sergey Nuyanzin commented on FLINK-31856:
-
merged to 1.0.x as
[
https://issues.apache.org/jira/browse/FLINK-32329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32329:
---
Labels: pull-request-available (was: )
> Do not overwrite env.java.opts.all in HA e2e test
XComp commented on code in PR #22774:
URL: https://github.com/apache/flink/pull/22774#discussion_r1228487316
##
flink-end-to-end-tests/test-scripts/test_ha_datastream.sh:
##
@@ -45,7 +45,8 @@ function run_ha_test() {
# change the pid dir to start log files always from 0,
snuyanzin merged PR #26:
URL: https://github.com/apache/flink-connector-opensearch/pull/26
--
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:
snuyanzin commented on PR #26:
URL:
https://github.com/apache/flink-connector-opensearch/pull/26#issuecomment-1589759681
for clarity backport of
https://github.com/apache/flink-connector-opensearch/pull/24
--
This is an automated message from the Apache Git Service.
To respond to the
zentol merged PR #22773:
URL: https://github.com/apache/flink/pull/22773
--
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-32328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32328.
Resolution: Fixed
master: 5fe0a506d598831376aefa75f900f2c59b6343b5
> Ensure surefire
[
https://issues.apache.org/jira/browse/FLINK-32330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32330.
Fix Version/s: (was: 1.18.0)
Resolution: Not A Problem
Turns out the Azure
[
https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-31856.
-
Fix Version/s: opensearch-1.1.0
Resolution: Fixed
> Add support for Opensearch
[
https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732177#comment-17732177
]
Sergey Nuyanzin commented on FLINK-31856:
-
Great that the issue is solved
thanks [~reta] for
snuyanzin merged PR #24:
URL: https://github.com/apache/flink-connector-opensearch/pull/24
--
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-32301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32301.
Resolution: Fixed
master: 4d22ad0cc3ff24619cd111e139cf3f9606521a6b
>
zentol merged PR #22748:
URL: https://github.com/apache/flink/pull/22748
--
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:
zentol commented on PR #22747:
URL: https://github.com/apache/flink/pull/22747#issuecomment-1589677933
@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.
zentol commented on code in PR #22764:
URL: https://github.com/apache/flink/pull/22764#discussion_r1228372238
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RobustActorSystem.java:
##
Review Comment:
> It's probably the threadFactory
[
https://issues.apache.org/jira/browse/FLINK-31476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732144#comment-17732144
]
Gyula Fora edited comment on FLINK-31476 at 6/13/23 3:42 PM:
-
[~chesnay]
[
https://issues.apache.org/jira/browse/FLINK-31476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732144#comment-17732144
]
Gyula Fora commented on FLINK-31476:
[~dmvk] please let me know if you have a POC/PR to review :)
XComp commented on code in PR #22764:
URL: https://github.com/apache/flink/pull/22764#discussion_r1228338586
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RobustActorSystem.java:
##
@@ -85,17 +86,52 @@ private static RobustActorSystem create(
[
https://issues.apache.org/jira/browse/FLINK-32238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32238:
-
Description:
I think I found a stable way to install libssl on CI.
-Update:-
-We have
[
https://issues.apache.org/jira/browse/FLINK-32238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32238:
-
Description:
I think I found a stable way to install libssl on CI.
-Update:-
-We have
[
https://issues.apache.org/jira/browse/FLINK-32238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732137#comment-17732137
]
Chesnay Schepler edited comment on FLINK-32238 at 6/13/23 3:12 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-32238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-32238.
Resolution: Fixed
> Stable approach for installing libssl
>
[
https://issues.apache.org/jira/browse/FLINK-32238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732137#comment-17732137
]
Chesnay Schepler commented on FLINK-32238:
--
1.16: 892f3caa606da046afe5637f3f58d791a9df4974
>
zentol commented on code in PR #22753:
URL: https://github.com/apache/flink/pull/22753#discussion_r1228288172
##
flink-rpc/flink-rpc-akka/pom.xml:
##
@@ -136,21 +123,11 @@ under the License.
-
-
flinkbot commented on PR #22774:
URL: https://github.com/apache/flink/pull/22774#issuecomment-1589486384
## CI report:
* 53288dfe670d0bb56f25bda776808b8598d68abb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-32330:
-
Summary: Install Java 17 in e2e builds (was: Setup Java 17 in e2e builds)
> Install
Chesnay Schepler created FLINK-32330:
Summary: Setup Java 17 in e2e builds
Key: FLINK-32330
URL: https://issues.apache.org/jira/browse/FLINK-32330
Project: Flink
Issue Type: Sub-task
StefanRRichter commented on code in PR #22771:
URL: https://github.com/apache/flink/pull/22771#discussion_r1228267599
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapper.java:
##
@@ -79,7 +82,16 @@
[
https://issues.apache.org/jira/browse/FLINK-3232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-3232:
--
Labels: pull-request-available (was: )
> Add option to eagerly deploy channels
>
Chesnay Schepler created FLINK-32329:
Summary: Do not overwrite env.java.opts.all in HA e2e test
Key: FLINK-32329
URL: https://issues.apache.org/jira/browse/FLINK-32329
Project: Flink
flinkbot commented on PR #22773:
URL: https://github.com/apache/flink/pull/22773#issuecomment-1589463450
## CI report:
* ff7a02f28456582b925fd1f93c7be6572e13ff0a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
StefanRRichter commented on code in PR #22771:
URL: https://github.com/apache/flink/pull/22771#discussion_r1228254143
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapper.java:
##
@@ -125,10 +130,16
[
https://issues.apache.org/jira/browse/FLINK-25006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-25006.
Resolution: Invalid
This was caused by missing module declarations that threw tests into
zentol commented on code in PR #22753:
URL: https://github.com/apache/flink/pull/22753#discussion_r1228245771
##
flink-rpc/flink-rpc-akka/pom.xml:
##
@@ -136,21 +123,11 @@ under the License.
-
-
[
https://issues.apache.org/jira/browse/FLINK-32328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32328:
---
Labels: pull-request-available (was: )
> Ensure surefire baseLine is picked up by IntelliJ
XComp commented on code in PR #22764:
URL: https://github.com/apache/flink/pull/22764#discussion_r1228244550
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RobustActorSystem.java:
##
Review Comment:
That's what I did. But I might just struggle
zentol opened a new pull request, #22773:
URL: https://github.com/apache/flink/pull/22773
This ensures that IntelliJ also picks up these settings.
This is important for Java 17 because the `baseArgLine` will contain module
declarations, which we need IntelliJ to also import.
Even
XComp commented on code in PR #22764:
URL: https://github.com/apache/flink/pull/22764#discussion_r1228244550
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RobustActorSystem.java:
##
Review Comment:
That's what I struggled with. But I might
Chesnay Schepler created FLINK-32328:
Summary: Ensure surefire baseLine is picked up by IntelliJ
Key: FLINK-32328
URL: https://issues.apache.org/jira/browse/FLINK-32328
Project: Flink
Chesnay Schepler created FLINK-32327:
Summary: Python Kafka connector runs into strange
NullPointerException
Key: FLINK-32327
URL: https://issues.apache.org/jira/browse/FLINK-32327
Project: Flink
zentol commented on code in PR #22764:
URL: https://github.com/apache/flink/pull/22764#discussion_r1228229005
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RobustActorSystem.java:
##
@@ -85,17 +86,52 @@ private static RobustActorSystem create(
pnowojski commented on code in PR #22771:
URL: https://github.com/apache/flink/pull/22771#discussion_r1228225553
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapper.java:
##
@@ -79,7 +82,16 @@ public
zentol commented on code in PR #22764:
URL: https://github.com/apache/flink/pull/22764#discussion_r1228226850
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RobustActorSystem.java:
##
Review Comment:
see the javadocs
--
This is an automated
XComp commented on code in PR #22753:
URL: https://github.com/apache/flink/pull/22753#discussion_r1228225178
##
flink-rpc/flink-rpc-akka/pom.xml:
##
@@ -136,21 +123,11 @@ under the License.
-
-
XComp commented on code in PR #22764:
URL: https://github.com/apache/flink/pull/22764#discussion_r1228191494
##
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RobustActorSystem.java:
##
@@ -85,17 +86,52 @@ private static RobustActorSystem create(
[
https://issues.apache.org/jira/browse/FLINK-32289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-32289:
---
Fix Version/s: 1.18.0
kafka-4.0.0
> The metadata column type is incorrect in
[
https://issues.apache.org/jira/browse/FLINK-32289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-32289.
Resolution: Fixed
> The metadata column type is incorrect in Kafka table connector example
>
[
https://issues.apache.org/jira/browse/FLINK-32289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732110#comment-17732110
]
Leonard Xu commented on FLINK-32289:
Fixed in：
flink(master)：
leonardBang merged PR #32:
URL: https://github.com/apache/flink-connector-kafka/pull/32
--
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-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732076#comment-17732076
]
Andriy Redko commented on FLINK-31856:
--
Thanks a lot [~mhjtrifork] , yeah, sadly there is no way to
[
https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17732074#comment-17732074
]
Weijie Guo commented on FLINK-26515:
Add exception handling logic via
reswqa merged PR #22743:
URL: https://github.com/apache/flink/pull/22743
--
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 179 matches
Mail list logo
