Guowei Ma created FLINK-6072:
Summary: TestCase CheckpointStateRestoreTest::testSetState should
be fail
Key: FLINK-6072
URL: https://issues.apache.org/jira/browse/FLINK-6072
Project: Flink
Guowei Ma created FLINK-11985:
-
Summary: Remove ignored command line parameter from yarn_setup.md
Key: FLINK-11985
URL: https://issues.apache.org/jira/browse/FLINK-11985
Project: Flink
Issue
Guowei Ma created FLINK-13480:
-
Summary: Export SlotManager status at debug mode.
Key: FLINK-13480
URL: https://issues.apache.org/jira/browse/FLINK-13480
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-13993:
-
Summary: Using FlinkUserCodeClassLoaders to load the user class in
the perjob mode
Key: FLINK-13993
URL: https://issues.apache.org/jira/browse/FLINK-13993
Project: Flink
Guowei Ma created FLINK-13426:
-
Summary: TaskExecutor uses the wrong Registrationid in the
heartbeat with RM.
Key: FLINK-13426
URL: https://issues.apache.org/jira/browse/FLINK-13426
Project: Flink
Guowei Ma created FLINK-15032:
-
Summary: Remove the eagerly serialization from
`RemoteRpcInvocation`
Key: FLINK-15032
URL: https://issues.apache.org/jira/browse/FLINK-15032
Project: Flink
Guowei Ma created FLINK-14465:
-
Summary: Let StandaloneJobClusterEntrypoint use user code class
loader
Key: FLINK-14465
URL: https://issues.apache.org/jira/browse/FLINK-14465
Project: Flink
Guowei Ma created FLINK-14466:
-
Summary: Let YarnJobClusterEntrypoint use user code class loader
Key: FLINK-14466
URL: https://issues.apache.org/jira/browse/FLINK-14466
Project: Flink
Issue
Guowei Ma created FLINK-14467:
-
Summary: Let MesosJobClusterEntrypoint use user code class loader
Key: FLINK-14467
URL: https://issues.apache.org/jira/browse/FLINK-14467
Project: Flink
Issue
Guowei Ma created FLINK-14991:
-
Summary: Export `FLINK_HOME` environment variable to all the
entrypoint
Key: FLINK-14991
URL: https://issues.apache.org/jira/browse/FLINK-14991
Project: Flink
Guowei Ma created FLINK-15784:
-
Summary: Show the Watermark metrics of source node in the web UI.
Key: FLINK-15784
URL: https://issues.apache.org/jira/browse/FLINK-15784
Project: Flink
Issue
Guowei Ma created FLINK-15786:
-
Summary: Load connector code with separate classloader
Key: FLINK-15786
URL: https://issues.apache.org/jira/browse/FLINK-15786
Project: Flink
Issue Type:
Guowei Ma created FLINK-17039:
-
Summary: Introduce TypeInformationExtractor interface
Key: FLINK-17039
URL: https://issues.apache.org/jira/browse/FLINK-17039
Project: Flink
Issue Type: Sub-task
Guowei Ma created FLINK-17038:
-
Summary: Decouple resolving Type and creating TypeInformation
process
Key: FLINK-17038
URL: https://issues.apache.org/jira/browse/FLINK-17038
Project: Flink
Guowei Ma created FLINK-17041:
-
Summary: Migrate current TypeInformation creation to the
TypeInformationExtractor framework
Key: FLINK-17041
URL: https://issues.apache.org/jira/browse/FLINK-17041
Guowei Ma created FLINK-19260:
-
Summary: Update documentation based on bin/flink output
Key: FLINK-19260
URL: https://issues.apache.org/jira/browse/FLINK-19260
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-19261:
-
Summary: Update document according to RestOptions
Key: FLINK-19261
URL: https://issues.apache.org/jira/browse/FLINK-19261
Project: Flink
Issue Type: Sub-task
Guowei Ma created FLINK-19512:
-
Summary: Introduce the new sink api
Key: FLINK-19512
URL: https://issues.apache.org/jira/browse/FLINK-19512
Project: Flink
Issue Type: Sub-task
Guowei Ma created FLINK-19510:
-
Summary: Introduce new unified sink api
Key: FLINK-19510
URL: https://issues.apache.org/jira/browse/FLINK-19510
Project: Flink
Issue Type: New Feature
Guowei Ma created FLINK-19511:
-
Summary: Rename the `SinkTransformation` to
`LegacySinkTransformation`
Key: FLINK-19511
URL: https://issues.apache.org/jira/browse/FLINK-19511
Project: Flink
Guowei Ma created FLINK-19586:
-
Summary: Implement the stream committer operator
Key: FLINK-19586
URL: https://issues.apache.org/jira/browse/FLINK-19586
Project: Flink
Issue Type: Sub-task
Guowei Ma created FLINK-19697:
-
Summary: Make the streaming committer retry-able
Key: FLINK-19697
URL: https://issues.apache.org/jira/browse/FLINK-19697
Project: Flink
Issue Type: Sub-task
Guowei Ma created FLINK-19736:
-
Summary: Implement the `SinkTransformation`
Key: FLINK-19736
URL: https://issues.apache.org/jira/browse/FLINK-19736
Project: Flink
Issue Type: Sub-task
Guowei Ma created FLINK-19738:
-
Summary: Remove the `getCommitter` from the
`AbstractStreamingCommitterOperator`
Key: FLINK-19738
URL: https://issues.apache.org/jira/browse/FLINK-19738
Project: Flink
Guowei Ma created FLINK-19531:
-
Summary: Implement the `WriterOperator`
Key: FLINK-19531
URL: https://issues.apache.org/jira/browse/FLINK-19531
Project: Flink
Issue Type: Sub-task
Guowei Ma created FLINK-19373:
-
Summary: `jmx.server.port`'s document is missing.
Key: FLINK-19373
URL: https://issues.apache.org/jira/browse/FLINK-19373
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-19374:
-
Summary: update the `table.exec.state.ttl`'s documentation
Key: FLINK-19374
URL: https://issues.apache.org/jira/browse/FLINK-19374
Project: Flink
Issue Type: Task
Guowei Ma created FLINK-19375:
-
Summary: The `kubernetes.secrets` and
`kubernetes.env.secretKeyRef`'s document is missing
Key: FLINK-19375
URL: https://issues.apache.org/jira/browse/FLINK-19375
Project:
Guowei Ma created FLINK-19760:
-
Summary: Make the `GlobalCommitter` a standalone interface that
does not extend the `Committer`
Key: FLINK-19760
URL: https://issues.apache.org/jira/browse/FLINK-19760
Guowei Ma created FLINK-19834:
-
Summary: Make the TestSink reusable in all the sink related tests.
Key: FLINK-19834
URL: https://issues.apache.org/jira/browse/FLINK-19834
Project: Flink
Issue
Guowei Ma created FLINK-19836:
-
Summary: Serialize the committable by the serializer provided by
the user during network shuffle
Key: FLINK-19836
URL: https://issues.apache.org/jira/browse/FLINK-19836
Guowei Ma created FLINK-19841:
-
Summary: Rename GlobalStreamingCommitterOperator to
StreamingGlobalCommitterOperator
Key: FLINK-19841
URL: https://issues.apache.org/jira/browse/FLINK-19841
Project: Flink
Guowei Ma created FLINK-20297:
-
Summary: Make `SerializerTestBase::getTestData` return List
Key: FLINK-20297
URL: https://issues.apache.org/jira/browse/FLINK-20297
Project: Flink
Issue Type:
Guowei Ma created FLINK-20337:
-
Summary: Make migrate `StreamingFileSink` to `FileSink` possible
Key: FLINK-20337
URL: https://issues.apache.org/jira/browse/FLINK-20337
Project: Flink
Issue
Guowei Ma created FLINK-20338:
-
Summary: Make the SinkWriter load previous sink's state.
Key: FLINK-20338
URL: https://issues.apache.org/jira/browse/FLINK-20338
Project: Flink
Issue Type:
Guowei Ma created FLINK-20339:
-
Summary: `FileWriter` support to load StreamingFileSink's state.
Key: FLINK-20339
URL: https://issues.apache.org/jira/browse/FLINK-20339
Project: Flink
Issue
Guowei Ma created FLINK-20652:
-
Summary: Improve the document for making the user could write a
DataStream job that could be execute in the batch execution mode.
Key: FLINK-20652
URL:
Guowei Ma created FLINK-20211:
-
Summary: Can not get the JobManager web ip according to the
document
Key: FLINK-20211
URL: https://issues.apache.org/jira/browse/FLINK-20211
Project: Flink
Issue
Guowei Ma created FLINK-20214:
-
Summary: Unnecessary warning log when starting a k8s session
cluster
Key: FLINK-20214
URL: https://issues.apache.org/jira/browse/FLINK-20214
Project: Flink
Issue
Guowei Ma created FLINK-20215:
-
Summary: Keep the "Access the Flink UI " document same in
“Kubernetes Setup” and "Native Kubernetes Setup Beta"
Key: FLINK-20215
URL: https://issues.apache.org/jira/browse/FLINK-20215
Guowei Ma created FLINK-20225:
-
Summary: Break link in the document
Key: FLINK-20225
URL: https://issues.apache.org/jira/browse/FLINK-20225
Project: Flink
Issue Type: Improvement
Guowei Ma created FLINK-20203:
-
Summary: Could not find any document about how to build a Flink
image from local build.
Key: FLINK-20203
URL: https://issues.apache.org/jira/browse/FLINK-20203
Project:
Guowei Ma created FLINK-20206:
-
Summary: Failed to start the session, but there is no clear prompt.
Key: FLINK-20206
URL: https://issues.apache.org/jira/browse/FLINK-20206
Project: Flink
Issue
Guowei Ma created FLINK-19936:
-
Summary: Make SinkITCase more stable
Key: FLINK-19936
URL: https://issues.apache.org/jira/browse/FLINK-19936
Project: Flink
Issue Type: Sub-task
Guowei Ma created FLINK-19958:
-
Summary: Unified exception signature in Sink API
Key: FLINK-19958
URL: https://issues.apache.org/jira/browse/FLINK-19958
Project: Flink
Issue Type: Sub-task
Guowei Ma created FLINK-19963:
-
Summary: Let the `SinkWriter` support using the `TimerService`
Key: FLINK-19963
URL: https://issues.apache.org/jira/browse/FLINK-19963
Project: Flink
Issue Type:
Guowei Ma created FLINK-20007:
-
Summary: SinkTransformationTranslator fail to handle the
PartitionTransformation
Key: FLINK-20007
URL: https://issues.apache.org/jira/browse/FLINK-20007
Project: Flink
Guowei Ma created FLINK-20031:
-
Summary: Keep the uid of SinkWriter same as the SinkTransformation
Key: FLINK-20031
URL: https://issues.apache.org/jira/browse/FLINK-20031
Project: Flink
Issue
Guowei Ma created FLINK-21234:
-
Summary: testKafkaSourceSinkWithKeyAndPartialValue[legacy = false,
format = csv] hang
Key: FLINK-21234
URL: https://issues.apache.org/jira/browse/FLINK-21234
Project:
Guowei Ma created FLINK-21235:
-
Summary:
leaderChange_withBlockingJobManagerTermination_doesNotAffectNewLeader hang
Key: FLINK-21235
URL: https://issues.apache.org/jira/browse/FLINK-21235
Project: Flink
Guowei Ma created FLINK-21272:
-
Summary: Resuming Savepoint (rocks, scale down, rocks timers)
end-to-end test' Fail
Key: FLINK-21272
URL: https://issues.apache.org/jira/browse/FLINK-21272
Project: Flink
Guowei Ma created FLINK-21275:
-
Summary: DataStreamTests::test_key_by_on_connect_stream Fail
Key: FLINK-21275
URL: https://issues.apache.org/jira/browse/FLINK-21275
Project: Flink
Issue Type:
Guowei Ma created FLINK-21173:
-
Summary: "Streaming SQL end-to-end test (Old planner)" e2e test
failed
Key: FLINK-21173
URL: https://issues.apache.org/jira/browse/FLINK-21173
Project: Flink
Guowei Ma created FLINK-21175:
-
Summary: OneInputStreamTaskTest.testWatermarkMetrics:914
expected:<1> but was:<-9223372036854775808>
Key: FLINK-21175
URL: https://issues.apache.org/jira/browse/FLINK-21175
Guowei Ma created FLINK-21194:
-
Summary: TaskExecutorITCase.testJobRecoveryWithFailingTaskExecutor
Fail
Key: FLINK-21194
URL: https://issues.apache.org/jira/browse/FLINK-21194
Project: Flink
Guowei Ma created FLINK-21214:
-
Summary:
FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Failed
Key: FLINK-21214
URL: https://issues.apache.org/jira/browse/FLINK-21214
Project: Flink
Guowei Ma created FLINK-21216:
-
Summary: StreamPandasConversionTests Fails
Key: FLINK-21216
URL: https://issues.apache.org/jira/browse/FLINK-21216
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21217:
-
Summary: Resuming Savepoint (rocks, scale up, rocks timers)
end-to-end test
Key: FLINK-21217
URL: https://issues.apache.org/jira/browse/FLINK-21217
Project: Flink
Guowei Ma created FLINK-21213:
-
Summary: Elasticsearch (v5.3.3) sink end-to-end test' failed
Key: FLINK-21213
URL: https://issues.apache.org/jira/browse/FLINK-21213
Project: Flink
Issue Type:
Guowei Ma created FLINK-21215:
-
Summary: UnalignedCheckpointITCase.execute
Key: FLINK-21215
URL: https://issues.apache.org/jira/browse/FLINK-21215
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21156:
-
Summary:
org.apache.flink.connector.jdbc.catalog.PostgresCatalogITCase Fail
Key: FLINK-21156
URL: https://issues.apache.org/jira/browse/FLINK-21156
Project: Flink
Guowei Ma created FLINK-21157:
-
Summary: "Running HA per-job cluster (rocks, incremental)
end-to-end test" gets stuck
Key: FLINK-21157
URL: https://issues.apache.org/jira/browse/FLINK-21157
Project:
Guowei Ma created FLINK-21244:
-
Summary: shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel
Fail
Key: FLINK-21244
URL: https://issues.apache.org/jira/browse/FLINK-21244
Project: Flink
Guowei Ma created FLINK-22662:
-
Summary:
YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint fail
Key: FLINK-22662
URL: https://issues.apache.org/jira/browse/FLINK-22662
Project: Flink
Guowei Ma created FLINK-22704:
-
Summary: ZooKeeperHaServicesTest.testCleanupJobData failed
Key: FLINK-22704
URL: https://issues.apache.org/jira/browse/FLINK-22704
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22702:
-
Summary: KafkaSourceITCase.testRedundantParallelism failed
Key: FLINK-22702
URL: https://issues.apache.org/jira/browse/FLINK-22702
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22703:
-
Summary:
SavepointITCase.testTriggerSavepointAndResumeWithFileBasedCheckpoints failed
Key: FLINK-22703
URL: https://issues.apache.org/jira/browse/FLINK-22703
Project:
Guowei Ma created FLINK-22705:
-
Summary: SQL Client end-to-end test (Old planner) Elasticsearch
(v7.5.1) failed due to fail to download the tar
Key: FLINK-22705
URL: https://issues.apache.org/jira/browse/FLINK-22705
Guowei Ma created FLINK-22710:
-
Summary:
ParquetProtoStreamingFileSinkITCase.testParquetProtoWriters failed
Key: FLINK-22710
URL: https://issues.apache.org/jira/browse/FLINK-22710
Project: Flink
Guowei Ma created FLINK-22613:
-
Summary: FlinkKinesisITCase.testStopWithSavepoint fails
Key: FLINK-22613
URL: https://issues.apache.org/jira/browse/FLINK-22613
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22735:
-
Summary: HiveTableSourceITCase.testStreamPartitionReadByCreateTime
failed because of times out
Key: FLINK-22735
URL: https://issues.apache.org/jira/browse/FLINK-22735
Guowei Ma created FLINK-22739:
-
Summary: CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail
due to TestTimedOutException
Key: FLINK-22739
URL: https://issues.apache.org/jira/browse/FLINK-22739
Guowei Ma created FLINK-22738:
-
Summary:
org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output for 900
seconds due to block on downloading docker image
Key: FLINK-22738
URL:
Guowei Ma created FLINK-22720:
-
Summary: UpsertKafkaTableITCase.testAggregate fail due to
ConcurrentModificationException
Key: FLINK-22720
URL: https://issues.apache.org/jira/browse/FLINK-22720
Project:
Guowei Ma created FLINK-22779:
-
Summary:
KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to
ConcurrentModificationException
Key: FLINK-22779
URL: https://issues.apache.org/jira/browse/FLINK-22779
Guowei Ma created FLINK-22775:
-
Summary: CassandraConnectorITCase.testCassandraTableSink Fail
Key: FLINK-22775
URL: https://issues.apache.org/jira/browse/FLINK-22775
Project: Flink
Issue Type:
Guowei Ma created FLINK-22755:
-
Summary: SequenceStreamingFileSinkITCase.testWriteSequenceFile fail
Key: FLINK-22755
URL: https://issues.apache.org/jira/browse/FLINK-22755
Project: Flink
Issue
Guowei Ma created FLINK-22756:
-
Summary: DispatcherTest.testJobStatusIsShownDuringTermination fail
Key: FLINK-22756
URL: https://issues.apache.org/jira/browse/FLINK-22756
Project: Flink
Issue
Guowei Ma created FLINK-22462:
-
Summary: JdbcExactlyOnceSinkE2eTest.testInsert failed because of
too many clients.
Key: FLINK-22462
URL: https://issues.apache.org/jira/browse/FLINK-22462
Project: Flink
Guowei Ma created FLINK-22465:
-
Summary: KafkaSourceITCase.testValueOnlyDeserializer hangs
Key: FLINK-22465
URL: https://issues.apache.org/jira/browse/FLINK-22465
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22466:
-
Summary: KafkaSourceLegacyITCase.testOneToOneSources fail because
the OperatorEvent lost
Key: FLINK-22466
URL: https://issues.apache.org/jira/browse/FLINK-22466
Project:
Guowei Ma created FLINK-22457:
-
Summary: KafkaSourceLegacyITCase.testMultipleSourcesOnePartition
fails because of timeout
Key: FLINK-22457
URL: https://issues.apache.org/jira/browse/FLINK-22457
Project:
Guowei Ma created FLINK-22545:
-
Summary: JVM crashes when runing
OperatorEventSendingCheckpointITCase.testOperatorEventAckLost
Key: FLINK-22545
URL: https://issues.apache.org/jira/browse/FLINK-22545
Guowei Ma created FLINK-22546:
-
Summary: testKafkaSourceSinkWithKeyAndFullValue failed
Key: FLINK-22546
URL: https://issues.apache.org/jira/browse/FLINK-22546
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22547:
-
Summary: OperatorCoordinatorHolderTest.
verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail
Key: FLINK-22547
URL: https://issues.apache.org/jira/browse/FLINK-22547
Guowei Ma created FLINK-22548:
-
Summary:
UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to
IllegalReferenceCountException
Key: FLINK-22548
URL:
Guowei Ma created FLINK-22439:
-
Summary: UnalignedCheckpointITCase hangs
Key: FLINK-22439
URL: https://issues.apache.org/jira/browse/FLINK-22439
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22440:
-
Summary: UpsertKafkaTableITCase fail due to create topic timeout
Key: FLINK-22440
URL: https://issues.apache.org/jira/browse/FLINK-22440
Project: Flink
Issue
Guowei Ma created FLINK-22496:
-
Summary:
ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook failed
Key: FLINK-22496
URL: https://issues.apache.org/jira/browse/FLINK-22496
Project: Flink
Guowei Ma created FLINK-22520:
-
Summary: KafkaSourceLegacyITCase.testMultipleSourcesOnePartition
hangs
Key: FLINK-22520
URL: https://issues.apache.org/jira/browse/FLINK-22520
Project: Flink
Guowei Ma created FLINK-21318:
-
Summary: ExecutionContextTest.testCatalogs fail
Key: FLINK-21318
URL: https://issues.apache.org/jira/browse/FLINK-21318
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21316:
-
Summary: E2E tests exceed 250 minutes.
Key: FLINK-21316
URL: https://issues.apache.org/jira/browse/FLINK-21316
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21941:
-
Summary: testSavepointRescalingOutPartitionedOperatorStateList fail
Key: FLINK-21941
URL: https://issues.apache.org/jira/browse/FLINK-21941
Project: Flink
Issue
Guowei Ma created FLINK-21988:
-
Summary: testRequestKvStateWithIrrelevantRegistration fail
Key: FLINK-21988
URL: https://issues.apache.org/jira/browse/FLINK-21988
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21983:
-
Summary: Test failed because "mvn-${sys/mvn.forkNumber}" is not
updated on time.
Key: FLINK-21983
URL: https://issues.apache.org/jira/browse/FLINK-21983
Project: Flink
Guowei Ma created FLINK-21987:
-
Summary: testRequestKvStateOfWrongJob failed
Key: FLINK-21987
URL: https://issues.apache.org/jira/browse/FLINK-21987
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-22002:
-
Summary:
AggregateReduceGroupingITCase.testSingleAggOnTable_HashAgg_WithLocalAgg fail
because of submitting task time-out.
Key: FLINK-22002
URL:
Guowei Ma created FLINK-22005:
-
Summary: SQL Client end-to-end test (Old planner) Elasticsearch
(v7.5.1)
Key: FLINK-22005
URL: https://issues.apache.org/jira/browse/FLINK-22005
Project: Flink
Guowei Ma created FLINK-22096:
-
Summary: ServerTransportErrorHandlingTest.testRemoteClose fail
Key: FLINK-22096
URL: https://issues.apache.org/jira/browse/FLINK-22096
Project: Flink
Issue Type:
Guowei Ma created FLINK-22103:
-
Summary: testNumberOfBuiltinFunctions fail
Key: FLINK-22103
URL: https://issues.apache.org/jira/browse/FLINK-22103
Project: Flink
Issue Type: Bug
1 - 100 of 171 matches
Mail list logo
