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 @@
+/*
+ *
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
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:
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
[
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17584579#comment-17584579
]
Yanfei Lei commented on FLINK-29095:
[~jingge] There is already a [trace
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
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:
[
https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17584578#comment-17584578
]
Yun Gao commented on FLINK-28941:
-
[~hxb] I'll have a look~
> Savepoint ignores MaxConcurrentCheckpoint
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
[
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=17584576#comment-17584576
]
Shengkai Fang commented on FLINK-28936:
---
Merged into master:
[
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
[
https://issues.apache.org/jira/browse/FLINK-28962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17584573#comment-17584573
]
lixiang commented on FLINK-28962:
-
thanks, I think this is the reason for the problem I'm having.:)
>
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:
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
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=17584570#comment-17584570
]
Yanfei Lei commented on FLINK-29102:
[~hxb] Thanks for reporting, I will fix it later.
>
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=17584569#comment-17584569
]
Xingbo Huang commented on FLINK-29102:
--
[~Yanfei Lei] Could you help take a look? Thx.
>
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
[
https://issues.apache.org/jira/browse/FLINK-28941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17584567#comment-17584567
]
Xingbo Huang commented on FLINK-28941:
--
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
>
[
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:
[
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
>
[
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
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=17584540#comment-17584540
]
Yunhong Zheng commented on FLINK-28981:
---
Yes, I will start the test today.
> Release Testing:
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
[
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:
[
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:
[
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
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:
[
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
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
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:
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:
[
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
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:
##
@@
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
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:
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
[
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
[
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
[
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-29096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17584228#comment-17584228
]
jackylau commented on FLINK-29096:
--
the sql escape is ' , so i think we should add test for it.
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-29096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jackylau updated FLINK-29096:
-
Description:
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
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=17584208#comment-17584208
]
Aitozi commented on FLINK-29088:
I think we can push the union project of both project to source. By
[
https://issues.apache.org/jira/browse/FLINK-29084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17584207#comment-17584207
]
Weike Dong commented on FLINK-29084:
Oh yes, but that issue is still left unresolved. So probably we
[
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
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-28940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17584162#comment-17584162
]
Zhu Zhu commented on FLINK-28940:
-
I'm working on it and it may need a bit more time.
> Release
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:
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-29091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-29091:
Fix Version/s: 1.16.0
> Fix the determinism declaration of the rand function to be consistent
[
https://issues.apache.org/jira/browse/FLINK-28948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-28948:
-
Assignee: Alexander Smirnov
> Add more test coverage for lookup table full caching
>
swuferhong commented on code in PR #20664:
URL: https://github.com/apache/flink/pull/20664#discussion_r953584123
##
tools/azure-pipelines/build-apache-repo.yml:
##
@@ -70,7 +70,7 @@ stages:
name: Default
e2e_pool_definition:
vmImage:
morhidi commented on PR #351:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/351#issuecomment-1225483762
I've addressed your comments @gyfora
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
swuferhong commented on code in PR #20664:
URL: https://github.com/apache/flink/pull/20664#discussion_r953582716
##
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceStatisticsReportTest.java:
##
@@ -292,20 +294,41 @@ private
1 - 100 of 199 matches
Mail list logo
