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: Sub
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
Compo
vinoyang created FLINK-12565:
Summary: PythonStreamBinderTest#testProgram test failer
Key: FLINK-12565
URL: https://issues.apache.org/jira/browse/FLINK-12565
Project: Flink
Issue Type: Bug
Hi Till,
Thanks for the background.
It seems that we cannot always rely on the user code to not cause leaks and
that can wreak havoc even when everything in Flink works as expected (user
code managed threads may not terminate, class loader GC may not work due to
references in the parent class loa
zhijiang created FLINK-12564:
Summary: Remove getBufferProvider method from
ResultPartitionWriter interface
Key: FLINK-12564
URL: https://issues.apache.org/jira/browse/FLINK-12564
Project: Flink
Jingsong Lee created FLINK-12563:
Summary: Introduce vector data format in blink
Key: FLINK-12563
URL: https://issues.apache.org/jira/browse/FLINK-12563
Project: Flink
Issue Type: Improvement
Hi,
I want to contribute to Apache Flink.
Would you please give me the contributor permission?
My JIRA ID is zxhe.
My JIRA Fullname is ZeXiong.
Thanks for all you discussions Timo, Jark Wu, Lin Li, Fabian
I have fired a new design doc in [1] which reorganized from the MVP doc[2] and
the initial doc[3] that both proposed by Shuyi Chen.
The main diff is that i extend the create table DDL to support complex sql type
(array, map and struct
Hequn Cheng created FLINK-12562:
---
Summary: Improve code in ExpandColumnFunctionsRule
Key: FLINK-12562
URL: https://issues.apache.org/jira/browse/FLINK-12562
Project: Flink
Issue Type: Improveme
Hi all,
following our unsuccessful application to Season of Docs Fabian, Seth,
Stephan and myself have drafted a FLIP for reworking our documentation and
implementing some (or most) of the changes, we would have liked to tackle
in SoD.
The overarching goals of the FLIP are:
* Top-level structure
Hi Greater Seattle folks!
We are hosting our next meetup with AWS Kinesis Analytics team on May 30
next Thursday in downtown Seattle.
We feature two talks this time:
1. *"AWS Kinesis Analytics: running Flink serverless in multi-tenant
environment"* by Kinesis Analytics team on:
- How
Ramesh Srinivasalu created FLINK-12561:
--
Summary: Unable to insert into cassandra table using FileWordCount
example using Remote Cassandra Host with credentials
Key: FLINK-12561
URL: https://issues.apache.org
Seth Wiesman created FLINK-12560:
Summary: Documentation language build flags
Key: FLINK-12560
URL: https://issues.apache.org/jira/browse/FLINK-12560
Project: Flink
Issue Type: Sub-task
Thanks for the update, Robert!
I am planning to prepare a use case content with how we use Flink at
MotaWord, focusing more on Flink as "application framework", rather than
confining our mindset to Flink as "stream processor", on non-Uber,
non-Alibaba scales. Hopefully over the weekend, I should b
godfrey he created FLINK-12559:
--
Summary: Introduce metadata handlers on window aggregate
Key: FLINK-12559
URL: https://issues.apache.org/jira/browse/FLINK-12559
Project: Flink
Issue Type: New F
Hi XiangWei,
Thank you for the inputs. I agree with you that it is possible that
containers may use extra memory in 1.8. As for native memory, it is memory
used by JVM and other processes outside JVM. So it's not limited by
MaxDirectMemorySize.
The community is working on a refactoring plan about
lamber-ken created FLINK-12558:
--
Summary: Yarn application can't stop when flink job finished
Key: FLINK-12558
URL: https://issues.apache.org/jira/browse/FLINK-12558
Project: Flink
Issue Type: B
Danny Chan created FLINK-12557:
--
Summary: Unify create table DDL with clause and connector
descriptor keys
Key: FLINK-12557
URL: https://issues.apache.org/jira/browse/FLINK-12557
Project: Flink
Alex created FLINK-12556:
Summary: Extend some end-to-end tests to run with custom (input)
File System implementation
Key: FLINK-12556
URL: https://issues.apache.org/jira/browse/FLINK-12556
Project: Flink
Andrey Zagrebin created FLINK-12555:
---
Summary: Introduce an incapsulated metric group layout for shuffle
API and deprecate old one
Key: FLINK-12555
URL: https://issues.apache.org/jira/browse/FLINK-12555
Hi,
> Concrete operator implementations will then go into the "API / DataStream"?
> (or "API / DataSet" or Table)
> Afaik, there were some ideas to share operator implementations between
> DataStream and Table
Yes & yes. I think for now we could keep the concrete operators implementations
under
Hi all,
Currently i am running my flink application in yarn session mode and
using below commnad :
*bin/yarn-session.sh -d -s 3 -jm 1024 -tm 4096*
when taskmanager complete to started,i found the container launching
command is :
* bin/java -Xms2765m -Xmx2765m -XX:MaxDirectMemorySize=1331m .
Rui Li created FLINK-12554:
--
Summary: Create TableFactory for Hive connector
Key: FLINK-12554
URL: https://issues.apache.org/jira/browse/FLINK-12554
Project: Flink
Issue Type: Sub-task
Com
Liya Fan created FLINK-12553:
Summary: Fix a bug in SqlDateTimeUtils#parseToTimeMillis
Key: FLINK-12553
URL: https://issues.apache.org/jira/browse/FLINK-12553
Project: Flink
Issue Type: Bug
25 matches
Mail list logo
