[jira] [Created] (FLINK-6072) TestCase CheckpointStateRestoreTest::testSetState should be fail

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

[jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator

[ https://issues.apache.org/jira/browse/FLINK-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944327#comment-15944327 ] Guowei Ma commented on FLINK-5892: -- hi [~Zentol] I am discussing the proposal with [~sric

[jira] [Commented] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16633622#comment-16633622 ] Guowei Ma commented on FLINK-10469: --- +1 > FileChannel may not write the whole buffer

[jira] [Commented] (FLINK-13840) Let StandaloneJobClusterEntrypoint use user code class loader

[ https://issues.apache.org/jira/browse/FLINK-13840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920265#comment-16920265 ] Guowei Ma commented on FLINK-13840: --- As Till said, it is an easy way to add a differen

[jira] [Created] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

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

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Fix Version/s: 1.10.0 > Using FlinkUserCodeClassLoaders to load the user class in the perjob mode > --

[jira] [Closed] (FLINK-13840) Let StandaloneJobClusterEntrypoint use user code class loader

[ https://issues.apache.org/jira/browse/FLINK-13840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-13840. - Resolution: Duplicate > Let StandaloneJobClusterEntrypoint use user code class loader >

[jira] [Commented] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16927484#comment-16927484 ] Guowei Ma commented on FLINK-13993: --- Thanks for reminding me. I'll close it. [~till.ro

[jira] [Commented] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930613#comment-16930613 ] Guowei Ma commented on FLINK-13993: --- I will do it. thanks. [~till.rohrmann] > Using F

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Remaining Estimate: 168h Original Estimate: 168h > Using FlinkUserCodeClassLoaders to load the us

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Remaining Estimate: 144h (was: 168h) Original Estimate: 144h (was: 168h) > Using FlinkUserCodeC

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Remaining Estimate: 48h (was: 144h) Original Estimate: 48h (was: 144h) > Using FlinkUserCodeCla

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Labels: pull-request-available (was: ) > Using FlinkUserCodeClassLoaders to load the user class in th

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Remaining Estimate: 30h (was: 48h) Original Estimate: 30h (was: 48h) > Using FlinkUserCodeClass

[jira] [Commented] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933201#comment-16933201 ] Guowei Ma commented on FLINK-13993: --- Sorry, I change the time. Actually, what I mean

[jira] [Comment Edited] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933201#comment-16933201 ] Guowei Ma edited comment on FLINK-13993 at 9/19/19 9:25 AM:

[jira] [Commented] (FLINK-20297) Make `SerializerTestBase::getTestData` return List

[ https://issues.apache.org/jira/browse/FLINK-20297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243025#comment-17243025 ] Guowei Ma commented on FLINK-20297: --- Sorry for replying so late. [~dwysakowicz] Ther

[jira] [Comment Edited] (FLINK-20297) Make `SerializerTestBase::getTestData` return List

[ https://issues.apache.org/jira/browse/FLINK-20297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243025#comment-17243025 ] Guowei Ma edited comment on FLINK-20297 at 12/3/20, 8:57 AM: -

[jira] [Commented] (FLINK-20297) Make `SerializerTestBase::getTestData` return List

[ https://issues.apache.org/jira/browse/FLINK-20297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243055#comment-17243055 ] Guowei Ma commented on FLINK-20297: --- I don't find any other case. Properly you are rig

[jira] [Closed] (FLINK-20297) Make `SerializerTestBase::getTestData` return List

[ https://issues.apache.org/jira/browse/FLINK-20297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-20297. - Resolution: Won't Fix > Make `SerializerTestBase::getTestData` return List > ---

[jira] [Created] (FLINK-20652) Improve the document for making the user could write a DataStream job that could be execute in the batch execution mode.

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

[jira] [Updated] (FLINK-20652) Improve the document for making the user could write a DataStream job that could be execute in the batch execution mode.

[ https://issues.apache.org/jira/browse/FLINK-20652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20652: -- Description: There are some users, that are from the `DataSet` or new Flink user, want to write a `Da

[jira] [Commented] (FLINK-19833) Rename Sink API Writer interface to SinkWriter

[ https://issues.apache.org/jira/browse/FLINK-19833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224659#comment-17224659 ] Guowei Ma commented on FLINK-19833: --- thanks [~kkl0u] no problem. > Rename Sink API Wr

[jira] [Created] (FLINK-19936) Make SinkITCase more stable

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

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Summary: Make SinkITCase stable (was: Make SinkITCase more stable) > Make SinkITCase stable > ---

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Description: In the streaming execution mode there are two uncertain things: # The order of receiving

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Description: In the streaming execution mode there are two uncertain things: # The order of receiving

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Description: In the streaming execution mode there are two uncertain things: # The order of receiving

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Description: In the streaming execution mode there are two uncertain things: # The order of receiving

[jira] [Commented] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225802#comment-17225802 ] Guowei Ma commented on FLINK-19936: --- Thanks [~sewen] . I think it might be the same re

[jira] [Created] (FLINK-19958) Unified exception signature in Sink API

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

[jira] [Updated] (FLINK-19958) Unified exception signature in Sink API

[ https://issues.apache.org/jira/browse/FLINK-19958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19958: -- Description: In the current Sink API some method does not throw any exception, which should throw int

[jira] [Updated] (FLINK-19958) Unified methods signature's exception in Sink API

[ https://issues.apache.org/jira/browse/FLINK-19958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19958: -- Summary: Unified methods signature's exception in Sink API (was: Unified exception signature in Sink

[jira] [Updated] (FLINK-19958) Adds the IOException to all the I/O related methods' signature.

[ https://issues.apache.org/jira/browse/FLINK-19958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19958: -- Summary: Adds the IOException to all the I/O related methods' signature. (was: Unified methods signat

[jira] [Updated] (FLINK-19958) Add the IOException to all the I/O related methods' signature.

[ https://issues.apache.org/jira/browse/FLINK-19958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19958: -- Summary: Add the IOException to all the I/O related methods' signature. (was: Adds the IOException to

[jira] [Updated] (FLINK-19958) Add the IOException to all the I/O related methods' signature in Sink API.

[ https://issues.apache.org/jira/browse/FLINK-19958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19958: -- Summary: Add the IOException to all the I/O related methods' signature in Sink API. (was: Add the IOE

[jira] [Created] (FLINK-19963) Let the `SinkWriter` support using the `TimerService`

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

[jira] [Updated] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19936: -- Attachment: image-2020-11-04-19-01-34-744.png > Make SinkITCase stable > -- > >

[jira] [Commented] (FLINK-19936) Make SinkITCase stable

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225991#comment-17225991 ] Guowei Ma commented on FLINK-19936: --- !image-2020-11-04-19-01-34-744.png! Thanks [~sew

[jira] [Created] (FLINK-20007) SinkTransformationTranslator fail to handle the PartitionTransformation

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

[jira] [Created] (FLINK-20031) Keep the uid of SinkWriter same as the SinkTransformation

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

[jira] [Updated] (FLINK-19697) Make the committer retry-able

[ https://issues.apache.org/jira/browse/FLINK-19697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19697: -- Summary: Make the committer retry-able (was: Make the streaming committer retry-able) > Make the com

[jira] [Commented] (FLINK-20113) Test K8s High Availability Service

[ https://issues.apache.org/jira/browse/FLINK-20113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231080#comment-17231080 ] Guowei Ma commented on FLINK-20113: --- Could assign this task to me. I can work for this

[jira] [Comment Edited] (FLINK-20113) Test K8s High Availability Service

[ https://issues.apache.org/jira/browse/FLINK-20113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231080#comment-17231080 ] Guowei Ma edited comment on FLINK-20113 at 11/13/20, 2:16 AM:

[jira] [Created] (FLINK-20203) Could not find any document about how to build a Flink image from local build.

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

[jira] [Commented] (FLINK-20113) Test K8s High Availability Service

[ https://issues.apache.org/jira/browse/FLINK-20113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234284#comment-17234284 ] Guowei Ma commented on FLINK-20113: --- [~fly_in_gis] ok. > Test K8s High Availability S

[jira] [Created] (FLINK-20206) Failed to start the session, but there is no clear prompt.

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

[jira] [Commented] (FLINK-18121) Support creating Docker image from local Flink distribution

[ https://issues.apache.org/jira/browse/FLINK-18121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234342#comment-17234342 ] Guowei Ma commented on FLINK-18121: --- +1 from the local file system. When I test https

[jira] [Created] (FLINK-20211) Can not get the JobManager web ip according to the document

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

[jira] [Updated] (FLINK-20211) Can not get the JobManager web ip according to the document

[ https://issues.apache.org/jira/browse/FLINK-20211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20211: -- Description: According to [https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deploymen

[jira] [Comment Edited] (FLINK-18121) Support creating Docker image from local Flink distribution

[ https://issues.apache.org/jira/browse/FLINK-18121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234342#comment-17234342 ] Guowei Ma edited comment on FLINK-18121 at 11/18/20, 9:13 AM:

[jira] [Created] (FLINK-20214) Unnecessary warning log when starting a k8s session cluster

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

[jira] [Updated] (FLINK-20203) Could not find any document about how to build a Flink image from local build.

[ https://issues.apache.org/jira/browse/FLINK-20203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20203: -- Component/s: Deployment / Kubernetes > Could not find any document about how to build a Flink image fr

[jira] [Updated] (FLINK-20203) Could not find any document about how to build a Flink image from local build.

[ https://issues.apache.org/jira/browse/FLINK-20203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20203: -- Description: If user wants to use or try some feature that does not include in the "official" Flink i

[jira] [Created] (FLINK-20215) Keep the "Access the Flink UI " document same in “Kubernetes Setup” and "Native Kubernetes Setup Beta"

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

[jira] [Updated] (FLINK-20215) Keep the "Access the Flink UI " document same in “Kubernetes Setup” and "Native Kubernetes Setup Beta"

[ https://issues.apache.org/jira/browse/FLINK-20215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20215: -- Priority: Critical (was: Major) > Keep the "Access the Flink UI " document same in “Kubernetes Setup”

[jira] [Updated] (FLINK-20215) Keep the "Access the Flink UI " document same in “Kubernetes Setup” and "Native Kubernetes Setup Beta"

[ https://issues.apache.org/jira/browse/FLINK-20215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20215: -- Description: Both the "https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/na

[jira] [Updated] (FLINK-20203) Could not find any document about how to build a Flink image from local build.

[ https://issues.apache.org/jira/browse/FLINK-20203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20203: -- Component/s: (was: Deployment / Kubernetes) Documentation > Could not find any do

[jira] [Created] (FLINK-20225) Break link in the document

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

[jira] [Updated] (FLINK-20215) Keep the "Access the Flink UI " document same in “Kubernetes Setup” and "Native Kubernetes Setup Beta"

[ https://issues.apache.org/jira/browse/FLINK-20215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20215: -- Component/s: (was: Deployment / Kubernetes) Documentation > Keep the "Access the

[jira] [Updated] (FLINK-20211) Can not get the JobManager web ip according to the document

[ https://issues.apache.org/jira/browse/FLINK-20211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20211: -- Component/s: (was: Deployment / Kubernetes) Documentation > Can not get the JobMa

[jira] [Commented] (FLINK-20113) Test K8s High Availability Service

[ https://issues.apache.org/jira/browse/FLINK-20113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234734#comment-17234734 ] Guowei Ma commented on FLINK-20113: --- I test four scenarios # Kubernetes ## Session C

[jira] [Updated] (FLINK-20083) OrcFsStreamingSinkITCase times out

[ https://issues.apache.org/jira/browse/FLINK-20083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20083: -- Attachment: image-2020-11-20-08-03-43-073.png > OrcFsStreamingSinkITCase times out > -

[jira] [Commented] (FLINK-20083) OrcFsStreamingSinkITCase times out

[ https://issues.apache.org/jira/browse/FLINK-20083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235798#comment-17235798 ] Guowei Ma commented on FLINK-20083: --- I found that `SplitFetcher` exits too early(line:

[jira] [Closed] (FLINK-20083) OrcFsStreamingSinkITCase times out

[ https://issues.apache.org/jira/browse/FLINK-20083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-20083. - Resolution: Fixed > OrcFsStreamingSinkITCase times out > -- > >

[jira] [Updated] (FLINK-20297) Make `SerializerTestBase::getTestData` return List

[ https://issues.apache.org/jira/browse/FLINK-20297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20297: -- Priority: Minor (was: Major) > Make `SerializerTestBase::getTestData` return List > -

[jira] [Created] (FLINK-20297) Make `SerializerTestBase::getTestData` return List

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

[jira] [Created] (FLINK-20337) Make migrate `StreamingFileSink` to `FileSink` possible

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:

[jira] [Created] (FLINK-20338) Make the SinkWriter load previous sink's state.

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

[jira] [Updated] (FLINK-20337) Make migrate `StreamingFileSink` to `FileSink` possible

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20337: -- Description: Flink-1.12 introduces the `FileSink` in FLINK-19510, which can guarantee the exactly onc

[jira] [Updated] (FLINK-20338) Make the StatefulSinkWriterOperator load previous sink's state.

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20338: -- Summary: Make the StatefulSinkWriterOperator load previous sink's state. (was: Make the SinkWriter lo

[jira] [Created] (FLINK-20339) `FileWriter` support to load StreamingFileSink's state.

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:

[jira] [Updated] (FLINK-20337) Make migrate `StreamingFileSink` to `FileSink` possible

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20337: -- Description: Flink-1.12 introduces the `FileSink` in FLINK-19510, which can guarantee the exactly onc

[jira] [Updated] (FLINK-20338) Make the `StatefulSinkWriterOperator` load previous `StreamingFileSink`'s state.

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20338: -- Summary: Make the `StatefulSinkWriterOperator` load previous `StreamingFileSink`'s state. (was: Make

[jira] [Updated] (FLINK-20337) Make migrate `StreamingFileSink` to `FileSink` possible

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20337: -- Description: Flink-1.12 introduces the `FileSink` in FLINK-19510, which can guarantee the exactly onc

[jira] [Updated] (FLINK-20338) Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state.

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20338: -- Summary: Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state. (was: Make the `Stat

[jira] [Commented] (FLINK-20337) Make migrate `StreamingFileSink` to `FileSink` possible

[ https://issues.apache.org/jira/browse/FLINK-20337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239098#comment-17239098 ] Guowei Ma commented on FLINK-20337: --- Sorry [~kkl0u] for responsing so late. I think it

[jira] [Closed] (FLINK-20338) Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state.

[ https://issues.apache.org/jira/browse/FLINK-20338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-20338. - Resolution: Won't Fix > Make the `StatefulSinkWriterOperator` load `StreamingFileSink`'s state. > --

[jira] [Closed] (FLINK-20339) `FileWriter` support to load StreamingFileSink's state.

[ https://issues.apache.org/jira/browse/FLINK-20339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-20339. - Resolution: Won't Fix > `FileWriter` support to load StreamingFileSink's state. > --

[jira] [Created] (FLINK-17038) Decouple resolving Type and creating TypeInformation process

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

[jira] [Updated] (FLINK-17038) Decouple resolving Type and creating TypeInformation process

[ https://issues.apache.org/jira/browse/FLINK-17038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-17038: -- Parent: FLINK-15674 Issue Type: Sub-task (was: Improvement) > Decouple resolving Type and cre

[jira] [Created] (FLINK-17039) Introduce TypeInformationExtractor interface

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

[jira] [Updated] (FLINK-17038) Decouple resolving Type from creating TypeInformation process

[ https://issues.apache.org/jira/browse/FLINK-17038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-17038: -- Summary: Decouple resolving Type from creating TypeInformation process (was: Decouple resolving Type

[jira] [Updated] (FLINK-17039) Introduce TypeInformationExtractor

[ https://issues.apache.org/jira/browse/FLINK-17039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-17039: -- Summary: Introduce TypeInformationExtractor (was: Introduce TypeInformationExtractor interface) > In

[jira] [Created] (FLINK-17041) Migrate current TypeInformation creation to the TypeInformationExtractor framework

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:

[jira] [Updated] (FLINK-17039) Introduce TypeInformationExtractor famework

[ https://issues.apache.org/jira/browse/FLINK-17039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-17039: -- Summary: Introduce TypeInformationExtractor famework (was: Introduce TypeInformationExtractor) > Int

[jira] [Created] (FLINK-19260) Update documentation based on bin/flink output

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

[jira] [Updated] (FLINK-19260) Update documentation based on bin/flink output

[ https://issues.apache.org/jira/browse/FLINK-19260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19260: -- Parent: FLINK-11779 Issue Type: Sub-task (was: Bug) > Update documentation based on bin/flink

[jira] [Created] (FLINK-19261) Update document according to RestOptions

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

[jira] [Updated] (FLINK-19261) Update documentation about `RestOptions`

[ https://issues.apache.org/jira/browse/FLINK-19261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19261: -- Summary: Update documentation about `RestOptions` (was: Update document according to RestOptions) >

[jira] [Updated] (FLINK-19260) Update documentation based on bin/flink output

[ https://issues.apache.org/jira/browse/FLINK-19260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19260: -- Component/s: (was: Command Line Client) > Update documentation based on bin/flink output > ---

[jira] [Created] (FLINK-19373) `jmx.server.port`'s document is missing.

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

[jira] [Created] (FLINK-19374) update the `table.exec.state.ttl`'s documentation

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

[jira] [Created] (FLINK-19375) The `kubernetes.secrets` and `kubernetes.env.secretKeyRef`'s document is missing

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

[jira] [Updated] (FLINK-19375) The `kubernetes.secrets` and `kubernetes.env.secretKeyRef`'s document is needed to be update

[ https://issues.apache.org/jira/browse/FLINK-19375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-19375: -- Summary: The `kubernetes.secrets` and `kubernetes.env.secretKeyRef`'s document is needed to be update

[jira] [Updated] (FLINK-19375) The `kubernetes.secrets` and `kubernetes.env.secretKeyRef`'s document needed update

[jira] [Created] (FLINK-19376) `table.generated-code.max-length` and `table.sql-dialec` 's document is needed to be updated

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

[jira] [Closed] (FLINK-19261) Update documentation about `RestOptions`

[ https://issues.apache.org/jira/browse/FLINK-19261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-19261. - Resolution: Invalid > Update documentation about `RestOptions` > ---

[jira] [Closed] (FLINK-19260) Update documentation based on bin/flink output

[ https://issues.apache.org/jira/browse/FLINK-19260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-19260. - Resolution: Invalid > Update documentation based on bin/flink output > -

[jira] [Commented] (FLINK-19373) `jmx.server.port`'s document is missing.

[ https://issues.apache.org/jira/browse/FLINK-19373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17200726#comment-17200726 ] Guowei Ma commented on FLINK-19373: --- It makes sense. I will do it. > `jmx.server.port

  1   2   3   4   5   6   7   8   9   10   >