Danny Chen created FLINK-18029:
--
Summary: Add more ITCases for Kafka with new formats
Key: FLINK-18029
URL: https://issues.apache.org/jira/browse/FLINK-18029
Project: Flink
Issue Type: Sub-task
Danny Chen created FLINK-18028:
--
Summary: E2E tests manually for Kafka 2 all kinds of other
connectors
Key: FLINK-18028
URL: https://issues.apache.org/jira/browse/FLINK-18028
Project: Flink
Iss
Benchao Li created FLINK-18027:
--
Summary: ROW value constructor cannot deal with complex expressions
Key: FLINK-18027
URL: https://issues.apache.org/jira/browse/FLINK-18027
Project: Flink
Issue
Danny Chen created FLINK-18026:
--
Summary: E2E tests manually for new SQL connectors and formats
Key: FLINK-18026
URL: https://issues.apache.org/jira/browse/FLINK-18026
Project: Flink
Issue Type:
Danny Chen created FLINK-18025:
--
Summary: E2E tests manually for Hive integrate streaming
Key: FLINK-18025
URL: https://issues.apache.org/jira/browse/FLINK-18025
Project: Flink
Issue Type: Sub-t
Danny Chen created FLINK-18024:
--
Summary: E2E tests manually for new Hive dependency jars
Key: FLINK-18024
URL: https://issues.apache.org/jira/browse/FLINK-18024
Project: Flink
Issue Type: Sub-t
Hi, Kartheek.
To subscribe, please send an e-mail to dev-subscr...@flink.apache.org. If
you have any questions, you can find more detailed instructions in [1].
Marta
[1]
https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list
On Fri, 29 May 2020 at 08:38, kartheek annamaneni
Danny Chen created FLINK-18023:
--
Summary: E2E tests manually for new filesystem connector
Key: FLINK-18023
URL: https://issues.apache.org/jira/browse/FLINK-18023
Project: Flink
Issue Type: Sub-t
Hi Kartheek,
Please mailto dev-subscr...@flink.apache.org with any content. The robot
will guide you to subscribe this mailing list.
See also this page
https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list
Best,
tison.
kartheek annamaneni 于2020年5月29日周五 下午2:38写道：
> Hi,
>
send email to dev-subscr...@flink.apache.org
--
发件人：kartheek annamaneni
发送时间：2020年5月29日(星期五) 14:38
收件人：dev
主 题：Subscription mail
Hi,
How can I subscribe to this?
Danny Chen created FLINK-18022:
--
Summary: Add e2e test for new streaming file sink
Key: FLINK-18022
URL: https://issues.apache.org/jira/browse/FLINK-18022
Project: Flink
Issue Type: Sub-task
Hi,
How can I subscribe to this?
Danny Chen created FLINK-18021:
--
Summary: Complement tests for 1.11 SQL
Key: FLINK-18021
URL: https://issues.apache.org/jira/browse/FLINK-18021
Project: Flink
Issue Type: Task
Componen
Dawid Wysakowicz created FLINK-18020:
Summary: SQLClientKafkaITCase.testKafka failed on Travis
Key: FLINK-18020
URL: https://issues.apache.org/jira/browse/FLINK-18020
Project: Flink
Issue
Dian Fu created FLINK-18019:
---
Summary: The configuration specified in TableConfig may not take
effect
Key: FLINK-18019
URL: https://issues.apache.org/jira/browse/FLINK-18019
Project: Flink
Issue T
Yangze Guo created FLINK-18018:
--
Summary: Bundle GPU plugin in "plugins/" directory
Key: FLINK-18018
URL: https://issues.apache.org/jira/browse/FLINK-18018
Project: Flink
Issue Type: Improvement
Yu Yang created FLINK-18017:
---
Summary: improve Kafka connector to handle record deserialization
exception and report related metrics
Key: FLINK-18017
URL: https://issues.apache.org/jira/browse/FLINK-18017
P
Thank you for driving this release Gordon!
We are still missing documentation for state ttl and unix sockets. This
doesn't need to block release testing, but it would be nice to get this
done before 2.1 is released.
Seth
https://issues.apache.org/jira/browse/FLINK-18015
https://issues.apache.org
Seth Wiesman created FLINK-18016:
Summary: Document Unix Socket Remote Functions
Key: FLINK-18016
URL: https://issues.apache.org/jira/browse/FLINK-18016
Project: Flink
Issue Type: Improvement
Seth Wiesman created FLINK-18015:
Summary: Document State TTL
Key: FLINK-18015
URL: https://issues.apache.org/jira/browse/FLINK-18015
Project: Flink
Issue Type: Improvement
Compone
Thanks Till.
I will take a look at that tomorrow and let you know if I hit any
roadblocks.
On Thu, May 28, 2020 at 12:11 PM Till Rohrmann wrote:
> I think what needs to be done is to implement
> a org.apache.flink.core.fs.RecoverableWriter for the respective file
> system. Similar to HadoopReco
David Anderson created FLINK-18014:
--
Summary: JSONDeserializationSchema: removed in Flink 1.8, but
still in the docs
Key: FLINK-18014
URL: https://issues.apache.org/jira/browse/FLINK-18014
Project: F
+1 (non-binding)
Checked issues listed in release notes: ok (*)
- Add shaded-11.0 as fixed version for FLINK-17513
- Minor: FLINK-16454 is listed in the release note but found no changes in
commit history
Checked sums and signatures: ok
Checked the maven central artifices: ok
Built from source: ok
+1 (binding)
- verified checksums and signature
- mvn clean verify passes on source release
- verified licenses
- checked pom.xml changes
Cheers,
Till
On Thu, May 28, 2020 at 1:05 PM Congxian Qiu wrote:
> +1 (non-binding)
>
> checked
> - mvn clean verify, ok
> - gpg & sha512, ok
> - all pom fi
I think what needs to be done is to implement
a org.apache.flink.core.fs.RecoverableWriter for the respective file
system. Similar to HadoopRecoverableWriter and S3RecoverableWriter.
Cheers,
Till
On Thu, May 28, 2020 at 6:00 PM Israel Ekpo wrote:
> Hi Till,
>
> Thanks for your feedback and guid
Hi Till,
Thanks for your feedback and guidance.
It seems similar work was done for S3 filesystem where relocations were
removed for those file system plugins.
https://issues.apache.org/jira/browse/FLINK-11956
It appears the same needs to be done for Azure File systems.
I will attempt to connec
+1
I'm in favour of backporting this because we otherwise would immediately
break the API between 1.11 and 1.12.
Best,
Aljoscha
On 26.05.20 17:05, Zhijiang wrote:
In the beginning, I have somehow similar concerns as Piotr mentioned below.
After some offline discussions, also as explained by
Hi Israel,
thanks for reaching out to the Flink community. As Guowei said, the
StreamingFileSink can currently only recover from faults if it writes to
HDFS or S3. Other file systems are currently not supported if you need
fault tolerance.
Maybe Klou can tell you more about the background and wha
Sivaprasanna Sethuraman created FLINK-18013:
---
Summary: Refactor Hadoop Utility classes/functions into a common
Maven module
Key: FLINK-18013
URL: https://issues.apache.org/jira/browse/FLINK-18013
FYI.
I created a Jira to track this improvement.
https://issues.apache.org/jira/browse/FLINK-18013
-
Sivaprasanna
On Thu, May 28, 2020 at 12:22 PM Sivaprasanna
wrote:
> Awesome. : )
> Thanks, Robert for signing up to be the reviewer. I will create Jira and
> share the link here.
>
> Stay safe.
Guowei,
What do we need to do to add support for it?
How do I get started on that?
On Wed, May 27, 2020 at 8:53 PM Guowei Ma wrote:
> Hi,
> I think the StreamingFileSink could not support Azure currently.
> You could find more detailed info from here[1].
>
> [1] https://issues.apache.org/jir
Till Rohrmann created FLINK-18012:
-
Summary: Deactivate slot timeout if
TaskSlotTable.tryMarkSlotActive is called
Key: FLINK-18012
URL: https://issues.apache.org/jira/browse/FLINK-18012
Project: Flink
Aljoscha Krettek created FLINK-18011:
Summary: Make WatermarkStrategy/WatermarkStrategies more ergonomic
Key: FLINK-18011
URL: https://issues.apache.org/jira/browse/FLINK-18011
Project: Flink
Chesnay Schepler created FLINK-18010:
Summary: Add more logging to HistoryServer
Key: FLINK-18010
URL: https://issues.apache.org/jira/browse/FLINK-18010
Project: Flink
Issue Type: Improve
Rui Li created FLINK-18009:
--
Summary: Select an invalid column crashes the SQL CLI
Key: FLINK-18009
URL: https://issues.apache.org/jira/browse/FLINK-18009
Project: Flink
Issue Type: Bug
Co
Chesnay Schepler created FLINK-18008:
Summary: HistoryServer does not log environment information on
startup
Key: FLINK-18008
URL: https://issues.apache.org/jira/browse/FLINK-18008
Project: Flink
Yubin Li created FLINK-18007:
Summary: Translate "Joins in Continuous Queries" page of
"Streaming Concepts" into Chinese
Key: FLINK-18007
URL: https://issues.apache.org/jira/browse/FLINK-18007
Project: Fl
Shengkai Fang created FLINK-18006:
-
Summary: It will throw Invalid lambda deserialization Exception
when writing to elastic search with new format
Key: FLINK-18006
URL: https://issues.apache.org/jira/browse/FLINK-
Timo Walther created FLINK-18005:
Summary: Implement type inference for CAST
Key: FLINK-18005
URL: https://issues.apache.org/jira/browse/FLINK-18005
Project: Flink
Issue Type: Sub-task
Hi all,
Following the consensus to do the next feature release for Flink Stateful
Functions,
we've finished all the planned features and have cut the feature branch:
https://github.com/apache/flink-statefun/tree/release-2.1
This time, we've added quite a bit more coverage for typical
functional t
Yun Tang created FLINK-18004:
Summary: Update checkpoint UI related pictures in documentation
Key: FLINK-18004
URL: https://issues.apache.org/jira/browse/FLINK-18004
Project: Flink
Issue Type: Bu
hailong wang created FLINK-18003:
Summary: Table hints support multi Options
Key: FLINK-18003
URL: https://issues.apache.org/jira/browse/FLINK-18003
Project: Flink
Issue Type: Improvement
Benchao Li created FLINK-18002:
--
Summary: Support forcing varchar type in Json format
Key: FLINK-18002
URL: https://issues.apache.org/jira/browse/FLINK-18002
Project: Flink
Issue Type: Improveme
+1 (non-binding)
checked
- mvn clean verify, ok
- gpg & sha512, ok
- all pom files point to the same version, ok
- checked license, ok
Best,
Congxian
Robert Metzger 于2020年5月27日周三 下午6:05写道：
> +1 (binding)
>
> Checks:
> - diff to flink-shaded 1.10:
>
> https://github.com/apache/flink-shaded/com
Timo Walther created FLINK-18001:
Summary: Add a new test base for evaluating expressions
Key: FLINK-18001
URL: https://issues.apache.org/jira/browse/FLINK-18001
Project: Flink
Issue Type: Su
Max created FLINK-18000:
---
Summary: Flink-job-manger Get a X509 error, when I try to delpoy
flink on kubelet 1.18.2
Key: FLINK-18000
URL: https://issues.apache.org/jira/browse/FLINK-18000
Project: Flink
Yubin Li created FLINK-17999:
Summary: Translate "Query Configuration" page of "Streaming
Concepts" into Chinese
Key: FLINK-17999
URL: https://issues.apache.org/jira/browse/FLINK-17999
Project: Flink
Daniel Laszlo Magyar created FLINK-17998:
Summary: Support limiting job history size
Key: FLINK-17998
URL: https://issues.apache.org/jira/browse/FLINK-17998
Project: Flink
Issue Type:
Tzu-Li (Gordon) Tai created FLINK-17997:
---
Summary: Revert manual merging of AWS KPL's THIRD_PARTY_NOTICE
files content in Stateful Functions distribution artifact
Key: FLINK-17997
URL: https://issues.apache.
Hi again, Kartik!
Our project idea is pretty open-ended — there really is a lot of work to do
in the Table API / SQL documentation, so we're not being picky about what
people choose to work on. Regarding timelines on our side, I think FLIP-60
and other documentation improvement proposals will be t
godfrey he created FLINK-17996:
--
Summary: NEP in
CatalogTableStatisticsConverter.convertToColumnStats method
Key: FLINK-17996
URL: https://issues.apache.org/jira/browse/FLINK-17996
Project: Flink
Jark Wu created FLINK-17995:
---
Summary: Add a new overview page for the new SQL connectors
Key: FLINK-17995
URL: https://issues.apache.org/jira/browse/FLINK-17995
Project: Flink
Issue Type: Sub-task
52 matches
Mail list logo
