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

2020-09-22 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17200074#comment-17200074 ] Kostas Kloudas commented on FLINK-19358: [~zhangjun] Just as a clarification, you have a single

[jira] [Commented] (FLINK-9940) File source continuous monitoring mode: S3 files sometimes missed

2020-08-24 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183087#comment-17183087 ] Kostas Kloudas commented on FLINK-9940: --- Hi [~Averell]and [~maguowei] Thanks for the discussion!

[jira] [Closed] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

2020-08-24 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8046. - Resolution: Duplicate > ContinuousFileMonitoringFunction wrongly ignores files with exact same

[jira] [Closed] (FLINK-18742) Some configuration args do not take effect at client

2020-08-24 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-18742. -- Fix Version/s: 1.11.2 1.12.0 Resolution: Fixed Merged on master

[jira] [Closed] (FLINK-17253) Support writing to viewfs for hadoop versions < 2.7 when using BulkFormatBuilder in StreamingFileSink

2020-08-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17253. -- Fix Version/s: 1.12.0 Resolution: Fixed Merged on master with

[jira] [Updated] (FLINK-17569) to support ViewFileSystem when wait lease revoke of hadoop filesystem

2020-08-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17569: --- Component/s: (was: FileSystems) Connectors / FileSystem > to support

[jira] [Closed] (FLINK-17569) to support ViewFileSystem when wait lease revoke of hadoop filesystem

2020-08-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17569. -- Fix Version/s: 1.12.0 Resolution: Fixed Merged on master with

[jira] [Commented] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-08-01 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17169377#comment-17169377 ] Kostas Kloudas commented on FLINK-18706: [~Yumeng] if you are using an exactly-once sink, then

[jira] [Commented] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-07-30 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168187#comment-17168187 ] Kostas Kloudas commented on FLINK-18706: [~Yumeng] No, stop-with-savepoint guarantees exactly

[jira] [Commented] (FLINK-18771) "Kerberized YARN per-job on Docker test" failed with "Client cannot authenticate via:[TOKEN, KERBEROS]"

2020-07-30 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167962#comment-17167962 ] Kostas Kloudas commented on FLINK-18771: [~dian.fu] Please let me know if my fix does not solve

[jira] [Commented] (FLINK-18771) "Kerberized YARN per-job on Docker test" failed with "Client cannot authenticate via:[TOKEN, KERBEROS]"

2020-07-30 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167865#comment-17167865 ] Kostas Kloudas commented on FLINK-18771: The commit is a0227e20430ee9eaff59464023de2385378f71ea

[jira] [Closed] (FLINK-18771) "Kerberized YARN per-job on Docker test" failed with "Client cannot authenticate via:[TOKEN, KERBEROS]"

2020-07-30 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-18771. -- Resolution: Fixed Merged with a0227e20430ee9eaff59464023de2385378f71ea > "Kerberized YARN

[jira] [Commented] (FLINK-18771) "Kerberized YARN per-job on Docker test" failed with "Client cannot authenticate via:[TOKEN, KERBEROS]"

2020-07-30 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167863#comment-17167863 ] Kostas Kloudas commented on FLINK-18771: This was a mistake on my side when merging. I will

[jira] [Assigned] (FLINK-18771) "Kerberized YARN per-job on Docker test" failed with "Client cannot authenticate via:[TOKEN, KERBEROS]"

2020-07-30 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-18771: -- Assignee: Kostas Kloudas > "Kerberized YARN per-job on Docker test" failed with

[jira] [Closed] (FLINK-13838) Support shipping archives for Yarn deployment

2020-07-30 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-13838. -- Fix Version/s: 1.12.0 Assignee: Yang Wang (was: Yang Wang) Resolution: Fixed

[jira] [Closed] (FLINK-18362) Shipping jdk by shipping archive

2020-07-30 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-18362. -- Fix Version/s: 1.12.0 Resolution: Implemented Merged on master with

[jira] [Commented] (FLINK-18752) Yarn ship logic should support files

2020-07-29 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167333#comment-17167333 ] Kostas Kloudas commented on FLINK-18752: This was always like this. It does not seem to be a

[jira] [Commented] (FLINK-18706) Stop with savepoint cannot guarantee exactly-once for kafka source

2020-07-27 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165563#comment-17165563 ] Kostas Kloudas commented on FLINK-18706: Hi [~Yumeng], the stop-with-savepoint does not

[jira] [Closed] (FLINK-18519) Propagate exception to client when execution fails for REST submission

2020-07-08 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-18519. -- Resolution: Fixed Fixed on master with 78b00f65c3cd9c3536e54fd63f240bc89c83e572 and on

[jira] [Updated] (FLINK-18519) Propagate exception to client when execution fails for REST submission

2020-07-07 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-18519: --- Component/s: (was: Runtime / Web Frontend) Runtime / REST > Propagate

[jira] [Updated] (FLINK-18519) Propagate exception to client when execution fails for REST submission

2020-07-07 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-18519: --- Fix Version/s: 1.12.0 > Propagate exception to client when execution fails for REST

[jira] [Created] (FLINK-18519) Propagate exception to client when execution fails for REST submission

2020-07-07 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-18519: -- Summary: Propagate exception to client when execution fails for REST submission Key: FLINK-18519 URL: https://issues.apache.org/jira/browse/FLINK-18519 Project:

[jira] [Updated] (FLINK-18469) Add Application Mode to release notes.

2020-07-02 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-18469: --- Fix Version/s: 1.11.0 > Add Application Mode to release notes. >

[jira] [Closed] (FLINK-18469) Add Application Mode to release notes.

2020-07-02 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-18469. -- Resolution: Fixed Merged on master with 01da0eaba100816cc9f0970de0b52fee35494c52 and on

[jira] [Created] (FLINK-18469) Add Application Mode to release notes.

2020-07-02 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-18469: -- Summary: Add Application Mode to release notes. Key: FLINK-18469 URL: https://issues.apache.org/jira/browse/FLINK-18469 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-18362) Shipping jdk by shipping archive

2020-07-02 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-18362: -- Assignee: gramo lee > Shipping jdk by shipping archive >

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

2020-06-24 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17639. -- Fix Version/s: 1.12.0 1.10.2 Resolution: Fixed Merged on master

[jira] [Closed] (FLINK-18352) org.apache.flink.core.execution.DefaultExecutorServiceLoader not thread safe

2020-06-22 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-18352. -- Resolution: Fixed Fixed on master with b05ab524836c1c07d128610248fe372c8d697974 on

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

2020-06-22 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142039#comment-17142039 ] Kostas Kloudas commented on FLINK-18211: Super! Can you also close the existing PR [~Echo Lee]

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

2020-06-22 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141882#comment-17141882 ] Kostas Kloudas commented on FLINK-18211: I think that you are right [~fly_in_gis] that the

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

2020-06-22 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141794#comment-17141794 ] Kostas Kloudas commented on FLINK-17639: No problem [~maguowei]! The release is not out yet :)

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

2020-06-22 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141793#comment-17141793 ] Kostas Kloudas commented on FLINK-18211: Thanks [~Echo Lee]! [~fly_in_gis] what is your opinion?

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

2020-06-22 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141749#comment-17141749 ] Kostas Kloudas commented on FLINK-17639: Hi [~maguowei]! Any news on this issue? :) > Document

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

2020-06-22 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17141734#comment-17141734 ] Kostas Kloudas commented on FLINK-18211: I understand the usefulness of such a feature, my only

[jira] [Updated] (FLINK-18352) org.apache.flink.core.execution.DefaultExecutorServiceLoader not thread safe

2020-06-19 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-18352: --- Fix Version/s: 1.12.0 1.10.2 1.11.0 >

[jira] [Updated] (FLINK-18352) org.apache.flink.core.execution.DefaultExecutorServiceLoader not thread safe

2020-06-19 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-18352: --- Component/s: Client / Job Submission >

[jira] [Assigned] (FLINK-18352) org.apache.flink.core.execution.DefaultExecutorServiceLoader not thread safe

2020-06-18 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-18352: -- Assignee: Kostas Kloudas >

[jira] [Comment Edited] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

2020-06-17 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138420#comment-17138420 ] Kostas Kloudas edited comment on FLINK-18211 at 6/17/20, 1:14 PM: -- Can

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

2020-06-17 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138420#comment-17138420 ] Kostas Kloudas commented on FLINK-18211: Can we go a bit back to why the

[jira] [Updated] (FLINK-16654) Implement Application Mode according to FLIP-85

2020-06-17 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16654: --- Fix Version/s: 1.11.0 > Implement Application Mode according to FLIP-85 >

[jira] [Closed] (FLINK-16654) Implement Application Mode according to FLIP-85

2020-06-17 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16654. -- Resolution: Implemented > Implement Application Mode according to FLIP-85 >

[jira] [Commented] (FLINK-18211) Dynamic properties setting 'pipeline.jars' will be overwritten

2020-06-16 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136406#comment-17136406 ] Kostas Kloudas commented on FLINK-18211: [~fly_in_gis] is right that the {{pipeline.jars}} was

[jira] [Closed] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-06-16 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17891. -- Fix Version/s: 1.12.0 1.10.2 1.11.0 Resolution:

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

2020-06-15 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17639: -- Assignee: Guowei Ma > Document which FileSystems are supported by the

[jira] [Commented] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-06-12 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134301#comment-17134301 ] Kostas Kloudas commented on FLINK-17891: [~tangshangwen] could you please verify that the PR

[jira] [Assigned] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-06-12 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17891: -- Assignee: Kostas Kloudas > FlinkYarnSessionCli sets wrong execution.target type >

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

2020-06-12 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17134246#comment-17134246 ] Kostas Kloudas commented on FLINK-17639: Hi [~maguowei], do you still want me to assign the

[jira] [Closed] (FLINK-17788) scala shell in yarn mode is broken

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17788. -- Resolution: Fixed Fixed on master with 6744033e1c05f51c8213d06f1fe4488c9673ed57 on

[jira] [Assigned] (FLINK-18241) Custom OptionsFactory in user code not working when configured via flink-conf.yaml

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-18241: -- Assignee: Dawid Wysakowicz > Custom OptionsFactory in user code not working when

[jira] [Commented] (FLINK-18209) Replace "charged" words in the Flink codebase.

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17133151#comment-17133151 ] Kostas Kloudas commented on FLINK-18209: +1 > Replace "charged" words in the Flink codebase. >

[jira] [Updated] (FLINK-17788) scala shell in yarn mode is broken

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17788: --- Fix Version/s: 1.12.0 1.10.2 1.11.0 > scala shell in

[jira] [Assigned] (FLINK-17788) scala shell in yarn mode is broken

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17788: -- Assignee: Kostas Kloudas > scala shell in yarn mode is broken >

[jira] [Updated] (FLINK-17810) Add document for K8s application mode

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17810: --- Fix Version/s: 1.12.0 1.11.0 > Add document for K8s application mode >

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

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16661: --- Fix Version/s: 1.11.0 > Introduce the YarnApplicationClusterEntrypoint >

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

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16658: --- Fix Version/s: 1.11.0 > Wire the EmbeddedExecutor to the StandaloneJobClusterEntryPoint. >

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

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16660: --- Fix Version/s: 1.11.0 > Introduce the ApplicationDispatcherBootstrap >

[jira] [Updated] (FLINK-16655) Introduce the EmbeddedExecutor for executing the main() on the Dispatcher

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16655: --- Fix Version/s: 1.11.0 > Introduce the EmbeddedExecutor for executing the main() on the

[jira] [Updated] (FLINK-16657) Wire the EmbeddedExecutor to the Web Submission logic.

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16657: --- Fix Version/s: 1.11.0 > Wire the EmbeddedExecutor to the Web Submission logic. >

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

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16656: --- Fix Version/s: 1.11.0 > Introduce DispatcherBootstrap to initialise Dispatcher >

[jira] [Commented] (FLINK-18237) IllegalArgumentException when reading filesystem partitioned table with stream mode

2020-06-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17132986#comment-17132986 ] Kostas Kloudas commented on FLINK-18237: Thanks a lot [~lzljs3620320]! >

[jira] [Closed] (FLINK-18084) Create documentation for the Application Mode

2020-06-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-18084. -- Resolution: Fixed Merged on master with 7aa5f3310ed781477e84de7e3a20da089ee3b4b5 and on

[jira] [Updated] (FLINK-18084) Create documentation for the Application Mode

2020-06-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-18084: --- Fix Version/s: 1.12.0 > Create documentation for the Application Mode >

[jira] [Commented] (FLINK-18237) IllegalArgumentException when reading filesystem partitioned table with stream mode

2020-06-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130385#comment-17130385 ] Kostas Kloudas commented on FLINK-18237: Hi [~lzljs3620320], could you post a bit more details

[jira] [Comment Edited] (FLINK-18237) IllegalArgumentException when reading filesystem partitioned table with stream mode

2020-06-10 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130385#comment-17130385 ] Kostas Kloudas edited comment on FLINK-18237 at 6/10/20, 8:16 AM: -- Hi

[jira] [Closed] (FLINK-18048) "--host" option could not take effect for standalone application cluster

2020-06-05 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-18048. -- Resolution: Fixed Merged on master with 58343736a479080987dad4cc2636d425197ed29d , on

[jira] [Updated] (FLINK-18048) "--host" option could not take effect for standalone application cluster

2020-06-05 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-18048: --- Fix Version/s: 1.12.0 > "--host" option could not take effect for standalone application

[jira] [Updated] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

2020-06-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17935: --- Fix Version/s: 1.12.0 > Logs could not show up when deploying Flink on Yarn via

[jira] [Closed] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

2020-06-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17935. -- Resolution: Fixed Fixed on master with a674b5e181a2af050aee4c4f23a86a6c61eda94f and on

[jira] [Updated] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

2020-06-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17935: --- Priority: Blocker (was: Critical) > Logs could not show up when deploying Flink on Yarn

[jira] [Closed] (FLINK-18087) Uploading user artifact for Yarn job cluster could not work

2020-06-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-18087. -- Resolution: Fixed Fixed on master with d56454a3a0abe9ba34d1fec27864863bbd8a7c5f and on

[jira] [Reopened] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

2020-06-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reopened FLINK-17935: > Logs could not show up when deploying Flink on Yarn via "--executor" >

[jira] [Closed] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

2020-06-04 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17935. -- Resolution: Fixed Fixed on master with 2eb7377163490878f12e4687db5fb4db0e6f47c2 and on

[jira] [Assigned] (FLINK-18087) Uploading user artifact for Yarn job cluster could not work

2020-06-03 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-18087: -- Assignee: Yang Wang > Uploading user artifact for Yarn job cluster could not work >

[jira] [Updated] (FLINK-18084) Create documentation for the Application Mode

2020-06-03 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-18084: --- Description: This ticket aims at documenting the application mode and its new capabilities.

[jira] [Created] (FLINK-18084) Create documentation for the Application Mode

2020-06-03 Thread Kostas Kloudas (Jira)
Kostas Kloudas created FLINK-18084: -- Summary: Create documentation for the Application Mode Key: FLINK-18084 URL: https://issues.apache.org/jira/browse/FLINK-18084 Project: Flink Issue

[jira] [Closed] (FLINK-16144) Add client.timeout setting and use that for CLI operations

2020-05-29 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16144. -- Fix Version/s: 1.12.0 Assignee: wangtong Resolution: Fixed Merged on master

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

2020-05-29 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17819: --- Fix Version/s: 1.12.0 1.10.2 > Yarn error unhelpful when forgetting

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

2020-05-29 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119020#comment-17119020 ] Kostas Kloudas edited comment on FLINK-17819 at 5/29/20, 7:52 AM: --

[jira] [Updated] (FLINK-17744) StreamContextEnvironment#execute cannot be call JobListener#onJobExecuted

2020-05-29 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17744: --- Fix Version/s: 1.10.2 > StreamContextEnvironment#execute cannot be call

[jira] [Comment Edited] (FLINK-17744) StreamContextEnvironment#execute cannot be call JobListener#onJobExecuted

2020-05-29 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119031#comment-17119031 ] Kostas Kloudas edited comment on FLINK-17744 at 5/29/20, 7:18 AM: --

[jira] [Updated] (FLINK-17744) StreamContextEnvironment#execute cannot be call JobListener#onJobExecuted

2020-05-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17744: --- Fix Version/s: (was: 1.10.0) 1.12.0 1.11.0 >

[jira] [Closed] (FLINK-17744) StreamContextEnvironment#execute cannot be call JobListener#onJobExecuted

2020-05-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17744. -- Resolution: Fixed Merged on master with 7dcfd90dd42648133bb7c1216740f47fffe89c13 and on

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

2020-05-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17819. -- Resolution: Fixed Merged on master with c8ab94f2107d28c0f3e356a4d4c801a88e719ed0 and on

[jira] [Commented] (FLINK-17788) scala shell in yarn mode is broken

2020-05-28 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118479#comment-17118479 ] Kostas Kloudas commented on FLINK-17788: Thanks a lot [~zjffdu] for the clarification. Let me

[jira] [Commented] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

2020-05-27 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117485#comment-17117485 ] Kostas Kloudas commented on FLINK-17935: My only concern with moving the configuration to the

[jira] [Commented] (FLINK-17788) scala shell in yarn mode is broken

2020-05-26 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116946#comment-17116946 ] Kostas Kloudas commented on FLINK-17788: [~zjffdu] I think that setting the Deployment target

[jira] [Comment Edited] (FLINK-17788) scala shell in yarn mode is broken

2020-05-26 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116780#comment-17116780 ] Kostas Kloudas edited comment on FLINK-17788 at 5/26/20, 2:47 PM: --

[jira] [Comment Edited] (FLINK-17788) scala shell in yarn mode is broken

2020-05-26 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116780#comment-17116780 ] Kostas Kloudas edited comment on FLINK-17788 at 5/26/20, 2:45 PM: --

[jira] [Commented] (FLINK-17788) scala shell in yarn mode is broken

2020-05-26 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116780#comment-17116780 ] Kostas Kloudas commented on FLINK-17788: [~zjffdu] can you be more specific on what you see as

[jira] [Comment Edited] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

2020-05-26 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116715#comment-17116715 ] Kostas Kloudas edited comment on FLINK-17935 at 5/26/20, 1:09 PM: -- I

[jira] [Commented] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

2020-05-26 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116715#comment-17116715 ] Kostas Kloudas commented on FLINK-17935: I already have a branch for this one. [~Echo Lee] I

[jira] [Assigned] (FLINK-17935) Logs could not show up when deploying Flink on Yarn via "--executor"

2020-05-26 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17935: -- Assignee: Kostas Kloudas > Logs could not show up when deploying Flink on Yarn via

[jira] [Closed] (FLINK-17870) dependent jars are missing to be shipped to cluster in scala shell

2020-05-25 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-17870. -- Resolution: Fixed Merged on master with ea54a54be1ea5629ccbd2421aa6f91b19870d40c on

[jira] [Updated] (FLINK-17870) dependent jars are missing to be shipped to cluster in scala shell

2020-05-25 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17870: --- Fix Version/s: 1.12.0 1.10.2 1.11.0 > dependent jars

[jira] [Comment Edited] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-05-25 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115951#comment-17115951 ] Kostas Kloudas edited comment on FLINK-17891 at 5/25/20, 3:21 PM: -- Hi

[jira] [Commented] (FLINK-17891) FlinkYarnSessionCli sets wrong execution.target type

2020-05-25 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115951#comment-17115951 ] Kostas Kloudas commented on FLINK-17891: Hi [~tangshangwen], as [~fly_in_gis] said, could you

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

2020-05-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17444: --- Affects Version/s: (was: 1.10.0) > StreamingFileSink Azure HadoopRecoverableWriter

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

2020-05-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-17444: --- Fix Version/s: (was: 1.11.0) > StreamingFileSink Azure HadoopRecoverableWriter class

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

2020-05-20 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112523#comment-17112523 ] Kostas Kloudas edited comment on FLINK-17444 at 5/20/20, 6:39 PM: -- So

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

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

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