[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17444: --- Priority: Minor (was: Major) > StreamingFileSink Azure HadoopRecoverableWriter class

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112523#comment-17112523 ] Kostas Kloudas commented on FLINK-17444: So from the discussion here, I think that this is not a

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17444: --- Issue Type: New Feature (was: Bug) > StreamingFileSink Azure HadoopRecoverableWriter class

[jira] [Comment Edited] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111903#comment-17111903 ] Kostas Kloudas edited comment on FLINK-17745 at 5/20/20, 8:44 AM: --

[jira] [Comment Edited] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111903#comment-17111903 ] Kostas Kloudas edited comment on FLINK-17745 at 5/20/20, 8:44 AM: --

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111903#comment-17111903 ] Kostas Kloudas commented on FLINK-17745: [~Echo Lee] Is it ok if we open a discussion in the ML

[jira] [Assigned] (FLINK-17819) Yarn error unhelpful when forgetting HADOOP_CLASSPATH

[ https://issues.apache.org/jira/browse/FLINK-17819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17819: -- Assignee: Kostas Kloudas > Yarn error unhelpful when forgetting HADOOP_CLASSPATH >

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111881#comment-17111881 ] Kostas Kloudas commented on FLINK-17745: [~Echo Lee] I also think that we can close this issue

[jira] [Commented] (FLINK-14982) YARN IT Test Case log config is mistakenly disabled

[ https://issues.apache.org/jira/browse/FLINK-14982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111230#comment-17111230 ] Kostas Kloudas commented on FLINK-14982: I would be up also for making the option visible and

[jira] [Commented] (FLINK-14982) YARN IT Test Case log config is mistakenly disabled

[ https://issues.apache.org/jira/browse/FLINK-14982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111229#comment-17111229 ] Kostas Kloudas commented on FLINK-14982: [~trohrmann] the

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111214#comment-17111214 ] Kostas Kloudas commented on FLINK-17745: [~Echo Lee] if I understand correctly the structure of

[jira] [Commented] (FLINK-14982) YARN IT Test Case log config is mistakenly disabled

[ https://issues.apache.org/jira/browse/FLINK-14982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1794#comment-1794 ] Kostas Kloudas commented on FLINK-14982: [~ZhenqiuHuang] are you planning to integrate

[jira] [Commented] (FLINK-14982) YARN IT Test Case log config is mistakenly disabled

[ https://issues.apache.org/jira/browse/FLINK-14982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1783#comment-1783 ] Kostas Kloudas commented on FLINK-14982: In all other cases, job submission goes through the

[jira] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17745: --- Fix Version/s: (was: 1.11.0) > PackagedProgram' extractedTempLibraries and jarfiles may

[jira] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17745: --- Affects Version/s: (was: 1.11.0) > PackagedProgram' extractedTempLibraries and jarfiles

[jira] [Comment Edited] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111007#comment-17111007 ] Kostas Kloudas edited comment on FLINK-17745 at 5/19/20, 9:27 AM: -- Hi

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111007#comment-17111007 ] Kostas Kloudas commented on FLINK-17745: Hi all, from the removed code in the PR, we were

[jira] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17745: --- Affects Version/s: (was: 1.10.0) 1.11.0 > PackagedProgram'

[jira] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17745: --- Issue Type: Improvement (was: Bug) > PackagedProgram' extractedTempLibraries and jarfiles

[jira] [Assigned] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17745: -- Assignee: Kostas Kloudas > PackagedProgram' extractedTempLibraries and jarfiles may

[jira] [Updated] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17745: --- Fix Version/s: (was: 1.10.0) 1.11.0 > PackagedProgram'

[jira] [Closed] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17796. -- Resolution: Fixed Merged on master with b591f906685ee1379d791d296bd0b305cc7e9bb7 and on

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110346#comment-17110346 ] Kostas Kloudas commented on FLINK-17444: This is the documentation issue

[jira] [Updated] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17796: --- Priority: Critical (was: Major) > Application mode should respect user specified classpath

[jira] [Updated] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17796: --- Fix Version/s: 1.11.0 > Application mode should respect user specified classpath

[jira] [Updated] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17796: --- Component/s: Client / Job Submission > Application mode should respect user specified

[jira] [Assigned] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17796: -- Assignee: Yang Wang > Application mode should respect user specified classpath

[jira] [Updated] (FLINK-17796) Application mode should respect user specified classpath configuration

[ https://issues.apache.org/jira/browse/FLINK-17796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17796: --- Affects Version/s: 1.11.0 > Application mode should respect user specified classpath

[jira] [Closed] (FLINK-17729) Make mandatory to have lib/, plugin/ and dist in yarn.provided.lib.dirs

[ https://issues.apache.org/jira/browse/FLINK-17729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17729. -- Resolution: Fixed Merged on master with 6d973180179bb88407e19bfdb0fb7e0af64572f6 > Make

[jira] [Closed] (FLINK-17632) Support to specify a remote path for job jar

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

[jira] [Created] (FLINK-17729) Make mandatory to have lib/, plugin/ and dist in yarn.provided.lib.dirs

Kostas Kloudas created FLINK-17729: -- Summary: Make mandatory to have lib/, plugin/ and dist in yarn.provided.lib.dirs Key: FLINK-17729 URL: https://issues.apache.org/jira/browse/FLINK-17729 Project:

[jira] [Closed] (FLINK-10934) Support application mode in kubernetes

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

[jira] [Comment Edited] (FLINK-17631) Supports char type for ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-17631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106249#comment-17106249 ] Kostas Kloudas edited comment on FLINK-17631 at 5/13/20, 12:14 PM: ---

[jira] [Commented] (FLINK-17631) Supports char type for ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-17631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106249#comment-17106249 ] Kostas Kloudas commented on FLINK-17631: Thanks for the quick replies [~jark] [~twalthr] and

[jira] [Closed] (FLINK-17648) YarnApplicationClusterEntryPoint should override getRPCPortRange

[ https://issues.apache.org/jira/browse/FLINK-17648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17648. -- Resolution: Fixed Merged on master with 09495d1bb4174e4ad32e5c62ca51a564aec1dbca >

[jira] [Assigned] (FLINK-17632) Support to specify a remote path for job jar

[ https://issues.apache.org/jira/browse/FLINK-17632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17632: -- Assignee: Yang Wang > Support to specify a remote path for job jar >

[jira] [Commented] (FLINK-17500) Deploy JobGraph from file in StandaloneClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106112#comment-17106112 ] Kostas Kloudas commented on FLINK-17500: Done :) > Deploy JobGraph from file in

[jira] [Assigned] (FLINK-17500) Deploy JobGraph from file in StandaloneClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17500: -- Assignee: Fabian Paul > Deploy JobGraph from file in StandaloneClusterEntrypoint >

[jira] [Assigned] (FLINK-17648) YarnApplicationClusterEntryPoint should override getRPCPortRange

[ https://issues.apache.org/jira/browse/FLINK-17648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17648: -- Assignee: Kostas Kloudas > YarnApplicationClusterEntryPoint should override

[jira] [Updated] (FLINK-17648) YarnApplicationClusterEntryPoint should override getRPCPortRange

[ https://issues.apache.org/jira/browse/FLINK-17648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17648: --- Component/s: Client / Job Submission > YarnApplicationClusterEntryPoint should override

[jira] [Updated] (FLINK-17648) YarnApplicationClusterEntryPoint should override getRPCPortRange

[ https://issues.apache.org/jira/browse/FLINK-17648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17648: --- Affects Version/s: 1.11.0 > YarnApplicationClusterEntryPoint should override

[jira] [Updated] (FLINK-17648) YarnApplicationClusterEntryPoint should override getRPCPortRange

[ https://issues.apache.org/jira/browse/FLINK-17648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17648: --- Fix Version/s: 1.11.0 > YarnApplicationClusterEntryPoint should override getRPCPortRange >

[jira] [Commented] (FLINK-17648) YarnApplicationClusterEntryPoint should override getRPCPortRange

[ https://issues.apache.org/jira/browse/FLINK-17648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106029#comment-17106029 ] Kostas Kloudas commented on FLINK-17648: Yes you are right [~fly_in_gis]! Are you working on it?

[jira] [Closed] (FLINK-17620) Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint

[ https://issues.apache.org/jira/browse/FLINK-17620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17620. -- Resolution: Implemented Merged on master with 6f724019eb1b751934081572175c14f120510103 >

[jira] [Updated] (FLINK-17632) Support to specify a remote path for job jar

[ https://issues.apache.org/jira/browse/FLINK-17632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17632: --- Affects Version/s: 1.11.0 > Support to specify a remote path for job jar >

[jira] [Created] (FLINK-17639) Document which FileSystems are supported by the StreamingFileSink

Kostas Kloudas created FLINK-17639: -- Summary: Document which FileSystems are supported by the StreamingFileSink Key: FLINK-17639 URL: https://issues.apache.org/jira/browse/FLINK-17639 Project: Flink

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105529#comment-17105529 ] Kostas Kloudas commented on FLINK-17444: That maybe could help as by now we support more

[jira] [Updated] (FLINK-13938) Use pre-uploaded libs to accelerate flink submission

[ https://issues.apache.org/jira/browse/FLINK-13938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-13938: --- Affects Version/s: 1.11.0 > Use pre-uploaded libs to accelerate flink submission >

[jira] [Closed] (FLINK-13938) Use pre-uploaded libs to accelerate flink submission

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

[jira] [Comment Edited] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105372#comment-17105372 ] Kostas Kloudas edited comment on FLINK-17444 at 5/12/20, 12:25 PM: ---

[jira] [Comment Edited] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105372#comment-17105372 ] Kostas Kloudas edited comment on FLINK-17444 at 5/12/20, 12:19 PM: ---

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105372#comment-17105372 ] Kostas Kloudas commented on FLINK-17444: What [~trohrmann] says is correct and it seems that

[jira] [Commented] (FLINK-17631) Supports char type for ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-17631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105332#comment-17105332 ] Kostas Kloudas commented on FLINK-17631: I see, but can't the validation happen at the user of

[jira] [Commented] (FLINK-17631) Supports char type for ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-17631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105318#comment-17105318 ] Kostas Kloudas commented on FLINK-17631: Hi [~danny0405], could you please explain what is the

[jira] [Created] (FLINK-17620) Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint

Kostas Kloudas created FLINK-17620: -- Summary: Rename StandaloneJobClusterEntryPoint to StandaloneApplicationClusterEntryPoint Key: FLINK-17620 URL: https://issues.apache.org/jira/browse/FLINK-17620

[jira] [Closed] (FLINK-17515) Move YARN staging functionality to a separate class

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

[jira] [Commented] (FLINK-16733) Refactor YarnClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-16733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099683#comment-17099683 ] Kostas Kloudas commented on FLINK-16733: Thanks a lot [~xintongsong]! I will move on then :) >

[jira] [Comment Edited] (FLINK-17515) Move YARN staging functionality to a separate class

[ https://issues.apache.org/jira/browse/FLINK-17515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099666#comment-17099666 ] Kostas Kloudas edited comment on FLINK-17515 at 5/5/20, 8:41 AM: -

[jira] [Commented] (FLINK-17515) Move YARN staging functionality to a separate class

[ https://issues.apache.org/jira/browse/FLINK-17515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099666#comment-17099666 ] Kostas Kloudas commented on FLINK-17515: [~felixzheng] sorry I also replied to the parent issue 

[jira] [Commented] (FLINK-16733) Refactor YarnClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-16733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099661#comment-17099661 ] Kostas Kloudas commented on FLINK-16733: Sorry, I just saw the last two comments.  I was not

[jira] [Commented] (FLINK-17515) Move YARN staging functionality to a separate class

[ https://issues.apache.org/jira/browse/FLINK-17515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099647#comment-17099647 ] Kostas Kloudas commented on FLINK-17515: Thanks for the comment [~felixzheng] . The code that I

[jira] [Created] (FLINK-17515) Move file uploading functionality to a separate class

Kostas Kloudas created FLINK-17515: -- Summary: Move file uploading functionality to a separate class Key: FLINK-17515 URL: https://issues.apache.org/jira/browse/FLINK-17515 Project: Flink

[jira] [Closed] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable

[ https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8799. - Resolution: Not A Problem > Make AbstractYarnClusterDescriptor immutable >

[jira] [Closed] (FLINK-11388) Add an OSS RecoverableWriter

[ https://issues.apache.org/jira/browse/FLINK-11388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-11388. -- Resolution: Abandoned > Add an OSS RecoverableWriter > > >

[jira] [Closed] (FLINK-9749) Rework Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9749. - Resolution: Implemented > Rework Bucketing Sink > - > > Key:

[jira] [Commented] (FLINK-17500) Deploy JobGraph from file in StandaloneClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099208#comment-17099208 ] Kostas Kloudas commented on FLINK-17500: [~uce] and [~trohrmann] with the introduction of the

[jira] [Updated] (FLINK-10934) Support application mode in kubernetes

[ https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-10934: --- Affects Version/s: 1.11.0 > Support application mode in kubernetes >

[jira] [Updated] (FLINK-10934) Support application mode in kubernetes

[ https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-10934: --- Component/s: Client / Job Submission > Support application mode in kubernetes >

[jira] [Commented] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid

[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17097587#comment-17097587 ] Kostas Kloudas commented on FLINK-17404: Thanks [~rmetzger] > Running HA per-job cluster

[jira] [Closed] (FLINK-16661) Introduce the YarnApplicationClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-16661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16661. -- Resolution: Implemented Merged on master with 3c4cd5cc69fa784f233d9d0f869d288c7688a806 >

[jira] [Commented] (FLINK-11388) Add an OSS RecoverableWriter

[ https://issues.apache.org/jira/browse/FLINK-11388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094854#comment-17094854 ] Kostas Kloudas commented on FLINK-11388: [~wujinhu] can I close this issue so that we can also

[jira] [Reopened] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reopened FLINK-10114: > Support Orc for StreamingFileSink > - > >

[jira] [Closed] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-10114. -- Resolution: Implemented Merged on master with 5d9a9b85edf4994f05518f5cbaf6cd3e2888ae43 >

[jira] [Closed] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-10114. -- Resolution: Fixed Merged on master with 5d9a9b85edf4994f05518f5cbaf6cd3e2888ae43 > Support

[jira] [Updated] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-10114: --- Fix Version/s: 1.11.0 > Support Orc for StreamingFileSink >

[jira] [Updated] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-10114: --- Affects Version/s: 1.11.0 > Support Orc for StreamingFileSink >

[jira] [Comment Edited] (FLINK-17364) Support StreamingFileSink in PrestoS3FileSystem

[ https://issues.apache.org/jira/browse/FLINK-17364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094843#comment-17094843 ] Kostas Kloudas edited comment on FLINK-17364 at 4/28/20, 8:05 PM: --

[jira] [Commented] (FLINK-17364) Support StreamingFileSink in PrestoS3FileSystem

[ https://issues.apache.org/jira/browse/FLINK-17364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094843#comment-17094843 ] Kostas Kloudas commented on FLINK-17364: [~qqibrow] sorry for the delay, I will check it in the

[jira] [Updated] (FLINK-17383) flink legacy planner should not use CollectionEnvironment any more

[ https://issues.apache.org/jira/browse/FLINK-17383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17383: --- Affects Version/s: 1.11.0 > flink legacy planner should not use CollectionEnvironment any

[jira] [Commented] (FLINK-17404) Running HA per-job cluster (rocks, non-incremental) gets stuck killing a non-existing pid

[ https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093366#comment-17093366 ] Kostas Kloudas commented on FLINK-17404: [~trohrmann] I agree with the comment on the other

[jira] [Commented] (FLINK-17394) Add RemoteEnvironment and RemoteStreamEnvironment in Python

[ https://issues.apache.org/jira/browse/FLINK-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093237#comment-17093237 ] Kostas Kloudas commented on FLINK-17394: I agree with [~aljoscha]. The whole reason why we

[jira] [Commented] (FLINK-17364) Support StreamingFileSink in PrestoS3FileSystem

[ https://issues.apache.org/jira/browse/FLINK-17364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091533#comment-17091533 ] Kostas Kloudas commented on FLINK-17364: Hi [~qqibrow]! Thanks for opening this. Are you

[jira] [Updated] (FLINK-17364) Support StreamingFileSink in PrestoS3FileSystem

[ https://issues.apache.org/jira/browse/FLINK-17364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17364: --- Affects Version/s: 1.10.0 > Support StreamingFileSink in PrestoS3FileSystem >

[jira] [Closed] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16662. -- Resolution: Fixed Merged on master with 19d9cee49bce02dd0cf232cfba003936b3b2f68e and on

[jira] [Closed] (FLINK-16660) Introduce the ApplicationDispatcherBootstrap

[ https://issues.apache.org/jira/browse/FLINK-16660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16660. -- Resolution: Implemented Merged on master with 3ff4cee8e69e8f1772458b63138021593d6acf36 >

[jira] [Closed] (FLINK-16658) Wire the EmbeddedExecutor to the StandaloneJobClusterEntryPoint.

[ https://issues.apache.org/jira/browse/FLINK-16658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16658. -- Resolution: Implemented Merged on master with 74fc5a7cc8132eec2a247f6894a81a63a1e6128a >

[jira] [Closed] (FLINK-16656) Introduce DispatcherBootstrap to initialise Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-16656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16656. -- Resolution: Implemented Merged on master with c89df66d1506a20588d704699f88a10571b66f43 >

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088051#comment-17088051 ] Kostas Kloudas commented on FLINK-16662: [~NicoK] could you please verify that this PR solves

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088047#comment-17088047 ] Kostas Kloudas commented on FLINK-16662: Hi [~zhanglibing1...@126.com], and thanks for working

[jira] [Closed] (FLINK-17052) Introduce PlanGenerator

[ https://issues.apache.org/jira/browse/FLINK-17052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17052. -- Resolution: Implemented Merged on master with 146b34e97206e471fffaf3103fa55342f2f0d253. >

[jira] [Updated] (FLINK-17052) Introduce PlanGenerator

[ https://issues.apache.org/jira/browse/FLINK-17052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17052: --- Affects Version/s: 1.11.0 > Introduce PlanGenerator > --- > >

[jira] [Assigned] (FLINK-17052) Introduce PlanGenerator

[ https://issues.apache.org/jira/browse/FLINK-17052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17052: -- Assignee: godfrey he > Introduce PlanGenerator > --- > >

[jira] [Commented] (FLINK-17110) Make StreamExecutionEnvironment#configure also affects StreamExecutionEnvironment#configuration

[ https://issues.apache.org/jira/browse/FLINK-17110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085596#comment-17085596 ] Kostas Kloudas commented on FLINK-17110: I agree that the two configurations should be

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085573#comment-17085573 ] Kostas Kloudas commented on FLINK-10114: I added this dependency after the discussion with

[jira] [Comment Edited] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084834#comment-17084834 ] Kostas Kloudas edited comment on FLINK-16662 at 4/16/20, 12:50 PM: ---

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084834#comment-17084834 ] Kostas Kloudas commented on FLINK-16662: Thanks for reporting and debugging all this. Apart from

[jira] [Assigned] (FLINK-17142) Bump ORC version

[ https://issues.apache.org/jira/browse/FLINK-17142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17142: -- Assignee: Sivaprasanna Sethuraman > Bump ORC version > > >

[jira] [Updated] (FLINK-17142) Bump ORC version

[ https://issues.apache.org/jira/browse/FLINK-17142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17142: --- Affects Version/s: 1.11.0 > Bump ORC version > > > Key:

[jira] [Updated] (FLINK-17142) Bump ORC version

[ https://issues.apache.org/jira/browse/FLINK-17142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17142: --- Fix Version/s: 1.11.0 > Bump ORC version > > > Key:

[jira] [Updated] (FLINK-17142) Bump ORC version

[ https://issues.apache.org/jira/browse/FLINK-17142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17142: --- Component/s: Connectors / ORC > Bump ORC version > > >

<    1   2   3   4   5   6   7   8   9   10   >