zhijiang created FLINK-13753:
Summary: Integrate new Source Operator with Mailbox Model in
StreamTask
Key: FLINK-13753
URL: https://issues.apache.org/jira/browse/FLINK-13753
Project: Flink
zhijiang created FLINK-13754:
Summary: Decouple OperatorChain from StreamStatusMaintainer
Key: FLINK-13754
URL: https://issues.apache.org/jira/browse/FLINK-13754
Project: Flink
Issue Type: Sub
hehuiyuan created FLINK-13756:
-
Summary: Modify Code Annotations for findAndCreateTableSource in
TableFactoryUtil
Key: FLINK-13756
URL: https://issues.apache.org/jira/browse/FLINK-13756
Project: Flink
hehuiyuan created FLINK-13757:
-
Summary: Document error for `logical functions`
Key: FLINK-13757
URL: https://issues.apache.org/jira/browse/FLINK-13757
Project: Flink
Issue Type: Wish
luoguohao created FLINK-13758:
-
Summary: failed to submit JobGraph when registered hdfs file in
DistributedCache
Key: FLINK-13758
URL: https://issues.apache.org/jira/browse/FLINK-13758
Project: Flink
zhijiang created FLINK-13762:
Summary: Integrate the implementation of
ForwardingValveOutputHandler for StreamOne/TwoInputProcessor
Key: FLINK-13762
URL: https://issues.apache.org/jira/browse/FLINK-13762
zhijiang created FLINK-13764:
Summary: Pass the counter of numRecordsIn into the constructors of
StreamOne/TwoInputProcessor
Key: FLINK-13764
URL: https://issues.apache.org/jira/browse/FLINK-13764
zhijiang created FLINK-13765:
Summary: Introduce the InputSelectionHandler for selecting next
input in StreamTwoInputSelectableProcessor
Key: FLINK-13765
URL: https://issues.apache.org/jira/browse/FLINK-13765
zhijiang created FLINK-13766:
Summary: Refactor the implementation of StreamInputProcessor based
on StreamTaskInput#emitNext
Key: FLINK-13766
URL: https://issues.apache.org/jira/browse/FLINK-13766
zhijiang created FLINK-13767:
Summary: Migrate isFinished method from AvailabilityListener to
AsyncDataInput
Key: FLINK-13767
URL: https://issues.apache.org/jira/browse/FLINK-13767
Project: Flink
zzsmdfj created FLINK-13792:
---
Summary: source and sink support manual rate limit
Key: FLINK-13792
URL: https://issues.apache.org/jira/browse/FLINK-13792
Project: Flink
Issue Type: Improvement
TisonKun created FLINK-13794:
Summary: Remove unused field printStatusDuringExecution in
ClusterClient
Key: FLINK-13794
URL: https://issues.apache.org/jira/browse/FLINK-13794
Project: Flink
zhijiang created FLINK-13798:
Summary: Refactor the process of checking stream status while
emitting watermark in source
Key: FLINK-13798
URL: https://issues.apache.org/jira/browse/FLINK-13798
Project
hehuiyuan created FLINK-13810:
-
Summary: Update `Elasticsearch Connector` label
Key: FLINK-13810
URL: https://issues.apache.org/jira/browse/FLINK-13810
Project: Flink
Issue Type: Wish
lidesheng created FLINK-13813:
-
Summary: metrics is different between overview ui and metric
response
Key: FLINK-13813
URL: https://issues.apache.org/jira/browse/FLINK-13813
Project: Flink
Sebb created FLINK-13821:
Summary: Website must link to License etc
Key: FLINK-13821
URL: https://issues.apache.org/jira/browse/FLINK-13821
Project: Flink
Issue Type: Bug
Reporter: Sebb
Alex created FLINK-13822:
Summary: TableAggregateITCase.testGroupByFlatAggregate test
failure: IllegalStateException: Concurrent access to KryoSerializer.
Key: FLINK-13822
URL: https://issues.apache.org/jira/browse/FLINK
wangsan created FLINK-13823:
---
Summary: Incorrect debug log in CompileUtils
Key: FLINK-13823
URL: https://issues.apache.org/jira/browse/FLINK-13823
Project: Flink
Issue Type: Bug
Alex created FLINK-13824:
Summary: Code duplication in tools/trawis_watchdog.sh to launch
watchdog process
Key: FLINK-13824
URL: https://issues.apache.org/jira/browse/FLINK-13824
Project: Flink
Alex created FLINK-13825:
Summary: The original plugins dir is not restored after e2e test
run
Key: FLINK-13825
URL: https://issues.apache.org/jira/browse/FLINK-13825
Project: Flink
Issue Type: Bug
TisonKun created FLINK-13827:
Summary: shell variable should be escaped in start-scala-shell.sh
Key: FLINK-13827
URL: https://issues.apache.org/jira/browse/FLINK-13827
Project: Flink
Issue Type
TisonKun created FLINK-13828:
Summary: Deprecate ConfigConstants.LOCAL_START_WEBSERVER
Key: FLINK-13828
URL: https://issues.apache.org/jira/browse/FLINK-13828
Project: Flink
Issue Type: Bug
zhangmeng created FLINK-13830:
-
Summary: The Document about Cluster on yarn have some problems
Key: FLINK-13830
URL: https://issues.apache.org/jira/browse/FLINK-13830
Project: Flink
Issue Type
andrew.D.lin created FLINK-13856:
Summary: Reduce the delete file api when the checkpoint is
completed
Key: FLINK-13856
URL: https://issues.apache.org/jira/browse/FLINK-13856
Project: Flink
hubin created FLINK-13858:
-
Summary: Add flink-connector-elasticsearch6 Specify the field as
the primary key id
Key: FLINK-13858
URL: https://issues.apache.org/jira/browse/FLINK-13858
Project: Flink
limbo created FLINK-13859:
-
Summary: JSONDeserializationSchema spell error
Key: FLINK-13859
URL: https://issues.apache.org/jira/browse/FLINK-13859
Project: Flink
Issue Type: Improvement
lining created FLINK-13868:
--
Summary: Job vertex add taskmanager id in rest api
Key: FLINK-13868
URL: https://issues.apache.org/jira/browse/FLINK-13868
Project: Flink
Issue Type: Improvement
YufeiLiu created FLINK-13870:
Summary: within method should applied in every individual pattern
Key: FLINK-13870
URL: https://issues.apache.org/jira/browse/FLINK-13870
Project: Flink
Issue Type
Alex created FLINK-13871:
Summary: Consolidate isRunning, canceled, isFinished fields in
StreamTask and SourceStreamTask
Key: FLINK-13871
URL: https://issues.apache.org/jira/browse/FLINK-13871
Project: Flink
ouyangwulin created FLINK-13873:
---
Summary: Change the colum family as tags for influxdb reporter
Key: FLINK-13873
URL: https://issues.apache.org/jira/browse/FLINK-13873
Project: Flink
Issue
liusong created FLINK-13879:
---
Summary: It seems that there might be some problem with the
DataStream.keyBy(xx).maxBy(yy)
Key: FLINK-13879
URL: https://issues.apache.org/jira/browse/FLINK-13879
Project
YufeiLiu created FLINK-13881:
Summary: CEP within method should applied in every independent
pattern
Key: FLINK-13881
URL: https://issues.apache.org/jira/browse/FLINK-13881
Project: Flink
Issue
lining created FLINK-13894:
--
Summary: Web Ui add log url for subtask of vertex
Key: FLINK-13894
URL: https://issues.apache.org/jira/browse/FLINK-13894
Project: Flink
Issue Type: Improvement
limbo created FLINK-13899:
-
Summary: Add SQL DDL for Elasticsearch 5.X version
Key: FLINK-13899
URL: https://issues.apache.org/jira/browse/FLINK-13899
Project: Flink
Issue Type: Improvement
TisonKun created FLINK-13912:
Summary: Remove ClusterClient#getClusterConnectionInfo
Key: FLINK-13912
URL: https://issues.apache.org/jira/browse/FLINK-13912
Project: Flink
Issue Type
TisonKun created FLINK-13929:
Summary: Revisit REST & JM URL
Key: FLINK-13929
URL: https://issues.apache.org/jira/browse/FLINK-13929
Project: Flink
Issue Type: Improvement
Compon
TisonKun created FLINK-13932:
Summary: PyTest ExecutionConfigTests.test_equals_and_hash fail
Key: FLINK-13932
URL: https://issues.apache.org/jira/browse/FLINK-13932
Project: Flink
Issue Type
vinoyang created FLINK-13939:
Summary: pyflink ExecutionConfigTests#test_equals_and_hash test
failed
Key: FLINK-13939
URL: https://issues.apache.org/jira/browse/FLINK-13939
Project: Flink
Issue
Stefano created FLINK-13944:
---
Summary: Table.toAppendStream: InvalidProgramException: Table
program cannot be compiled.
Key: FLINK-13944
URL: https://issues.apache.org/jira/browse/FLINK-13944
Project
lining created FLINK-13949:
--
Summary: Delete deduplicating JobVertexDetailsInfo.VertexTaskDetail
Key: FLINK-13949
URL: https://issues.apache.org/jira/browse/FLINK-13949
Project: Flink
Issue Type
Alex created FLINK-13955:
Summary: Integrate ContinuousFileReaderOperator with StreamTask
mailbox execution model
Key: FLINK-13955
URL: https://issues.apache.org/jira/browse/FLINK-13955
Project: Flink
TisonKun created FLINK-13961:
Summary: Remove obsolete abstraction JobExecutor(Service)
Key: FLINK-13961
URL: https://issues.apache.org/jira/browse/FLINK-13961
Project: Flink
Issue Type: Sub
vinoyang created FLINK-13965:
Summary: Keep hasDeprecatedKeys in ConfigOption and mark it with
@Deprecated annotation
Key: FLINK-13965
URL: https://issues.apache.org/jira/browse/FLINK-13965
Project
TisonKun created FLINK-13970:
Summary: Remove or move LifoSetQueue
Key: FLINK-13970
URL: https://issues.apache.org/jira/browse/FLINK-13970
Project: Flink
Issue Type: Sub-task
lining created FLINK-13971:
--
Summary: Add TaskManager In
org.apache.flink.runtime.rest.messages.JobVertexTaskManagersInfo.TaskManagersInfo
Key: FLINK-13971
URL: https://issues.apache.org/jira/browse/FLINK-13971
forideal created FLINK-13974:
Summary: isAssignable function return wrong result
Key: FLINK-13974
URL: https://issues.apache.org/jira/browse/FLINK-13974
Project: Flink
Issue Type: Bug
lining created FLINK-13987:
--
Summary: add new logs api, see more log files and can see logs by
pages
Key: FLINK-13987
URL: https://issues.apache.org/jira/browse/FLINK-13987
Project: Flink
Issue
TisonKun created FLINK-13988:
Summary: Remove legacy JobManagerMode
Key: FLINK-13988
URL: https://issues.apache.org/jira/browse/FLINK-13988
Project: Flink
Issue Type: Sub-task
TisonKun created FLINK-13989:
Summary: Remove legacy ClassloadingProps
Key: FLINK-13989
URL: https://issues.apache.org/jira/browse/FLINK-13989
Project: Flink
Issue Type: Sub-task
TisonKun created FLINK-13990:
Summary: Remove JobModificationException
Key: FLINK-13990
URL: https://issues.apache.org/jira/browse/FLINK-13990
Project: Flink
Issue Type: Sub-task
TisonKun created FLINK-13992:
Summary: Refactor Optional parameter in
InputGateWithMetrics#updateMetrics
Key: FLINK-13992
URL: https://issues.apache.org/jira/browse/FLINK-13992
Project: Flink
TisonKun created FLINK-13997:
Summary: Remove legacy LeaderAddressAndId
Key: FLINK-13997
URL: https://issues.apache.org/jira/browse/FLINK-13997
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-14004:
Summary: Define SourceReader interface to verify the integration
with StreamOneInputProcessor
Key: FLINK-14004
URL: https://issues.apache.org/jira/browse/FLINK-14004
Project
sunjincheng created FLINK-14006:
---
Summary: Add doc for how to using Java UDFs in Python API
Key: FLINK-14006
URL: https://issues.apache.org/jira/browse/FLINK-14006
Project: Flink
Issue Type
sunjincheng created FLINK-14007:
---
Summary: Add doc for how to using Java user-defined source/sink in
Python API
Key: FLINK-14007
URL: https://issues.apache.org/jira/browse/FLINK-14007
Project: Flink
TisonKun created FLINK-14010:
Summary: Dispatcher & JobManagers don't give up leadership when AM
is shut down
Key: FLINK-14010
URL: https://issues.apache.org/jira/browse/FLINK-14010
Proje
Alex created FLINK-14011:
Summary: Make some fields final and initialize them during
construction in AsyncWaitOperator
Key: FLINK-14011
URL: https://issues.apache.org/jira/browse/FLINK-14011
Project: Flink
liupengcheng created FLINK-14037:
Summary: Deserializing the input/output formats failed: unread
block data
Key: FLINK-14037
URL: https://issues.apache.org/jira/browse/FLINK-14037
Project: Flink
liupengcheng created FLINK-14038:
Summary: ExecutionGraph deploy failed due to akka timeout
Key: FLINK-14038
URL: https://issues.apache.org/jira/browse/FLINK-14038
Project: Flink
Issue Type
TisonKun created FLINK-14041:
Summary: Refactor LeaderRetrievalServiceHostnameResolutionTest and
remove StandaloneUtils
Key: FLINK-14041
URL: https://issues.apache.org/jira/browse/FLINK-14041
Project
TisonKun created FLINK-14050:
Summary: Refactor YarnClusterDescriptor inheritance
Key: FLINK-14050
URL: https://issues.apache.org/jira/browse/FLINK-14050
Project: Flink
Issue Type: Sub-task
TisonKun created FLINK-14051:
Summary: Deploy job cluster in attached mode
Key: FLINK-14051
URL: https://issues.apache.org/jira/browse/FLINK-14051
Project: Flink
Issue Type: Sub-task
jackylau created FLINK-14053:
Summary: blink planner dense_rank corner case bug
Key: FLINK-14053
URL: https://issues.apache.org/jira/browse/FLINK-14053
Project: Flink
Issue Type: Bug
TisonKun created FLINK-14068:
Summary: Use Java's Duration instead of Flink's Time
Key: FLINK-14068
URL: https://issues.apache.org/jira/browse/FLINK-14068
Project: Flink
Issue Type
zhangjun created FLINK-14077:
Summary: get java.util.ConcurrentModificationException when push
metrics to PushGateway
Key: FLINK-14077
URL: https://issues.apache.org/jira/browse/FLINK-14077
Project
Junling created FLINK-14085:
---
Summary: schema changes after using "create view" command via
flink-table-sql-client
Key: FLINK-14085
URL: https://issues.apache.org/jira/browse/FLINK-14085
Proj
wangxiyuan created FLINK-14086:
--
Summary: PrometheusReporterEndToEndITCase doesn't support ARM arch
Key: FLINK-14086
URL: https://issues.apache.org/jira/browse/FLINK-14086
Project: Flink
luojiangyu created FLINK-14087:
--
Summary: throws java.lang.ArrayIndexOutOfBoundsException when
emiting the data using RebalancePartitioner.
Key: FLINK-14087
URL: https://issues.apache.org/jira/browse/FLINK-14087
zzsmdfj created FLINK-14093:
---
Summary: Java8 lambdas and exceptions lead to compile error
Key: FLINK-14093
URL: https://issues.apache.org/jira/browse/FLINK-14093
Project: Flink
Issue Type: Bug
xymaqingxiang created FLINK-14094:
-
Summary: Fix OperatorIOMetricGroup repeat register problem
Key: FLINK-14094
URL: https://issues.apache.org/jira/browse/FLINK-14094
Project: Flink
Issue
TisonKun created FLINK-14096:
Summary: Merge NewClusterClient into ClusterClient
Key: FLINK-14096
URL: https://issues.apache.org/jira/browse/FLINK-14096
Project: Flink
Issue Type: Sub-task
Alex created FLINK-14097:
Summary: Optimize AsyncWaitOperator to process more than one
element per mailbox letter
Key: FLINK-14097
URL: https://issues.apache.org/jira/browse/FLINK-14097
Project: Flink
Alex created FLINK-14103:
Summary: StreamTask refactoring: refine and improve exceptions
passed to failExternally call
Key: FLINK-14103
URL: https://issues.apache.org/jira/browse/FLINK-14103
Project: Flink
TisonKun created FLINK-14105:
Summary: Make flink-runtime scala-free
Key: FLINK-14105
URL: https://issues.apache.org/jira/browse/FLINK-14105
Project: Flink
Issue Type: Task
Components
TisonKun created FLINK-14113:
Summary: Remove class JobWithJars
Key: FLINK-14113
URL: https://issues.apache.org/jira/browse/FLINK-14113
Project: Flink
Issue Type: Sub-task
Components
TisonKun created FLINK-14114:
Summary: Shift down ClusterClient#timeout to RestClusterClient
Key: FLINK-14114
URL: https://issues.apache.org/jira/browse/FLINK-14114
Project: Flink
Issue Type
liupengcheng created FLINK-14123:
Summary: Change taskmanager.memory.fraction default value to 0.6
Key: FLINK-14123
URL: https://issues.apache.org/jira/browse/FLINK-14123
Project: Flink
YufeiLiu created FLINK-14124:
Summary: potential memory leak in netty server
Key: FLINK-14124
URL: https://issues.apache.org/jira/browse/FLINK-14124
Project: Flink
Issue Type: Improvement
zhaoshuo created FLINK-31881:
Summary: The Chinese documentation page of Flink official CEP is
experiencing confusion.
Key: FLINK-31881
URL: https://issues.apache.org/jira/browse/FLINK-31881
Project
yuzelin created FLINK-31882:
---
Summary: SqlGateway will throw exception when executing
DeleteFromFilterOperation
Key: FLINK-31882
URL: https://issues.apache.org/jira/browse/FLINK-31882
Project: Flink
chenyu created FLINK-31883:
--
Summary: StreamSQLExample.Order has nullability issues
Key: FLINK-31883
URL: https://issues.apache.org/jira/browse/FLINK-31883
Project: Flink
Issue Type: Bug
jackylau created FLINK-31902:
Summary: cast expr to type with not null should throw exception
like calcite
Key: FLINK-31902
URL: https://issues.apache.org/jira/browse/FLINK-31902
Project: Flink
jackylau created FLINK-31904:
Summary: fix current serveral flink nullable type handle
Key: FLINK-31904
URL: https://issues.apache.org/jira/browse/FLINK-31904
Project: Flink
Issue Type
jackylau created FLINK-31906:
Summary: typeof should only return type exclude nullable
Key: FLINK-31906
URL: https://issues.apache.org/jira/browse/FLINK-31906
Project: Flink
Issue Type
jackylau created FLINK-31908:
Summary: cast expr to type with not null should not change
nullable of expr
Key: FLINK-31908
URL: https://issues.apache.org/jira/browse/FLINK-31908
Project: Flink
datariver created FLINK-31914:
-
Summary: Failing to close FlinkKafkaInternalProducer created in
KafkaWriter with exactly-once semantic results in memory leak
Key: FLINK-31914
URL: https://issues.apache.org/jira
caiyi created FLINK-31928:
-
Summary: flink-kubernetes works not properly in IPv6 environment
in k8s
Key: FLINK-31928
URL: https://issues.apache.org/jira/browse/FLINK-31928
Project: Flink
Issue Type
caiyi created FLINK-31929:
-
Summary: HighAvailabilityServicesUtils.getWebMonitorAddress works
not properly in IPv6 stack of k8s
Key: FLINK-31929
URL: https://issues.apache.org/jira/browse/FLINK-31929
Project
caiyi created FLINK-31930:
-
Summary: MetricQueryService works not properly in k8s with IPv6
stack
Key: FLINK-31930
URL: https://issues.apache.org/jira/browse/FLINK-31930
Project: Flink
Issue Type
://issues.apache.org/jira/browse/FLINK-31939
Project: Flink
Issue Type: Bug
Affects Versions: 1.15.4, 1.16.0, 1.14.2
Reporter: AmitK
While running some basic Beam code that is reading a file and transforming it
for further processing, I am unable to get past the
padavan created FLINK-31958:
---
Summary: Table to DataStream allow partial fields
Key: FLINK-31958
URL: https://issues.apache.org/jira/browse/FLINK-31958
Project: Flink
Issue Type: Improvement
padavan created FLINK-31960:
---
Summary: SQL OverBy. Error on a code that does not exist
Key: FLINK-31960
URL: https://issues.apache.org/jira/browse/FLINK-31960
Project: Flink
Issue Type: Bug
padavan created FLINK-31967:
---
Summary: SQL with LAG function NullPointerException
Key: FLINK-31967
URL: https://issues.apache.org/jira/browse/FLINK-31967
Project: Flink
Issue Type: Bug
hanjie created FLINK-32009:
--
Summary: Slot request bulk is not fulfillable! Could not allocate
the required slot within slot request timeout
Key: FLINK-32009
URL: https://issues.apache.org/jira/browse/FLINK-32009
xueyongyang created FLINK-32011:
---
Summary: flink1.15.2 loaded all the data in the table in mysql5.7
Key: FLINK-32011
URL: https://issues.apache.org/jira/browse/FLINK-32011
Project: Flink
Issue
Liu created FLINK-32023:
---
Summary: execution.buffer-timeout cannot be set to -1 ms
Key: FLINK-32023
URL: https://issues.apache.org/jira/browse/FLINK-32023
Project: Flink
Issue Type: Improvement
xueyongyang created FLINK-32026:
---
Summary: jdbc-3.1.0-1.16 left join conversion error
Key: FLINK-32026
URL: https://issues.apache.org/jira/browse/FLINK-32026
Project: Flink
Issue Type
Joekwal created FLINK-32040:
---
Summary: The WatermarkStrategy defined with the
Function(with_idleness) report an error
Key: FLINK-32040
URL: https://issues.apache.org/jira/browse/FLINK-32040
Project: Flink
Spongebob created FLINK-32065:
-
Summary: Got NoSuchFileException when initialize source function.
Key: FLINK-32065
URL: https://issues.apache.org/jira/browse/FLINK-32065
Project: Flink
Issue
leishuiyu created FLINK-32068:
-
Summary: flink-connector-jdbc support clickhouse
Key: FLINK-32068
URL: https://issues.apache.org/jira/browse/FLINK-32068
Project: Flink
Issue Type: New Feature
701 - 800 of 36655 matches
Mail list logo
