Zakelly Lan created FLINK-34191:
---
Summary: Remove RestoreMode#LEGACY
Key: FLINK-34191
URL: https://issues.apache.org/jira/browse/FLINK-34191
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-34190:
---
Summary: Deprecate RestoreMode#LEGACY
Key: FLINK-34190
URL: https://issues.apache.org/jira/browse/FLINK-34190
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-34189:
---
Summary: FLIP-416: Deprecate and remove the RestoreMode#LEGACY
Key: FLINK-34189
URL: https://issues.apache.org/jira/browse/FLINK-34189
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-34177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-34177.
--
Resolution: Not A Problem
Closing this for now as the behaviour is intended. If you would like to
[
https://issues.apache.org/jira/browse/FLINK-34179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809278#comment-17809278
]
Gyula Fora commented on FLINK-34179:
I am not aware of the bitnami helm chart, and I definitely
[
https://issues.apache.org/jira/browse/FLINK-34177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809280#comment-17809280
]
Gyula Fora commented on FLINK-34177:
Flink session jobs need to be created in the same namespace as
[
https://issues.apache.org/jira/browse/FLINK-34180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-34180:
--
Assignee: Leonard Xu
> Accept Flink CDC project as part of Apache Flink
>
[
https://issues.apache.org/jira/browse/FLINK-34179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-34179:
---
Priority: Minor (was: Blocker)
> More than one taskmanager is not coming up in flink (session
Leonard Xu created FLINK-34188:
--
Summary: Setup release infrastructure for Flink CDC project
Key: FLINK-34188
URL: https://issues.apache.org/jira/browse/FLINK-34188
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-34181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34181:
---
Component/s: Flink CDC
> Migrate repo from ververica to apche
>
[
https://issues.apache.org/jira/browse/FLINK-34182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34182:
---
Component/s: Flink CDC
> Migrate doc website from ververica to flink
>
Leonard Xu created FLINK-34187:
--
Summary: Setup CI for Flink CDC project
Key: FLINK-34187
URL: https://issues.apache.org/jira/browse/FLINK-34187
Project: Flink
Issue Type: Sub-task
Leonard Xu created FLINK-34186:
--
Summary: Migrate issue management from Github to JIRA
Key: FLINK-34186
URL: https://issues.apache.org/jira/browse/FLINK-34186
Project: Flink
Issue Type:
Leonard Xu created FLINK-34185:
--
Summary: Remove unwanted bundle dependencies
Key: FLINK-34185
URL: https://issues.apache.org/jira/browse/FLINK-34185
Project: Flink
Issue Type: Sub-task
Leonard Xu created FLINK-34184:
--
Summary: Update copyright and license file
Key: FLINK-34184
URL: https://issues.apache.org/jira/browse/FLINK-34184
Project: Flink
Issue Type: Sub-task
Leonard Xu created FLINK-34182:
--
Summary: Migrate doc website from ververica to flink
Key: FLINK-34182
URL: https://issues.apache.org/jira/browse/FLINK-34182
Project: Flink
Issue Type:
Leonard Xu created FLINK-34183:
--
Summary: Add NOTICE files for Flink CDC project
Key: FLINK-34183
URL: https://issues.apache.org/jira/browse/FLINK-34183
Project: Flink
Issue Type: Sub-task
Leonard Xu created FLINK-34181:
--
Summary: Migrate repo from ververica to apche
Key: FLINK-34181
URL: https://issues.apache.org/jira/browse/FLINK-34181
Project: Flink
Issue Type: Sub-task
Leonard Xu created FLINK-34180:
--
Summary: Accept Flink CDC project as part of Apache Flink
Key: FLINK-34180
URL: https://issues.apache.org/jira/browse/FLINK-34180
Project: Flink
Issue Type: New
1996fanrui commented on code in PR #759:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/759#discussion_r1461443852
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java:
##
@@ -160,14 +160,23 @@ private void runScalingLogic(Context
leonardBang commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r146161
##
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRowDataDeSerializationSchemaTest.java:
##
@@ -330,23 +338,87 @@ void
[
https://issues.apache.org/jira/browse/FLINK-34178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34178:
---
Labels: pull-request-available (was: )
> The ScalingTracking of autoscaler is wrong
>
1996fanrui opened a new pull request, #759:
URL: https://github.com/apache/flink-kubernetes-operator/pull/759
## What is the purpose of the change
The ScalingTracking of autoscaler is wrong, it's always greater than
AutoScalerOptions#STABILIZATION_INTERVAL.
### Reason
HuangZhenQiu commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r1461426662
##
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRowDataDeSerializationSchemaTest.java:
##
@@ -330,23 +338,87 @@ void
leonardBang commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r1461418192
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java:
##
@@ -317,6 +408,21 @@ public static Schema
[
https://issues.apache.org/jira/browse/FLINK-34179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikhil_D updated FLINK-34179:
-
Description: Deployed flink in aws eks cluster using bitnami helm chart
(bitnami/flink 1.18). After
Nikhil_D created FLINK-34179:
Summary: More than one taskmanager is not coming up in flink
(session mode) in aws eks cluster
Key: FLINK-34179
URL: https://issues.apache.org/jira/browse/FLINK-34179
leonardBang commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r1461404314
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFormatOptions.java:
##
@@ -71,5 +70,11 @@ public InlineElement getDescription() {
HuangZhenQiu commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r1461398939
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroToRowDataConverters.java:
##
@@ -121,6 +128,12 @@ private static
HuangZhenQiu commented on PR #756:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/756#issuecomment-1903350455
@gyfora Thanks for all of the suggestion. I have changed scripts
accordingly. Please approve the ci build workflow for further verification.
--
This is an
HuangZhenQiu commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r1461398939
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroToRowDataConverters.java:
##
@@ -121,6 +128,12 @@ private static
HuangZhenQiu commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r1461398939
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroToRowDataConverters.java:
##
@@ -121,6 +128,12 @@ private static
[
https://issues.apache.org/jira/browse/FLINK-34166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809254#comment-17809254
]
lincoln lee commented on FLINK-34166:
-
fixed in master: 27e6ac836171c5c5539ceeb234a806be661cc30a
>
lincoln-lil merged PR #24152:
URL: https://github.com/apache/flink/pull/24152
--
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:
Rui Fan created FLINK-34178:
---
Summary: The ScalingTracking of autoscaler is wrong
Key: FLINK-34178
URL: https://issues.apache.org/jira/browse/FLINK-34178
Project: Flink
Issue Type: Bug
leonardBang commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r1461377732
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroToRowDataConverters.java:
##
@@ -121,6 +128,12 @@ private static AvroToRowDataConverter
HuangZhenQiu commented on PR #23511:
URL: https://github.com/apache/flink/pull/23511#issuecomment-1903283601
@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
HuangZhenQiu commented on PR #23511:
URL: https://github.com/apache/flink/pull/23511#issuecomment-1903283177
@leonardBang
Thanks for providing valuable comments. I have refactor the code to resolve
your comments. Another following PR will be created to change precision. Thanks!
--
1996fanrui commented on code in PR #24003:
URL: https://github.com/apache/flink/pull/24003#discussion_r1461348956
##
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/FixedDelayRestartBackoffTimeStrategy.java:
##
@@ -61,8 +61,9 @@ public long
[
https://issues.apache.org/jira/browse/FLINK-34176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34176:
Summary: Remove unnecessary failure-rate and fixed-delay restart-strategies
(was: Remove unnecessary
[
https://issues.apache.org/jira/browse/FLINK-34176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34176:
Description:
h2. Could we deprecate the failure-rate and fixed-delay restart-strategies
directly?
HuangZhenQiu commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r1461340507
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroToRowDataConverters.java:
##
@@ -121,6 +128,12 @@ private static
Pramod created FLINK-34177:
--
Summary: Not able to create FlinkSessionJob in different namespace
than flink deployment
Key: FLINK-34177
URL: https://issues.apache.org/jira/browse/FLINK-34177
Project: Flink
Rui Fan created FLINK-34176:
---
Summary: Remove unnecessary implemetations of
RestartBackoffTimeStrategy
Key: FLINK-34176
URL: https://issues.apache.org/jira/browse/FLINK-34176
Project: Flink
Issue
flinkbot commented on PR #24162:
URL: https://github.com/apache/flink/pull/24162#issuecomment-1903131997
## CI report:
* 5b90be3d7e080cfaea62a1711406a21319b415a2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34100:
---
Labels: pull-request-available (was: )
> Support session window table function without
xuyangzhong opened a new pull request, #24162:
URL: https://github.com/apache/flink/pull/24162
## What is the purpose of the change
Introduce windowed unslice window assigner. And support session window table
function without pulling up with window agg.
Note: this is a draft
[
https://issues.apache.org/jira/browse/FLINK-33221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33221.
-
Resolution: Fixed
> Add config options for administrator JVM options
>
[
https://issues.apache.org/jira/browse/FLINK-33221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809233#comment-17809233
]
Rui Fan commented on FLINK-33221:
-
Merged to master(1.19.0) via :
zhougit86 commented on PR #43:
URL:
https://github.com/apache/flink-connector-kafka/pull/43#issuecomment-1903098823
> @zhougit86 Can you please rebase your PR?
@MartijnVisser Would you please tell me I should rebase this onto which
branch? And would you please let me know you
1996fanrui merged PR #24098:
URL: https://github.com/apache/flink/pull/24098
--
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-34174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809232#comment-17809232
]
RocMarshal commented on FLINK-34174:
The main reason for initiating this ticket is
[
https://issues.apache.org/jira/browse/FLINK-34175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuyang updated FLINK-34175:
---
Description:
The following test added to SlicingWindowAggOperatorTest can re-produce this
problem.
xuyang created FLINK-34175:
--
Summary: When meeting WindowedSliceAssigner, slice window agg
registers an wrong timestamp timer
Key: FLINK-34175
URL: https://issues.apache.org/jira/browse/FLINK-34175
[
https://issues.apache.org/jira/browse/FLINK-33450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809223#comment-17809223
]
Rui Fan commented on FLINK-33450:
-
Merged to main(1.8.0) via :
*
[
https://issues.apache.org/jira/browse/FLINK-33450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33450.
-
Resolution: Fixed
> Implement JdbcAutoScalerStateStore
> --
>
>
RocMarshal commented on PR #24158:
URL: https://github.com/apache/flink/pull/24158#issuecomment-1903021276
Hi, @1996fanrui Thanks for your review.
The main reason for initiating this pr is
https://issues.apache.org/jira/browse/FLINK-31449
(IIUC) as the current classes are no
MOBIN-F closed pull request #36: [FLINK-33971]Specifies whether to use HBase
table that supports dynamic columns.
URL: https://github.com/apache/flink-connector-hbase/pull/36
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
1996fanrui merged PR #741:
URL: https://github.com/apache/flink-kubernetes-operator/pull/741
--
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:
flinkbot commented on PR #24161:
URL: https://github.com/apache/flink/pull/24161#issuecomment-1903008823
## CI report:
* cc0d27ae8047710e53107d9fd9b50b8578c9ff25 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24160:
URL: https://github.com/apache/flink/pull/24160#issuecomment-1903006337
## CI report:
* d487b086c0cccb48244e46b106bcd26143e6a272 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
caodizhou commented on PR #24115:
URL: https://github.com/apache/flink/pull/24115#issuecomment-1903002055
@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
luoyuxia commented on code in PR #24152:
URL: https://github.com/apache/flink/pull/24152#discussion_r1461300877
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/KeyedLookupJoinWrapper.java:
##
@@ -129,40 +129,55 @@ public
flinkbot commented on PR #24159:
URL: https://github.com/apache/flink/pull/24159#issuecomment-1902987990
## CI report:
* 719a6c42f3b0f7adfb7047f9ac2a29d6a62b3afb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xishuaidelin opened a new pull request, #24161:
URL: https://github.com/apache/flink/pull/24161
## 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
xishuaidelin opened a new pull request, #24160:
URL: https://github.com/apache/flink/pull/24160
## 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
xishuaidelin opened a new pull request, #24159:
URL: https://github.com/apache/flink/pull/24159
## 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
lincoln-lil commented on code in PR #24152:
URL: https://github.com/apache/flink/pull/24152#discussion_r1461293471
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/KeyedLookupJoinWrapper.java:
##
@@ -129,40 +129,55 @@ public
[
https://issues.apache.org/jira/browse/FLINK-34049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-34049.
-
Resolution: Implemented
> Refactor classes related to window TVF aggregation to prepare for
1996fanrui commented on PR #741:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/741#issuecomment-1902917759
Thanks for the patient review, merging~
--
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-34049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809213#comment-17809213
]
Shengkai Fang commented on FLINK-34049:
---
Merged into master:
fsk119 merged PR #24068:
URL: https://github.com/apache/flink/pull/24068
--
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:
libenchao commented on code in PR #79:
URL:
https://github.com/apache/flink-connector-jdbc/pull/79#discussion_r1461286671
##
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTablePlanTest.java:
##
@@ -70,6 +98,51 @@ public void testFilterPushdown()
yuchen-ecnu commented on PR #24130:
URL: https://github.com/apache/flink/pull/24130#issuecomment-1902905798
Hi @Myasuka , do you have time to help review this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
luoyuxia commented on code in PR #24152:
URL: https://github.com/apache/flink/pull/24152#discussion_r1461275950
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/KeyedLookupJoinWrapper.java:
##
@@ -129,40 +129,55 @@ public
[
https://issues.apache.org/jira/browse/FLINK-32417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32417:
---
Labels: pull-request-available (was: )
> DynamicKafkaSource User Documentation
>
mas-chen commented on PR #80:
URL:
https://github.com/apache/flink-connector-kafka/pull/80#issuecomment-1902871885
FYI: @mxm @tzulitai
--
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
mas-chen opened a new pull request, #80:
URL: https://github.com/apache/flink-connector-kafka/pull/80
…, metrics, and config options
I verified locally that the documentation comes up properly and that all the
links work.
gyfora commented on code in PR #755:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/755#discussion_r1461096099
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/ReconciliationUtils.java:
##
@@ -126,6 +126,9 @@ private
[
https://issues.apache.org/jira/browse/FLINK-34131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-34131:
--
Assignee: Nicolas Fraison
> Checkpoint check window should take in account checkpoint job
[
https://issues.apache.org/jira/browse/FLINK-34131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-34131.
--
Resolution: Fixed
merged to main 775bc5f41df09accefca6590112509c6023b2fb4
> Checkpoint check window
[
https://issues.apache.org/jira/browse/FLINK-34131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-34131:
---
Fix Version/s: kubernetes-operator-1.8.0
> Checkpoint check window should take in account
gyfora merged PR #758:
URL: https://github.com/apache/flink-kubernetes-operator/pull/758
--
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-32212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809152#comment-17809152
]
Anurag Kyal commented on FLINK-32212:
-
I am running into this issue as well after my job restarts
leonardBang commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r1460846335
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroToRowDataConverters.java:
##
@@ -121,6 +128,12 @@ private static AvroToRowDataConverter
85 matches
Mail list logo
