Hi Shammon,
Thanks for the update!
Best regards,
Jing
On Fri, Jul 7, 2023 at 4:46 AM Shammon FY wrote:
> Thanks Jing, sounds good to me.
>
> I have updated the FLIP and renamed the lineage related classes to
> `LineageGraph`, `LineageVertex` and `LineageEdge` and keep it consistent
> with the
Hi Dong,
Thanks for your clarification.
> Actually, I think it could make sense to toggle isBacklog between true and
> false while the job is running.
>
If isBacklog is toggled too often back and forth(e.g. by unexpected
mistake, unstable system, etc), a large amount of RecordAttributes might b
Xintong Song created FLINK-32557:
Summary: API deprecations in Flink 1.18
Key: FLINK-32557
URL: https://issues.apache.org/jira/browse/FLINK-32557
Project: Flink
Issue Type: Technical Debt
Xintong Song created FLINK-32558:
Summary: Properly deprecate DataSet API
Key: FLINK-32558
URL: https://issues.apache.org/jira/browse/FLINK-32558
Project: Flink
Issue Type: Sub-task
Xintong Song created FLINK-32559:
Summary: Deprecate Queryable State
Key: FLINK-32559
URL: https://issues.apache.org/jira/browse/FLINK-32559
Project: Flink
Issue Type: Sub-task
Comp
Xintong Song created FLINK-32560:
Summary: Properly deprecate all Scala APIs
Key: FLINK-32560
URL: https://issues.apache.org/jira/browse/FLINK-32560
Project: Flink
Issue Type: Sub-task
Thanks all for the discussion. I've created FLINK-32557 for this.
Best,
Xintong
On Thu, Jul 6, 2023 at 1:00 AM Jing Ge wrote:
> Hi Alex,
>
>
> > > 3. remove SinkFunction.
> > Which steps do you imply for the 1.18 release and for the 2.0 release?
> >
>
> for 2.0 release. 1.18 will be released
Xin Hao created FLINK-32561:
---
Summary: Change the status field reconciliationTimestamp from long
to Date
Key: FLINK-32561
URL: https://issues.apache.org/jira/browse/FLINK-32561
Project: Flink
Issu
Shengnan YU created FLINK-32562:
---
Summary: FileSink Compactor Service should not use FileWriter from
Sink for OutputStreamBasedFileCompactor
Key: FLINK-32562
URL: https://issues.apache.org/jira/browse/FLINK-32562
Thanks all for the discussion.
The wiki has been updated as discussed. I'm starting a vote now.
Best,
Xintong
On Wed, Jul 5, 2023 at 9:52 AM Xintong Song wrote:
> Hi ConradJam,
>
> I think Chesnay has already put his name as the Contributor for the two
> tasks you listed. Maybe you can reac
Etienne Chauchot created FLINK-32563:
Summary: Allow connectors CI to specify the main supported Flink
version
Key: FLINK-32563
URL: https://issues.apache.org/jira/browse/FLINK-32563
Project: Flin
Hi all,
I'd like to start the VOTE for the must-have work items for release 2.0
[1]. The corresponding discussion thread is [2].
Please note that once the vote is approved, any changes to the must-have
items (adding / removing must-have items, changing the priority) requires
another vote. Assigni
@Xintong
> - IIUC, the testing scenario you described is like blocking the source for
> proceeding (emit data, finish, etc.) until a checkpoint is finished.
It is more tricky than that - we need to prevent the Sink from receiving a
checkpoint barrier until the Source is done emitting a given set o
Hi Alex,
I would follow FLIP-197 and try to release them asap depending on dev
resources and how difficult those issues are. The fastest timeline is the
period defined in FLIP-197 in ideal conditions.
Best regards,
Jing
On Fri, Jul 7, 2023 at 12:20 PM Alexander Fedulov <
alexander.fedu...@gmail.
Hanyu Zheng created FLINK-32564:
---
Summary: Support cast BYTES to BIGINT
Key: FLINK-32564
URL: https://issues.apache.org/jira/browse/FLINK-32564
Project: Flink
Issue Type: Sub-task
R
Hanyu Zheng created FLINK-32565:
---
Summary: Support cast BYTES to DOUBLE
Key: FLINK-32565
URL: https://issues.apache.org/jira/browse/FLINK-32565
Project: Flink
Issue Type: Sub-task
R
16 matches
Mail list logo