Thanks for all the inputs, I have updated the document and POC code.
Best,
Godfrey
Yun Gao 于2022年7月26日周二 11:11写道：
>
> Hi,
>
> Thanks all for all the valuable discussion on this FLIP, +1 for implementing
> dynamic partition pruning / dynamic filtering pushdown since it is a key
> optimization
Paul Lin created FLINK-28685:
Summary: Optimize CatalogManager getTable implementation
Key: FLINK-28685
URL: https://issues.apache.org/jira/browse/FLINK-28685
Project: Flink
Issue Type:
Zhipeng Zhang created FLINK-28684:
-
Summary: NullPointerException at
OneHotEncoder.GenerateModelDataOperator.snapshot
Key: FLINK-28684
URL: https://issues.apache.org/jira/browse/FLINK-28684
Project:
Jingsong Lee created FLINK-28683:
Summary: Modify changelog-file to changelog-producer
Key: FLINK-28683
URL: https://issues.apache.org/jira/browse/FLINK-28683
Project: Flink
Issue Type:
xuyang created FLINK-28682:
--
Summary: support join hint in flink batch
Key: FLINK-28682
URL: https://issues.apache.org/jira/browse/FLINK-28682
Project: Flink
Issue Type: Sub-task
nyingping created FLINK-28681:
-
Summary: The number of windows allocated by sliding windows is
inaccurate, when the window length is irregular
Key: FLINK-28681
URL: https://issues.apache.org/jira/browse/FLINK-28681
Hi,
Thanks all for all the valuable discussion on this FLIP, +1 for implementing
dynamic partition pruning / dynamic filtering pushdown since it is a key
optimization
to improve the performance on batch processing.
Also due to introducing the speculative execution for the batch processing, we
Huang Xingbo created FLINK-28680:
Summary: No space left on device on Azure e2e_2_ci tests
Key: FLINK-28680
URL: https://issues.apache.org/jira/browse/FLINK-28680
Project: Flink
Issue Type:
+1
Best,
Godfrey
Jark Wu 于2022年7月25日周一 17:23写道：
>
> +1 (binding)
>
> Best,
> Jark
>
> On Mon, 25 Jul 2022 at 15:10, Jing Ge wrote:
>
> > Hi all,
> >
> > Many thanks for all your feedback. Based on the discussion in [1], I'd like
> > to start a vote on FLIP-247 [2].
> >
> > The vote will last
Huang Xingbo created FLINK-28679:
Summary: HiveServer2Endpoint compile failed
Key: FLINK-28679
URL: https://issues.apache.org/jira/browse/FLINK-28679
Project: Flink
Issue Type: Bug
Hello ,
Let me attempt to clarify
You have two categories of terminology: data sources and data processing
runtimes.
For data sources you have BOUNDED and UNBOUNDED
For processing runtime you have BATCH and STREAMING
When you are referring to data sources, BOUNDED data sets have a fixed
xuyang created FLINK-28678:
--
Summary: Support SQL hint for Filter, SetOp, Sort, Window, Values
Key: FLINK-28678
URL: https://issues.apache.org/jira/browse/FLINK-28678
Project: Flink
Issue Type: New
Hello Again!
I am very beginners in flink.
it is not important issue. so you can skip.
but, I have question. noting relation one.
I confuse in some streaming
oneday some people want to not finished protocol.
I want to explain "Dedekind Cut"
is it unbounded streaming? can be?
or
Jane Chan created FLINK-28677:
-
Summary: Primary key should not be null when creating Spark table
Key: FLINK-28677
URL: https://issues.apache.org/jira/browse/FLINK-28677
Project: Flink
Issue
Benchao Li created FLINK-28676:
--
Summary: Update copyright year to 2014-2022 in NOTICE files
Key: FLINK-28676
URL: https://issues.apache.org/jira/browse/FLINK-28676
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-28675:
Summary: AvroDeserializationSchema should eagerly validate that
class is SpecificRecord
Key: FLINK-28675
URL: https://issues.apache.org/jira/browse/FLINK-28675
Weike Dong created FLINK-28674:
--
Summary: EqualiserCodeGenerator generates wrong equaliser for
Timestamp fields in BinaryRowData
Key: FLINK-28674
URL: https://issues.apache.org/jira/browse/FLINK-28674
Yunfeng Zhou created FLINK-28673:
Summary: Migrate Flink ML to Flink 1.15.1
Key: FLINK-28673
URL: https://issues.apache.org/jira/browse/FLINK-28673
Project: Flink
Issue Type: Improvement
sazzad16 commented on PR #2:
URL:
https://github.com/apache/flink-connector-redis/pull/2#issuecomment-1193897653
Hi @knaufk,
Thanks for the pointers and the feedback!
@MartijnVisser has also sent me more read material including
songwenbin created FLINK-28672:
--
Summary: properties.allow.auto.create.topics无效
Key: FLINK-28672
URL: https://issues.apache.org/jira/browse/FLINK-28672
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-28671:
Summary: Update Spark3 to create/drop table in Compatibility
Matrix
Key: FLINK-28671
URL: https://issues.apache.org/jira/browse/FLINK-28671
Project: Flink
Hi everyone,
The voting time for FLIP-252: Amazon DynamoDB Sink Connector [1] has
passed. I'm closing the vote now.
There were 6 +1 votes, 5 of which are binding:
- Tzu-Li (Gordon) Tai (binding)
- Konstantin Knauf (binding)
- Robert Metzger (binding)
- Martijn Visser (binding)
- Becket Qin
Jingsong Lee created FLINK-28670:
Summary: Documentation of spark2 is wrong
Key: FLINK-28670
URL: https://issues.apache.org/jira/browse/FLINK-28670
Project: Flink
Issue Type: Bug
Jingsong Lee created FLINK-28669:
Summary: FileStoreExpireTest.testExpireWithTime failed
Key: FLINK-28669
URL: https://issues.apache.org/jira/browse/FLINK-28669
Project: Flink
Issue Type:
Jane Chan created FLINK-28668:
-
Summary: Fail to create partitioned table without primary key for
Spark
Key: FLINK-28668
URL: https://issues.apache.org/jira/browse/FLINK-28668
Project: Flink
+1 (binding)
Best,
Jark
On Mon, 25 Jul 2022 at 15:10, Jing Ge wrote:
> Hi all,
>
> Many thanks for all your feedback. Based on the discussion in [1], I'd like
> to start a vote on FLIP-247 [2].
>
> The vote will last for at least 72 hours unless there is an objection or
> insufficient votes.
>
zhangjingcun created FLINK-28667:
Summary: "evictor" operations of "window_all" are supported in
Python datastream API
Key: FLINK-28667
URL: https://issues.apache.org/jira/browse/FLINK-28667
Project:
Jane Chan created FLINK-28666:
-
Summary: Alter spark table's primary key should throw exception
Key: FLINK-28666
URL: https://issues.apache.org/jira/browse/FLINK-28666
Project: Flink
Issue Type:
Jingsong Lee created FLINK-28665:
Summary: flink-table-store-benchmark-jar-with-dependencies.jar
NOTICE file is wrong
Key: FLINK-28665
URL: https://issues.apache.org/jira/browse/FLINK-28665
Project:
Thanks for the update Sebastian :)
Best,
Piotrek
pon., 25 lip 2022 o 08:12 Sebastian Mattheis
napisał(a):
> Hi everybody,
>
> I discussed last week the semantics and an implementation stragegy of the
> configuration parameter with Piotr and did the implementation and some
> tests this weekend.
Hi all,
Many thanks for all your feedback. Based on the discussion in [1], I'd like
to start a vote on FLIP-247 [2].
The vote will last for at least 72 hours unless there is an objection or
insufficient votes.
Best regards,
Jing
[1]
+1 (binding)
Op ma 25 jul. 2022 om 04:56 schreef Yang Wang :
> +1 (binding)
>
> Best,
> Yang
>
> bo zhaobo 于2022年7月25日周一 09:38写道：
>
> > Hi all,
> >
> > Thank you very much for all feedback after the discussion in [2][3].
> > Now I'd like to proceed with the vote for FLIP-250 [1], as no more
> >
+1 (binding)
Op ma 25 jul. 2022 om 06:01 schreef Becket Qin :
> +1
>
> On Mon, Jul 25, 2022 at 9:22 AM Grant L (Grant)
> wrote:
>
> > +1
> >
> > On 2022/07/21 18:27:52 Robert Metzger wrote:
> > > +1
> > >
> > > On Wed, Jul 20, 2022 at 10:48 PM Konstantin Knauf
> > wrote:
> > >
> > > > +1.
Juntao Hu created FLINK-28664:
-
Summary: Support AvroWriters in PyFlink
Key: FLINK-28664
URL: https://issues.apache.org/jira/browse/FLINK-28664
Project: Flink
Issue Type: New Feature
Yingjie Cao created FLINK-28663:
---
Summary: Allow multiple downstream consumer job vertices sharing
the same intermediate dataset at scheduler side
Key: FLINK-28663
URL:
Hi everybody,
I discussed last week the semantics and an implementation stragegy of the
configuration parameter with Piotr and did the implementation and some
tests this weekend.
A short summary of what I discussed and recapped with Piotr:
- The configuration parameter allows (and tolerates)
36 matches
Mail list logo
