Hi Arvid,
Thank you very much for looking at this and for Robert to pass this through to
you. Some quick thoughts.
The current design is not because it came from an earlier version of the fix,
Chesnay and I came up with this design, is because we took the assumptions
that:
* the existing
Sergey Nuyanzin created FLINK-36361:
---
Summary: Do not use StringBuilder for EquivalentExprShuttle
Key: FLINK-36361
URL: https://issues.apache.org/jira/browse/FLINK-36361
Project: Flink
Issu
Hi David,
Sorry for confusion,
Regarding two points you mentioned below , please find the response
* I thought we have 1 condition per Flink job state, so I assume we
have one true condition and potentially other historical false ones.
Right, we will have one condition per Job stat
The release sync will be held at the following time.
- 14:00, Sep 25, BJT (GMT+8)
- 08:00, Sep 25, CEST (GMT+2)
- 23:00, Sep 24, PDT (GMT-7)
Everyone is welcome to join via Google Meet [1]. The topics to be discussed
can be found at the Status / Follow-ups section of the release wiki page
[2]. If
Xintong Song created FLINK-36360:
Summary: Prepare release process and Scripts for the preview
release
Key: FLINK-36360
URL: https://issues.apache.org/jira/browse/FLINK-36360
Project: Flink
Matthias Pohl created FLINK-36356:
-
Summary: HadoopRecoverableWriterTest.testRecoverWithState due to
IOException
Key: FLINK-36356
URL: https://issues.apache.org/jira/browse/FLINK-36356
Project: Flink
Hong Liang Teoh created FLINK-36359:
---
Summary: IT case for DDB Streams connector
Key: FLINK-36359
URL: https://issues.apache.org/jira/browse/FLINK-36359
Project: Flink
Issue Type: Improveme
Hi Robert, thanks for looping me in.
I have looked at the branch and the FLIP. Apicurio looks like a promising
alternative to Confluent SR and I'm certain that it's a good addition to
Flink.
However, at the current form it looks heavily overengineered. I'm
suspecting that comes from the attempt t
Hi Martin,
So sorry about the late response to this email. I was on leave for all of
August and haven't had a chance to get back to this.
I don't think any existing operators are suitable to me that I know of. I'm
using the ContinuousFileReaderOperator to read large files as it was
designed for,
@Arvid: Could you take a look at this.
Thanks a lot.
On Wed, Aug 14, 2024 at 6:19 PM David Radley
wrote:
> Hi Danny,
> Thank you for your feedback. I have brought a fork up to date with one
> commit so you can
> see the code; I need to test more scenarios and add more unit tests, but
> it shows
Hi David,
* Yes, we’re taking the approach of having Calcite depend on flink-core and
flink-table-code-splitter. So not really porting now, just utilizing this
component in Flink.
* I don’t really have an answer for the question about Janino
post-processing optimizations.
* We’re p
xuyang created FLINK-36362:
--
Summary: Remove dependency about `flink-java` in table module
Key: FLINK-36362
URL: https://issues.apache.org/jira/browse/FLINK-36362
Project: Flink
Issue Type: Technica
xuyang created FLINK-36363:
--
Summary: Remove references to scala-relate api in tests among
table modules
Key: FLINK-36363
URL: https://issues.apache.org/jira/browse/FLINK-36363
Project: Flink
Issue
zhanghuaibei created FLINK-36365:
Summary: The fetchsize parameter of
flink-sql-connector-mysql-cdc-3.2.0 does not take effect
Key: FLINK-36365
URL: https://issues.apache.org/jira/browse/FLINK-36365
P
Jacky Lau created FLINK-36358:
-
Summary: to_timestamp result is not correct when the string
precision is long than date format
Key: FLINK-36358
URL: https://issues.apache.org/jira/browse/FLINK-36358
Proje
Hong Liang Teoh created FLINK-36357:
---
Summary: SDK retry for KDS connector
Key: FLINK-36357
URL: https://issues.apache.org/jira/browse/FLINK-36357
Project: Flink
Issue Type: Sub-task
Zakelly Lan created FLINK-36364:
---
Summary: Do not reuse serialized key in Forst map state and/or
other namespaces
Key: FLINK-36364
URL: https://issues.apache.org/jira/browse/FLINK-36364
Project: Flink
17 matches
Mail list logo
