Zhijiang created FLINK-17994:
Summary: Fix the race condition between
CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived
Key: FLINK-17994
URL: https://issues.apache.org/jira/browse/FLINK-17994
dingli123 created FLINK-17993:
-
Summary: read schema from orc file
Key: FLINK-17993
URL: https://issues.apache.org/jira/browse/FLINK-17993
Project: Flink
Issue Type: Improvement
Zhijiang created FLINK-17992:
Summary: Exception from RemoteInputChannel#onBuffer should not
fail the whole NetworkClientHandler
Key: FLINK-17992
URL: https://issues.apache.org/jira/browse/FLINK-17992
底限 created FLINK-17991:
--
Summary: Add JdbcAsyncLookupFunction
Key: FLINK-17991
URL: https://issues.apache.org/jira/browse/FLINK-17991
Project: Flink
Issue Type: New Feature
Components:
Dian Fu created FLINK-17990:
---
Summary: ArrowSourceFunctionTestBase.testParallelProcessing is
instable
Key: FLINK-17990
URL: https://issues.apache.org/jira/browse/FLINK-17990
Project: Flink
Issue
Hi,
I think the StreamingFileSink could not support Azure currently.
You could find more detailed info from here[1].
[1] https://issues.apache.org/jira/browse/FLINK-17444
Best,
Guowei
Israel Ekpo 于2020年5月28日周四 上午6:04写道：
> You can assign the task to me and I will like to collaborate with
You can assign the task to me and I will like to collaborate with someone
to fix it.
On Wed, May 27, 2020 at 5:52 PM Israel Ekpo wrote:
> Some users are running into issues when using Azure Blob Storage for the
> StreamFileSink
>
> https://issues.apache.org/jira/browse/FLINK-17989
>
> The issue
Some users are running into issues when using Azure Blob Storage for the
StreamFileSink
https://issues.apache.org/jira/browse/FLINK-17989
The issue is because certain packages are relocated in the POM file and
some classes are dropped in the final shaded jar
I have attempted to comment out the
Israel Ekpo created FLINK-17989:
---
Summary: java.lang.NoClassDefFoundError:
org/apache/flink/fs/azure/common/hadoop/HadoopRecoverableWriter
Key: FLINK-17989
URL: https://issues.apache.org/jira/browse/FLINK-17989
Roman Khachatryan created FLINK-17988:
-
Summary: Checkpointing slows down after reaching
state.checkpoints.num-retained
Key: FLINK-17988
URL: https://issues.apache.org/jira/browse/FLINK-17988
Robert Metzger created FLINK-17987:
--
Summary: KafkaITCase.testStartFromGroupOffsets fails with
SchemaException: Error reading field
Key: FLINK-17987
URL: https://issues.apache.org/jira/browse/FLINK-17987
Hi,
Accidentally hit on Single Reply button instead of Reply All.
Are you able to see my previous mail now?
On Wed, May 27, 2020 at 11:09 PM Marta Paes Moreira
wrote:
> Hi, Kartik!
>
> Sorry that you didn't get our replies to your self-presentation. You can
> find them below!
>
> Let me know if
Hi, Kartik!
Sorry that you didn't get our replies to your self-presentation. You can
find them below!
Let me know if you have any questions.
Marta
-- Forwarded message -
From: Marta Paes Moreira
Date: Thu, May 14, 2020 at 8:37 AM
Subject: Re: Season of Docs - Ex-participant
Roman Khachatryan created FLINK-17986:
-
Summary: Erroneous check in
FsCheckpointStateOutputStream#write(int)
Key: FLINK-17986
URL: https://issues.apache.org/jira/browse/FLINK-17986
Project: Flink
Hi all,
Quick update on progress:
There is still ongoing work on adding state TTL for remote functions
(FLINK-17875), but the PR is expected to be mergeable over the next day or
two.
Therefore the feature branch cut will be slightly delayed. I'll announce
the cut in a separate email once it
Seth Wiesman created FLINK-17985:
Summary: Consolidate Connector Documentation
Key: FLINK-17985
URL: https://issues.apache.org/jira/browse/FLINK-17985
Project: Flink
Issue Type: Improvement
Seth Wiesman created FLINK-17984:
Summary: Update Flink sidebar nav
Key: FLINK-17984
URL: https://issues.apache.org/jira/browse/FLINK-17984
Project: Flink
Issue Type: Improvement
Seth Wiesman created FLINK-17983:
Summary: Add new Flink docs homepage (style)
Key: FLINK-17983
URL: https://issues.apache.org/jira/browse/FLINK-17983
Project: Flink
Issue Type: Improvement
Seth Wiesman created FLINK-17982:
Summary: Finish Flink concepts docs
Key: FLINK-17982
URL: https://issues.apache.org/jira/browse/FLINK-17982
Project: Flink
Issue Type: Improvement
Seth Wiesman created FLINK-17981:
Summary: Add new Flink docs homepage content
Key: FLINK-17981
URL: https://issues.apache.org/jira/browse/FLINK-17981
Project: Flink
Issue Type: Improvement
Seth Wiesman created FLINK-17980:
Summary: Simplify Flink Getting Started Material
Key: FLINK-17980
URL: https://issues.apache.org/jira/browse/FLINK-17980
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-17979:
-
Summary: Support rescaling for Unaligned Checkpoints
Key: FLINK-17979
URL: https://issues.apache.org/jira/browse/FLINK-17979
Project: Flink
Issue
Till Rohrmann created FLINK-17978:
-
Summary: Test Hadoop dependency change
Key: FLINK-17978
URL: https://issues.apache.org/jira/browse/FLINK-17978
Project: Flink
Issue Type: Task
Till Rohrmann created FLINK-17977:
-
Summary: Check log sanity
Key: FLINK-17977
URL: https://issues.apache.org/jira/browse/FLINK-17977
Project: Flink
Issue Type: Task
Components:
Till Rohrmann created FLINK-17976:
-
Summary: Test native K8s integration
Key: FLINK-17976
URL: https://issues.apache.org/jira/browse/FLINK-17976
Project: Flink
Issue Type: Task
Till Rohrmann created FLINK-17975:
-
Summary: Test ZooKeeper 3.5 support
Key: FLINK-17975
URL: https://issues.apache.org/jira/browse/FLINK-17975
Project: Flink
Issue Type: Task
Till Rohrmann created FLINK-17974:
-
Summary: Test new Flink Docker image
Key: FLINK-17974
URL: https://issues.apache.org/jira/browse/FLINK-17974
Project: Flink
Issue Type: Task
Till Rohrmann created FLINK-17973:
-
Summary: Test memory configuration of Flink cluster
Key: FLINK-17973
URL: https://issues.apache.org/jira/browse/FLINK-17973
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-17972:
-
Summary: Consider restructuring channel state
Key: FLINK-17972
URL: https://issues.apache.org/jira/browse/FLINK-17972
Project: Flink
Issue Type:
Joey Pereira created FLINK-17971:
Summary: Speed up RocksDB bulk loading with SST generation and
ingestion
Key: FLINK-17971
URL: https://issues.apache.org/jira/browse/FLINK-17971
Project: Flink
Till Rohrmann created FLINK-17970:
-
Summary: Increase default value of IO pool executor to 4 * #cores
Key: FLINK-17970
URL: https://issues.apache.org/jira/browse/FLINK-17970
Project: Flink
Bhagavan created FLINK-17969:
Summary: Enhance Flink (Task) logging to include job name as
context diagnostic information
Key: FLINK-17969
URL: https://issues.apache.org/jira/browse/FLINK-17969
Project:
Robert Metzger created FLINK-17968:
--
Summary: Hadoop Configuration is not properly serialized in
HBaseRowInputFormat
Key: FLINK-17968
URL: https://issues.apache.org/jira/browse/FLINK-17968
Project:
Aven Wu created FLINK-17967:
---
Summary: Could not find document *** in docs
Key: FLINK-17967
URL: https://issues.apache.org/jira/browse/FLINK-17967
Project: Flink
Issue Type: Bug
Vijaya Bhaskar V created FLINK-17966:
Summary: Documentation improvement of checkpointing API
Key: FLINK-17966
URL: https://issues.apache.org/jira/browse/FLINK-17966
Project: Flink
Issue
Rui Li created FLINK-17965:
--
Summary: Hive dialect doesn't properly handle special character
escaping with SQL CLI
Key: FLINK-17965
URL: https://issues.apache.org/jira/browse/FLINK-17965
Project: Flink
夏帅 created FLINK-17964:
--
Summary: Hivemodule does not support map type
Key: FLINK-17964
URL: https://issues.apache.org/jira/browse/FLINK-17964
Project: Flink
Issue Type: Bug
Components:
Tzu-Li (Gordon) Tai created FLINK-17963:
---
Summary: Revert execution environment patching in
StatefulFunctionsJob (FLINK-16926)
Key: FLINK-17963
URL: https://issues.apache.org/jira/browse/FLINK-17963
+1 (binding)
Checks:
- diff to flink-shaded 1.10:
https://github.com/apache/flink-shaded/compare/release-10.0...release-11.0-rc1
- mvn clean install passes on the source archive
- sha of source archive is correct
- source archive is signed by Chesnay
- mvn staging repo looks reasonable
-
Hequn Cheng created FLINK-17962:
---
Summary: Add document for how to define Python UDF with DDL
Key: FLINK-17962
URL: https://issues.apache.org/jira/browse/FLINK-17962
Project: Flink
Issue Type:
Etienne Chauchot created FLINK-17961:
Summary: Create an Elasticsearch source
Key: FLINK-17961
URL: https://issues.apache.org/jira/browse/FLINK-17961
Project: Flink
Issue Type: New
Hequn Cheng created FLINK-17960:
---
Summary: Improve commands in the "Common Questions" document for
PyFlink
Key: FLINK-17960
URL: https://issues.apache.org/jira/browse/FLINK-17960
Project: Flink
I agree with Konstantin and Steven that it makes sense to point this out
explicitly.
I think that the following would be helpful:
1/ Mention breaking compatibility in release notes
2/ Update the linked table to reflect compatibilities while pointing out
what the community commits to maintain
Hequn Cheng created FLINK-17959:
---
Summary: Exception: "CANCELLED: call already cancelled" is thrown
when run python udf
Key: FLINK-17959
URL: https://issues.apache.org/jira/browse/FLINK-17959
Project:
Yang Wang created FLINK-17958:
-
Summary: Kubernetes session constantly allocates taskmanagers
after cancel a job
Key: FLINK-17958
URL: https://issues.apache.org/jira/browse/FLINK-17958
Project: Flink
Danny Chen created FLINK-17957:
--
Summary: Forbidden syntax "CREATE SYSTEM FUNCTION" for sql parser
Key: FLINK-17957
URL: https://issues.apache.org/jira/browse/FLINK-17957
Project: Flink
Issue
Aljoscha Krettek created FLINK-17956:
Summary: Add Flink 1.11 MigrationVersion
Key: FLINK-17956
URL: https://issues.apache.org/jira/browse/FLINK-17956
Project: Flink
Issue Type: Task
47 matches
Mail list logo
