zhoulii commented on PR #19946:
URL: https://github.com/apache/flink/pull/19946#issuecomment-1154791356
> > Maybe add a hotfix commit "Rework BinaryInputFormatTest to be based on
AssertJ" first. And then add the new test using AssertJ.
>
> same as @zhuzhurk's previous suggestion, you
[
https://issues.apache.org/jira/browse/FLINK-28028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553931#comment-17553931
]
Martijn Visser commented on FLINK-28028:
A potential solution was brought forwar
[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28033:
---
Description:
File: StatusWatermarkValve.java
Method: findAndOutputNewMinWatermarkAcrossAli
shuiqiangchen commented on PR #19140:
URL: https://github.com/apache/flink/pull/19140#issuecomment-1154786882
@HuangXingBo Thank you for your comments. I have updated the PR according to
your suggestions, please have look.
--
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28033:
---
Priority: Major (was: Blocker)
> find and output new min watermark mybe wrong when in multi
reswqa commented on code in PR #19946:
URL: https://github.com/apache/flink/pull/19946#discussion_r896438515
##
flink-core/src/test/java/org/apache/flink/api/common/io/BinaryInputFormatTest.java:
##
@@ -73,13 +76,21 @@ public void testCreateInputSplitsWithOneFile() throws
IOExc
reswqa commented on code in PR #19946:
URL: https://github.com/apache/flink/pull/19946#discussion_r896430817
##
flink-core/src/test/java/org/apache/flink/api/common/io/BinaryInputFormatTest.java:
##
@@ -154,17 +170,60 @@ public void testGetStatisticsMultiplePaths() throws
IOExc
reswqa commented on code in PR #19946:
URL: https://github.com/apache/flink/pull/19946#discussion_r896430817
##
flink-core/src/test/java/org/apache/flink/api/common/io/BinaryInputFormatTest.java:
##
@@ -154,17 +170,60 @@ public void testGetStatisticsMultiplePaths() throws
IOExc
[
https://issues.apache.org/jira/browse/FLINK-28026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553929#comment-17553929
]
Jingsong Lee commented on FLINK-28026:
--
[~Aiden Gong] Thanks!
> Add benchmark modu
[
https://issues.apache.org/jira/browse/FLINK-28026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-28026:
Assignee: Aiden Gong
> Add benchmark module for flink table store
> -
[
https://issues.apache.org/jira/browse/FLINK-28032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-28032.
Resolution: Information Provided
The thread dump on taskmanager does not have a good format for people to
[
https://issues.apache.org/jira/browse/FLINK-28037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553927#comment-17553927
]
Martijn Visser commented on FLINK-28037:
[~renqs] Can you have a look at this on
[
https://issues.apache.org/jira/browse/FLINK-28037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28037:
---
Affects Version/s: (was: 1.14.0)
(was: 1.14.2)
reswqa commented on PR #19946:
URL: https://github.com/apache/flink/pull/19946#issuecomment-1154783029
> Maybe add a hotfix commit "Rework BinaryInputFormatTest to be based on
AssertJ" first. And then add the new test using AssertJ.
same as @zhuzhurk's previous suggestion, you should
dusukang commented on PR #19741:
URL: https://github.com/apache/flink/pull/19741#issuecomment-1154782595
@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.
reswqa commented on code in PR #19946:
URL: https://github.com/apache/flink/pull/19946#discussion_r896422901
##
flink-core/src/test/java/org/apache/flink/api/common/io/BinaryInputFormatTest.java:
##
@@ -73,13 +76,21 @@ public void testCreateInputSplitsWithOneFile() throws
IOExc
fsk119 commented on code in PR #19823:
URL: https://github.com/apache/flink/pull/19823#discussion_r896426974
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java:
##
@@ -0,0 +1,303 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-28038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei resolved FLINK-28038.
--
Resolution: Fixed
> RocksDB rescaling improvement & rescaling benchmark - umbrella ticket
> --
[
https://issues.apache.org/jira/browse/FLINK-28038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei reassigned FLINK-28038:
Assignee: Yanfei Lei
> RocksDB rescaling improvement & rescaling benchmark - umbrella ticket
> --
[
https://issues.apache.org/jira/browse/FLINK-28038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-28038:
-
Fix Version/s: 1.16.0
> RocksDB rescaling improvement & rescaling benchmark - umbrella ticket
>
fsk119 commented on code in PR #19823:
URL: https://github.com/apache/flink/pull/19823#discussion_r896425180
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/session/SessionManager.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-28035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553917#comment-17553917
]
Jingsong Lee commented on FLINK-28035:
--
Can you add some description?
> Don't chec
[
https://issues.apache.org/jira/browse/FLINK-28035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28035:
---
Labels: pull-request-available (was: )
> Don't check num of buckets for rescale bucket cond
JingsongLi commented on PR #157:
URL:
https://github.com/apache/flink-table-store/pull/157#issuecomment-1154769567
Why just check for rescale? Throws exception for normal reading?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
Jingsong Lee created FLINK-28040:
Summary: Introduce Trino reader for table store
Key: FLINK-28040
URL: https://issues.apache.org/jira/browse/FLINK-28040
Project: Flink
Issue Type: Sub-task
zhoulii commented on code in PR #19946:
URL: https://github.com/apache/flink/pull/19946#discussion_r896417184
##
flink-core/src/test/java/org/apache/flink/api/common/io/BinaryInputFormatTest.java:
##
@@ -160,11 +161,45 @@ public void testGetStatisticsMultiplePaths() throws
IOEx
[
https://issues.apache.org/jira/browse/FLINK-27947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-27947:
-
Parent: FLINK-28039
Issue Type: Sub-task (was: New Feature)
> Introduce Spark Reader fo
[
https://issues.apache.org/jira/browse/FLINK-23399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-23399:
---
Parent: FLINK-28038
Issue Type: Sub-task (was: Improvement)
> Add a performance benchmark f
Jingsong Lee created FLINK-28039:
Summary: Flink Table Store Ecosystem: Compute Engine Readers
Key: FLINK-28039
URL: https://issues.apache.org/jira/browse/FLINK-28039
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-26560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei updated FLINK-26560:
---
Parent: FLINK-28038
Issue Type: Sub-task (was: Improvement)
> Make the threshold of the ove
dianfu commented on code in PR #19896:
URL: https://github.com/apache/flink/pull/19896#discussion_r896402211
##
docs/content.zh/docs/dev/datastream/event-time/generating_watermarks.md:
##
@@ -77,6 +77,19 @@ WatermarkStrategy
})
```
{{< /tab >}}
+{{< tab "Python" >}}
Review
Yanfei Lei created FLINK-28038:
--
Summary: RocksDB rescaling improvement & rescaling benchmark -
umbrella ticket
Key: FLINK-28038
URL: https://issues.apache.org/jira/browse/FLINK-28038
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-26941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-26941:
---
Assignee: Yue Ma
> Support Pattern end with notFollowedBy with window
> ---
reswqa commented on code in PR #19927:
URL: https://github.com/apache/flink/pull/19927#discussion_r896405257
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java:
##
@@ -1201,6 +1243,33 @@ private void verifyFractions(
reswqa commented on code in PR #19927:
URL: https://github.com/apache/flink/pull/19927#discussion_r896405257
##
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java:
##
@@ -1201,6 +1243,33 @@ private void verifyFractions(
zhuzhurk commented on code in PR #19946:
URL: https://github.com/apache/flink/pull/19946#discussion_r896403096
##
flink-core/src/test/java/org/apache/flink/api/common/io/BinaryInputFormatTest.java:
##
@@ -160,11 +161,45 @@ public void testGetStatisticsMultiplePaths() throws
IOE
zhuzhurk commented on code in PR #19946:
URL: https://github.com/apache/flink/pull/19946#discussion_r896402127
##
flink-core/src/test/java/org/apache/flink/api/common/io/BinaryInputFormatTest.java:
##
@@ -160,11 +161,45 @@ public void testGetStatisticsMultiplePaths() throws
IOE
godfreyhe commented on PR #14376:
URL: https://github.com/apache/flink/pull/14376#issuecomment-1154742694
@libenchao, Hope you can continue to move forward
--
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
Aitozi commented on PR #19840:
URL: https://github.com/apache/flink/pull/19840#issuecomment-1154742585
Hi @KarmaGYZ , I have rebased this PR based on the previous commit, please
take a look again, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the mess
reswqa commented on PR #19882:
URL: https://github.com/apache/flink/pull/19882#issuecomment-1154728455
@wsry Just a very small hotfix, would you like to take 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
reswqa closed pull request #14498: [hotfix][typo]Fix typo in
StreamingJobGraphGenerator.areOperatorsChainable
URL: https://github.com/apache/flink/pull/14498
--
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 t
reswqa commented on PR #14498:
URL: https://github.com/apache/flink/pull/14498#issuecomment-1154727170
fixed by FLINK-27903
--
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.
flinkbot commented on PR #19950:
URL: https://github.com/apache/flink/pull/19950#issuecomment-1154726348
## CI report:
* 19abcb256444ba684736e355bf76986a79d5f501 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
diohabara opened a new pull request, #19950:
URL: https://github.com/apache/flink/pull/19950
I translate a Chinese comment in the sample code into English for more
people to understand it.
--
This is an automated message from the Apache Git Service.
To respond to the message, plea
Jiangfei Liu created FLINK-28037:
Summary: Flink SQL Upsert-Kafka can not support Flink1.14.x
Key: FLINK-28037
URL: https://issues.apache.org/jira/browse/FLINK-28037
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-15635:
Parent: FLINK-14055
Issue Type: Sub-task (was: Improvement)
> Allow passing a ClassLoader to Envi
[
https://issues.apache.org/jira/browse/FLINK-27828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553892#comment-17553892
]
Jiangfei Liu commented on FLINK-27828:
--
checkpoint config:
CheckpointConfi
[
https://issues.apache.org/jira/browse/FLINK-27828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553891#comment-17553891
]
Jiangfei Liu commented on FLINK-27828:
--
parallelism:3
checkpoint config:
[ https://issues.apache.org/jira/browse/FLINK-27828 ]
Jiangfei Liu deleted comment on FLINK-27828:
--
was (Author: JIRAUSER290004):
parallelism:3
checkpoint config:
CheckpointConfig checkpointConfig = env.getCheckpointConfig();
[
https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553889#comment-17553889
]
godfrey he commented on FLINK-26721:
https://dev.azure.com/apache-flink/apache-flink
flinkbot commented on PR #19949:
URL: https://github.com/apache/flink/pull/19949#issuecomment-1154694926
## CI report:
* b2f5199f5d430f4684e63f5f4d4317690c7f53e2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
reswqa commented on code in PR #19946:
URL: https://github.com/apache/flink/pull/19946#discussion_r896360739
##
flink-core/src/test/java/org/apache/flink/api/common/io/BinaryInputFormatTest.java:
##
@@ -160,11 +161,45 @@ public void testGetStatisticsMultiplePaths() throws
IOExc
luoyuxia opened a new pull request, #19949:
URL: https://github.com/apache/flink/pull/19949
## What is the purpose of the change
To make `HiveInspectors` use correct writable type to create
ConstantObjectInspector
## Brief change log
Replace `org.apache.hadoop.io.Byt
[
https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28036:
---
Labels: pull-request-available (was: )
> HiveInspectors should use correct writable type to
snuyanzin commented on PR #18779:
URL: https://github.com/apache/flink/pull/18779#issuecomment-1154691101
@MartijnVisser sorry for the poke.
Could you please have a look once you have time?
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
[
https://issues.apache.org/jira/browse/FLINK-27658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-27658.
---
Assignee: dalongliu
Resolution: Fixed
Done via:
2e37a06368596ca9ed04366a879f2facfb7ef509
> FlinkUser
zhuzhurk merged PR #19860:
URL: https://github.com/apache/flink/pull/19860
--
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
reswqa commented on code in PR #19849:
URL: https://github.com/apache/flink/pull/19849#discussion_r896357754
##
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/session/SessionManagerTest.java:
##
@@ -0,0 +1,109 @@
+/*
+ * Licensed to the Apache
reswqa commented on code in PR #19939:
URL: https://github.com/apache/flink/pull/19939#discussion_r896353277
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/connector/file/table/FileSystemStatisticsReportTest.java:
##
@@ -0,0 +1,309 @@
+/*
+ * Licensed to the A
reswqa commented on code in PR #19939:
URL: https://github.com/apache/flink/pull/19939#discussion_r896352923
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkRecomputeStatisticsProgram.java:
##
@@ -0,0 +1,203 @@
+/*
+ *
zhoulii commented on code in PR #19946:
URL: https://github.com/apache/flink/pull/19946#discussion_r896348640
##
flink-core/src/test/java/org/apache/flink/api/common/io/BinaryInputFormatTest.java:
##
@@ -160,6 +160,44 @@ public void testGetStatisticsMultiplePaths() throws
IOExc
[
https://issues.apache.org/jira/browse/FLINK-28034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553883#comment-17553883
]
Takayuki Eimizu commented on FLINK-28034:
-
I have already implemented a fix for
PatrickRen commented on PR #19456:
URL: https://github.com/apache/flink/pull/19456#issuecomment-1154675519
@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
[
https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28036:
-
Description:
In HiveInspectors, we will create Hive's ConstantObjectInspector by passing
writable type
dianfu commented on code in PR #19295:
URL: https://github.com/apache/flink/pull/19295#discussion_r895598233
##
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java:
##
@@ -261,15 +261,31 @@ public Collection>, Long>>
advanceTime(
final NFAStat
[
https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28036:
-
Summary: HiveInspectors should use correct writable type to creaet
ConstantObjectInspector (was: Use co
luoyuxia created FLINK-28036:
Summary: Use correct writable type to creaet
ConstantObjectInspector
Key: FLINK-28036
URL: https://issues.apache.org/jira/browse/FLINK-28036
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28036:
-
Fix Version/s: 1.16.0
> Use correct writable type to creaet ConstantObjectInspector
> --
[
https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28036:
-
Component/s: Connectors / Hive
> Use correct writable type to creaet ConstantObjectInspector
> -
[
https://issues.apache.org/jira/browse/FLINK-28036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-28036:
-
Description: In
> HiveInspectors should use correct writable type to creaet
> ConstantObjectInspector
[
https://issues.apache.org/jira/browse/FLINK-27395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Natan HP updated FLINK-27395:
-
Description:
I got this exception on flink taskmanager, but I can see that the data is
successfully pub
[
https://issues.apache.org/jira/browse/FLINK-27395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Natan HP updated FLINK-27395:
-
Description:
I got this exception on flink taskmanager, but I can see that the data is
successfully pub
[
https://issues.apache.org/jira/browse/FLINK-27395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Natan HP closed FLINK-27395.
> IllegalStateException: Could not find policy 'pick_first'. on Flink
> Application
> ---
[
https://issues.apache.org/jira/browse/FLINK-27395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Natan HP resolved FLINK-27395.
--
Resolution: Resolved
> IllegalStateException: Could not find policy 'pick_first'. on Flink
> Applicat
zhuzhurk commented on code in PR #19946:
URL: https://github.com/apache/flink/pull/19946#discussion_r896335558
##
flink-core/src/test/java/org/apache/flink/api/common/io/BinaryInputFormatTest.java:
##
@@ -160,6 +160,44 @@ public void testGetStatisticsMultiplePaths() throws
IOEx
[
https://issues.apache.org/jira/browse/FLINK-27395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Natan HP updated FLINK-27395:
-
Description:
I got this exception on flink taskmanager, but I can see that the data is
successfully pub
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553870#comment-17553870
]
Jing Zhang edited comment on FLINK-28003 at 6/14/22 3:14 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553870#comment-17553870
]
Jing Zhang commented on FLINK-28003:
As discussed with [~fsk119] offline, we add a c
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang reassigned FLINK-28003:
--
Assignee: Shengkai Fang
> A unexpected replacement happened in SqlClient, for example, replac
lsyldliu commented on PR #19860:
URL: https://github.com/apache/flink/pull/19860#issuecomment-1154661119
@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.
[
https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-27944:
Fix Version/s: 1.15.2
(was: 1.15.1)
> IO metrics collision happens if a task has un
PatrickRen commented on PR #19828:
URL: https://github.com/apache/flink/pull/19828#issuecomment-1154653485
@becketqin @leonardBang Please take a look when you are available. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
[
https://issues.apache.org/jira/browse/FLINK-28035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-28035:
--
Summary: Don't check num of buckets for rescale bucket condition (was:
Enable scan reading different
PatrickRen commented on PR #19828:
URL: https://github.com/apache/flink/pull/19828#issuecomment-1154652936
Thanks for the review @zou-can ! Initially I was trying to fix this case
from the root that `KafkaPartitionSplitReader#wakeup` should only wake up the
blocking `KafkaConsumer#poll` inv
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553860#comment-17553860
]
Jing Zhang edited comment on FLINK-28003 at 6/14/22 2:51 AM:
-
Jane Chan created FLINK-28035:
-
Summary: Enable scan reading different bucket num for rescale
bucket
Key: FLINK-28035
URL: https://issues.apache.org/jira/browse/FLINK-28035
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553860#comment-17553860
]
Jing Zhang commented on FLINK-28003:
[~martijnvisser] Thanks for response, however y
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang updated FLINK-28003:
---
Summary: A unexpected replacement happened in SqlClient, for example,
replace 'pos ' to 'POSITION'
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Zhang reopened FLINK-28003:
> 'pos ' field would be updated to 'POSITION' when use SqlClient
> --
[
https://issues.apache.org/jira/browse/FLINK-27951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553859#comment-17553859
]
Zili Sun commented on FLINK-27951:
--
[~martijnvisser] I have done the work and have crea
Takayuki Eimizu created FLINK-28034:
---
Summary: ClassCastException occurred in creating a checkpoint with
merge windows
Key: FLINK-28034
URL: https://issues.apache.org/jira/browse/FLINK-28034
Projec
[
https://issues.apache.org/jira/browse/FLINK-28029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-28029.
Resolution: Duplicate
> Checkpoint always hangs when running some jobs
> -
[
https://issues.apache.org/jira/browse/FLINK-28030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-28030.
Resolution: Duplicate
> Checkpoint always hangs when running some jobs
> -
[
https://issues.apache.org/jira/browse/FLINK-28031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-28031.
Resolution: Duplicate
> Checkpoint always hangs when running some jobs
> -
paul8263 commented on PR #19772:
URL: https://github.com/apache/flink/pull/19772#issuecomment-1154618703
Hi @wangyang0918 ,
Could you please review this PR? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17553848#comment-17553848
]
YeAble commented on FLINK-28033:
In my mind,it can do like this:
{code:java}
long newMin
lsyldliu commented on PR #19860:
URL: https://github.com/apache/flink/pull/19860#issuecomment-1154606842
@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.
[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YeAble updated FLINK-28033:
---
Priority: Blocker (was: Major)
> find and output new min watermark mybe wrong when in multichannel
> --
YeAble created FLINK-28033:
--
Summary: find and output new min watermark mybe wrong when in
multichannel
Key: FLINK-28033
URL: https://issues.apache.org/jira/browse/FLINK-28033
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YeAble updated FLINK-28033:
---
Affects Version/s: (was: 1.15.0)
> find and output new min watermark mybe wrong when in multichannel
> -
1 - 100 of 343 matches
Mail list logo
