1996fanrui commented on code in PR #23599:
URL: https://github.com/apache/flink/pull/23599#discussion_r1382890456
##
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java:
##
@@ -253,13 +274,19 @@ public void loadBigData(
[
https://issues.apache.org/jira/browse/FLINK-32721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783126#comment-17783126
]
Yao Zhang commented on FLINK-32721:
---
Hi [~jackylau], [~libenchao] and [~lsy],
It seems that the
huwh commented on code in PR #23465:
URL: https://github.com/apache/flink/pull/23465#discussion_r1382886222
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfoWithHistory.java:
##
@@ -208,7 +214,34 @@ public static class ExceptionInfo {
flinkbot commented on PR #23671:
URL: https://github.com/apache/flink/pull/23671#issuecomment-1794248152
## CI report:
* 178c79746143e96148ffa990e75aab0602604713 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783123#comment-17783123
]
Yuchi Duan commented on FLINK-33437:
I have already solved this problem, and tested in our
paul8263 opened a new pull request, #23671:
URL: https://github.com/apache/flink/pull/23671
…t support CHAR type
## What is the purpose of the change
Support max aggregation with char data type by reusing the existing
MaxAggFunction.
## Brief change log
MartijnVisser commented on PR #24:
URL:
https://github.com/apache/flink-connector-hbase/pull/24#issuecomment-1794236324
CC @ferenc-csaky
--
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
MartijnVisser commented on PR #22:
URL:
https://github.com/apache/flink-connector-hbase/pull/22#issuecomment-1794236276
CC @ferenc-csaky
--
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-33451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-33451:
---
Summary: Implement FileSytem based AutoScalerStateStore (e.g :
HbaseAutoScalerStateStore) (was:
huwh commented on code in PR #23599:
URL: https://github.com/apache/flink/pull/23599#discussion_r1382863857
##
flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java:
##
@@ -253,13 +274,19 @@ public void loadBigData(
flinkbot commented on PR #23670:
URL: https://github.com/apache/flink/pull/23670#issuecomment-1794217063
## CI report:
* d9cc305fa4af38fcfaf5fe60568ce0e0c56ffed5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
RavenLite opened a new pull request, #23670:
URL: https://github.com/apache/flink/pull/23670
(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,
Jiabao-Sun commented on PR #17:
URL:
https://github.com/apache/flink-connector-mongodb/pull/17#issuecomment-1794209251
Tests for plan has been added.
--
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
[
https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783111#comment-17783111
]
Zakelly Lan commented on FLINK-20672:
-
I would like to fix this if no one takes.
>
RocMarshal commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1382851909
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocatorFactory.java:
##
@@ -84,4 +96,25 @@ public ExecutionSlotAllocator
flinkbot commented on PR #23669:
URL: https://github.com/apache/flink/pull/23669#issuecomment-1794180188
## CI report:
* 2779239ff7d889f0a15dd837609dbb900b9bc693 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
WencongLiu commented on PR #23666:
URL: https://github.com/apache/flink/pull/23666#issuecomment-1794179565
> @WencongLiu I have finished the translation, PTAL, thanks!
Thanks for the contribution. I'll take a look.
--
This is an automated message from the Apache Git Service.
To
flinkbot commented on PR #23668:
URL: https://github.com/apache/flink/pull/23668#issuecomment-1794179424
## CI report:
* 8cf6ef0c8e877dfc01984cef744382ad6d68ea97 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fengjiajie commented on PR #23478:
URL: https://github.com/apache/flink/pull/23478#issuecomment-1794179250
> Hi @fengjiajie, could you pick the fix to branch release-1.18 and
release-1.17 as well?
Hi @LadyForest , thank you for moving this forward. cherry-picks to 1.17 and
1.18:
fengjiajie opened a new pull request, #23669:
URL: https://github.com/apache/flink/pull/23669
…t for equal and non-equal comparisons for codegen
This closes #23478
1.18 backport for parent PR https://github.com/apache/flink/pull/23478
## What is the purpose of
fengjiajie opened a new pull request, #23668:
URL: https://github.com/apache/flink/pull/23668
…t for equal and non-equal comparisons for codegen
This closes #23478
1.17 backport for parent PR https://github.com/apache/flink/pull/23478
## What is the purpose of
leonardBang commented on PR #17:
URL:
https://github.com/apache/flink-connector-mongodb/pull/17#issuecomment-1794172578
> Thanks @leonardBang, shall we remove `flink-table-planner-loader`
dependency and replace it with `flink-table-planner-2.12`?
`flink-table-planner-loader` is
[
https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783106#comment-17783106
]
Jane Chan commented on FLINK-33171:
---
Fixed in master 04b98e6e80ca3a68324775166dedb7d58ae4d60b
>
LadyForest commented on PR #23478:
URL: https://github.com/apache/flink/pull/23478#issuecomment-1794159224
Hi @fengjiajie, could you pick the fix to branch release-1.18 and
release-1.17 as well?
--
This is an automated message from the Apache Git Service.
To respond to the message,
Jiabao-Sun commented on PR #17:
URL:
https://github.com/apache/flink-connector-mongodb/pull/17#issuecomment-1794157929
Thanks @leonardBang, shall we remove `flink-table-planner-loader` dependency
and replace it with `flink-table-planner-2.12`?
--
This is an automated message from the
LadyForest merged PR #23478:
URL: https://github.com/apache/flink/pull/23478
--
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:
leonardBang commented on PR #17:
URL:
https://github.com/apache/flink-connector-mongodb/pull/17#issuecomment-1794153008
> Hi @xuyangzhong。 To implement the planner's test, the
[flink-table-planner](https://issues.apache.org/jira/browse/FLINK-table-planner)_2.12
related dependencies need
Jiabao-Sun commented on PR #17:
URL:
https://github.com/apache/flink-connector-mongodb/pull/17#issuecomment-1794142093
Hi @leonardBang, could you help do the final check?
I think we may introduce it in the release 1.18 version.
--
This is an automated message from the Apache Git
flinkbot commented on PR #23667:
URL: https://github.com/apache/flink/pull/23667#issuecomment-1794139627
## CI report:
* a21e88a92bee3aa6f9ab6750c46f9f4506c534db UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
paul8263 opened a new pull request, #23667:
URL: https://github.com/apache/flink/pull/23667
…take effect in SocketTextStreamFunction
## What is the purpose of the change
Flink socket text stream connection cannot retry when it cannot connect to
the designated host and
[
https://issues.apache.org/jira/browse/FLINK-32763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32763:
---
Labels: pull-request-available (was: )
> Uncaught exceptions cause retry not to take
KarmaGYZ commented on code in PR #23658:
URL: https://github.com/apache/flink/pull/23658#discussion_r1382812017
##
flink-core/src/test/java/org/apache/flink/configuration/TaskManagerLoadBalanceModeTest.java:
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/FLINK-20772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783090#comment-17783090
]
Zakelly Lan commented on FLINK-20772:
-
Hi, [~dorbae]. Seems this is still valid in 1.18. Are you
RocMarshal commented on code in PR #23658:
URL: https://github.com/apache/flink/pull/23658#discussion_r1382783206
##
flink-core/src/test/java/org/apache/flink/configuration/TaskManagerLoadBalanceModeTest.java:
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783089#comment-17783089
]
Yue Ma commented on FLINK-7:
Update: [https://github.com/facebook/rocksdb/pull/11868] merged in
masteryhx commented on code in PR #23441:
URL: https://github.com/apache/flink/pull/23441#discussion_r1382767597
##
flink-core/src/main/java/org/apache/flink/api/common/state/AppendingState.java:
##
@@ -58,10 +58,11 @@ public interface AppendingState extends State {
* of
flinkbot commented on PR #23666:
URL: https://github.com/apache/flink/pull/23666#issuecomment-1794051414
## CI report:
* a6d7cf4800f6402a265b52433f010b007164d335 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liyubin117 commented on PR #23666:
URL: https://github.com/apache/flink/pull/23666#issuecomment-1794045001
@WencongLiu I have finished the translation, PTAL, thanks!
--
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-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33445:
---
Labels: pull-request-available starter (was: starter)
> Translate DataSet migration
liyubin117 opened a new pull request, #23666:
URL: https://github.com/apache/flink/pull/23666
## What is the purpose of the change
Translate DataSet migration guideline to Chinese
https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/datastream/dataset_migration/
[
https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-5865:
Fix Version/s: 1.19.0
> Throw original exception in states
> --
>
RocMarshal commented on code in PR #23658:
URL: https://github.com/apache/flink/pull/23658#discussion_r1382746995
##
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java:
##
@@ -708,6 +711,49 @@ public class TaskManagerOptions {
[
https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-5865.
-
Resolution: Fixed
merged cee2611e into master.
About the [FLIP-368.
[
https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu reassigned FLINK-5865:
---
Assignee: Zakelly Lan
> Throw original exception in states
>
masteryhx closed pull request #23371: [FLINK-5865][state] Unwrapping exceptions
and throw the original ones in state interfaces
URL: https://github.com/apache/flink/pull/23371
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
Zakelly commented on code in PR #23441:
URL: https://github.com/apache/flink/pull/23441#discussion_r1382739665
##
flink-core/src/main/java/org/apache/flink/api/common/state/ListState.java:
##
@@ -48,10 +48,13 @@ public interface ListState extends MergingState> {
* given
[
https://issues.apache.org/jira/browse/FLINK-32763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783074#comment-17783074
]
Yao Zhang commented on FLINK-32763:
---
Hi community,
I got the same issue and wanna work on it.
Could
masteryhx commented on code in PR #23441:
URL: https://github.com/apache/flink/pull/23441#discussion_r1382731932
##
flink-core/src/main/java/org/apache/flink/api/common/state/AppendingState.java:
##
@@ -58,10 +58,11 @@ public interface AppendingState extends State {
* of
KarmaGYZ commented on code in PR #23658:
URL: https://github.com/apache/flink/pull/23658#discussion_r1382732177
##
flink-core/src/test/java/org/apache/flink/configuration/TaskManagerLoadBalanceModeTest.java:
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Foundation
masteryhx commented on PR #22800:
URL: https://github.com/apache/flink/pull/22800#issuecomment-1793983788
> I'm closing that as I will be publishing a FLIP counter-proposal that uses
tracing to achieve the same goal.
Thanks @pnowojski for helping to push it forward, look forward to
flinkbot commented on PR #23665:
URL: https://github.com/apache/flink/pull/23665#issuecomment-1793864899
## CI report:
* c39e1268d3bf6ea6d22dda5755837a1798159c8e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28048:
---
Labels: pull-request-available (was: )
> Introduce Source API alternative to
afedulov opened a new pull request, #23665:
URL: https://github.com/apache/flink/pull/23665
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
afedulov commented on code in PR #23553:
URL: https://github.com/apache/flink/pull/23553#discussion_r1382648870
##
flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/functions/FromElementsGeneratorFunction.java:
##
@@ -0,0 +1,211 @@
+/*
+
afedulov commented on PR #23553:
URL: https://github.com/apache/flink/pull/23553#issuecomment-1793845354
@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.
afedulov commented on code in PR #23553:
URL: https://github.com/apache/flink/pull/23553#discussion_r1382645917
##
flink-formats/flink-avro/src/test/java/org/apache/flink/table/runtime/batch/AvroTypesITCase.java:
##
@@ -240,7 +240,7 @@ public void testAvroToAvro() {
}
afedulov commented on code in PR #23553:
URL: https://github.com/apache/flink/pull/23553#discussion_r1382643573
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/processor/MultipleInputNodeCreationProcessorTest.java:
##
@@ -123,7
afedulov commented on code in PR #23553:
URL: https://github.com/apache/flink/pull/23553#discussion_r1382643298
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java:
##
@@ -1188,14 +1191,14 @@ void
[
https://issues.apache.org/jira/browse/FLINK-33300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782993#comment-17782993
]
Sergey Nuyanzin commented on FLINK-33300:
-
Merged as
[
https://issues.apache.org/jira/browse/FLINK-33300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33300:
Fix Version/s: 1.19.0
> Update testcontainers dependency to v1.19.1
>
[
https://issues.apache.org/jira/browse/FLINK-33300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-33300.
-
Resolution: Fixed
> Update testcontainers dependency to v1.19.1
>
[
https://issues.apache.org/jira/browse/FLINK-33300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-33300:
---
Assignee: Sergey Nuyanzin
> Update testcontainers dependency to v1.19.1
>
snuyanzin merged PR #23537:
URL: https://github.com/apache/flink/pull/23537
--
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 #23537:
URL: https://github.com/apache/flink/pull/23537#issuecomment-1793759229
thanks for taking a look
--
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
flinkbot commented on PR #23664:
URL: https://github.com/apache/flink/pull/23664#issuecomment-1793757644
## CI report:
* f2aa5883e67f13ff7b664b3b3f7f851a30488e92 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin opened a new pull request, #23664:
URL: https://github.com/apache/flink/pull/23664
## What is the purpose of the change
To support java 21.
Since JDK21 there was removed of constructor within
https://bugs.openjdk.org/browse/JDK-8303083
Netty should support it and the
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reopened FLINK-1:
-
Sorry, probably I wasn't clear enough
Need to reopen this because to fix we need to update
[
https://issues.apache.org/jira/browse/FLINK-33458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782983#comment-17782983
]
xiangyu feng commented on FLINK-33458:
--
Hi [~agsharath], thx for reporting this. However, I think
[
https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782972#comment-17782972
]
RocMarshal edited comment on FLINK-25420 at 11/5/23 10:09 AM:
--
Hi,
[
https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782972#comment-17782972
]
RocMarshal commented on FLINK-25420:
Hi, [~martijnvisser] [~eskabetxe]
I have divided the work
[
https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782969#comment-17782969
]
RocMarshal edited comment on FLINK-33463 at 11/5/23 9:36 AM:
-
The ticket is
[
https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33459:
---
Labels: pull-request-available (was: )
> Support the new source that keeps the same
boring-cyborg[bot] commented on PR #78:
URL:
https://github.com/apache/flink-connector-jdbc/pull/78#issuecomment-1793683582
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
RocMarshal opened a new pull request, #78:
URL: https://github.com/apache/flink-connector-jdbc/pull/78
# Main change
- [FLINK-33459][Connector/JDBC] Add dependency items about
flink-connector-base and testing into the pom.xml
- [FLINK-33459][Connector/JDBC] Support the new source
[
https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782969#comment-17782969
]
RocMarshal commented on FLINK-33463:
The ticket is mainly to do the two items:
1. Support the
LadyForest commented on PR #23478:
URL: https://github.com/apache/flink/pull/23478#issuecomment-1793681676
> @lincoln-lil @LadyForest When you have time, please take a look if any
further modifications are needed, thanks.
I'm sorry for the late reply; I'll take a look as soon as
[
https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782968#comment-17782968
]
RocMarshal commented on FLINK-33459:
The ticket is mainly to do the two items:
1. Support the new
RocMarshal created FLINK-33462:
--
Summary: Sort out the document page about the new Jdbc source.
Key: FLINK-33462
URL: https://issues.apache.org/jira/browse/FLINK-33462
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33459:
---
Summary: Support the new source that keeps the same functionality as the
original JDBC input format
RocMarshal created FLINK-33463:
--
Summary: Support the implementation of dynamic source tables based
on the new source
Key: FLINK-33463
URL: https://issues.apache.org/jira/browse/FLINK-33463
Project:
RocMarshal created FLINK-33461:
--
Summary: Support stream related semantics for the new jdbc source
Key: FLINK-33461
URL: https://issues.apache.org/jira/browse/FLINK-33461
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33459:
---
Summary: Support the new source that supports the same functionality as the
original JDBC input
[
https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33459:
---
Summary: Port the new source that supports the same functionality as the
original JDBC input format
RocMarshal created FLINK-33460:
--
Summary: Support more authentication connection types such as the
secret.
Key: FLINK-33460
URL: https://issues.apache.org/jira/browse/FLINK-33460
Project: Flink
RocMarshal created FLINK-33459:
--
Summary: Introduce the new source that supports the same
functionality as the original JDBC input format
Key: FLINK-33459
URL: https://issues.apache.org/jira/browse/FLINK-33459
85 matches
Mail list logo
