GOODBOY008 opened a new pull request, #23960:
URL: https://github.com/apache/flink/pull/23960
[FLINK-25537] [JUnit5 Migration] Module: flink-core package api-common
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/FLINK-31615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-31615.
Resolution: Fixed
Fixed in master(1.19): 7ded6089a5fc827b9d09ef490c8d1e4965a0c4bf
> Fix some part
[
https://issues.apache.org/jira/browse/FLINK-31615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-31615:
---
Priority: Minor (was: Not a Priority)
> Fix some parts forgot to translate in "Table API" page of "
[
https://issues.apache.org/jira/browse/FLINK-31615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-31615:
---
Fix Version/s: 1.19.0
> Fix some parts forgot to translate in "Table API" page of "Table API & SQL"
[
https://issues.apache.org/jira/browse/FLINK-31615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-31615:
---
Affects Version/s: 1.18.0
> Fix some parts forgot to translate in "Table API" page of "Table API & S
[
https://issues.apache.org/jira/browse/FLINK-31615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-31615:
--
Assignee: Hang Ruan
> Fix some parts forgot to translate in "Table API" page of "Table API &
RocMarshal commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1432336723
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java:
##
@@ -118,26 +129,47 @@ public DefaultDeclarativeSlotPoo
leonardBang closed pull request #22272: [Flink-31615][doc-zh] Translates the
query_state_warning in "Table API" page of "Table API & SQL" and fixes some
content
URL: https://github.com/apache/flink/pull/22272
--
This is an automated message from the Apache Git Service.
To respond to the mess
ruanhang1993 opened a new pull request, #22272:
URL: https://github.com/apache/flink/pull/22272
## What is the purpose of the change
This pull request translates the query_state_warning in "Table API" page of
"Table API & SQL" and fixes some content.
## Brief change log
leonardBang closed pull request #22272: [Flink-31615][doc-zh] Translates the
query_state_warning in "Table API" page of "Table API & SQL" and fixes some
content
URL: https://github.com/apache/flink/pull/22272
--
This is an automated message from the Apache Git Service.
To respond to the mess
ruibinx commented on code in PR #23938:
URL: https://github.com/apache/flink/pull/23938#discussion_r1432355528
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateRestoreOperation.java:
##
@@ -168,9 +170,25 @@ public Void restore() throws Exception {
RocMarshal commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1432351722
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java:
##
@@ -334,7 +334,9 @@ public void onUnknownDeploymentsOf(
RocMarshal commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1432351722
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java:
##
@@ -334,7 +334,9 @@ public void onUnknownDeploymentsOf(
RocMarshal commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1432336723
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java:
##
@@ -118,26 +129,47 @@ public DefaultDeclarativeSlotPoo
fredia commented on PR #23938:
URL: https://github.com/apache/flink/pull/23938#issuecomment-1863955270
@ruibinx Thanks for the clarification and update, LGTM, let's wait for CI
green.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
fredia commented on code in PR #23938:
URL: https://github.com/apache/flink/pull/23938#discussion_r1432321260
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateRestoreOperation.java:
##
@@ -168,9 +170,25 @@ public Void restore() throws Exception {
ruibinx commented on code in PR #23938:
URL: https://github.com/apache/flink/pull/23938#discussion_r1432300092
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateRestoreOperation.java:
##
@@ -168,9 +170,25 @@ public Void restore() throws Exception {
ruibinx commented on code in PR #23938:
URL: https://github.com/apache/flink/pull/23938#discussion_r1432299988
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/OperatorStateRestoreOperationTest.java:
##
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software Found
ruibinx commented on code in PR #23938:
URL: https://github.com/apache/flink/pull/23938#discussion_r1432299647
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/OperatorStateRestoreOperationTest.java:
##
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software Found
Anshul1128 opened a new pull request, #737:
URL: https://github.com/apache/flink-kubernetes-operator/pull/737
## What is the purpose of the change
Improving the optimization of pod distribution and placement within a
Kubernetes cluster is essential for enhancing resource utili
[
https://issues.apache.org/jira/browse/FLINK-25029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798831#comment-17798831
]
liang yu commented on FLINK-25029:
--
Hi， [~liufangqi] [~dmvk] ， are you still working o
lsyldliu closed pull request #23671: [FLINK-32721][table-planner] Fix SQL MAX
aggregation function does no…
URL: https://github.com/apache/flink/pull/23671
--
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
snuyanzin closed pull request #23959: [FLINK-31664][table] Add ARRAY_INTERSECT
function
URL: https://github.com/apache/flink/pull/23959
--
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 c
snuyanzin commented on PR #23959:
URL: https://github.com/apache/flink/pull/23959#issuecomment-1863913063
Please do not create double PRs for the same issue
it is already the thirs one open
https://github.com/apache/flink/pull/22320
https://github.com/apache/flink/pull/23171
--
Th
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798825#comment-17798825
]
Zakelly Lan commented on FLINK-33881:
-
Thanks for clarification! It is definitely us
[
https://issues.apache.org/jira/browse/FLINK-33892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-33892:
--
Assignee: (was: Lijie Wang)
> FLIP-383: Support Job Recovery for Batch Jobs
> ---
[
https://issues.apache.org/jira/browse/FLINK-33892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-33892:
--
Assignee: Lijie Wang
> FLIP-383: Support Job Recovery for Batch Jobs
> --
[
https://issues.apache.org/jira/browse/FLINK-33892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-33892:
--
Assignee: Lijie Wang
> FLIP-383: Support Job Recovery for Batch Jobs
> --
Lijie Wang created FLINK-33892:
--
Summary: FLIP-383: Support Job Recovery for Batch Jobs
Key: FLINK-33892
URL: https://issues.apache.org/jira/browse/FLINK-33892
Project: Flink
Issue Type: New Fea
flinkbot commented on PR #23959:
URL: https://github.com/apache/flink/pull/23959#issuecomment-1863879876
## CI report:
* 59ffefac3cbac5d32690c38d52d1d2e967f7652b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liuyongvs closed pull request #22629: [FLINK-31664][table] Add ARRAY_INTERSECT
function
URL: https://github.com/apache/flink/pull/22629
--
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 c
zhuzhurk commented on PR #23942:
URL: https://github.com/apache/flink/pull/23942#issuecomment-1863877534
> Hi @zhuzhurk , thanks a lot for the comment in advance. The current PR is
still missing some tests. I originally planned to develop all the tests and
then find you and @JunRuiLee .
liuyongvs commented on PR #23959:
URL: https://github.com/apache/flink/pull/23959#issuecomment-1863875160
hi @xuyangzhong @lsyldliu do you have time to help review it?
The implementation refers to the spark implementation
https://github.com/apache/spark/blob/50b652e241f7e31b9930335
liuyongvs opened a new pull request, #23959:
URL: https://github.com/apache/flink/pull/23959
- What is the purpose of the change
This is an implementation of ARRAY_INTERSECT
- Brief change log
ARRAY_INTERSECT for Table API and SQL
```
Returns an array of the element
liuyongvs closed pull request #23943: [FLINK-32721] [planner] Support CharType
for the MaxAggFunction
URL: https://github.com/apache/flink/pull/23943
--
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
liuyongvs commented on PR #23943:
URL: https://github.com/apache/flink/pull/23943#issuecomment-1863863632
i close it now
--
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
liuyongvs commented on PR #23943:
URL: https://github.com/apache/flink/pull/23943#issuecomment-1863863494
> @liuyongvs Thanks for your contribution, this will be fixed by #18375,
this pr will be closed later.
@lsyldliu thanks for your clarify, i also add comments for the pr you refer
liuyongvs commented on code in PR #18375:
URL: https://github.com/apache/flink/pull/18375#discussion_r1432254893
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AggregateITCase.scala:
##
@@ -1331,6 +1331,81 @@ class AggregateIT
[
https://issues.apache.org/jira/browse/FLINK-33891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798819#comment-17798819
]
Zhanghao Chen commented on FLINK-33891:
---
[~huweihua] Could you help take a look?
hehuiyuan commented on code in PR #23945:
URL: https://github.com/apache/flink/pull/23945#discussion_r1432229793
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java:
##
@@ -310,6 +313,10 @@ public void open() throws Catalog
hehuiyuan commented on code in PR #23945:
URL: https://github.com/apache/flink/pull/23945#discussion_r1432229793
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java:
##
@@ -310,6 +313,10 @@ public void open() throws Catalog
TanYuxin-tyx commented on code in PR #23927:
URL: https://github.com/apache/flink/pull/23927#discussion_r1431327842
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionIndexSet.java:
##
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-33534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798400#comment-17798400
]
Weijie Guo edited comment on FLINK-33534 at 12/20/23 3:55 AM:
reswqa merged PR #23953:
URL: https://github.com/apache/flink/pull/23953
--
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.apache
fredia commented on code in PR #23938:
URL: https://github.com/apache/flink/pull/23938#discussion_r1432205407
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/OperatorStateRestoreOperationTest.java:
##
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apache Software Founda
[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798808#comment-17798808
]
Ruibin Xing commented on FLINK-33863:
-
[~Yanfei Lei] Hi, I will try to illustrate th
[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798802#comment-17798802
]
Yanfei Lei edited comment on FLINK-33863 at 12/20/23 3:18 AM:
KarmaGYZ commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1432179061
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java:
##
@@ -334,7 +334,9 @@ public void onUnknownDeploymentsOf(
.
[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-33863:
--
Assignee: Ruibin Xing
> Compressed Operator state restore failed
> --
[
https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798802#comment-17798802
]
Yanfei Lei commented on FLINK-33863:
Is it because once the file stream has reached
zhuzhurk commented on PR #23942:
URL: https://github.com/apache/flink/pull/23942#issuecomment-1863767529
How about to add an internal method
`RestartStrategies#exponentialDelayRestart(...)` which accepts the attempts
param and modify `RestartStrategies#fromConfiguration(...)` accordingly? T
flinkbot commented on PR #23958:
URL: https://github.com/apache/flink/pull/23958#issuecomment-1863766624
## CI report:
* 4e85a45962578fc6b79ff2f1e37b41cba852e602 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798801#comment-17798801
]
Tongtong Zhu commented on FLINK-33882:
--
[~jingge] Are you asking me to write the te
[
https://issues.apache.org/jira/browse/FLINK-33882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tongtong Zhu updated FLINK-33882:
-
Attachment: image-2023-12-20-10-42-00-237.png
> UT/IT for checkpointing statistics
> ---
[
https://issues.apache.org/jira/browse/FLINK-33891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33891:
---
Labels: pull-request-available (was: )
> Remove the obsolete SingleJobGraphStore
>
X-czh opened a new pull request, #23958:
URL: https://github.com/apache/flink/pull/23958
## What is the purpose of the change
SingleJobGraphStore was introduced a long time ago in FLIP-6. It is only
used in a test case in DefaultDispatcherRunnerITCase#
leaderChange_withBloc
Zhanghao Chen created FLINK-33891:
-
Summary: Remove the obsolete SingleJobGraphStore
Key: FLINK-33891
URL: https://issues.apache.org/jira/browse/FLINK-33891
Project: Flink
Issue Type: Technic
[
https://issues.apache.org/jira/browse/FLINK-33881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798799#comment-17798799
]
Jinzhong Li commented on FLINK-33881:
-
[~Zakelly] Thanks for your reply.
I think t
xuyangzhong commented on PR #23760:
URL: https://github.com/apache/flink/pull/23760#issuecomment-1863752804
@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 commen
[
https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-33877.
Fix Version/s: 1.19.0
Resolution: Fixed
> CollectSinkFunctionTest.testConfiguredPortIsUsed
[
https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798797#comment-17798797
]
xiaogang zhou commented on FLINK-33728:
---
[~mapohl] Hi Matthias , would you please
[
https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798796#comment-17798796
]
Jiabao Sun commented on FLINK-33877:
Merged into master via
409f44660eb434a57237af2
[
https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798795#comment-17798795
]
Junrui Li commented on FLINK-27756:
---
https://dev.azure.com/apache-flink/apache-flink/_
[
https://issues.apache.org/jira/browse/FLINK-33856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798787#comment-17798787
]
Jiang Xin commented on FLINK-33856:
---
Sounds reasonable. Have you already started worki
Xuannan Su created FLINK-33890:
--
Summary: Determine the initial status before receiving the first
RecordAttributes
Key: FLINK-33890
URL: https://issues.apache.org/jira/browse/FLINK-33890
Project: Flink
Sxnan commented on code in PR #23919:
URL: https://github.com/apache/flink/pull/23919#discussion_r1432093951
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordAttributesCombiner.java:
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to the Apache Software Fou
Jiabao-Sun commented on code in PR #85:
URL:
https://github.com/apache/flink-connector-jdbc/pull/85#discussion_r1432091019
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java:
##
@@ -64,4 +69,14 @@ public void testFilterPushdown()
sharath1709 commented on PR #23937:
URL: https://github.com/apache/flink/pull/23937#issuecomment-1863633658
@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 commen
JingGe opened a new pull request, #706:
URL: https://github.com/apache/flink-web/pull/706
Add the content of release Flink-1.18.1
--
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 comm
[
https://issues.apache.org/jira/browse/FLINK-33888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33888:
Description:
The final step of building the candidate is to propose a website pull request
containing the
[
https://issues.apache.org/jira/browse/FLINK-33837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge closed FLINK-33837.
---
Release Note: canceled
Resolution: Won't Fix
> Vote on the release candidate
> ---
[
https://issues.apache.org/jira/browse/FLINK-33833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge closed FLINK-33833.
---
Release Note: canceled
Resolution: Fixed
> Build Release Candidate: 1.18.1-rc1
> -
[
https://issues.apache.org/jira/browse/FLINK-33836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge closed FLINK-33836.
---
Release Note: canceled
Resolution: Won't Fix
> Propose a pull request for website updates
> --
[
https://issues.apache.org/jira/browse/FLINK-33842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-33842:
---
Assignee: Jing Ge (was: Matthias Pohl)
> Publish the Dockerfiles for the new release
> ---
[
https://issues.apache.org/jira/browse/FLINK-33841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-33841:
---
Assignee: Jing Ge (was: Qingsheng Ren)
> Create Git tag and mark version as released in Jira
> ---
[
https://issues.apache.org/jira/browse/FLINK-33840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-33840:
---
Assignee: Jing Ge (was: Qingsheng Ren)
> Deploy artifacts to Maven Central Repository
> --
[
https://issues.apache.org/jira/browse/FLINK-33889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33889:
Summary: Vote on the release candidate (was: CLONE - Vote on the release
candidate)
> Vote on the releas
[
https://issues.apache.org/jira/browse/FLINK-33888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33888:
Summary: Propose a pull request for website updates (was: CLONE - Propose
a pull request for website upda
[
https://issues.apache.org/jira/browse/FLINK-33886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33886:
Summary: Build and stage Java and Python artifacts (was: CLONE - Build and
stage Java and Python artifact
[
https://issues.apache.org/jira/browse/FLINK-33887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-33887.
-
Resolution: Fixed
> Stage source and binary releases on dist.apache.org
> --
[
https://issues.apache.org/jira/browse/FLINK-33886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge resolved FLINK-33886.
-
Resolution: Fixed
> Build and stage Java and Python artifacts
>
[
https://issues.apache.org/jira/browse/FLINK-33887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33887:
Summary: Stage source and binary releases on dist.apache.org (was: CLONE -
Stage source and binary releas
Jing Ge created FLINK-33886:
---
Summary: CLONE - Build and stage Java and Python artifacts
Key: FLINK-33886
URL: https://issues.apache.org/jira/browse/FLINK-33886
Project: Flink
Issue Type: Sub-task
Jing Ge created FLINK-33888:
---
Summary: CLONE - Propose a pull request for website updates
Key: FLINK-33888
URL: https://issues.apache.org/jira/browse/FLINK-33888
Project: Flink
Issue Type: Sub-task
Jing Ge created FLINK-33885:
---
Summary: Build Release Candidate: 1.18.1-rc2
Key: FLINK-33885
URL: https://issues.apache.org/jira/browse/FLINK-33885
Project: Flink
Issue Type: New Feature
Affects
Jing Ge created FLINK-33889:
---
Summary: CLONE - Vote on the release candidate
Key: FLINK-33889
URL: https://issues.apache.org/jira/browse/FLINK-33889
Project: Flink
Issue Type: Sub-task
Affects
Jing Ge created FLINK-33887:
---
Summary: CLONE - Stage source and binary releases on
dist.apache.org
Key: FLINK-33887
URL: https://issues.apache.org/jira/browse/FLINK-33887
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-33362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-33362:
Fix Version/s: 1.18.2
(was: 1.18.1)
> Document Externalized Declarative Resource Ma
JingGe merged PR #23955:
URL: https://github.com/apache/flink/pull/23955
--
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.apache
sharath1709 commented on PR #23937:
URL: https://github.com/apache/flink/pull/23937#issuecomment-1863449372
@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 co
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798719#comment-17798719
]
david radley edited comment on FLINK-33365 at 12/19/23 7:36 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798719#comment-17798719
]
david radley commented on FLINK-33365:
--
[~Sergey Nuyanzin] I have pushed up my late
davidradl commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1431857437
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSourceITCase.java:
##
@@ -356,6 +356,152 @@ void testLookupJoin(
davidradl commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1431856416
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java:
##
@@ -96,28 +98,70 @@ public JdbcDynamicTableSourc
[
https://issues.apache.org/jira/browse/FLINK-33884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33884:
---
Labels: pull-request-available (was: )
> Update Pulsar dependency to 3.0.2 in Pulsar Connec
dchristle opened a new pull request, #72:
URL: https://github.com/apache/flink-connector-pulsar/pull/72
## Purpose of the change
Update the Pulsar dependency version to pick up patch fixes.
## Brief change log
- Update `pulsar.version` to `3.0.2` in pom.xml.
boring-cyborg[bot] commented on PR #72:
URL:
https://github.com/apache/flink-connector-pulsar/pull/72#issuecomment-1863247716
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
David Christle created FLINK-33884:
--
Summary: Update Pulsar dependency to 3.0.2 in Pulsar Connector
Key: FLINK-33884
URL: https://issues.apache.org/jira/browse/FLINK-33884
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-33486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798684#comment-17798684
]
David Christle commented on FLINK-33486:
We also observe this issue, typically a
snuyanzin commented on code in PR #85:
URL:
https://github.com/apache/flink-connector-jdbc/pull/85#discussion_r1431724158
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java:
##
@@ -64,4 +69,14 @@ public void testFilterPushdown() {
1 - 100 of 175 matches
Mail list logo
