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
Comp
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 Type:
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 Ty
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
Iss
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: New
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,
hash-
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 c
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:
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 p
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 Fl
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,
readerParallelism)
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
I
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
Components
Dian Fu created FLINK-19642:
---
Summary: RocksDBListStatePerformanceTest.testRocksDbListStateAPIs
is instable
Key: FLINK-19642
URL: https://issues.apache.org/jira/browse/FLINK-19642
Project: Flink
I
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: Fl
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 T
shizhengchao created FLINK-19638:
Summary: AvroUnionLogicalSerializerTest class compile error
Key: FLINK-19638
URL: https://issues.apache.org/jira/browse/FLINK-19638
Project: Flink
Issue Type
Chesnay Schepler created FLINK-19637:
Summary: Remove AllocationIdsExposingResourceManagerGateway
Key: FLINK-19637
URL: https://issues.apache.org/jira/browse/FLINK-19637
Project: Flink
Is
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 parallelism
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
C
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 KeyedSortedMap
26 matches
Mail list logo
