[
https://issues.apache.org/jira/browse/FLINK-27193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Akshay Hazari updated FLINK-27193:
--
Description:
We have a unit test to check if Kyro serialisation and deserialisation results
[
https://issues.apache.org/jira/browse/FLINK-27193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Akshay Hazari updated FLINK-27193:
--
Priority: Minor (was: Not a Priority)
> Kyro Serialisation and Deserialisation returns a
[
https://issues.apache.org/jira/browse/FLINK-27193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Akshay Hazari updated FLINK-27193:
--
Description:
We have a unit test to check if Kyro serialisation and deserialisation results
Akshay Hazari created FLINK-27193:
-
Summary: Kyro Serialisation and Deserialisation returns a
different object
Key: FLINK-27193
URL: https://issues.apache.org/jira/browse/FLINK-27193
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520915#comment-17520915
]
Gyula Fora commented on FLINK-27190:
What improvements do you suggest?
> Revisit error handling in
liuzhuang2017 commented on code in PR #19413:
URL: https://github.com/apache/flink/pull/19413#discussion_r847981768
##
docs/content.zh/docs/ops/state/large_state_tuning.md:
##
@@ -166,149 +125,101 @@ public class MyOptionsFactory implements
ConfigurableRocksDBOptionsFactory {
[
https://issues.apache.org/jira/browse/FLINK-27165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520914#comment-17520914
]
Anton Kalashnikov commented on FLINK-27165:
---
I can try to take a look. But I don't see that it
masteryhx commented on code in PR #19142:
URL: https://github.com/apache/flink/pull/19142#discussion_r847968836
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java:
##
@@ -391,7 +394,7 @@ static void
[
https://issues.apache.org/jira/browse/FLINK-27192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Karthik updated FLINK-27192:
Issue Type: Technical Debt (was: Bug)
> Parquet File Read From Local
>
>
>
JingsongLi commented on code in PR #87:
URL: https://github.com/apache/flink-table-store/pull/87#discussion_r847944688
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/StartsWith.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache
JingsongLi commented on code in PR #87:
URL: https://github.com/apache/flink-table-store/pull/87#discussion_r847942602
##
flink-table-store-core/src/test/java/org/apache/flink/table/store/file/predicate/PredicateTest.java:
##
@@ -325,11 +345,29 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-26761:
---
Fix Version/s: 1.16.0
> Fix the cast exception thrown by PreValidateReWriter when insert
>
[
https://issues.apache.org/jira/browse/FLINK-26761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520902#comment-17520902
]
godfrey he commented on FLINK-26761:
[~zoucao] you are right, it's a bug. would you like to fix it ?
[
https://issues.apache.org/jira/browse/FLINK-27192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Karthik updated FLINK-27192:
Component/s: Table SQL / API
Table SQL / Client
Fix Version/s: 1.13.6
[
https://issues.apache.org/jira/browse/FLINK-27189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-27189:
Summary: Support to always add quotes for string data in CSV format (was:
Ability for table api to
[
https://issues.apache.org/jira/browse/FLINK-27189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-27189:
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
(was: API / Python)
>
Karthik created FLINK-27192:
---
Summary: Hi,
Key: FLINK-27192
URL: https://issues.apache.org/jira/browse/FLINK-27192
Project: Flink
Issue Type: Bug
Reporter: Karthik
--
This
[
https://issues.apache.org/jira/browse/FLINK-27138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520899#comment-17520899
]
yanbiao commented on FLINK-27138:
-
[~martijnvisser] got it，thanks for your help:)
> flink1.14.0-sql-job
[
https://issues.apache.org/jira/browse/FLINK-26829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-26829:
--
Assignee: luoyuxia
> ClassCastException will be thrown when the second operand of divide is
[
https://issues.apache.org/jira/browse/FLINK-25242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520898#comment-17520898
]
godfrey he commented on FLINK-25242:
good catch~
> UDF with primitive int argument does not accept
weibozhao commented on code in PR #83:
URL: https://github.com/apache/flink-ml/pull/83#discussion_r847916030
##
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LinearModelData.java:
##
@@ -37,60 +38,68 @@
import java.io.OutputStream;
/**
- *
weibozhao commented on code in PR #83:
URL: https://github.com/apache/flink-ml/pull/83#discussion_r847915850
##
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/logisticregression/LinearModelData.java:
##
@@ -37,60 +38,68 @@
import java.io.OutputStream;
/**
- *
[
https://issues.apache.org/jira/browse/FLINK-26757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-26757.
--
Resolution: Fixed
merged in master: 4034d3cd6d13e88e2e5ca101510bf333e94a53fa
> change the default
Myasuka merged PR #19324:
URL: https://github.com/apache/flink/pull/19324
--
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:
Myasuka commented on code in PR #19413:
URL: https://github.com/apache/flink/pull/19413#discussion_r847908442
##
docs/content.zh/docs/ops/state/large_state_tuning.md:
##
@@ -166,149 +125,101 @@ public class MyOptionsFactory implements
ConfigurableRocksDBOptionsFactory {
}
zoltar9264 commented on code in PR #19252:
URL: https://github.com/apache/flink/pull/19252#discussion_r847906550
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -38,6 +38,8 @@ under the License.
在启动 CheckPoint 机制时，状态会随着 CheckPoint 而持久化，以防止数据丢失、保障恢复时的一致性。
zoltar9264 commented on PR #19252:
URL: https://github.com/apache/flink/pull/19252#issuecomment-1095911460
Thank for your review again @masteryhx , I hive fixed problems you mentioned.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
zoltar9264 commented on code in PR #19252:
URL: https://github.com/apache/flink/pull/19252#discussion_r847905580
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -306,77 +329,75 @@ public class MyOptionsFactory implements
ConfigurableRocksDBOptionsFactory {
{{<
luoyuxia commented on PR #19400:
URL: https://github.com/apache/flink/pull/19400#issuecomment-1095903340
Thanks @Tartarus0zm for contribution.
It's a continue work of #17990.
LGTM.
@beyond1920 @wuchong Could you please help review & merge?
--
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-27191:
-
Component/s: Connectors / Hive
> Support multi kerberos-enabled Hive clusters
>
luoyuxia created FLINK-27191:
Summary: Support multi kerberos-enabled Hive clusters
Key: FLINK-27191
URL: https://issues.apache.org/jira/browse/FLINK-27191
Project: Flink
Issue Type:
luoyuxia commented on PR #19423:
URL: https://github.com/apache/flink/pull/19423#issuecomment-1095873524
@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.
flinkbot commented on PR #19429:
URL: https://github.com/apache/flink/pull/19429#issuecomment-1095867338
## CI report:
* 9e092e3dfca1ea6effdf2edd26acdf9c590d5ac6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
wenlong88 commented on PR #19179:
URL: https://github.com/apache/flink/pull/19179#issuecomment-1095863004
LGTM
--
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
liuzhuang2017 opened a new pull request, #19429:
URL: https://github.com/apache/flink/pull/19429
Fix the "capacity-planning" page of "Tuning Checkpoints and Large State"
## What is the purpose of the change
Fix the "capacity-planning" page of "Tuning Checkpoints and
LadyForest commented on code in PR #87:
URL: https://github.com/apache/flink-table-store/pull/87#discussion_r847890543
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java:
##
@@ -95,9 +102,46 @@ public Predicate
zoltar9264 commented on code in PR #19252:
URL: https://github.com/apache/flink/pull/19252#discussion_r847887144
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -306,77 +329,75 @@ public class MyOptionsFactory implements
ConfigurableRocksDBOptionsFactory {
{{<
zoltar9264 commented on code in PR #19252:
URL: https://github.com/apache/flink/pull/19252#discussion_r847885936
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -38,6 +38,8 @@ under the License.
在启动 CheckPoint 机制时，状态会随着 CheckPoint 而持久化，以防止数据丢失、保障恢复时的一致性。
masteryhx commented on code in PR #19252:
URL: https://github.com/apache/flink/pull/19252#discussion_r847882156
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -306,77 +329,75 @@ public class MyOptionsFactory implements
ConfigurableRocksDBOptionsFactory {
{{< top
masteryhx commented on code in PR #19252:
URL: https://github.com/apache/flink/pull/19252#discussion_r847877301
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -38,6 +38,8 @@ under the License.
在启动 CheckPoint 机制时，状态会随着 CheckPoint 而持久化，以防止数据丢失、保障恢复时的一致性。
[
https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520882#comment-17520882
]
Yao Zhang commented on FLINK-27018:
---
Hi [~fpaul] and [~jeff-zou] ,
I reproduced this issue with Flink
JingsongLi commented on code in PR #87:
URL: https://github.com/apache/flink-table-store/pull/87#discussion_r847865264
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/predicate/PredicateConverter.java:
##
@@ -95,9 +102,46 @@ public Predicate
beyond1920 closed pull request #19109: [FLINK-26681][hive] Support sql
statement end with ";" for Hive dialect query
URL: https://github.com/apache/flink/pull/19109
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
yunfengzhou-hub commented on code in PR #83:
URL: https://github.com/apache/flink-ml/pull/83#discussion_r847844186
##
flink-ml-lib/src/main/java/org/apache/flink/ml/classification/ftrl/Ftrl.java:
##
@@ -0,0 +1,395 @@
+/*
Review Comment:
Jira tickets for algorithms that are
[
https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520859#comment-17520859
]
Feifan Wang commented on FLINK-27187:
-
I think it's ok. Should I open a new ticket do this work ? Or
[
https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520845#comment-17520845
]
Roman Khachatryan commented on FLINK-27187:
---
How about "totalAttemptsPerUpload"?
> The
[
https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520836#comment-17520836
]
Feifan Wang commented on FLINK-27187:
-
[~roman] , how would you like to name the metric of "the
[
https://issues.apache.org/jira/browse/FLINK-27187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520833#comment-17520833
]
Roman Khachatryan commented on FLINK-27187:
---
The number of the successfull attempt is actually
[
https://issues.apache.org/jira/browse/FLINK-27132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520830#comment-17520830
]
Roman Khachatryan commented on FLINK-27132:
---
Sorry, I mean the 5th item.
And yes, I mean ZK
[
https://issues.apache.org/jira/browse/FLINK-26070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-26070:
---
Labels: pull-request-available stale-major (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-25962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-25962:
---
Labels: pull-request-available stale-major (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21383:
---
Labels: auto-deprioritized-major usability (was: stale-major usability)
Priority:
[
https://issues.apache.org/jira/browse/FLINK-27132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-27132:
--
Description:
When considering the following case: # A job starts from a checkpoint in
[
https://issues.apache.org/jira/browse/FLINK-27132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-27132:
--
Description:
When considering the following case: # A job starts from a checkpoint in
[
https://issues.apache.org/jira/browse/FLINK-27132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-27132:
--
Description:
When considering the following case: # A job starts from a checkpoint in
[
https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520813#comment-17520813
]
Ted Chang commented on FLINK-26811:
---
[~wangyang0918] good reference. I will add that.
> Document CRD
[
https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520811#comment-17520811
]
Steven Zhen Wu commented on FLINK-27101:
[~yunta] a pluggable checkpoint trigger policy might
Matyas Orhidi created FLINK-27190:
-
Summary: Revisit error handling in main reconcile() loop
Key: FLINK-27190
URL: https://issues.apache.org/jira/browse/FLINK-27190
Project: Flink
Issue
flinkbot commented on PR #19428:
URL: https://github.com/apache/flink/pull/19428#issuecomment-1095522423
## CI report:
* 8cb988ee3e60ba740733ece9b96bde1c86d5bef4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520798#comment-17520798
]
David Perkins commented on FLINK-25694:
---
A new version was finally released. Created a PR with the
[
https://issues.apache.org/jira/browse/FLINK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25694:
---
Labels: pull-request-available (was: )
> GSON/Alluxio Vulnerability
>
David-N-Perkins opened a new pull request, #19428:
URL: https://github.com/apache/flink/pull/19428
## What is the purpose of the change
* Updated presto to the latest version due to GSON bug
## Brief change log
- Updated prosto library to `.272`
## Verifying this change
flinkbot commented on PR #19427:
URL: https://github.com/apache/flink/pull/19427#issuecomment-1095484285
## CI report:
* 05707cf8955f190d65021d61c5afd8164e831315 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27140:
---
Labels: pull-request-available (was: )
> Move JobResultStore dirty entry creation into
zentol opened a new pull request, #19427:
URL: https://github.com/apache/flink/pull/19427
Prevents the main thread from doing a potentially long running operation,
moving it instead to the io executor.
Needed to adjust some tests to rely on the runner termination future instead
of
[
https://issues.apache.org/jira/browse/FLINK-26140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26140:
---
Labels: pull-request-available (was: )
> Add basic handling mechanism to deal with job
gyfora commented on PR #165:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1095479699
Opening this for review/discussion, I will work on adding tests for the core
logic.
cc @wangyang0918 @tweise @Aitozi
--
This is an automated message from the
shameet created FLINK-27189:
---
Summary: Ability for table api to always add quotes to generated
csv
Key: FLINK-27189
URL: https://issues.apache.org/jira/browse/FLINK-27189
Project: Flink
Issue
Daisy Tsang created FLINK-27188:
---
Summary: Deprecate StreamingFileSink
Key: FLINK-27188
URL: https://issues.apache.org/jira/browse/FLINK-27188
Project: Flink
Issue Type: Improvement
blake-wilson commented on PR #19417:
URL: https://github.com/apache/flink/pull/19417#issuecomment-1095295771
Test failure is from a Kafka integration test and appears to be unrelated
```
2022-04-11T07:53:52.3560140Z Apr 11 07:53:52 Caused by:
java.lang.IllegalStateException: Cannot
Feifan Wang created FLINK-27187:
---
Summary: The attemptsPerUpload metric may be lower than it
actually is
Key: FLINK-27187
URL: https://issues.apache.org/jira/browse/FLINK-27187
Project: Flink
Aitozi commented on PR #164:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/164#issuecomment-1095272470
@gyfora I introduced the `SavepointObserver` and `JobStatusObserver` to
solve the code duplication. Please take a look again
--
This is an automated message from the
gaborgsomogyi commented on code in PR #19372:
URL: https://github.com/apache/flink/pull/19372#discussion_r847507611
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/token/KerberosDelegationTokenManager.java:
##
@@ -110,13 +126,84 @@ public void
gaborgsomogyi commented on code in PR #19372:
URL: https://github.com/apache/flink/pull/19372#discussion_r847504606
##
flink-runtime/src/test/java/org/apache/flink/runtime/security/token/KerberosDelegationTokenManagerTest.java:
##
@@ -20,13 +20,27 @@
import
whitecloud6688 commented on PR #19416:
URL: https://github.com/apache/flink/pull/19416#issuecomment-1095242154
感谢回复，可能是我理解错了，FlinkSQL中创建的表，在SparkSQL中是不可读取数据的，如果要读，需要创建外部表关联到FlinkSQL表的路径。所以用desc
Flink表是看不到字段的，但是能看到 Table Properties 中的 flink.schema 描述。 @luoyuxia
@MartijnVisser
--
This
[
https://issues.apache.org/jira/browse/FLINK-27155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520657#comment-17520657
]
Feifan Wang commented on FLINK-27155:
-
Thanks for your reply [~roman] , I’m glad to implement this
[
https://issues.apache.org/jira/browse/FLINK-24700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520654#comment-17520654
]
Francesco Guardiani commented on FLINK-24700:
-
Has this one already been solved [~twalthr]
[
https://issues.apache.org/jira/browse/FLINK-26905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-26905.
--
Resolution: Fixed
Implemented via
asfgit closed pull request #129: [FLINK-26905] Re-add FlinkDeploymentList and
FlinkSessionJobList classes
URL: https://github.com/apache/flink-kubernetes-operator/pull/129
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
infoverload commented on code in PR #19414:
URL: https://github.com/apache/flink/pull/19414#discussion_r847454084
##
flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/src/main/java/org/apache/flink/streaming/tests/StatefulStreamJobUpgradeTestProgram.java:
##
@@
slinkydeveloper commented on code in PR #19426:
URL: https://github.com/apache/flink/pull/19426#discussion_r847453122
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeCasts.java:
##
@@ -589,6 +591,37 @@ protected Boolean
slinkydeveloper commented on code in PR #19349:
URL: https://github.com/apache/flink/pull/19349#discussion_r847448720
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/test/WithTableEnvironment.java:
##
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the Apache
zentol commented on PR #526:
URL: https://github.com/apache/flink-web/pull/526#issuecomment-1095162237
I would really like to see the experimental OpenAPI specification being part
of the announcement. That's not something that existing users would stumble
upon in the docs I'm afraid.
--
twalthr commented on code in PR #19349:
URL: https://github.com/apache/flink/pull/19349#discussion_r847357250
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/test/WithTableEnvironment.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software
flinkbot commented on PR #19426:
URL: https://github.com/apache/flink/pull/19426#issuecomment-1095157121
## CI report:
* 1dd50a02ec38485aa442a46ca439df7861565ed0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
matriv commented on PR #19426:
URL: https://github.com/apache/flink/pull/19426#issuecomment-1095153446
Added the validation only in the `supportsExplicitCasting` as there are
cases where we do implicit casting between TIMESTAMP and numeric, i.e. In
`TemporalTypesTest`:
```
[
https://issues.apache.org/jira/browse/FLINK-25928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25928:
---
Labels: pull-request-available (was: )
> Refactor timestamp<->number validation messages
>
matriv opened a new pull request, #19426:
URL: https://github.com/apache/flink/pull/19426
## What is the purpose of the change
Throw early a validation error with workaround suggestion for
casting between numeric types and `TIMESTAMP`/`TIMESTAMP_LTZ` before
reaching the
gaborgsomogyi commented on code in PR #19372:
URL: https://github.com/apache/flink/pull/19372#discussion_r847414464
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/token/KerberosDelegationTokenManager.java:
##
@@ -110,13 +126,84 @@ public void
gaborgsomogyi commented on code in PR #19372:
URL: https://github.com/apache/flink/pull/19372#discussion_r847413385
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/token/KerberosDelegationTokenManager.java:
##
@@ -110,13 +126,84 @@ public void
zoltar9264 commented on PR #19403:
URL: https://github.com/apache/flink/pull/19403#issuecomment-1095130896
Thanks @RocMarshal , Is there any thing need I to do ? Such as squash
commits ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
zoltar9264 commented on code in PR #19252:
URL: https://github.com/apache/flink/pull/19252#discussion_r847395187
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -306,77 +329,75 @@ public class MyOptionsFactory implements
ConfigurableRocksDBOptionsFactory {
{{<
zoltar9264 commented on code in PR #19252:
URL: https://github.com/apache/flink/pull/19252#discussion_r847393806
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -306,77 +329,75 @@ public class MyOptionsFactory implements
ConfigurableRocksDBOptionsFactory {
{{<
zoltar9264 commented on code in PR #19252:
URL: https://github.com/apache/flink/pull/19252#discussion_r847386103
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -38,6 +38,8 @@ under the License.
在启动 CheckPoint 机制时，状态会随着 CheckPoint 而持久化，以防止数据丢失、保障恢复时的一致性。
gaborgsomogyi commented on code in PR #19372:
URL: https://github.com/apache/flink/pull/19372#discussion_r847376435
##
flink-runtime/src/test/java/org/apache/flink/runtime/security/token/KerberosDelegationTokenManagerTest.java:
##
@@ -79,4 +93,48 @@ public void
zoltar9264 commented on code in PR #19252:
URL: https://github.com/apache/flink/pull/19252#discussion_r847374465
##
docs/content.zh/docs/ops/state/state_backends.md:
##
@@ -306,77 +329,75 @@ public class MyOptionsFactory implements
ConfigurableRocksDBOptionsFactory {
{{<
slinkydeveloper commented on code in PR #19414:
URL: https://github.com/apache/flink/pull/19414#discussion_r847359774
##
flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/src/main/java/org/apache/flink/streaming/tests/StatefulStreamJobUpgradeTestProgram.java:
##
@@
infoverload commented on code in PR #19414:
URL: https://github.com/apache/flink/pull/19414#discussion_r847355828
##
flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/src/main/java/org/apache/flink/streaming/tests/StatefulStreamJobUpgradeTestProgram.java:
##
@@
infoverload commented on code in PR #19414:
URL: https://github.com/apache/flink/pull/19414#discussion_r847354659
##
flink-end-to-end-tests/flink-distributed-cache-via-blob-test/src/main/java/org/apache/flink/streaming/tests/DistributedCacheViaBlobTestProgram.java:
##
@@ -65,7
gaborgsomogyi commented on PR #19372:
URL: https://github.com/apache/flink/pull/19372#issuecomment-1095077528
> Should the obtainDelegationTokens(Credentials credentials) be implemented?
Maybe it could be a shared code path for the renewal (the one time renewal that
is scheduled)?
1 - 100 of 366 matches
Mail list logo
