[jira] [Commented] (FLINK-20686) CLI help message should include 'run-application' action

[ https://issues.apache.org/jira/browse/FLINK-20686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252758#comment-17252758 ] Kostas Kloudas commented on FLINK-20686: Yes, I think so too [~fly_in_gis] > CLI help message

[jira] [Commented] (FLINK-20687) Missing 'yarn-application' target in CLI help message

[ https://issues.apache.org/jira/browse/FLINK-20687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252516#comment-17252516 ] Kostas Kloudas commented on FLINK-20687: Hi [~jiang7chengzitc], you are right about the

[jira] [Closed] (FLINK-19969) CliFrontendParser does not provide any help for run-application

[ https://issues.apache.org/jira/browse/FLINK-19969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19969. -- Fix Version/s: 1.13.0 Resolution: Fixed master:

[jira] [Closed] (FLINK-20304) Fail hard when trying to run job with broadcast state in BATCH execution mode

[ https://issues.apache.org/jira/browse/FLINK-20304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-20304. -- Fix Version/s: 1.13.0 Resolution: Fixed master:

[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=17238592#comment-17238592 ] Kostas Kloudas commented on FLINK-20337: [~maguowei] I think that all this could become a single

[jira] [Closed] (FLINK-20180) Translation the FileSink Document into Chinese

[ https://issues.apache.org/jira/browse/FLINK-20180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-20180. -- Resolution: Implemented master: 8abaaecf72e122b02d6194897245c071901a88a9 > Translation the

[jira] [Updated] (FLINK-20180) Translation the FileSink Document into Chinese

[ https://issues.apache.org/jira/browse/FLINK-20180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-20180: --- Component/s: Documentation > Translation the FileSink Document into Chinese >

[jira] [Assigned] (FLINK-20180) Translation the FileSink Document into Chinese

[ https://issues.apache.org/jira/browse/FLINK-20180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-20180: -- Assignee: Yun Gao > Translation the FileSink Document into Chinese >

[jira] [Updated] (FLINK-20180) Translation the FileSink Document into Chinese

[ https://issues.apache.org/jira/browse/FLINK-20180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-20180: --- Affects Version/s: 1.12.0 > Translation the FileSink Document into Chinese >

[jira] [Assigned] (FLINK-19969) CliFrontendParser does not provide any help for run-application

[ https://issues.apache.org/jira/browse/FLINK-19969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19969: -- Assignee: Kostas Kloudas > CliFrontendParser does not provide any help for

[jira] [Closed] (FLINK-20240) Add setter in the environment for the `execution.runtime-mode`

[ https://issues.apache.org/jira/browse/FLINK-20240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-20240. -- Fix Version/s: 1.12.0 Resolution: Implemented master:

[jira] [Created] (FLINK-20240) Add setter in the environment for the `execution.runtime-mode`

Kostas Kloudas created FLINK-20240: -- Summary: Add setter in the environment for the `execution.runtime-mode` Key: FLINK-20240 URL: https://issues.apache.org/jira/browse/FLINK-20240 Project: Flink

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235328#comment-17235328 ] Kostas Kloudas commented on FLINK-20115: [~trohrmann] I will add the setter. I do not think that

[jira] [Commented] (FLINK-20115) Test Batch execution for the DataStream API 

[ https://issues.apache.org/jira/browse/FLINK-20115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17234572#comment-17234572 ] Kostas Kloudas commented on FLINK-20115: Of course we can add it if we think that this can help

[jira] [Closed] (FLINK-20197) FileSink fails with UnsupportedOperationException when using default values

[ https://issues.apache.org/jira/browse/FLINK-20197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-20197. -- Resolution: Fixed master: ac94befe5992ce34d9c3e5050a485e8aa2681cd3 > FileSink fails with

[jira] [Closed] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-20143. -- Fix Version/s: 1.11.3 1.12.0 Resolution: Fixed master:

[jira] [Commented] (FLINK-10029) Refactor Streaming File Sink for better separation of concerns.

[ https://issues.apache.org/jira/browse/FLINK-10029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233721#comment-17233721 ] Kostas Kloudas commented on FLINK-10029: Hi [~neighborhood], to which classes are you referring

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233592#comment-17233592 ] Kostas Kloudas commented on FLINK-20143: Yes, I will try to merge it today and hopefully it will

[jira] [Closed] (FLINK-20141) Add documentation about the FileSink

[ https://issues.apache.org/jira/browse/FLINK-20141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-20141. -- Resolution: Fixed master: 2162fc25f933dda20678b7faa810ddf75395c930 > Add documentation about

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232791#comment-17232791 ] Kostas Kloudas commented on FLINK-19461: So [~azagrebin] you think that this issue can be

[jira] [Assigned] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-20143: -- Assignee: Yang Wang > use `yarn.provided.lib.dirs` config deploy job failed in yarn

[jira] [Updated] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-20143: --- Affects Version/s: 1.11.2 > use `yarn.provided.lib.dirs` config deploy job failed in yarn

[jira] [Closed] (FLINK-20152) Document which execution.target values are supported

[ https://issues.apache.org/jira/browse/FLINK-20152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-20152. -- Resolution: Fixed master: 4e74e08d84f4a074db0f4272690243c8c6c45844 release-1.11:

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232590#comment-17232590 ] Kostas Kloudas commented on FLINK-20143: Thanks [~fly_in_gis], feel free to ping me for a

[jira] [Commented] (FLINK-20152) Document which execution.target values are supported

[ https://issues.apache.org/jira/browse/FLINK-20152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232065#comment-17232065 ] Kostas Kloudas commented on FLINK-20152: That is correct. I will remove then the

[jira] [Commented] (FLINK-20152) Document which execution.target values are supported

[ https://issues.apache.org/jira/browse/FLINK-20152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231604#comment-17231604 ] Kostas Kloudas commented on FLINK-20152: The problem is though that the *-application options it

[jira] [Commented] (FLINK-20152) Document which execution.target values are supported

[ https://issues.apache.org/jira/browse/FLINK-20152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231583#comment-17231583 ] Kostas Kloudas commented on FLINK-20152: Yes. I will open a PR. > Document which

[jira] [Commented] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231575#comment-17231575 ] Kostas Kloudas commented on FLINK-19461: I think that this has to do with how we split the total

[jira] [Comment Edited] (FLINK-19461) yarn-sesson.sh -jm -tm arguments have no effect

[ https://issues.apache.org/jira/browse/FLINK-19461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231575#comment-17231575 ] Kostas Kloudas edited comment on FLINK-19461 at 11/13/20, 3:47 PM: --- I

[jira] [Assigned] (FLINK-20152) Document which execution.target values are supported

[ https://issues.apache.org/jira/browse/FLINK-20152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-20152: -- Assignee: Kostas Kloudas > Document which execution.target values are supported >

[jira] [Commented] (FLINK-20152) Document which execution.target values are supported

[ https://issues.apache.org/jira/browse/FLINK-20152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231571#comment-17231571 ] Kostas Kloudas commented on FLINK-20152: Actually

[jira] [Commented] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231540#comment-17231540 ] Kostas Kloudas commented on FLINK-19358: [~trohrmann] From the discussion here it seems that we

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231522#comment-17231522 ] Kostas Kloudas commented on FLINK-20143: [~fly_in_gis] do you have an idea about this issue? >

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231415#comment-17231415 ] Kostas Kloudas commented on FLINK-20143: Hi [~zhisheng], I run the command that I wrote in my

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231361#comment-17231361 ] Kostas Kloudas commented on FLINK-20143: Also could you run the same command with DEBUG logging

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231360#comment-17231360 ] Kostas Kloudas commented on FLINK-20143: Can't you use {{yarn logs -applicationId

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231326#comment-17231326 ] Kostas Kloudas commented on FLINK-20143: Also the above command seems to be problematic.

[jira] [Comment Edited] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231306#comment-17231306 ] Kostas Kloudas edited comment on FLINK-20143 at 11/13/20, 9:28 AM: --- As

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231306#comment-17231306 ] Kostas Kloudas commented on FLINK-20143: As discussed in the issue, you have to specify the full

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231301#comment-17231301 ] Kostas Kloudas commented on FLINK-20143: I am not sure if I can figure out what is happening

[jira] [Comment Edited] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231283#comment-17231283 ] Kostas Kloudas edited comment on FLINK-20143 at 11/13/20, 9:19 AM: ---

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231283#comment-17231283 ] Kostas Kloudas commented on FLINK-20143: Also I think that your second command is not correct.

[jira] [Commented] (FLINK-20143) use `yarn.provided.lib.dirs` config deploy job failed in yarn per job mode

[ https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231276#comment-17231276 ] Kostas Kloudas commented on FLINK-20143: Can you share with us the job manager and task manager

[jira] [Created] (FLINK-20141) Add documentation about the FileSink

Kostas Kloudas created FLINK-20141: -- Summary: Add documentation about the FileSink Key: FLINK-20141 URL: https://issues.apache.org/jira/browse/FLINK-20141 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-20020) Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract.

[ https://issues.apache.org/jira/browse/FLINK-20020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-20020: -- Assignee: Nicholas Jiang > Make UnsuccessfulExecutionException part of the >

[jira] [Commented] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228363#comment-17228363 ] Kostas Kloudas commented on FLINK-19973: Thanks a lot [~zhisheng]! > 【Flink-Deployment】YARN CLI

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

[ https://issues.apache.org/jira/browse/FLINK-19697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19697: -- Assignee: Guowei Ma > Make the committer retry-able > -

[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 ] Kostas Kloudas updated FLINK-19697: --- Affects Version/s: 1.12.0 > Make the committer retry-able > - >

[jira] [Commented] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227866#comment-17227866 ] Kostas Kloudas commented on FLINK-19973: Shall we close this issue [~zhisheng]? >

[jira] [Closed] (FLINK-20032) Make FileSink support processing time

[ https://issues.apache.org/jira/browse/FLINK-20032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-20032. -- Fix Version/s: 1.12.0 Assignee: Yun Gao Resolution: Implemented master:

[jira] [Updated] (FLINK-19963) Give SinkWriter access to processing-time service

[ https://issues.apache.org/jira/browse/FLINK-19963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19963: --- Fix Version/s: 1.12.0 > Give SinkWriter access to processing-time service >

[jira] [Closed] (FLINK-19963) Give SinkWriter access to processing-time service

[ https://issues.apache.org/jira/browse/FLINK-19963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19963. -- Resolution: Implemented master: 0ccea4309ff709b5ea3dfc1bc1cc3dc727d6f96a > Give SinkWriter

[jira] [Updated] (FLINK-19963) Give SinkWriter access to processing-time service

[ https://issues.apache.org/jira/browse/FLINK-19963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19963: --- Affects Version/s: 1.12.0 > Give SinkWriter access to processing-time service >

[jira] [Assigned] (FLINK-19963) Give SinkWriter access to processing-time service

[ https://issues.apache.org/jira/browse/FLINK-19963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19963: -- Assignee: Guowei Ma > Give SinkWriter access to processing-time service >

[jira] [Assigned] (FLINK-20020) Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract.

[ https://issues.apache.org/jira/browse/FLINK-20020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-20020: -- Assignee: (was: Kostas Kloudas) > Make UnsuccessfulExecutionException part of

[jira] [Created] (FLINK-20020) Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract.

Kostas Kloudas created FLINK-20020: -- Summary: Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract. Key: FLINK-20020 URL: https://issues.apache.org/jira/browse/FLINK-20020

[jira] [Closed] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19909. -- Resolution: Fixed master: 2422fb5fc9da3aac95bbd52a6cac7d11479c1ae1 1.11:

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

[ https://issues.apache.org/jira/browse/FLINK-20007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-20007: --- Component/s: Connectors / Common > SinkTransformationTranslator fail to handle the

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

[ https://issues.apache.org/jira/browse/FLINK-20007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-20007. -- Fix Version/s: 1.12.0 Assignee: Guowei Ma Resolution: Fixed master:

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

[ https://issues.apache.org/jira/browse/FLINK-20007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-20007: --- Affects Version/s: 1.12.0 > SinkTransformationTranslator fail to handle the

[jira] [Closed] (FLINK-19993) Remove the flink-connector-filesystem module

[ https://issues.apache.org/jira/browse/FLINK-19993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19993. -- Fix Version/s: 1.12.0 Resolution: Implemented master:

[jira] [Assigned] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19973: -- Assignee: Kostas Kloudas > 【Flink-Deployment】YARN CLI Parameter doesn't work when

[jira] [Comment Edited] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226634#comment-17226634 ] Kostas Kloudas edited comment on FLINK-19973 at 11/5/20, 10:40 AM: ---

[jira] [Comment Edited] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226634#comment-17226634 ] Kostas Kloudas edited comment on FLINK-19973 at 11/5/20, 10:38 AM: ---

[jira] [Commented] (FLINK-19973) 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target: yarn-per-job` config

[ https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226634#comment-17226634 ] Kostas Kloudas commented on FLINK-19973: Yes, this is because if you set the {{execution.target:

[jira] [Created] (FLINK-19993) Remove the flink-connector-filesystem module

Kostas Kloudas created FLINK-19993: -- Summary: Remove the flink-connector-filesystem module Key: FLINK-19993 URL: https://issues.apache.org/jira/browse/FLINK-19993 Project: Flink Issue Type:

[jira] [Updated] (FLINK-19993) Remove the flink-connector-filesystem module

[ https://issues.apache.org/jira/browse/FLINK-19993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19993: --- Description: The flink-connector-filesystem module contains (only) the deprecated

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

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19936. -- Fix Version/s: 1.12.0 Resolution: Fixed master:

[jira] [Comment Edited] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225613#comment-17225613 ] Kostas Kloudas edited comment on FLINK-19909 at 11/3/20, 6:52 PM: --

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225613#comment-17225613 ] Kostas Kloudas commented on FLINK-19909: There is an open PR. It would be great if [~fly_in_gis]

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

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19936: --- Affects Version/s: 1.12.0 > Make SinkITCase stable > -- > >

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

[ https://issues.apache.org/jira/browse/FLINK-19936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19936: -- Assignee: Guowei Ma > Make SinkITCase stable > -- > >

[jira] [Closed] (FLINK-19760) Make the `GlobalCommitter` a standalone interface that does not extend the `Committer`

[ https://issues.apache.org/jira/browse/FLINK-19760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19760. -- Fix Version/s: 1.12.0 Resolution: Implemented master:

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

[ https://issues.apache.org/jira/browse/FLINK-19833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19833. -- Resolution: Implemented master: 34d0a9c84fbb43b5c2fc77c0932ba1dd1c22dbf4 > Rename Sink API

[jira] [Closed] (FLINK-19841) Rename GlobalStreamingCommitterOperator to StreamingGlobalCommitterOperator

[ https://issues.apache.org/jira/browse/FLINK-19841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19841. -- Fix Version/s: 1.12.0 Resolution: Implemented master:

[jira] [Comment Edited] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224523#comment-17224523 ] Kostas Kloudas edited comment on FLINK-19909 at 11/2/20, 9:16 AM: -- Yes

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224523#comment-17224523 ] Kostas Kloudas commented on FLINK-19909: Yes [~trohrmann] I phrased it wrongly before. But this

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224486#comment-17224486 ] Kostas Kloudas commented on FLINK-19909: Thanks for the logs [~fly_in_gis], I am having a look

[jira] [Assigned] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19909: -- Assignee: Kostas Kloudas > Flink application in attach mode could not terminate when

[jira] [Comment Edited] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224241#comment-17224241 ] Kostas Kloudas edited comment on FLINK-19909 at 11/2/20, 8:03 AM: --

[jira] [Updated] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19909: --- Fix Version/s: 1.11.3 > Flink application in attach mode could not terminate when the only

[jira] [Updated] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19909: --- Affects Version/s: 1.11.3 > Flink application in attach mode could not terminate when the

[jira] [Updated] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19909: --- Priority: Blocker (was: Critical) > Flink application in attach mode could not terminate

[jira] [Comment Edited] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224253#comment-17224253 ] Kostas Kloudas edited comment on FLINK-19909 at 11/1/20, 12:58 PM: ---

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224253#comment-17224253 ] Kostas Kloudas commented on FLINK-19909: [~fly_in_gis] We want different behaviour when we

[jira] [Commented] (FLINK-19909) Flink application in attach mode could not terminate when the only job is canceled

[ https://issues.apache.org/jira/browse/FLINK-19909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17224241#comment-17224241 ] Kostas Kloudas commented on FLINK-19909: Thanks for opening this [~fly_in_gis]! I changed this

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

[ https://issues.apache.org/jira/browse/FLINK-19833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19833: -- Assignee: Kostas Kloudas > Rename Sink API Writer interface to SinkWriter >

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

[ https://issues.apache.org/jira/browse/FLINK-19833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19833: --- Affects Version/s: 1.12.0 > Rename Sink API Writer interface to SinkWriter >

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

[ https://issues.apache.org/jira/browse/FLINK-19833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19833: --- Fix Version/s: 1.12.0 > Rename Sink API Writer interface to SinkWriter >

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

[ https://issues.apache.org/jira/browse/FLINK-19833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19833: -- Assignee: Guowei Ma (was: Kostas Kloudas) > Rename Sink API Writer interface to

[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=17222067#comment-17222067 ] Kostas Kloudas commented on FLINK-19833: Given that for the Sink work there are already open

[jira] [Updated] (FLINK-19834) Make the TestSink reusable in all the sink related tests.

[ https://issues.apache.org/jira/browse/FLINK-19834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19834: --- Component/s: Tests > Make the TestSink reusable in all the sink related tests. >

[jira] [Updated] (FLINK-19834) Make the TestSink reusable in all the sink related tests.

[ https://issues.apache.org/jira/browse/FLINK-19834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19834: --- Affects Version/s: 1.12.0 > Make the TestSink reusable in all the sink related tests. >

[jira] [Updated] (FLINK-19834) Make the TestSink reusable in all the sink related tests.

[ https://issues.apache.org/jira/browse/FLINK-19834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19834: --- Fix Version/s: 1.12.0 > Make the TestSink reusable in all the sink related tests. >

[jira] [Assigned] (FLINK-19834) Make the TestSink reusable in all the sink related tests.

[ https://issues.apache.org/jira/browse/FLINK-19834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19834: -- Assignee: Guowei Ma > Make the TestSink reusable in all the sink related tests. >

[jira] [Updated] (FLINK-19814) Disable FeedbackTransformation for BATCH mode

[ https://issues.apache.org/jira/browse/FLINK-19814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19814: --- Fix Version/s: 1.12.0 > Disable FeedbackTransformation for BATCH mode >

[jira] [Closed] (FLINK-19815) Disable CoFeedbackTransformation for BATCH mode

[ https://issues.apache.org/jira/browse/FLINK-19815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19815. -- Resolution: Implemented master: 756995330b01285b63fb8601d971d98af1616fff > Disable

[jira] [Updated] (FLINK-19815) Disable CoFeedbackTransformation for BATCH mode

[ https://issues.apache.org/jira/browse/FLINK-19815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19815: --- Fix Version/s: 1.12.0 > Disable CoFeedbackTransformation for BATCH mode >

[jira] [Closed] (FLINK-19814) Disable FeedbackTransformation for BATCH mode

[ https://issues.apache.org/jira/browse/FLINK-19814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-19814. -- Resolution: Implemented master: 74300e83442be84b9c69c6f88e20103181c10464 > Disable

[jira] [Updated] (FLINK-19815) Disable CoFeedbackTransformation for BATCH mode

[ https://issues.apache.org/jira/browse/FLINK-19815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-19815: --- Affects Version/s: 1.12.0 > Disable CoFeedbackTransformation for BATCH mode >

  1   2   3   4   5   6   7   8   9   10   >