Robert Metzger created FLINK-17592:
--
Summary: flink-table-planner doesn't compile on Scala 2.12
Key: FLINK-17592
URL: https://issues.apache.org/jira/browse/FLINK-17592
Project: Flink
Issue T
Jark Wu created FLINK-17591:
---
Summary: TableEnvironmentITCase.testExecuteSqlAndToDataStream
failed
Key: FLINK-17591
URL: https://issues.apache.org/jira/browse/FLINK-17591
Project: Flink
Issue Type
Yun Gao created FLINK-17590:
---
Summary: Add Bucket lifecycle listener to support acquiring bucket
state
Key: FLINK-17590
URL: https://issues.apache.org/jira/browse/FLINK-17590
Project: Flink
Issue
Yun Gao created FLINK-17589:
---
Summary: Extend StreamingFileSink to Support Streaming Hive
Connector
Key: FLINK-17589
URL: https://issues.apache.org/jira/browse/FLINK-17589
Project: Flink
Issue Typ
Thanks for the RC!
+1 (binding)
- repeated benchmark runs
On Fri, May 8, 2020 at 10:52 AM Robert Metzger wrote:
> Thanks a lot for creating another RC!
>
> +1 (binding)
>
> - checked diff to last RC:
>
> https://github.com/apache/flink/compare/release-1.10.1-rc2...release-1.10.1-rc3
> - kin
Jeff Zhang created FLINK-17588:
--
Summary: Throw exception when hadoop jar is missing in flink
scala's yarn mode.
Key: FLINK-17588
URL: https://issues.apache.org/jira/browse/FLINK-17588
Project: Flink
Jingsong Lee created FLINK-17587:
Summary: Filesystem streaming sink support partition commit
(success file)
Key: FLINK-17587
URL: https://issues.apache.org/jira/browse/FLINK-17587
Project: Flink
Wei Zhong created FLINK-17586:
-
Summary: Due to the new behavior of the table planner the Python
dependency management command line options does not work
Key: FLINK-17586
URL: https://issues.apache.org/jira/browse/FL
Wei Zhong created FLINK-17585:
-
Summary: "PythonProgramOptions" changes the entry point class when
user submit a Java sql job which contains Python UDF
Key: FLINK-17585
URL: https://issues.apache.org/jira/browse/FLIN
Hi Maowei,
Welcome to the community! Currently, there are no special permissions
required to contribute to Flink. Just ping a committer if you want to
work on some JIRA ticket and someone will assign the ticket to you.
Here is some information about how to contribute to Flink [1].
[1] https://fl
Hi Guys, I want to contribute to Apache Flink. Would you please give me the
permission as a contributor? My JIRA ID is limaowei66.
All tables being described by Flink's DDL are dynamic tables. But dynamic
table is more like a logical concept, but not physical things.
Physically, dynamic table has two different forms, one is a materialized
table which changes over time (e.g. Database table, HBase table),
another form is stream
Yaron Shani created FLINK-17584:
---
Summary: disableAutoTypeRegistration option does not work with
Streaming API, only with Batch
Key: FLINK-17584
URL: https://issues.apache.org/jira/browse/FLINK-17584
Pr
I think we need the TEMPORAL TABLE syntax because they are conceptually
more than just regular tables.
In a addition to being a table that always holds the latest values (and can
thereby serve as input to a continuous query), the system also needs to
track the history of such a table to be able to
Steve Bairos created FLINK-17583:
Summary: Allow option to store a savepoint's _metadata file
separate from its data files
Key: FLINK-17583
URL: https://issues.apache.org/jira/browse/FLINK-17583
Proje
Seth Wiesman created FLINK-17582:
Summary: Update quickstarts to use universal Kafka connector
Key: FLINK-17582
URL: https://issues.apache.org/jira/browse/FLINK-17582
Project: Flink
Issue Typ
Thanks a lot for creating another RC!
+1 (binding)
- checked diff to last RC:
https://github.com/apache/flink/compare/release-1.10.1-rc2...release-1.10.1-rc3
- kinesis dependency change is properly documented
- started Flink locally (on Java11 :) )
- seems to be build off the specified commi
Robert Metzger created FLINK-17581:
--
Summary: Update translation of S3 documentation
Key: FLINK-17581
URL: https://issues.apache.org/jira/browse/FLINK-17581
Project: Flink
Issue Type: Task
Arvid Heise created FLINK-17580:
---
Summary: NPE in unaligned checkpoint for EndOfPartition events
Key: FLINK-17580
URL: https://issues.apache.org/jira/browse/FLINK-17580
Project: Flink
Issue Typ
+dev
Best,
Kurt
On Fri, May 8, 2020 at 3:35 PM Caizhi Weng wrote:
> Hi Jeff,
>
> Thanks for the response. However I'm using executeAsync so that I can run
> the job asynchronously and get a JobClient to monitor the job. JobListener
> only works for synchronous execute method. Is there other w
Yangze Guo created FLINK-17579:
--
Summary: Set the resource id of taskexecutor from environment
variable if possible in standalone mode
Key: FLINK-17579
URL: https://issues.apache.org/jira/browse/FLINK-17579
Hi LakeShen
You could refer to [1] and [2] to know the temporary directory in YARN, the
related log could be
"Setting directories for temporary files to: " or "Overriding Fink's temporary
file directories with those specified in the Flink config: "
[1]
https://github.com/apache/flink/blob/0dd
Tom Wells created FLINK-17578:
-
Summary: Union of 2 SideOutputs behaviour incorrect
Key: FLINK-17578
URL: https://issues.apache.org/jira/browse/FLINK-17578
Project: Flink
Issue Type: Bug
Danny Chen created FLINK-17577:
--
Summary: SinkFormat#createSinkFormat should use
DynamicTableSink.Context as the first parameter
Key: FLINK-17577
URL: https://issues.apache.org/jira/browse/FLINK-17577
Pr
Dian Fu created FLINK-17576:
---
Summary: HiveTableSinkTest and TableEnvHiveConnectorTest are
instable
Key: FLINK-17576
URL: https://issues.apache.org/jira/browse/FLINK-17576
Project: Flink
Issue Typ
Maxim Malykhin created FLINK-17575:
--
Summary: KafkaException: Received exception when fetching the next
record from XXX-14. If needed, please seek past the record to continue
consumption.
Key: FLINK-17575
URL: h
Yangze Guo created FLINK-17574:
--
Summary: Deduplicate the process execution logic in Flink
Key: FLINK-17574
URL: https://issues.apache.org/jira/browse/FLINK-17574
Project: Flink
Issue Type: Impr
Tammy zhang created FLINK-17573:
---
Summary: There is duplicate source data in ProcessWindowFunction
Key: FLINK-17573
URL: https://issues.apache.org/jira/browse/FLINK-17573
Project: Flink
Issue T
Yingjie Cao created FLINK-17572:
---
Summary: Remove checkpoint alignment buffered metric from webui
Key: FLINK-17572
URL: https://issues.apache.org/jira/browse/FLINK-17572
Project: Flink
Issue Ty
Congxian Qiu(klion26) created FLINK-17571:
-
Summary: A better way to show the files used in currently
checkpoints
Key: FLINK-17571
URL: https://issues.apache.org/jira/browse/FLINK-17571
Projec
Wei Zhong created FLINK-17570:
-
Summary: BatchTableEnvironment#fromValues(Object... values) causes
StackOverflowError
Key: FLINK-17570
URL: https://issues.apache.org/jira/browse/FLINK-17570
Project: Flin
konwu created FLINK-17569:
-
Summary: to support ViewFileSystem when wait lease revoke of
hadoop filesystem
Key: FLINK-17569
URL: https://issues.apache.org/jira/browse/FLINK-17569
Project: Flink
Issu
Yingjie Cao created FLINK-17568:
---
Summary: Task may consume data after checkpoint barrier before
performing checkpoint for unaligned checkpoint
Key: FLINK-17568
URL: https://issues.apache.org/jira/browse/FLINK-17568
Huang Xingbo created FLINK-17567:
Summary: Create a dedicated Python directory in release directory
to place Python-related source and binary packages
Key: FLINK-17567
URL: https://issues.apache.org/jira/browse/FL
34 matches
Mail list logo
