Dian Fu created FLINK-19654:
---
Summary: Improve the execution time of PyFlink end-to-end tests
Key: FLINK-19654
URL: https://issues.apache.org/jira/browse/FLINK-19654
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-19653:
---
Summary: HiveCatalogITCase fails on azure
Key: FLINK-19653
URL: https://issues.apache.org/jira/browse/FLINK-19653
Project: Flink
Issue Type: Improvement
Qingsheng Ren created FLINK-19652:
-
Summary: Support pure string format for Kafka table connector
Key: FLINK-19652
URL: https://issues.apache.org/jira/browse/FLINK-19652
Project: Flink
Issue
Shengkai Fang created FLINK-19651:
-
Summary: Support filter push down for the Jdbc connector
Key: FLINK-19651
URL: https://issues.apache.org/jira/browse/FLINK-19651
Project: Flink
Issue
Shengkai Fang created FLINK-19650:
-
Summary: Support the limit push down for the Jdbc connector
Key: FLINK-19650
URL: https://issues.apache.org/jira/browse/FLINK-19650
Project: Flink
Issue
gsralex created FLINK-19649:
---
Summary: In Flink's module
flink-sql-parser/sqlCreateTable/unparse, the tables without columns are not
supported.
Key: FLINK-19649
URL: https://issues.apache.org/jira/browse/FLINK-19649
Shengkai Fang created FLINK-19648:
-
Summary: Support nested projection push down for hbase connector
Key: FLINK-19648
URL: https://issues.apache.org/jira/browse/FLINK-19648
Project: Flink
Shengkai Fang created FLINK-19647:
-
Summary: Support limit push down for hbase connector
Key: FLINK-19647
URL: https://issues.apache.org/jira/browse/FLINK-19647
Project: Flink
Issue Type:
Hi devs,
Currently, Flink adopts a hash-style blocking shuffle implementation which
writes data sent to different reducer tasks into separate files
concurrently. Compared to sort-merge based approach writes those data
together into a single file and merges those small files into bigger ones,
Hi,
Thanks for bringing this discussion.
I think limiting the key type to Long can't resolve the comparison problem,
because the bytes order and value order of negative numbers is different.
Unless, we limit the key type to positive Long. But how to check this
before submitting a job?
In Blink
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
Dian Fu created FLINK-19645:
---
Summary:
ShuffleCompressionITCase.testDataCompressionForBlockingShuffle is instable
Key: FLINK-19645
URL: https://issues.apache.org/jira/browse/FLINK-19645
Project: Flink
Thanks for the reply! Look forward to learning more about this prototype.
Is there any way that we could track this TemporalState like Jira issue? or
should we start to create one in Jira? so anyone has interest like me,
could be part of the loop. Besides, is there any written docs/code about
the
I'm very interested in this topic, and have even done some prototyping of
solution 1 -- limiting the key type to Long -- which Nico Kruber and I
called TemporalState in our prototype.
I look forward to sharing what we learned, and to discussing this further,
but I am completely overwhelmed with
Hi Chesnay/Team
Thank you so much.I have tried with the solution but it is not working as
expected showing compilation issues and tried all the ways .Please find
below code snippet :
s3PathList.stream()
.map(directory -> S3Service.customCreateInputStream(environment, directory,
Leonard Xu created FLINK-19644:
--
Summary: Support read specific partition of Hive table in temporal
join
Key: FLINK-19644
URL: https://issues.apache.org/jira/browse/FLINK-19644
Project: Flink
Huang Xingbo created FLINK-19643:
Summary: Add Pandas UDAF Doc
Key: FLINK-19643
URL: https://issues.apache.org/jira/browse/FLINK-19643
Project: Flink
Issue Type: Sub-task
Dian Fu created FLINK-19642:
---
Summary: RocksDBListStatePerformanceTest.testRocksDbListStateAPIs
is instable
Key: FLINK-19642
URL: https://issues.apache.org/jira/browse/FLINK-19642
Project: Flink
Caizhi Weng created FLINK-19641:
---
Summary: Optimize parallelism calculating of HiveTableSource by
checking file number
Key: FLINK-19641
URL: https://issues.apache.org/jira/browse/FLINK-19641
Project:
Dawid Wysakowicz created FLINK-19640:
Summary: Expose to users the batch-style execution for bounded
keyed streams
Key: FLINK-19640
URL: https://issues.apache.org/jira/browse/FLINK-19640
Project:
Shengkai Fang created FLINK-19639:
-
Summary: Support SupportsNestedProjectionPushDown in planner
Key: FLINK-19639
URL: https://issues.apache.org/jira/browse/FLINK-19639
Project: Flink
Issue
shizhengchao created FLINK-19638:
Summary: AvroUnionLogicalSerializerTest class compile error
Key: FLINK-19638
URL: https://issues.apache.org/jira/browse/FLINK-19638
Project: Flink
Issue
Chesnay Schepler created FLINK-19637:
Summary: Remove AllocationIdsExposingResourceManagerGateway
Key: FLINK-19637
URL: https://issues.apache.org/jira/browse/FLINK-19637
Project: Flink
Agreed!
Aljoscha
On 14.10.20 06:38, Jingsong Li wrote:
Hi Aljoscha,
Thanks for your feedback.
Yes, we should add DataStream Providers to the table bridge module.
I think your concerns are right, including the relationship between
DataStream and table.
My understanding is that the
Chesnay Schepler created FLINK-19636:
Summary: Add declarative SlotPool
Key: FLINK-19636
URL: https://issues.apache.org/jira/browse/FLINK-19636
Project: Flink
Issue Type: Task
Hi devs,
Current DataStream API doesn't have SortedMapState supported. There are
lots of use cases based on sorted time-series data like range-query or
higher/lower key fetch, and ordered data seems like a nature of time-series
stream processing. Therefore, we propose to support the
Hi Till,
Very thanks for the feedbacks !
> 1) When restarting all tasks independent of the status at checkpoint time
> (finished, running, scheduled), we might allocate more resources than we
> actually need to run the remaining job. From a scheduling perspective it
> would be easier if we
Robert Metzger created FLINK-19635:
--
Summary: HBaseConnectorITCase.testTableSourceSinkWithDDL is
unstable with a result mismatch
Key: FLINK-19635
URL: https://issues.apache.org/jira/browse/FLINK-19635
appleyuchi created FLINK-19634:
--
Summary: Official Flink visualizer display bug
Key: FLINK-19634
URL: https://issues.apache.org/jira/browse/FLINK-19634
Project: Flink
Issue Type: Bug
I remember this conversation popping up a few times already and I'm in
general a big fan of removing BucketingSink.
However, until now there were a few features lacking in StreamingFileSink
that are present in BucketingSink and that are being actively used (I can't
exactly remember them now, but
dalongliu created FLINK-19633:
-
Summary: Fix ArrayIndexOutOfBoundsException in
RetractableTopNFunction
Key: FLINK-19633
URL: https://issues.apache.org/jira/browse/FLINK-19633
Project: Flink
31 matches
Mail list logo