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 websit
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 Ty
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
C
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 t
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 Type
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: https://issues.apache.org/jira/browse/FLINK-12
Bowen Li created FLINK-12580:
Summary: Rename GenericHiveMetastoreCatalogTest to
HiveCatalogFlinkMetadataTest, and HiveCatalogTest to HiveCatalogHiveMetadataTest
Key: FLINK-12580
URL: https://issues.apache.org/jira/br
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: Improvemen
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
Issue
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
Transformer
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 to
yitzchak lieberman created FLINK-12574:
--
Summary: using sink StreamingFileSink files are overwritten when
resuming application causing data loss
Key: FLINK-12574
URL: https://issues.apache.org/jira/browse/FLI
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 Type:
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 Ty
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: Fl
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 T
24 matches
Mail list logo
