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
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
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
[
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 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
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
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 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
[
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
>
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
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
[
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
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
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
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
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_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`
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
[
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
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
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
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
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
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
[
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
[
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
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
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 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.
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
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.
--
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
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
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 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.
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
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
[
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
> -
[
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
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-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
[
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:
---
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
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
[
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
> ---
[
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
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
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`
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
54 matches
Mail list logo
