Thank you Jincheng for the release!
+1 (non-binding)
- Release notes are correct.
- Built from source archive successfully.
- Signatures and hash are correct.
- All artifacts(11 artifacts including flink-shaded) have been deployed to
the maven central repository.
One minor comment for the
Kazunori Shinhira created FLINK-12586:
-
Summary: Stderr and stdout are reversed in OptimizerPlanEnvironment
Key: FLINK-12586
URL: https://issues.apache.org/jira/browse/FLINK-12586
Project: Flink
sunjincheng created FLINK-12585:
---
Summary: Align Stream/BatchTableEnvironment with JAVA Table API
Key: FLINK-12585
URL: https://issues.apache.org/jira/browse/FLINK-12585
Project: Flink
Issue
zhangjun created FLINK-12584:
Summary: Add Bucket File Syetem Table Sink
Key: FLINK-12584
URL: https://issues.apache.org/jira/browse/FLINK-12584
Project: Flink
Issue Type: New Feature
Hi,
I want to contribute to Apache Flink.
Would you please give me the contributor permission?
My Jira ID is habren
Thanks & Best Regards,
Jason
Question regarding end-to-end exactly once guarantee implementation using
2PC?
As I understand how it operates, the pre-phase state is when the checkpoint
is initiated and the checkpoint barrier advances from source to sink. Once
the pre-phase is complete (and successful), then the next step in
sunjincheng created FLINK-12583:
---
Summary: Add all format support align with the Java Table API
Key: FLINK-12583
URL: https://issues.apache.org/jira/browse/FLINK-12583
Project: Flink
Issue
Bowen Li created FLINK-12582:
Summary: Alterations in GenericInMemoryCatalog should check
existing object and new object are of the same class
Key: FLINK-12582
URL: https://issues.apache.org/jira/browse/FLINK-12582
Bowen Li created FLINK-12581:
Summary: HiveCatalog.alterTable() and alterDatabase() should check
the existing object and new object are of same type
Key: FLINK-12581
URL:
Bowen Li created FLINK-12580:
Summary: Rename GenericHiveMetastoreCatalogTest to
HiveCatalogFlinkMetadataTest, and HiveCatalogTest to HiveCatalogHiveMetadataTest
Key: FLINK-12580
URL:
Theo Diefenthal created FLINK-12579:
---
Summary: Influx Metric exporter throws a lot of negative infinity
errors
Key: FLINK-12579
URL: https://issues.apache.org/jira/browse/FLINK-12579
Project: Flink
Jungtaek Lim created FLINK-12578:
Summary: Use secure URLs for Maven repositories
Key: FLINK-12578
URL: https://issues.apache.org/jira/browse/FLINK-12578
Project: Flink
Issue Type:
Nico Kruber created FLINK-12577:
---
Summary: Flink uses Kryo serializer if given a SpecificRecord type
Key: FLINK-12577
URL: https://issues.apache.org/jira/browse/FLINK-12577
Project: Flink
Hi,
I want to contribute to Apache Flink.
Would you please give me the contributor permission?
My JIRA ID is lujisen.
祝工作顺利，身体健康！
*
陆继森
手 机：18560768631
E-Mail：luj...@126.com
*
Yes, this is our conclusion. I'd like to add only one point that
registering user defined aggregator is also needed which is currently
provided by 'bridge' and finally will be merged into Table API. It's same
with collect().
I will add a TableEnvironment argument in Estimator.fit() and
Piotr Nowojski created FLINK-12576:
--
Summary: inputQueueLength metric does not work for
LocalInputChannels
Key: FLINK-12576
URL: https://issues.apache.org/jira/browse/FLINK-12576
Project: Flink
godfrey he created FLINK-12575:
--
Summary: Introduce planner rules to remove redundant shuffle and
collation
Key: FLINK-12575
URL: https://issues.apache.org/jira/browse/FLINK-12575
Project: Flink
We discussed this in private and came to the conclusion that we should (for
now) have the dependency on flink-table-api-xxx-bridge because we need access
to the collect() method, which is not yet available in the Table API. Once that
is available the code can be refactored but for now we want
yitzchak lieberman created FLINK-12574:
--
Summary: using sink StreamingFileSink files are overwritten when
resuming application causing data loss
Key: FLINK-12574
URL:
yitzchak lieberman created FLINK-12573:
--
Summary: ability to add suffix to part file created in Bucket
(StreamingFileSink)
Key: FLINK-12573
URL: https://issues.apache.org/jira/browse/FLINK-12573
zjuwangg created FLINK-12572:
Summary: Implement TableSource and InputFormat to read Hive tables
Key: FLINK-12572
URL: https://issues.apache.org/jira/browse/FLINK-12572
Project: Flink
Issue
zhijiang created FLINK-12571:
Summary: Make NetworkEnvironment#start() return the binded data
port
Key: FLINK-12571
URL: https://issues.apache.org/jira/browse/FLINK-12571
Project: Flink
Issue
Andrey Zagrebin created FLINK-12570:
---
Summary: Switch Task from ResultPartition to ResultPartitionWriter
interface
Key: FLINK-12570
URL: https://issues.apache.org/jira/browse/FLINK-12570
Project:
Ankit Chaudhary created FLINK-12569:
---
Summary: Broken/Outdated docker/build.sh for flink 1.8.0
Key: FLINK-12569
URL: https://issues.apache.org/jira/browse/FLINK-12569
Project: Flink
Issue
Rui Li created FLINK-12568:
--
Summary: Implement TableSink and OutputFormat to write Hive tables
Key: FLINK-12568
URL: https://issues.apache.org/jira/browse/FLINK-12568
Project: Flink
Issue Type:
Danny Chan created FLINK-12567:
--
Summary: Rework DescriptorProperties to adapt unified DDL with
clause and Descriptor key value pairs
Key: FLINK-12567
URL: https://issues.apache.org/jira/browse/FLINK-12567
Timo Walther created FLINK-12566:
Summary: Remove row interval type
Key: FLINK-12566
URL: https://issues.apache.org/jira/browse/FLINK-12566
Project: Flink
Issue Type: Sub-task
27 matches
Mail list logo
