[
https://issues.apache.org/jira/browse/FLINK-29104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-29104:
--
Description: We've checked some options but in a case-by-case way, and it's
time for CoreOptions to fo
Jane Chan created FLINK-29104:
-
Summary: Check mutability of CoreOptions
Key: FLINK-29104
URL: https://issues.apache.org/jira/browse/FLINK-29104
Project: Flink
Issue Type: Improvement
C
qingwei91 commented on PR #20235:
URL: https://github.com/apache/flink/pull/20235#issuecomment-1226841548
@JingGe sorry I misunderstood, I've fixed it now
--
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
[
https://issues.apache.org/jira/browse/FLINK-28412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584645#comment-17584645
]
bo zhao commented on FLINK-28412:
-
For Flink 1.16.0, fabric8 client had been bumped to 5
[
https://issues.apache.org/jira/browse/FLINK-28590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangMu closed FLINK-28590.
--
Fix Version/s: 1.15.1
1.15.0
Release Note: Dependency conflict
Resolution: Won't
JingsongLi commented on code in PR #270:
URL: https://github.com/apache/flink-table-store/pull/270#discussion_r954495687
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/aggregate/FieldListaggAgg.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licens
flinkbot commented on PR #20678:
URL: https://github.com/apache/flink/pull/20678#issuecomment-1226777261
## CI report:
* aa69795f01dd7d94722712ddd20c755a8f8791c6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29097:
---
Labels: pull-request-available (was: )
> Moving json se/deserializers from sql-gateway-api
WencongLiu opened a new pull request, #20678:
URL: https://github.com/apache/flink/pull/20678
## What is the purpose of the change
*Moving json se/deserializers from sql-gateway-api to sql-gateway*
## Brief change log
- *Moving json se/deserializers from sql
JingsongLi merged PR #274:
URL: https://github.com/apache/flink-table-store/pull/274
--
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...@
SteNicholas commented on PR #20642:
URL: https://github.com/apache/flink/pull/20642#issuecomment-1226755242
@wangyang0918 , PTAL.
--
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 comm
[
https://issues.apache.org/jira/browse/FLINK-29098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-29098:
Assignee: Jane Chan
> StoreWriteOperator#prepareCommit should let logSinkFunction flush f
JingsongLi commented on code in PR #274:
URL: https://github.com/apache/flink-table-store/pull/274#discussion_r954477033
##
flink-table-store-benchmark/README.md:
##
@@ -36,26 +37,23 @@ This is the benchmark module for Flink Table Store.
Inspired by [Nexmark](https:
Review C
[
https://issues.apache.org/jira/browse/FLINK-29098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-29098:
--
Description: The cause for unstable
CompositePkAndMultiPartitionedTableITCase#testEnableLogAndStreamin
[
https://issues.apache.org/jira/browse/FLINK-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584579#comment-17584579
]
Yanfei Lei commented on FLINK-29095:
[~jingge] There is already a [trace
log|https
fsk119 commented on code in PR #20609:
URL: https://github.com/apache/flink/pull/20609#discussion_r954471863
##
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkDistribution.java:
##
@@ -537,4 +455,85 @@ public void copyLo
hehetown created FLINK-29103:
Summary: FileNotFoundException: No such file or directory: s3://
Key: FLINK-29103
URL: https://issues.apache.org/jira/browse/FLINK-29103
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584578#comment-17584578
]
Yun Gao commented on FLINK-28941:
-
[~hxb] I'll have a look~
> Savepoint ignores MaxConc
swuferhong commented on PR #20664:
URL: https://github.com/apache/flink/pull/20664#issuecomment-1226734408
@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-28936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-28936:
-
Assignee: yuzelin (was: Shengkai Fang)
> Fix RSET endpoint can not serialize CHAR(0)
>
[
https://issues.apache.org/jira/browse/FLINK-28936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-28936.
-
Resolution: Fixed
> Fix RSET endpoint can not serialize CHAR(0)
> --
[
https://issues.apache.org/jira/browse/FLINK-28936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584576#comment-17584576
]
Shengkai Fang commented on FLINK-28936:
---
Merged into master: 64f11ee95499af94d9ca3
[
https://issues.apache.org/jira/browse/FLINK-29102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-29102:
Assignee: Yanfei Lei
> ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFa
[
https://issues.apache.org/jira/browse/FLINK-28962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584573#comment-17584573
]
lixiang commented on FLINK-28962:
-
thanks, I think this is the reason for the problem I'
fsk119 merged PR #20617:
URL: https://github.com/apache/flink/pull/20617
--
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.apache
flinkbot commented on PR #20677:
URL: https://github.com/apache/flink/pull/20677#issuecomment-1226726369
## CI report:
* e29a28c60b18b01c96c4f41a8f12d22e87fd0bf7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-22900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22900:
---
Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
pull-request-avail
jlon opened a new pull request, #20677:
URL: https://github.com/apache/flink/pull/20677
## What is the purpose of the change
Fix the problem of partition matching error caused by the parent directory
is a hidden file in the case of multiple partitions.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-29102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584570#comment-17584570
]
Yanfei Lei commented on FLINK-29102:
[~hxb] Thanks for reporting, I will fix it lat
Xingbo Huang created FLINK-29102:
Summary: ChangelogLocalRecoveryITCase.testRestartTM failed with
AssertionFailedError
Key: FLINK-29102
URL: https://issues.apache.org/jira/browse/FLINK-29102
Project:
[
https://issues.apache.org/jira/browse/FLINK-29102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584569#comment-17584569
]
Xingbo Huang commented on FLINK-29102:
--
[~Yanfei Lei] Could you help take a look? T
tsreaper opened a new pull request, #274:
URL: https://github.com/apache/flink-table-store/pull/274
This PR adds more functionality for table store benchmark.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
[
https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584567#comment-17584567
]
Xingbo Huang commented on FLINK-28941:
--
[https://dev.azure.com/apache-flink/apache-
Weijie Guo created FLINK-29101:
--
Summary: PipelinedRegionSchedulingStrategy benchmark shows
performance degradation
Key: FLINK-29101
URL: https://issues.apache.org/jira/browse/FLINK-29101
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-27655:
--
Component/s: Table Store
> Implement Avro File statistic collector
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-27517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-27517:
--
Component/s: Table Store
> Introduce rolling file writer to write one record each time for append-only
> tabl
[
https://issues.apache.org/jira/browse/FLINK-27546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-27546:
--
Component/s: Table Store
> Add append only writer which implements the RecordWriter interface.
> -
[
https://issues.apache.org/jira/browse/FLINK-27580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-27580:
--
Component/s: Table Store
> Implement filter pushdown for TableStoreHiveStorageHandler
> --
[
https://issues.apache.org/jira/browse/FLINK-27656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-27656:
--
Component/s: Table Store
> Add parquet file format
>
>
> Key: FLINK-
[
https://issues.apache.org/jira/browse/FLINK-27706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-27706:
--
Component/s: Table Store
> Refactor all subclasses of FileStoreTableITCase to use the batchSql.
>
[
https://issues.apache.org/jira/browse/FLINK-27696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-27696:
--
Component/s: Table Store
> Add bin-pack strategy to split the whole bucket data files into several small
> sp
[
https://issues.apache.org/jira/browse/FLINK-27678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-27678:
--
Component/s: Table Store
> Support append-only table for file store.
> ---
[
https://issues.apache.org/jira/browse/FLINK-27708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-27708:
--
Component/s: Table Store
> Add background compaction task for append-only table when ingesting.
>
Aitozi commented on code in PR #20671:
URL: https://github.com/apache/flink/pull/20671#discussion_r954441207
##
docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md:
##
@@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar
$FLINK_HOME/usrlib/my-flink-job.jar
Af
lincoln-lil commented on code in PR #20577:
URL: https://github.com/apache/flink/pull/20577#discussion_r954433834
##
docs/content/docs/dev/table/sql/queries/hints.md:
##
@@ -84,4 +84,324 @@ insert into kafka_table1 /*+
OPTIONS('sink.partitioner'='round-robin') */ select
```
Thomas Weise created FLINK-29100:
Summary: Deployment with last-state upgrade mode stuck after
initial error
Key: FLINK-29100
URL: https://issues.apache.org/jira/browse/FLINK-29100
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584540#comment-17584540
]
Yunhong Zheng commented on FLINK-28981:
---
Yes, I will start the test today.
> Rele
swuferhong commented on PR #20664:
URL: https://github.com/apache/flink/pull/20664#issuecomment-1226668783
@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-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge reassigned FLINK-29095:
---
Assignee: Roman Khachatryan
> logging state file deletion
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-24750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-24750:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
auto-deprioritize
[
https://issues.apache.org/jira/browse/FLINK-28395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28395:
---
Labels: auto-deprioritized-critical pull-request-available test-stability
(was: pull-requ
[
https://issues.apache.org/jira/browse/FLINK-29099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
seth saperstein updated FLINK-29099:
Description:
Deadlock is reached as the result of:
* max lookahead reached for local wate
dannycranmer merged PR #566:
URL: https://github.com/apache/flink-web/pull/566
--
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.
[
https://issues.apache.org/jira/browse/FLINK-25859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-25859:
-
Assignee: Yuri Gusev (was: Zichen Liu)
> Add documentation for DynamoDB Async Sink
> -
flinkbot commented on PR #20676:
URL: https://github.com/apache/flink/pull/20676#issuecomment-1226136355
## CI report:
* e0467ae64ab836b5fd790462384eb10a76efc888 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28948:
---
Labels: pull-request-available (was: )
> Add more test coverage for lookup table full cachi
SmirAlex opened a new pull request, #20676:
URL: https://github.com/apache/flink/pull/20676
## What is the purpose of the change
This pull request introduces more tests for recently added feature with full
caching lookup and adds missing metrics for `LookupFullCache`
seth saperstein created FLINK-29099:
---
Summary: Deadlock for Single Subtask in Kinesis Consumer
Key: FLINK-29099
URL: https://issues.apache.org/jira/browse/FLINK-29099
Project: Flink
Issue T
meng1222 closed pull request #19959: [hotfix][doc]Fixed the problem that the
Checkpoint document directory…
URL: https://github.com/apache/flink/pull/19959
--
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
SwimSweet commented on code in PR #20671:
URL: https://github.com/apache/flink/pull/20671#discussion_r953898308
##
docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md:
##
@@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar
$FLINK_HOME/usrlib/my-flink-job.jar
SwimSweet commented on code in PR #20671:
URL: https://github.com/apache/flink/pull/20671#discussion_r953898308
##
docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md:
##
@@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar
$FLINK_HOME/usrlib/my-flink-job.jar
SwimSweet commented on code in PR #20671:
URL: https://github.com/apache/flink/pull/20671#discussion_r953898308
##
docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md:
##
@@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar
$FLINK_HOME/usrlib/my-flink-job.jar
dannycranmer merged PR #128:
URL: https://github.com/apache/flink-docker/pull/128
--
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...@fli
dannycranmer merged PR #127:
URL: https://github.com/apache/flink-docker/pull/127
--
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...@fli
[
https://issues.apache.org/jira/browse/FLINK-29098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-29098:
--
Description: The reason that
CompositePkAndMultiPartitionedTableITCase#testEnableLogAndStreamingReadWr
Jane Chan created FLINK-29098:
-
Summary: StoreWriteOperator#prepareCommit should let
logSinkFunction flush first before fetching offset
Key: FLINK-29098
URL: https://issues.apache.org/jira/browse/FLINK-29098
gyfora commented on code in PR #351:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/351#discussion_r953822021
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractFlinkResourceReconciler.java:
##
@@ -122,16
xuyangzhong commented on PR #20669:
URL: https://github.com/apache/flink/pull/20669#issuecomment-1225736385
@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 commen
zhipeng93 merged PR #145:
URL: https://github.com/apache/flink-ml/pull/145
--
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
zhipeng93 commented on PR #145:
URL: https://github.com/apache/flink-ml/pull/145#issuecomment-1225711837
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 unsubscrib
[
https://issues.apache.org/jira/browse/FLINK-26326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-26326:
---
Fix Version/s: (was: 1.17.0)
> FLIP-203: Support native and incremental savepoints 1.1
>
[
https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-26683:
---
Fix Version/s: (was: 1.17.0)
> Commit side effects if stop-with-savepoint failed while f
[
https://issues.apache.org/jira/browse/FLINK-22805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-22805:
---
Fix Version/s: (was: 1.17.0)
> Dynamic configuration of Flink checkpoint interval
>
[
https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-11499:
---
Priority: Not a Priority (was: Minor)
> Extend StreamingFileSink BulkFormats to support arb
[
https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-11499:
---
Fix Version/s: (was: 1.17.0)
> Extend StreamingFileSink BulkFormats to support arbitrary
flinkbot commented on PR #20675:
URL: https://github.com/apache/flink/pull/20675#issuecomment-1225691809
## CI report:
* 42a985a26da6ed1ad9b5ed85d25e4593c3b107b0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-15378:
---
Fix Version/s: (was: 1.17.0)
> StreamFileSystemSink supported mutil hdfs plugins.
>
[
https://issues.apache.org/jira/browse/FLINK-15012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-15012:
---
Fix Version/s: (was: 1.17.0)
> Checkpoint directory not cleaned up
> ---
[
https://issues.apache.org/jira/browse/FLINK-20103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-20103:
---
Fix Version/s: (was: 1.17.0)
> Improve test coverage with chaos testing & side-by-side t
[
https://issues.apache.org/jira/browse/FLINK-18405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-18405:
---
Fix Version/s: (was: 1.17.0)
> Add watermark support for unaligned checkpoints
> ---
[
https://issues.apache.org/jira/browse/FLINK-29096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29096:
---
Labels: pull-request-available (was: )
> json_value when the path has blank, the result is
Wencong Liu created FLINK-29097:
---
Summary: Moving json se/deserializers from sql-gateway-api to
sql-gateway
Key: FLINK-29097
URL: https://issues.apache.org/jira/browse/FLINK-29097
Project: Flink
liuyongvs opened a new pull request, #20675:
URL: https://github.com/apache/flink/pull/20675
## What is the purpose of the change
*Add test for json_value, which json path has blank characters*
## Does this pull request potentially affect one of the following parts:
Aitozi commented on code in PR #20671:
URL: https://github.com/apache/flink/pull/20671#discussion_r953754456
##
docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md:
##
@@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar
$FLINK_HOME/usrlib/my-flink-job.jar
Af
[
https://issues.apache.org/jira/browse/FLINK-29096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584228#comment-17584228
]
jackylau commented on FLINK-29096:
--
the sql escape is ' , so i think we should add test
[
https://issues.apache.org/jira/browse/FLINK-29096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-29096:
-
Attachment: image-2022-08-24-20-33-59-052.png
> json_value when the path has blank, the result is not ri
[
https://issues.apache.org/jira/browse/FLINK-29096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-29096:
-
Description:
!https://aone.alipay.com/v2/api/workitem/adapter/file/url?fileIdentifier=workitem%2Falipay%
jackylau created FLINK-29096:
Summary: json_value when the path has blank, the result is not
right
Key: FLINK-29096
URL: https://issues.apache.org/jira/browse/FLINK-29096
Project: Flink
Issue Ty
SwimSweet commented on code in PR #20671:
URL: https://github.com/apache/flink/pull/20671#discussion_r953733196
##
docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md:
##
@@ -97,14 +97,34 @@ COPY /path/of/my-flink-job.jar
$FLINK_HOME/usrlib/my-flink-job.jar
[
https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584208#comment-17584208
]
Aitozi commented on FLINK-29088:
I think we can push the union project of both project t
[
https://issues.apache.org/jira/browse/FLINK-29084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584207#comment-17584207
]
Weike Dong commented on FLINK-29084:
Oh yes, but that issue is still left unresolved
[
https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29088:
---
Description:
It can be reproduce by
{code:java}
util.addTable(
s"""
|create table newX(
pnowojski commented on code in PR #19380:
URL: https://github.com/apache/flink/pull/19380#discussion_r953608744
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PartitionRequestNotifier.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software
Jing Ge created FLINK-29095:
---
Summary: logging state file deletion
Key: FLINK-29095
URL: https://issues.apache.org/jira/browse/FLINK-29095
Project: Flink
Issue Type: New Feature
Component
[
https://issues.apache.org/jira/browse/FLINK-29091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-29091:
Summary: Fix the determinism declaration of the rand function to be
consistent with current behavi
[
https://issues.apache.org/jira/browse/FLINK-28940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17584162#comment-17584162
]
Zhu Zhu commented on FLINK-28940:
-
I'm working on it and it may need a bit more time.
>
flinkbot commented on PR #20674:
URL: https://github.com/apache/flink/pull/20674#issuecomment-1225509434
## CI report:
* 81d7dfd17ac31b8f7dbc90ef56df5d556211253d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Bartosz Mikulski created FLINK-29094:
Summary: Cannot stop Python job with savepoint when using Kafka
Consumer
Key: FLINK-29094
URL: https://issues.apache.org/jira/browse/FLINK-29094
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-29091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29091:
---
Labels: pull-request-available (was: )
> Fix the determinism declaration of the rand functi
lincoln-lil opened a new pull request, #20674:
URL: https://github.com/apache/flink/pull/20674
## What is the purpose of the change
RAND and RAND_INTEGER are declared as dynamic function (isDynamicFuntion
returns true), as the declaration it should only evaluate once at query-level
(not
1 - 100 of 197 matches
Mail list logo
