swuferhong commented on PR #19850:
URL: https://github.com/apache/flink/pull/19850#issuecomment-1154599188
CI failed, @xuyangzhong, you can have 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
URL above to
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553860#comment-17553860
]
Jing Zhang commented on FLINK-28003:
[~martijnvisser] Thanks for response, however you might
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=17553860#comment-17553860
]
Jing Zhang edited comment on FLINK-28003 at 6/14/22 2:51 AM:
-
[
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
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
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
[
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
>
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,
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:
afedulov commented on code in PR #19856:
URL: https://github.com/apache/flink/pull/19856#discussion_r896140006
##
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/container/FlinkContainersConfig.java:
##
@@ -0,0 +1,599 @@
+/*
afedulov commented on PR #19856:
URL: https://github.com/apache/flink/pull/19856#issuecomment-1154456010
@PatrickRen could you please take a look at my comments above?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
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
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553889#comment-17553889
]
godfrey he commented on FLINK-26721:
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
[
https://issues.apache.org/jira/browse/FLINK-27963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553796#comment-17553796
]
Dmytro edited comment on FLINK-27963 at 6/13/22 9:28 PM:
-
Hi [~renqs], thank you
[
https://issues.apache.org/jira/browse/FLINK-28032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pauli Gandhi updated FLINK-28032:
-
Summary: Checkpointing hangs and times out with some jobs (was: Flink
checkpointing hangs and
[
https://issues.apache.org/jira/browse/FLINK-28033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553848#comment-17553848
]
YeAble commented on FLINK-28033:
In my mind,it can do like this:
{code:java}
long newMinWatermark =
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-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
>
[
https://issues.apache.org/jira/browse/FLINK-27951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553859#comment-17553859
]
Zili Sun commented on FLINK-27951:
--
[~martijnvisser] I have done the work and have created a pr, can
[
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-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553870#comment-17553870
]
Jing Zhang commented on FLINK-28003:
As discussed with [~fsk119] offline, we add a configure to
[
https://issues.apache.org/jira/browse/FLINK-28003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553870#comment-17553870
]
Jing Zhang edited comment on FLINK-28003 at 6/14/22 3:14 AM:
-
As discussed
[
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
[
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-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
>
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
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
afedulov commented on code in PR #19856:
URL: https://github.com/apache/flink/pull/19856#discussion_r896150381
##
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/container/FlinkImageBuilder.java:
##
@@ -149,15 +160,15 @@
[
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-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,
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-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
[
https://issues.apache.org/jira/browse/FLINK-28034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553883#comment-17553883
]
Takayuki Eimizu commented on FLINK-28034:
-
I have already implemented a fix for this issue and
afedulov commented on code in PR #19856:
URL: https://github.com/apache/flink/pull/19856#discussion_r896140006
##
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/container/FlinkContainersConfig.java:
##
@@ -0,0 +1,599 @@
+/*
afedulov commented on code in PR #19856:
URL: https://github.com/apache/flink/pull/19856#discussion_r896150381
##
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/container/FlinkImageBuilder.java:
##
@@ -149,15 +160,15 @@
afedulov commented on code in PR #19856:
URL: https://github.com/apache/flink/pull/19856#discussion_r896150381
##
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/container/FlinkImageBuilder.java:
##
@@ -149,15 +160,15 @@
[
https://issues.apache.org/jira/browse/FLINK-27962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553808#comment-17553808
]
Dmytro commented on FLINK-27962:
Hi [~renqs] , [~martijnvisser] !
I got these logs and still cleaning
Pauli Gandhi created FLINK-28029:
Summary: Checkpoint always hangs when running some jobs
Key: FLINK-28029
URL: https://issues.apache.org/jira/browse/FLINK-28029
Project: Flink
Issue Type:
Pauli Gandhi created FLINK-28031:
Summary: Checkpoint always hangs when running some jobs
Key: FLINK-28031
URL: https://issues.apache.org/jira/browse/FLINK-28031
Project: Flink
Issue Type:
Pauli Gandhi created FLINK-28030:
Summary: Checkpoint always hangs when running some jobs
Key: FLINK-28030
URL: https://issues.apache.org/jira/browse/FLINK-28030
Project: Flink
Issue Type:
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`
[
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
[
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
>
[
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
>
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
[
https://issues.apache.org/jira/browse/FLINK-28032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pauli Gandhi updated FLINK-28032:
-
Summary: Flink checkpointing hangs and times out with some jobs (was:
Flink checkpointing
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-27963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553796#comment-17553796
]
Dmytro commented on FLINK-27963:
Hi [~renqs], thank you for reaching out!
I believe this exception
[
https://issues.apache.org/jira/browse/FLINK-25087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553830#comment-17553830
]
Zhanghao Chen commented on FLINK-25087:
---
[~zjureel] Since MainThreadExecutor#schedule, which is
luoyuxia commented on code in PR #19931:
URL: https://github.com/apache/flink/pull/19931#discussion_r896270154
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -387,7 +387,9 @@
luoyuxia commented on code in PR #19931:
URL: https://github.com/apache/flink/pull/19931#discussion_r896270154
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -387,7 +387,9 @@
luoyuxia commented on code in PR #19931:
URL: https://github.com/apache/flink/pull/19931#discussion_r896270154
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -387,7 +387,9 @@
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
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
[
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
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`
[
https://issues.apache.org/jira/browse/FLINK-27963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553796#comment-17553796
]
Dmytro edited comment on FLINK-27963 at 6/13/22 9:46 PM:
-
Hi [~renqs], thank you
Pauli Gandhi created FLINK-28032:
Summary: Flink checkpointing hangs with some jobs
Key: FLINK-28032
URL: https://issues.apache.org/jira/browse/FLINK-28032
Project: Flink
Issue Type: Bug
[
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
>
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-28032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pauli Gandhi updated FLINK-28032:
-
Description:
We have noticed that Flink jobs hangs and eventually times out after 2 hours
luoyuxia commented on code in PR #19931:
URL: https://github.com/apache/flink/pull/19931#discussion_r896270154
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/copy/HiveParserBaseSemanticAnalyzer.java:
##
@@ -387,7 +387,9 @@
[
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-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
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
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-27828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553891#comment-17553891
]
Jiangfei Liu commented on FLINK-27828:
--
parallelism:3
checkpoint config:
CheckpointConfig
[ 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-27828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553892#comment-17553892
]
Jiangfei Liu commented on FLINK-27828:
--
checkpoint config:
CheckpointConfig
[
https://issues.apache.org/jira/browse/FLINK-28028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-28028:
Description:
Currently, the most common way to use credential is to use:
CREATE TABLE mytable (
...
[
https://issues.apache.org/jira/browse/FLINK-28028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-28028:
Description:
Currently, the most common way to use credential is to use:
{{CREATE TABLE ...}}
CREATE
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
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,
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
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.
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
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
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`
[
https://issues.apache.org/jira/browse/FLINK-28018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553484#comment-17553484
]
Zhu Zhu commented on FLINK-28018:
-
I have assigned you the ticket. Feel free to open a fix for it.
>
lsyldliu commented on code in PR #19860:
URL: https://github.com/apache/flink/pull/19860#discussion_r895518287
##
flink-core/src/main/java/org/apache/flink/util/FlinkUserCodeClassLoader.java:
##
@@ -67,4 +67,9 @@ protected Class loadClassWithoutExceptionHandling(String
name,
zhuzhurk commented on code in PR #19860:
URL: https://github.com/apache/flink/pull/19860#discussion_r895522296
##
flink-core/src/main/java/org/apache/flink/util/FlinkUserCodeClassLoader.java:
##
@@ -67,4 +67,9 @@ protected Class loadClassWithoutExceptionHandling(String
name,
fredia commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r895525160
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java:
##
@@ -141,6 +158,29 @@ public void storeLocalState(
JingsongLi merged PR #153:
URL: https://github.com/apache/flink-table-store/pull/153
--
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:
JingsongLi commented on PR #151:
URL:
https://github.com/apache/flink-table-store/pull/151#issuecomment-1153705258
> @JingsongLi Yes, in the case of a large amount of data, there is a lot of
data that needs to be sharded. Parallel streams will first allocate the same
key to the internal
JingsongLi merged PR #137:
URL: https://github.com/apache/flink-table-store/pull/137
--
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-28016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-28016:
-
Description:
We are currently de-facto limited to Maven 3.2.5 because our packaging
[
https://issues.apache.org/jira/browse/FLINK-19869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-19869:
---
Summary: Flink SQL JDBC connector for Postgres can't handle UUID datatype
(was: Support
lsyldliu commented on code in PR #19860:
URL: https://github.com/apache/flink/pull/19860#discussion_r895539630
##
flink-core/src/main/java/org/apache/flink/util/FlinkUserCodeClassLoader.java:
##
@@ -67,4 +67,9 @@ protected Class loadClassWithoutExceptionHandling(String
name,
1 - 100 of 320 matches
Mail list logo
