Sergey Nuyanzin created FLINK-31802:
---
Summary: Python py37-cython: commands failed
Key: FLINK-31802
URL: https://issues.apache.org/jira/browse/FLINK-31802
Project: Flink
Issue Type: Bug
Thanks Danny
+1 (non-binding)
* Hashes and Signatures look good
* All required files on dist.apache.org
* Tag is present in Github
* Verified source archive does not contain any binary files
* Source archive builds using maven
Cheers,
Hong
> On 14 Apr 2023, at 06:36, Elphas Toringepi wrote:
Hi Dong,
Thanks for driving this release!
+1 (binding)
* Checked JIRA release notes
* Verified signature and checksum for the source
* Download the source code and build the code with JDK8
* Browsed through README.md files.
Best,
Guowei
On Fri, Apr 14, 2023 at 2:48 PM Zhipeng Zhang
wrote:
>
Thanks Danny
+1 (non-binding)
* Hashes and Signatures look good
* All required files on dist.apache.org
* Tag is present in Github
* Verified source archive does not contain any binary files
* Source archive builds using maven
Cheers,
Hong
> On 14 Apr 2023, at 05:21, Elphas Toringepi wrote:
+1 (non binding)
On Fri, 14 Apr 2023 at 1:23 PM, Teoh, Hong
wrote:
> Thanks Danny
>
> +1 (non-binding)
>
> * Hashes and Signatures look good
> * All required files on dist.apache.org
> * Tag is present in Github
> * Verified source archive does not contain any binary files
> * Source archive bui
Sergey Nuyanzin created FLINK-31803:
---
Summary:
UpdateJobResourceRequirementsRecoveryITCase.testRescaledJobGraphsWillBeRecoveredCorrectly(Path)
is unstable on azure
Key: FLINK-31803
URL: https://issues.apache.or
Chesnay Schepler created FLINK-31804:
Summary: ITCase MiniCluster test architecture rule should accept
MiniClusterTestEnvironment
Key: FLINK-31804
URL: https://issues.apache.org/jira/browse/FLINK-31804
Chesnay Schepler created FLINK-31805:
Summary: Cassandra Source shouldn't use IOUtils
Key: FLINK-31805
URL: https://issues.apache.org/jira/browse/FLINK-31805
Project: Flink
Issue Type: Te
Chesnay Schepler created FLINK-31806:
Summary: Prod architecture tests didn't detect non-public API usage
Key: FLINK-31806
URL: https://issues.apache.org/jira/browse/FLINK-31806
Project: Flink
Chesnay Schepler created FLINK-31807:
Summary: Test architecture tests don't cover all tests
Key: FLINK-31807
URL: https://issues.apache.org/jira/browse/FLINK-31807
Project: Flink
Issue T
Hi tanjialiang
Thanks for reporting this, I think it's a reasonable requirements.
The problem might be introduced during the optimization when
reusing the mutable state in Source. So the DecodingFormat#copy can
avoid this situation.
But after checking the related code for DynamicTableSink,
The FLIP looks good to me. +1 to start a vote.
I just have a question: what will happen if the "executeTruncation" returns
false without any exceptions?
Best,
Jark
On Thu, 13 Apr 2023 at 19:59, Jing Ge wrote:
> Thanks Yuxia for the clarification and FLIP update. The FLIP looks good!
>
> Best r
+1 (binding)
- Validated hashes
- Verified signature
- Verified that no binaries exist in the source archive
- Build the source with Maven via mvn clean install -Pcheck-convergence
-Dflink.version=1.17.0
- Verified licenses
- Verified web PR
- Started a cluster and the Flink SQL client, successful
Weihua Hu created FLINK-31808:
-
Summary: wrong examples of how to set operator name in documents
Key: FLINK-31808
URL: https://issues.apache.org/jira/browse/FLINK-31808
Project: Flink
Issue Type
Fan Hong created FLINK-31809:
Summary: Improve efficiency of ListStateWithCache#snapshotState
Key: FLINK-31809
URL: https://issues.apache.org/jira/browse/FLINK-31809
Project: Flink
Issue Type: Im
Hi Hongshun
Thanks for updating the FLIP, it totally sounds good to me.
I just have one comment: How does sql job set new discovery offsets
initializer?
I found `DataStream` jobs can set different offsets initializers for new
discovery partitions in `KafkaSourceBuilder.setNewDiscoveryOffsets`. Do
Robert Metzger created FLINK-31810:
--
Summary: RocksDBException: Bad table magic number on checkpoint
rescale
Key: FLINK-31810
URL: https://issues.apache.org/jira/browse/FLINK-31810
Project: Flink
Hi, Jark.
I'm expecting if the "executeTruncation" returns false, Flink will throw an
generic exception like "Fail to execute truncate table statement."
But the connector implementation can also throw more specific exception like
"Fail to execute truncate table statement for it table is been writ
Hi, Mang.
+1 for completing the support for atomicity of CTAS, this is very useful in
batch scenarios and integrate with the data lake which support transcation.
I just have one question, IIUC, the DynamiacTableSink will need to know it's
for normal case or the atomicity with CTAS as well as nec
Hi everyone,
Please review and vote on the release candidate #1 for the version 3.1.0,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
This version supports both Flink 1.16.x and Flink 1.17.x
The complete staging area is available for
This vote is cancelled. I have opened the v3.1.0-rc1 vote [1] to replace it.
Thanks,
Danny
[1] https://lists.apache.org/thread/h9s3q3zb3nlrlo4twmk8s3y4jtj0mjcr
On Thu, Apr 13, 2023 at 6:33 PM Danny Cranmer
wrote:
> Hey Etienne.
>
> I saw the v3.0.1 fix version in Jira and assumed we were going
Thanks Danny
+1 (non-binding)
* Checked release notes
* Validated signature and checksum
* Apache source builds with JDK 11
* Approved website PR
Kind regards,
Elphas
On Fri, Apr 14, 2023 at 1:14 PM Danny Cranmer
wrote:
> Hi everyone,
> Please review and vote on the release candidate #1 for
jirawech.s created FLINK-31811:
--
Summary: Unsupported complex data type for Flink SQL
Key: FLINK-31811
URL: https://issues.apache.org/jira/browse/FLINK-31811
Project: Flink
Issue Type: Bug
Nicolas Fraison created FLINK-31812:
---
Summary: SavePoint from /jars/:jarid:/run api on body is not
anymore emptyToNull if empty
Key: FLINK-31812
URL: https://issues.apache.org/jira/browse/FLINK-31812
Hong Liang Teoh created FLINK-31813:
---
Summary: Initial implementation of Kinesis Source using FLIP-27
Key: FLINK-31813
URL: https://issues.apache.org/jira/browse/FLINK-31813
Project: Flink
Hi Yuxia,
Thank you for the updating. That sounds good to me.
Best,
Jark
> 2023年4月14日 19:00，yuxia 写道：
>
> Hi, Jark.
> I'm expecting if the "executeTruncation" returns false, Flink will throw an
> generic exception like "Fail to execute truncate table statement."
> But the connector implementa
Hello! +1 (non-binding)
I've validated the source for the RC1:
flink-connector-gcp-pubsub-3.0.1-src.tgz
* The sha512 checksum is OK.
* The source file is signed correctly.
* The signature A5F3BCE4CBE993573EC5966A65321B8382B219AF is found in the
KEYS file, and on https://keys.openpgp.org
* The sou
Hi Mang,
This is the FLIP I was looking forward to after FLIP-218. Thanks for
driving it. I have two questions and would like to know your thoughts,
thanks:
1. It looks like you found another way to design the atomic CTAS with new
serializable TwoPhaseCatalogTable instead of making Catalog serial
Hi, Aitozi,
Thanks you for your feedback, and +1 for your point of view.
Best,
tanjialiang.
Replied Message
| From | Aitozi |
| Date | 4/14/2023 16:19 |
| To | |
| Subject | Re: [DISCUSS] EncodingFormat and DecondingFormat provide copy API |
Hi tanjialiang
Thanks for reporting this, I th
29 matches
Mail list logo
