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
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
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
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.
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,
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-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-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-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-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553889#comment-17553889
]
godfrey he commented on FLINK-26721:
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
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-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
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,
[
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
>
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:
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
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 @@
+/*
+ *
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-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
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
[
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
[
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
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
[
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
[
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-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
>
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-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-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-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: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-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
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
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-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:
-
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 commented on FLINK-28003:
[~martijnvisser] Thanks for response, however you might
[
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-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
>
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
[
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
[
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-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
>
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
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 @@
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-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
[
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-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
[
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
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
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:
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-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:
[
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
[
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
[
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-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
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
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 @@
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_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_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 @@
+/*
[
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
[
https://issues.apache.org/jira/browse/FLINK-28028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-28028:
Component/s: Table SQL / API
Table SQL / Runtime
> Common secure credential protection
Jing Ge created FLINK-28028:
---
Summary: Common secure credential protection mechanism in Flink SQL
Key: FLINK-28028
URL: https://issues.apache.org/jira/browse/FLINK-28028
Project: Flink
Issue Type:
MartijnVisser closed pull request #19948: [FLINK-20969][Scala] Update Scala
from 2.12.7 to 2.12.16. This upgrad…
URL: https://github.com/apache/flink/pull/19948
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
MartijnVisser commented on PR #19948:
URL: https://github.com/apache/flink/pull/19948#issuecomment-1154204506
Closing as I wanted to open this PR on my local repo, not against the Flink
repo
--
This is an automated message from the Apache Git Service.
To respond to the message, please
flinkbot commented on PR #19948:
URL: https://github.com/apache/flink/pull/19948#issuecomment-1154201548
## CI report:
* 2a9bac36aa03861b1835bc2ce57fd8e92bfb3ff8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
MartijnVisser opened a new pull request, #19948:
URL: https://github.com/apache/flink/pull/19948
…e is not binary compatible (see FLINK-12461) and this can influence your
Flink applications.
## What is the purpose of the change
*(For example: This pull request makes
Mrzyxing commented on PR #548:
URL: https://github.com/apache/flink-web/pull/548#issuecomment-1154162662
@Myasuka 前面的都已经修改。
剩余被动语态的问题，添加了一个 info msg 说明针对的是英文文档，看起来像这样：
fredia commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r895935387
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java:
##
@@ -98,6 +104,15 @@ public class TaskLocalStateStoreImpl implements
fredia commented on code in PR #19907:
URL: https://github.com/apache/flink/pull/19907#discussion_r895935127
##
flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogLocalRecoveryITCase.java:
##
@@ -0,0 +1,180 @@
+/*
+ * Licensed to the Apache Software
morhidi commented on PR #253:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/253#issuecomment-1154147708
@Aitozi @gyfora I ended up adding some extra e2e tests for multi namespace
session job deployments. We don't have too much resources on a minikube cluster
but I managed
1 - 100 of 320 matches
Mail list logo
