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-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-17038:
-
Summary: Decouple resolving Type and creating TypeInformation
process
Key: FLINK-17038
URL: https://issues.apache.org/jira/browse/FLINK-17038
Project: Flink
Issue
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-17041:
-
Summary: Migrate current TypeInformation creation to the
TypeInformationExtractor framework
Key: FLINK-17041
URL: https://issues.apache.org/jira/browse/FLINK-17041
Project:
Guowei Ma created FLINK-14464:
-
Summary: Introduce the 'AbstractUserClassPathJobGraphRetriever'
which could construct the 'user code class path' from the "job" dir.
Key: FLINK-14464
URL: https://issues.apache.org/jira
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
Issu
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 Type:
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 Type
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
Iss
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
Issue
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 Type
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: Improveme
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 Type
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
Issue
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-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: F
Guowei Ma created FLINK-19376:
-
Summary: `table.generated-code.max-length` and `table.sql-dialec`
's document is needed to be updated
Key: FLINK-19376
URL: https://issues.apache.org/jira/browse/FLINK-19376
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
Co
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
Issu
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
Component
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
Compo
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-19696:
-
Summary: Implement Batch committer for the new API
Key: FLINK-19696
URL: https://issues.apache.org/jira/browse/FLINK-19696
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
C
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-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
Proj
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 Typ
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
Pro
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-19936:
-
Summary: Make SinkITCase more stable
Key: FLINK-19936
URL: https://issues.apache.org/jira/browse/FLINK-19936
Project: Flink
Issue Type: Sub-task
Componen
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: S
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 Typ
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: Fli
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 Ty
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
Compon
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: Impr
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 Type:
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: Sub-tas
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 Type:
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: https://issues.apache.org/jira/br
Guowei Ma created FLINK-27406:
-
Summary: After canceling the job, it is falsely reported as a job
failure.
Key: FLINK-27406
URL: https://issues.apache.org/jira/browse/FLINK-27406
Project: Flink
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: Flink
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
Issu
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
Iss
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: Bu
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-21215:
-
Summary: UnalignedCheckpointITCase.execute
Key: FLINK-21215
URL: https://issues.apache.org/jira/browse/FLINK-21215
Project: Flink
Issue Type: Bug
Compone
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
Compone
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-21234:
-
Summary: testKafkaSourceSinkWithKeyAndPartialValue[legacy = false,
format = csv] hang
Key: FLINK-21234
URL: https://issues.apache.org/jira/browse/FLINK-21234
Project: Flink
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-21244:
-
Summary: shouldPerformUnalignedCheckpointOnLocalAndRemoteChannel
Fail
Key: FLINK-21244
URL: https://issues.apache.org/jira/browse/FLINK-21244
Project: Flink
Issue
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: 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
Components:
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
Co
Guowei Ma created FLINK-21428:
-
Summary:
DeclarativeSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing
fail
Key: FLINK-21428
URL: https://issues.apache.org/jira/browse/FLINK-21428
Project
Guowei Ma created FLINK-21429:
-
Summary:
JsonFileCompactionITCase>CompactionITCaseBase.testNonPartition
Key: FLINK-21429
URL: https://issues.apache.org/jira/browse/FLINK-21429
Project: Flink
Iss
Guowei Ma created FLINK-21431:
-
Summary: UpsertKafkaTableITCase.testTemporalJoin hang
Key: FLINK-21431
URL: https://issues.apache.org/jira/browse/FLINK-21431
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21446:
-
Summary: KafkaProducerTestBase.testExactlyOnce Fail
Key: FLINK-21446
URL: https://issues.apache.org/jira/browse/FLINK-21446
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21447:
-
Summary: Resuming Savepoint (file, async, scale up) end-to-end
test Fail
Key: FLINK-21447
URL: https://issues.apache.org/jira/browse/FLINK-21447
Project: Flink
Is
Guowei Ma created FLINK-21470:
-
Summary: testSafetyNetClose fail
Key: FLINK-21470
URL: https://issues.apache.org/jira/browse/FLINK-21470
Project: Flink
Issue Type: Bug
Components: API /
Guowei Ma created FLINK-21497:
-
Summary:
FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover fail
Key: FLINK-21497
URL: https://issues.apache.org/jira/browse/FLINK-21497
Project: Fli
Guowei Ma created FLINK-21508:
-
Summary: CollectITCase hangs
Key: FLINK-21508
URL: https://issues.apache.org/jira/browse/FLINK-21508
Project: Flink
Issue Type: Bug
Components: API / Dat
Guowei Ma created FLINK-21550:
-
Summary: ZooKeeperHaServicesTest.testSimpleClose fail
Key: FLINK-21550
URL: https://issues.apache.org/jira/browse/FLINK-21550
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21551:
-
Summary: FlinkKafkaProducerITCase.testHappyPath fail
Key: FLINK-21551
URL: https://issues.apache.org/jira/browse/FLINK-21551
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21574:
-
Summary:
WindowDistinctAggregateITCase.testCumulateWindow_GroupingSets unstable
Key: FLINK-21574
URL: https://issues.apache.org/jira/browse/FLINK-21574
Project: Flink
Guowei Ma created FLINK-21593:
-
Summary: RocksDBListStatePerformanceTest.testRocksDbListStateAPI
fail because of timeout
Key: FLINK-21593
URL: https://issues.apache.org/jira/browse/FLINK-21593
Project: Fl
Guowei Ma created FLINK-21595:
-
Summary: DispatcherResourceManagerComponent.deregisterApplication
time-out
Key: FLINK-21595
URL: https://issues.apache.org/jira/browse/FLINK-21595
Project: Flink
Guowei Ma created FLINK-21596:
-
Summary:
CheckpointFailureManagerITCase.testAsyncCheckpointFailureTriggerJobFailed fail
Key: FLINK-21596
URL: https://issues.apache.org/jira/browse/FLINK-21596
Project: Fl
Guowei Ma created FLINK-21597:
-
Summary: testMapAfterRepartitionHasCorrectParallelism2 Fail
because of "NoResourceAvailableException"
Key: FLINK-21597
URL: https://issues.apache.org/jira/browse/FLINK-21597
Guowei Ma created FLINK-21598:
-
Summary: testDetachedModeSecureWithPreInstallKeytab fail
Key: FLINK-21598
URL: https://issues.apache.org/jira/browse/FLINK-21598
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21599:
-
Summary: execute[Parallel union, p =
10](org.apache.flink.test.checkpointing.UnalignedCheckpointITCase) failed
because of oom.
Key: FLINK-21599
URL: https://issues.apache.org/jira/brow
Guowei Ma created FLINK-21600:
-
Summary: Resuming Savepoint (rocks, no parallelism change, heap
timers) end-to-end test failed
Key: FLINK-21600
URL: https://issues.apache.org/jira/browse/FLINK-21600
Proje
Guowei Ma created FLINK-21644:
-
Summary: Resuming Savepoint (rocks, scale up, heap timers)
end-to-end test failed
Key: FLINK-21644
URL: https://issues.apache.org/jira/browse/FLINK-21644
Project: Flink
Guowei Ma created FLINK-21652:
-
Summary:
Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because
of throwing SocketTimeOut Exception during closing stage.
Key: FLINK-21652
URL: https://issues.
Guowei Ma created FLINK-21653:
-
Summary:
org.apache.flink.streaming.scala.api.TextOutputFormatITCase.testPath failed
because of "Not enough resources available for scheduling."
Key: FLINK-21653
URL: https://issues.ap
Guowei Ma created FLINK-21654:
-
Summary:
YARNSessionCapacitySchedulerITCase.testStartYarnSessionClusterInQaTeamQueue
fail because of NullPointerException
Key: FLINK-21654
URL: https://issues.apache.org/jira/browse/FL
Guowei Ma created FLINK-21659:
-
Summary: Running HA per-job cluster (rocks, incremental)
end-to-end test fails
Key: FLINK-21659
URL: https://issues.apache.org/jira/browse/FLINK-21659
Project: Flink
Guowei Ma created FLINK-21677:
-
Summary:
org.apache.flink.test.state.operator.restore.unkeyed.ChainBreakTest hangs
Key: FLINK-21677
URL: https://issues.apache.org/jira/browse/FLINK-21677
Project: Flink
Guowei Ma created FLINK-21728:
-
Summary: DegreesWithExceptionITCase crash
Key: FLINK-21728
URL: https://issues.apache.org/jira/browse/FLINK-21728
Project: Flink
Issue Type: Bug
Componen
Guowei Ma created FLINK-21729:
-
Summary: SimpleRecoveryFailureRateStrategyITBase fail
Key: FLINK-21729
URL: https://issues.apache.org/jira/browse/FLINK-21729
Project: Flink
Issue Type: Bug
Guowei Ma created FLINK-21740:
-
Summary: CliTableauResultViewTest.testCancelBatchResult fails
Key: FLINK-21740
URL: https://issues.apache.org/jira/browse/FLINK-21740
Project: Flink
Issue Type: B
Guowei Ma created FLINK-21779:
-
Summary:
testResourceCanBeAllocatedForDifferentJobWithDeclarationBeforeSlotFree fail
because of timeout
Key: FLINK-21779
URL: https://issues.apache.org/jira/browse/FLINK-21779
Guowei Ma created FLINK-21780:
-
Summary: SourceStreamTaskTest hangs (no output for 900 seconds)
Key: FLINK-21780
URL: https://issues.apache.org/jira/browse/FLINK-21780
Project: Flink
Issue Type:
Guowei Ma created FLINK-21809:
-
Summary: PyFlink end-to-end test fail
Key: FLINK-21809
URL: https://issues.apache.org/jira/browse/FLINK-21809
Project: Flink
Issue Type: Bug
Components:
Guowei Ma created FLINK-21832:
-
Summary: Avro Confluent Schema Registry nightly end-to-end fail
Key: FLINK-21832
URL: https://issues.apache.org/jira/browse/FLINK-21832
Project: Flink
Issue Type
1 - 100 of 179 matches
Mail list logo
