Jacky Lau created FLINK-37009:
-
Summary: Migrate PruneAggregateCallRule
Key: FLINK-37009
URL: https://issues.apache.org/jira/browse/FLINK-37009
Project: Flink
Issue Type: Sub-task
Compo
yuxiqian commented on code in PR #3823:
URL: https://github.com/apache/flink-cdc/pull/3823#discussion_r1903736412
##
flink-cdc-cli/src/test/java/org/apache/flink/cdc/cli/CliFrontendTest.java:
##
@@ -145,6 +146,31 @@ void testPipelineExecuting() throws Exception {
asser
[
https://issues.apache.org/jira/browse/FLINK-36974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36974:
---
Labels: pull-request-available (was: )
> support overwrite flink config by command line
>
X-czh commented on code in PR #25797:
URL: https://github.com/apache/flink/pull/25797#discussion_r1903397742
##
docs/layouts/shortcodes/generated/pipeline_configuration.html:
##
@@ -20,6 +20,12 @@
Duration
The interval of the automatic watermark emissio
zhuzhurk commented on PR #25887:
URL: https://github.com/apache/flink/pull/25887#issuecomment-2572026995
@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.
github-actions[bot] commented on PR #3679:
URL: https://github.com/apache/flink-cdc/pull/3679#issuecomment-2571801368
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
liuyongvs opened a new pull request, #25900:
URL: https://github.com/apache/flink/pull/25900
## What is the purpose of the change
The PR migrates PruneAggregateCallRule to java
## Verifying this change
This change is already covered by existing tests
## Does this p
[
https://issues.apache.org/jira/browse/FLINK-37009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37009:
---
Labels: pull-request-available (was: )
> Migrate PruneAggregateCallRule
> -
liuyongvs commented on code in PR #25900:
URL: https://github.com/apache/flink/pull/25900#discussion_r1903784779
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PruneAggregateCallRule.java:
##
@@ -0,0 +1,238 @@
+/*
+ * Licensed
X-czh commented on PR #25877:
URL: https://github.com/apache/flink/pull/25877#issuecomment-2572349685
Squashed both commits into one
--
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
yiyutian1 commented on PR #25763:
URL: https://github.com/apache/flink/pull/25763#issuecomment-2572428331
> Thanks for addressing feedback it looks we are approaching
>
> There is at least one case found showing regression
>
> ```sql
> SELECT to_timestamp_ltz(123, CAST(NULL A
Samrat002 commented on PR #25877:
URL: https://github.com/apache/flink/pull/25877#issuecomment-2572300758
NIT : Squash both the commits into one.
--
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
JunRuiLee commented on code in PR #25552:
URL: https://github.com/apache/flink/pull/25552#discussion_r1903626133
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java:
##
@@ -77,6 +77,10 @@ public class StreamEdge implements Serializable {
pr
JunRuiLee commented on code in PR #25552:
URL: https://github.com/apache/flink/pull/25552#discussion_r1903628396
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/BlockingInputInfo.java:
##
@@ -0,0 +1,146 @@
+/*
+ * Licensed to the Apache Software F
flinkbot commented on PR #25899:
URL: https://github.com/apache/flink/pull/25899#issuecomment-2572234932
## CI report:
* 1494ec245bca1ca1f43d7153421033bfa7cbc602 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
noorall commented on PR #25887:
URL: https://github.com/apache/flink/pull/25887#issuecomment-2572182080
> Thanks @noorall for fixing. LGTM. Could you post the results of the three
regressed benchmark cases after the fix?
I tested it on my own computer, and here are the test results:
zhuzhurk merged PR #25887:
URL: https://github.com/apache/flink/pull/25887
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apac
[
https://issues.apache.org/jira/browse/FLINK-36989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-36989.
---
Fix Version/s: 2.0.0
Resolution: Fixed
81f882bcf79770072f3cee9a026c658ed9b04219
> Scheduler benchmar
[
https://issues.apache.org/jira/browse/FLINK-36993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36993:
---
Labels: pull-request-available (was: )
> FLIP-492: Support Query Modifications for Material
hackergin commented on code in PR #25880:
URL: https://github.com/apache/flink/pull/25880#discussion_r1903610990
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/materializedtable/MaterializedTableManager.java:
##
@@ -804,6 +808,78 @@ protect
hackergin commented on code in PR #25880:
URL: https://github.com/apache/flink/pull/25880#discussion_r1903612300
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableAsQueryOperation.java:
##
@@ -0,0 +1,142 @
hackergin commented on code in PR #25880:
URL: https://github.com/apache/flink/pull/25880#discussion_r1903611482
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlMaterializedTableNodeToOperationConverterTest.java:
##
@@ -391,6 +392,17
zhuzhurk commented on code in PR #25552:
URL: https://github.com/apache/flink/pull/25552#discussion_r1903612414
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismAndInputInfosDecider.java:
##
@@ -128,12 +128,8 @@ public Paral
Ryan van Huuksloot created FLINK-37008:
--
Summary: Flink UI should show the type of checkpoint (full vs
incremental)
Key: FLINK-37008
URL: https://issues.apache.org/jira/browse/FLINK-37008
Project
linjianchang commented on PR #3833:
URL: https://github.com/apache/flink-cdc/pull/3833#issuecomment-2572228210
**source oracle table structure：**
create table PORTAL.SYSTEM_USER
(
sys_user_id NUMBER not null,
staff_idNUMBER not null,
sys_user_code VARCHAR2(2
ryanvanhuuksloot opened a new pull request, #25899:
URL: https://github.com/apache/flink/pull/25899
## What is the purpose of the change
It would be useful for the UI to show if a checkpoint is full or
incremental. I'm curious how others would like to expose this in the UI / A
[
https://issues.apache.org/jira/browse/FLINK-37008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37008:
---
Labels: pull-request-available (was: )
> Flink UI should show the type of checkpoint (full
He-Pin commented on PR #25866:
URL: https://github.com/apache/flink/pull/25866#issuecomment-2572345937
@XComp Is there any update can share, thanks.
--
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 t
Zakelly Lan created FLINK-37010:
---
Summary: Unify KeyedProcessFunction and the async one
Key: FLINK-37010
URL: https://issues.apache.org/jira/browse/FLINK-37010
Project: Flink
Issue Type: Sub-ta
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1903771370
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -853,18 +848,13 @@ private Stream toTimestam
XComp commented on PR #25827:
URL: https://github.com/apache/flink/pull/25827#issuecomment-2572493197
> Do you have an idea what could be wrong?
The [CI
build](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=64350&view=logs&j=d3c25614-fe65-5341-2db6-c20b16adba8d
Zakelly commented on code in PR #25717:
URL: https://github.com/apache/flink/pull/25717#discussion_r1903721138
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/asyncprocessing/AsyncStateKeyedProcessOperator.java:
##
@@ -0,0 +1,196 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910011#comment-17910011
]
Zhanghao Chen commented on FLINK-33265:
---
[~yunta] [~lincoln.86xy] RocMarshal has a
kurtostfeld commented on PR #25896:
URL: https://github.com/apache/flink/pull/25896#issuecomment-2572500238
The following test failure is caused by a test file, external to the main
git repo, that I don't have access to change. It simply needs Class
changed to Class.
```
/tmp/juni
ikstewa commented on PR #24035:
URL: https://github.com/apache/flink/pull/24035#issuecomment-2571733258
@sharath1709 I'm trying to follow up on this change to understand why we do
not support optional primitive types. I believe proto3 has support for field
presence on primitives when they h
MartijnVisser opened a new pull request, #25898:
URL: https://github.com/apache/flink/pull/25898
## What is the purpose of the change
This PR is a Work In Progress, and will change Flink to use Java 17 by
default.
## Brief change log
## Verifying this change
flinkbot commented on PR #25898:
URL: https://github.com/apache/flink/pull/25898#issuecomment-2571590347
## CI report:
* a0684fd6aa67d81c3e117622b82495fe6c08fe41 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Sergey Nuyanzin created FLINK-37007:
---
Summary: FLIP-494: Add missing createTable/createView methods to
TableEnvironment
Key: FLINK-37007
URL: https://issues.apache.org/jira/browse/FLINK-37007
Projec
snuyanzin closed pull request #21753: [FLINK-30782][build] Use https for
schemaLocations
URL: https://github.com/apache/flink/pull/21753
--
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
[
https://issues.apache.org/jira/browse/FLINK-36593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-36593:
--
Fix Version/s: 1.19.2
> Upgrade io.airlift:aircompressor to mitigate CVE
> ---
[
https://issues.apache.org/jira/browse/FLINK-36593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909918#comment-17909918
]
Alexander Fedulov edited comment on FLINK-36593 at 1/5/25 3:59 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-36593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909918#comment-17909918
]
Alexander Fedulov commented on FLINK-36593:
---
Merged to 1.19: ff4243a7b4c25dd87
afedulov merged PR #25886:
URL: https://github.com/apache/flink/pull/25886
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apac
afedulov merged PR #25885:
URL: https://github.com/apache/flink/pull/25885
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apac
[
https://issues.apache.org/jira/browse/FLINK-33571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909920#comment-17909920
]
Alexander Fedulov commented on FLINK-33571:
---
*Merged to 1.19:* 3b334bd1b0d0162
[
https://issues.apache.org/jira/browse/FLINK-33571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov updated FLINK-33571:
--
Fix Version/s: 1.19.2
> Bump json-path from 2.7.0 to 2.9.0
> -
afedulov commented on PR #25827:
URL: https://github.com/apache/flink/pull/25827#issuecomment-2571694701
@XComp I retriggered a [follow-up
PR](https://github.com/apache/flink/pull/25794) after this one has been merged:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildI
snuyanzin commented on code in PR #25865:
URL: https://github.com/apache/flink/pull/25865#discussion_r1903312062
##
flink-kubernetes/pom.xml:
##
@@ -31,7 +31,7 @@ under the License.
jar
- 6.9.2
+ 6.13.4
Review Comment:
since it
snuyanzin commented on code in PR #25865:
URL: https://github.com/apache/flink/pull/25865#discussion_r1903311567
##
pom.xml:
##
@@ -1857,7 +1857,7 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-33117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17909877#comment-17909877
]
Alexander Fedulov commented on FLINK-33117:
---
*Merged:*
* master (2.0): fbf532
[
https://issues.apache.org/jira/browse/FLINK-33117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Fedulov resolved FLINK-33117.
---
Resolution: Fixed
> a wrong scala example in udfs page
> ---
snuyanzin commented on PR #25898:
URL: https://github.com/apache/flink/pull/25898#issuecomment-2571616830
@MartijnVisser I think you need to rebase to the latest master
the failure seems to be related to the bug in master fixed within
https://github.com/apache/flink/pull/25895
--
This
[
https://issues.apache.org/jira/browse/FLINK-37006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-37006.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> Apply changes from FLINK-36277 to Adapti
X-czh commented on code in PR #25797:
URL: https://github.com/apache/flink/pull/25797#discussion_r1903292910
##
flink-core/src/main/java/org/apache/flink/api/common/serialization/SerializerConfigImpl.java:
##
@@ -356,6 +356,9 @@ public void configure(ReadableConfig configuration
54 matches
Mail list logo
