considered valid.
Please take a look at the FLIP page [1] to get more details. Any feedback about
the FLIP-228 would be appreciated!
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-228%3A+Support+Within+between+events+in+CEP+Pattern
Best regards,
Nicholas Jiang
Hi everyone，
Thanks for feedback for FLIP-228: Support Within between events in CEP
Pattern[1] on the discussion thread[2]. I'd like to start a VOTE thread for
FLIP-228.
The vote will be open for at least 72 hours unless there is an objection or not
enough votes.
Regards,
Nic
Regards,
Nicholas Jiang
Awesome! Big +1.
Regards,
Nicholas Jiang
On 2023/12/07 03:24:59 Leonard Xu wrote:
> Dear Flink devs,
>
> As you may have heard, we at Alibaba (Ververica) are planning to donate CDC
> Connectors for the Apache Flink project[1] to the Apache Flink community.
>
> CDC Connector
e/display/FLINK/FLIP-150%3A+Introduce+Hybrid+Source
<https://cwiki.apache.org/confluence/display/FLINK/FLIP-150%3A+Introduce+Hybrid+Source>
Best,
Nicholas Jiang
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
including Quick Start etc.
Best,
Nicholas Jiang
On 2022/03/31 08:53:40 Yang Wang wrote:
> +1 (non-binding)
>
> Verified via the following steps:
>
> * Verify checksums and GPG signatures
> * Verify that the source distributions do not contain any binaries
> * Build source dist
the Flink
deployment or job, that there is no need to distinguish and let users configure
separately.
Best,
Nicholas Jiang
On 2022/04/01 18:25:14 Gyula Fóra wrote:
> Hi Devs!
>
> *Background*:
> With more and more features and options added to the flink kubernetes
> operator it w
Hi David.
Thanks for the proposal of Temporal State. I'm working for the benchmark of
CEPOperator. I have question about how much performance improvement can
Temporal State bring to CEPOperator and whether there is any expected
performance?
Best,
Nicholas Jiang
On 2022/04/11 12:54:15
getTable interface, what's the return value schema?
5.How does the user get the operation log?
Thanks,
Nicholas Jiang
On 2022/04/21 06:42:30 Shengkai Fang wrote:
> Hi, Flink developers.
>
> I want to start a discussion about the FLIP-91: Support Flink SQL
> Gateway[1]. Flink SQ
d in the design. What's the behavior of the
compatibility?
Finally, for the public interfaces, could you please fully provide its
definition including input parameters and the corresponding return value
schema?
Thanks,
Nicholas Jiang
On 2022/04/21 06:45:13 Shengkai Fang wrote:
> Hi, F
Hi everyone,
+1 for the release (non-binding).
- Built and compiled source codes [PASSED]
- Went through quick start guide [PASSED]
- Checked README.md [PASSED]
- Checked that use the table store jar to build query table application [PASSED]
Best regards,
Nicholas Jiang
On 2022/04/29 02:24
Hi Shengkai,
I have another concern about the submission of batch job. Does the Flink SQL
gateway support to submit batch job? In Kyuubi, BatchProcessBuilder is used to
submit batch job. What about the Flink SQL gateway?
Best regards,
Nicholas Jiang
On 2022/04/24 03:28:36 Shengkai Fang wrote
Congrats Yang!
Best regards,
Nicholas Jiang
On 2022/05/05 11:18:10 Xintong Song wrote:
> Hi all,
>
> I'm very happy to announce that Yang Wang has joined the Flink PMC!
>
> Yang has been consistently contributing to our community, by contributing
> codes, parti
+1 (non-binding)
Best,
Nicholas Jiang
On 2022/05/20 02:38:39 Shengkai Fang wrote:
> Hi, everyone.
>
> Thanks for your feedback for FLIP-91: Support SQL Gateway[1] on the
> discussion thread[2]. I'd like to start a vote for it. The vote will be
> open for at least 72 hour
If there are other questions, any feedback is welcome.
Regards,
Nicholas Jiang
On 2022/05/07 09:16:55 Dian Fu wrote:
> Hi Nicholas,
>
> Thanks a lot for bringing up this discussion. If I recall it correctly,
> this feature has been requested many times by the users and is among one
Hi Yue,
Thanks for providing the benefit of this feature. After this feature is merged,
you are welcome to try this feature in business scenarios.
Regards,
Nicholas Jiang
On 2022/05/06 11:31:48 yue ma wrote:
> hi Nicholas,
>
> Thanks for bringing this discussion, we also think it&#
GNIZE is suitable for new FLIP to
discuss.
Regards,
Nicholas Jiang
On 2022/05/25 11:36:33 Martijn Visser wrote:
> Hi Nicholas,
>
> Thanks for creating the FLIP, I can imagine that there will be many use
> cases who can be created using this new feature.
>
> The FLIP doesn&
Hi Yang!
+1 (not-binding)
Verified the following successfully:
- Build from source, build container from source
- Run the examples for application, session and session job deployments
successfully and without any errors.
Regards,
Nicholas Jiang
On 2022/05/31 06:26:02 Yang Wang wrote:
>
`PREVIOUS_AND_NEXT` and `FIRST_AND_LAST` which directly indicate the time
interval within the PREVIOUS and NEXT event and within the FIRST and LAST
event. `RELATIVE_TO_FIRST` and `RELATIVE_TO_PREVIOUS` are not clear to
understand which event is relative to FIRST or PREVIOUS event.
Best,
Nicholas Jiang
On 2022
Hi Atri, Martijn,
MATCH_RECOGNIZE will support Batch mode in Flink 1.16. The pull request[1]
which support MATCH_RECOGNIZE in Batch mode will be merge to master branch
today. You could use in master branch.
Best,
Nicholas Jiang
[1]https://github.com/apache/flink/pull/18408
On 2022/06/08 08
Congrats! Thanks Yang for driving the 1.0.0 release, and thanks to all
contribution.
Best,
Nicholas Jiang
On 2022/06/08 10:54:37 Lijie Wang wrote:
> Congrats! Thanks Yang for driving the release, and thanks to all
> contributors!
>
> Best,
> Lijie
>
> John Gerassimou
is fully considered for
time interval between events matched in the loop or times case.
Best,
Nicholas Jiang
On 2022/06/08 08:11:58 Nicholas Jiang wrote:
> Hi Dian,
>
> Thanks for your feedback about the Public Interface update for supporting the
> within between events feature. I h
+1 (not-binding)
Best,
Nicholas Jiang
On 2022/06/07 05:31:21 Shengkai Fang wrote:
> Hi, everyone.
>
> Thanks for all feedback for FLIP-223: Support HiveServer2 Endpoint[1] on
> the discussion thread[2]. I'd like to start a vote for it. The vote will be
> open for at least 7
Hi Dian, Guys,
Thanks for your suggestion for the `PREVIOUS_AND_CURRENT`. I have updated the
naming of WithinType value in the FLIP.
If there are no other questions, I will start the VOTE thread next Monday.
Regards,
Nicholas Jiang
On 2022/06/10 10:02:46 Dian Fu wrote:
> Hi Nicho
Congratulations, Jingsong!
Regards,
Nicholas Jiang
On 2022/06/13 07:01:11 Qingsheng Ren wrote:
> Congratulations, Jingsong!
>
> Best,
> Qingsheng
>
> > On Jun 13, 2022, at 14:58, Becket Qin wrote:
> >
> > Hi all,
> >
> > I'm very happy
Congratulations, Ingo!
Best,
Nicholas Jiang
Congratulations, Matthias!
Best,
Nicholas Jiang
engine design, do you have any
comments? This core of the FLIP is about the multiple rule and dynamic rule
changing mechanism.
Best,
Nicholas Jiang
renaming rule, your suggestion
looks good to me and no any new concept introduces. But does this introduce
Rule concept or reuse the Pattern concept for the DynamicPattern renaming?
Best,
Nicholas Jiang
On 2021/12/13 07:45:04 Konstantin Knauf wrote:
> Thanks, Yufeng, for starting t
ldn't represent how to match
the Pattern, and how to process after matched but the Rule could explain this.
Therefore I prefer to rename the Rule not the DynamicPattern.
Best,
Nicholas Jiang
On 2021/12/13 08:23:23 Konstantin Knauf wrote:
> Hi Nicholas,
>
> I am not sure I understand
function.
Best
Nicholas Jiang
PatternProcessor contains the specific pattern and how to process the
pattern, and this contains the dynamic meaning. What's more, CEP.rule() method
could be renamed to CEP.patternProcess(). WDYT?
Best,
Nicholas Jiang
On 2021/12/14 07:32:46 Konstantin Knauf wrote:
> Hi Nicholas
the
latest rules through OperatorCoodinator, and will initiate a heartbeat to check
whether the latest rules on each TaskManager are consistent. We will describe
how to deal with the Failover scenario in more detail on FLIP.
Best,
Nicholas Jiang
On 2021/12/14 13:06:16 Martijn Visser wrote:
>
or example, a pattern
corresponds to a group of users? The scenarios mentioned above need to be
solved by case by case.
Best,
Nicholas Jiang
On 2021/12/17 11:43:10 yue ma wrote:
> Glad to see the Community's progress in Flink CEP. After reading this Flip,
> I have few questions, would you ple
t Qin who is the author of
OperatorCoordinator to help us to answer this concern.
Best,
Nicholas Jiang
On 2021/12/20 10:07:14 Martijn Visser wrote:
> Hi all,
>
> Really like the discussion on this topic moving forward. I really think
> this feature will be much appreciated by the Fl
(custom source / operator + broadcast), Becket has given
the explanation for the OperatorCoordinator V.S. side-input / broadcast stream.
You could share your thoughts about this.
Best,
Nicholas Jiang
On 2021/12/21 08:24:53 David Morávek wrote:
> Hi Yunfeng,
>
> thanks for drafting this F
Hi Konstantin, Becket, Martijn,
Thanks for sharing your feedback. What other concerns do you have about
OperatorCoodinator? If an agreement is reached on OperatorCoodinator, I will
start the voting thread.
Best,
Nicholas Jiang
On 2021/12/22 03:19:58 Becket Qin wrote:
> Hi Konstan
ract them from the actual enumerator could be
defined in the state conversion function which is invoked in
"HybridSplitEnumerator" when switch one "SwitchableSplitEnumerator" to
another "SwitchableSplitEnumerator". Because the "SwitchableSplitEnumerator"
interfa
ss sources is
send the corresponding "SourceEvent" to coordination. The end-position or
start-position don't need to be stored in checkpoint state, only implements
the "getEndState" interface for end-position.
Best,
Nicholas Jiang
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
need to provide RocketMQ's Source and Sink
(Legacy and FLIP-27 based), TableSource and TableSink. This integration
invokes the cooperation between Flink and RocketMQ community, therefore for
this community cooperation you could negotiate with Flink community
developers like PMC etc.
Best,
N
Congrats, Rui!
Best,
Nicholas Jiang
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
lease help to review the
abstract implementation, and compare with the interfaces mentioned in
FLIP-150.
Thanks,
Nicholas Jiang
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
Congratulations, Xintong!
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
Congratulations, Arvid!
--
Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
store jar - PASSED
* Checked all NOTICE files - PASSED
Regards,
Nicholas Jiang
On 2022/08/17 10:16:54 Jingsong Li wrote:
> Hi everyone,
>
> Please review and vote on the release candidate #2 for the version 0.2.0 of
> Apache Flink Table Store, as follows:
>
> [ ] +1, Approve t
store jar - PASSED
* Checked all NOTICE files - PASSED
* Checked the website updates - PASSED
Regards,
Nicholas Jiang
On 2022/08/24 07:46:00 Jingsong Li wrote:
> Hi everyone,
>
> Please review and vote on the release candidate #3 for the version 0.2.0 of
> Apache Flink Table Store, as
Nicholas Jiang created FLINK-14956:
--
Summary: MemoryMappedBoundedData Compressed Buffer Slicer
Key: FLINK-14956
URL: https://issues.apache.org/jira/browse/FLINK-14956
Project: Flink
Issue
Nicholas Jiang created FLINK-19646:
--
Summary: StreamExecutionEnvironment support new Source interface
based on FLIP-27
Key: FLINK-19646
URL: https://issues.apache.org/jira/browse/FLINK-19646
Project
Nicholas Jiang created FLINK-19984:
--
Summary: Add TypeSerializerTestCoverageTest to check whether tests
based on SerializerTestBase and TypeSerializerUpgradeTestBase
Key: FLINK-19984
URL: https
Nicholas Jiang created FLINK-31050:
--
Summary: Supports IN predicate in ORC format of table store
Key: FLINK-31050
URL: https://issues.apache.org/jira/browse/FLINK-31050
Project: Flink
Issue
Nicholas Jiang created FLINK-31076:
--
Summary: Supports filter predicate in Parquet format of table store
Key: FLINK-31076
URL: https://issues.apache.org/jira/browse/FLINK-31076
Project: Flink
Nicholas Jiang created FLINK-31190:
--
Summary: Supports Spark call procedure command on Table Store
Key: FLINK-31190
URL: https://issues.apache.org/jira/browse/FLINK-31190
Project: Flink
Nicholas Jiang created FLINK-31194:
--
Summary: ntroduces savepoint mechanism of Table Store
Key: FLINK-31194
URL: https://issues.apache.org/jira/browse/FLINK-31194
Project: Flink
Issue Type
Nicholas Jiang created FLINK-31232:
--
Summary: Parquet format supports MULTISET type for Table Store
Key: FLINK-31232
URL: https://issues.apache.org/jira/browse/FLINK-31232
Project: Flink
Nicholas Jiang created FLINK-31250:
--
Summary: ParquetSchemaConverter supports MULTISET type for parquet
format
Key: FLINK-31250
URL: https://issues.apache.org/jira/browse/FLINK-31250
Project: Flink
Nicholas Jiang created FLINK-27097:
--
Summary: Document custom validator implementations
Key: FLINK-27097
URL: https://issues.apache.org/jira/browse/FLINK-27097
Project: Flink
Issue Type
Nicholas Jiang created FLINK-27392:
--
Summary: CEP Pattern supports definition of the maximum time gap
between events
Key: FLINK-27392
URL: https://issues.apache.org/jira/browse/FLINK-27392
Project
Nicholas Jiang created FLINK-27401:
--
Summary: CEP supports AggregateFunction in IterativeCondition
Key: FLINK-27401
URL: https://issues.apache.org/jira/browse/FLINK-27401
Project: Flink
Nicholas Jiang created FLINK-21045:
--
Summary: Support 'load module' and 'unload module' SQL syntax
Key: FLINK-21045
URL: https://issues.apache.org/jira/browse/FLINK-21045
Nicholas Jiang created FLINK-21849:
--
Summary: 'SHOW MODULES' tests for CliClientITCase lack the default
module test case
Key: FLINK-21849
URL: https://issues.apache.org/jira/browse/F
Nicholas Jiang created FLINK-22793:
--
Summary: HybridSource Table Implementation
Key: FLINK-22793
URL: https://issues.apache.org/jira/browse/FLINK-22793
Project: Flink
Issue Type: Sub-task
Nicholas Jiang created FLINK-24336:
--
Summary: PyFlink
Key: FLINK-24336
URL: https://issues.apache.org/jira/browse/FLINK-24336
Project: Flink
Issue Type: Bug
Reporter: Nicholas
Nicholas Jiang created FLINK-28560:
--
Summary: Support Spark 3.3 profile for SparkSource
Key: FLINK-28560
URL: https://issues.apache.org/jira/browse/FLINK-28560
Project: Flink
Issue Type
Nicholas Jiang created FLINK-28578:
--
Summary: Upgrade Spark version of flink-table-store-spark to
3.1.3, 3.2.2 or 3.3.0 or later
Key: FLINK-28578
URL: https://issues.apache.org/jira/browse/FLINK-28578
Nicholas Jiang created FLINK-28705:
--
Summary: Update copyright year to 2014-2022 in NOTICE files
Key: FLINK-28705
URL: https://issues.apache.org/jira/browse/FLINK-28705
Project: Flink
Issue
Nicholas Jiang created FLINK-28840:
--
Summary: Introduce Roadmap document of Flink Table Store
Key: FLINK-28840
URL: https://issues.apache.org/jira/browse/FLINK-28840
Project: Flink
Issue
Nicholas Jiang created FLINK-28903:
--
Summary: flink-table-store-hive-catalog could not shade
hive-shims-0.23
Key: FLINK-28903
URL: https://issues.apache.org/jira/browse/FLINK-28903
Project: Flink
Nicholas Jiang created FLINK-28930:
--
Summary: Add "What is Flink Table Store?" link to flink website
Key: FLINK-28930
URL: https://issues.apache.org/jira/browse/FLINK-28930
Proj
Nicholas Jiang created FLINK-29756:
--
Summary: Support materialized column to improve query performance
for complex types
Key: FLINK-29756
URL: https://issues.apache.org/jira/browse/FLINK-29756
Nicholas Jiang created FLINK-17610:
--
Summary: Align the behavior of result of internal map state to
return empty iterator
Key: FLINK-17610
URL: https://issues.apache.org/jira/browse/FLINK-17610
70 matches
Mail list logo
