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

[ https://issues.apache.org/jira/browse/FLINK-17110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083038#comment-17083038 ] Kostas Kloudas commented on FLINK-17110: Hi [~wenlong.lwl], from the JIRA and the description,

[jira] [Closed] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

[ https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16533. -- Resolution: Won't Fix We decided to avoid such a change, as reflected in the discussion. >

[jira] [Commented] (FLINK-17055) List jobs via bin/flink throws FlinkException indicating no cluster id was specified

[ https://issues.apache.org/jira/browse/FLINK-17055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078677#comment-17078677 ] Kostas Kloudas commented on FLINK-17055: Hi [~felixzheng], [~tison] is correct. When using the

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

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

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

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

[jira] [Closed] (FLINK-8722) Refactor BroadcastState examples.

[ https://issues.apache.org/jira/browse/FLINK-8722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8722. - Resolution: Won't Fix > Refactor BroadcastState examples. > - >

[jira] [Closed] (FLINK-8724) Add BroadcastState examples with predetermined state transitions for the broadcast state

[ https://issues.apache.org/jira/browse/FLINK-8724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-8724. - Resolution: Won't Fix > Add BroadcastState examples with predetermined state transitions for the

[jira] [Commented] (FLINK-16560) StreamExecutionEnvironment configuration is empty when building program via PackagedProgramUtils#createJobGraph

[ https://issues.apache.org/jira/browse/FLINK-16560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072777#comment-17072777 ] Kostas Kloudas commented on FLINK-16560: I think that this is resolved by

[jira] [Commented] (FLINK-16903) Add sink.parallelism for file system factory

[ https://issues.apache.org/jira/browse/FLINK-16903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072773#comment-17072773 ] Kostas Kloudas commented on FLINK-16903: At a first glance I tend to agree with [~twalthr] on

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

[ https://issues.apache.org/jira/browse/FLINK-16655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16655: --- Summary: Introduce the EmbeddedExecutor for executing the main() on the Dispatcher (was:

[jira] [Updated] (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 updated FLINK-16658: --- Description: This will replace the current logic of job execution in the

[jira] [Updated] (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 updated FLINK-16656: --- Description: This will be a "Container" of all the initial "state" of the dispatcher both

[jira] [Updated] (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 updated FLINK-16656: --- Summary: Introduce DispatcherBootstrap to initialise Dispatcher (was: Introduce the

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

[ https://issues.apache.org/jira/browse/FLINK-16655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16655: --- Summary: Introduce the EmbeddedExecutor for executing main on Dispatcher (was: Introduce

[jira] [Closed] (FLINK-13483) PrestoS3FileSystemITCase.testDirectoryListing fails on Travis

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

[jira] [Updated] (FLINK-13566) Support checkpoint configuration through flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-13566: --- Fix Version/s: 1.10.0 > Support checkpoint configuration through flink-conf.yaml >

[jira] [Commented] (FLINK-13566) Support checkpoint configuration through flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068626#comment-17068626 ] Kostas Kloudas commented on FLINK-13566: Isn't this solved [~dwysakowicz]? > Support checkpoint

[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=17068430#comment-17068430 ] Kostas Kloudas commented on FLINK-10114: [~zenfenan] I will have a look at the design doc. There

[jira] [Updated] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart runs without exit

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

[jira] [Commented] (FLINK-16794) ClassNotFoundException caused by ClassLoader.getSystemClassLoader using impertinently

[ https://issues.apache.org/jira/browse/FLINK-16794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068407#comment-17068407 ] Kostas Kloudas commented on FLINK-16794: Hi [~haokstar] could you provide a stack trace and an

[jira] [Closed] (FLINK-16777) expose Pipeline in JobClient

[ https://issues.apache.org/jira/browse/FLINK-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16777. -- Resolution: Won't Fix > expose Pipeline in JobClient > > >

[jira] [Commented] (FLINK-16777) expose Pipeline in JobClient

[ https://issues.apache.org/jira/browse/FLINK-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068404#comment-17068404 ] Kostas Kloudas commented on FLINK-16777: I am not familiar with the other sinks you mention, but

[jira] [Commented] (FLINK-16791) Could not deploy Yarn job cluster when using flink-s3-fs-hadoop-1.10.0.jar

[ https://issues.apache.org/jira/browse/FLINK-16791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17068402#comment-17068402 ] Kostas Kloudas commented on FLINK-16791: Hi [~Backlight], does this mean we can close this

[jira] [Commented] (FLINK-16775) expose FlinkKafkaConsumer/FlinkKafkaProducer Properties for other system

[ https://issues.apache.org/jira/browse/FLINK-16775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067745#comment-17067745 ] Kostas Kloudas commented on FLINK-16775: [~jackylau] Could you please add more details about how

[jira] [Commented] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067744#comment-17067744 ] Kostas Kloudas commented on FLINK-16774: [~jackylau] Could you please add more details about how

[jira] [Commented] (FLINK-16791) Could not deploy Yarn job cluster when using flink-s3-fs-hadoop-1.10.0.jar

[ https://issues.apache.org/jira/browse/FLINK-16791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067564#comment-17067564 ] Kostas Kloudas commented on FLINK-16791: Hi [~Backlight], since 1.10 it is recommended to use

[jira] [Commented] (FLINK-16777) expose Pipeline in JobClient

[ https://issues.apache.org/jira/browse/FLINK-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067515#comment-17067515 ] Kostas Kloudas commented on FLINK-16777: Hi [~jackylau], I am not sure about the other issues

[jira] [Comment Edited] (FLINK-16777) expose Pipeline in JobClient

[ https://issues.apache.org/jira/browse/FLINK-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17066739#comment-17066739 ] Kostas Kloudas edited comment on FLINK-16777 at 3/25/20, 3:21 PM: -- Hi

[jira] [Comment Edited] (FLINK-16777) expose Pipeline in JobClient

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

[jira] [Commented] (FLINK-16777) expose Pipeline in JobClient

[ https://issues.apache.org/jira/browse/FLINK-16777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17066739#comment-17066739 ] Kostas Kloudas commented on FLINK-16777: Hi [~jackylau], I think that this is not something we

[jira] [Closed] (FLINK-16692) flink joblistener can register from config

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

[jira] [Assigned] (FLINK-16692) flink joblistener can register from config

[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-16692: -- Assignee: jackylau > flink joblistener can register from config >

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064662#comment-17064662 ] Kostas Kloudas commented on FLINK-16692: Thanks [~jackylau], I also had a first pass on the PR.

[jira] [Commented] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064658#comment-17064658 ] Kostas Kloudas commented on FLINK-16715: [~xintongsong] I see your point. In general the whole

[jira] [Comment Edited] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064658#comment-17064658 ] Kostas Kloudas edited comment on FLINK-16715 at 3/23/20, 9:33 AM: --

[jira] [Closed] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

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

[jira] [Commented] (FLINK-16692) flink joblistener can register from config

[ https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064587#comment-17064587 ] Kostas Kloudas commented on FLINK-16692: Hi, I think this is a nice feature to have. I have 2

[jira] [Assigned] (FLINK-7771) Make the operator state queryable

[ https://issues.apache.org/jira/browse/FLINK-7771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-7771: - Assignee: (was: Kostas Kloudas) > Make the operator state queryable >

[jira] [Assigned] (FLINK-6215) Make the StatefulSequenceSource scalable.

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

[jira] [Closed] (FLINK-4407) Add DSL for specifying Window Triggers

[ https://issues.apache.org/jira/browse/FLINK-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-4407. - Resolution: Won't Fix > Add DSL for specifying Window Triggers >

[jira] [Closed] (FLINK-15852) Job is submitted to the wrong session cluster

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

[jira] [Commented] (FLINK-16629) Streaming bucketing end-to-end test output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-16629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062463#comment-17062463 ] Kostas Kloudas commented on FLINK-16629: Yes, I think that given that we are probably going to

[jira] [Commented] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policies

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062459#comment-17062459 ] Kostas Kloudas commented on FLINK-11499: [~pnowojski] I think it makes sense to have this

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

[ https://issues.apache.org/jira/browse/FLINK-16661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16661: --- Description: This will be the final step to support "Application Mode" for Yarn. So far,

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

Kostas Kloudas created FLINK-16661: -- Summary: Introduce the YarnApplicationClusterEntrypoint Key: FLINK-16661 URL: https://issues.apache.org/jira/browse/FLINK-16661 Project: Flink Issue

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

Kostas Kloudas created FLINK-16660: -- Summary: Introduce the ApplicationDispatcherBootstrap Key: FLINK-16660 URL: https://issues.apache.org/jira/browse/FLINK-16660 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-16658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16658: --- Description: This will replace the current logic of job execution in the

[jira] [Updated] (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 updated FLINK-16658: --- Summary: Wire the EmbeddedExecutor to the StandaloneJobClusterEntryPoint. (was: Wire the

[jira] [Updated] (FLINK-16655) Introduce the EmbeddedExecutor

[ https://issues.apache.org/jira/browse/FLINK-16655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16655: --- Description: Running the user's {{main}} method in "Application Mode" implies: 1)

[jira] [Created] (FLINK-16658) Wire the EmbeddedExecutor to the StandaloneClusterEntrypoint.

Kostas Kloudas created FLINK-16658: -- Summary: Wire the EmbeddedExecutor to the StandaloneClusterEntrypoint. Key: FLINK-16658 URL: https://issues.apache.org/jira/browse/FLINK-16658 Project: Flink

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

Kostas Kloudas created FLINK-16657: -- Summary: Wire the EmbeddedExecutor to the Web Submission logic. Key: FLINK-16657 URL: https://issues.apache.org/jira/browse/FLINK-16657 Project: Flink

[jira] [Created] (FLINK-16656) Introduce the DispatcherBootstrap

Kostas Kloudas created FLINK-16656: -- Summary: Introduce the DispatcherBootstrap Key: FLINK-16656 URL: https://issues.apache.org/jira/browse/FLINK-16656 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16655) Introduce the EmbeddedExecutor

Kostas Kloudas created FLINK-16655: -- Summary: Introduce the EmbeddedExecutor Key: FLINK-16655 URL: https://issues.apache.org/jira/browse/FLINK-16655 Project: Flink Issue Type: Sub-task

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

[ https://issues.apache.org/jira/browse/FLINK-16654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16654: --- Description: This is an umbrella issue that will help us track the progress of

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

Kostas Kloudas created FLINK-16654: -- Summary: Implement Application Mode according to FLIP-85 Key: FLINK-16654 URL: https://issues.apache.org/jira/browse/FLINK-16654 Project: Flink Issue

[jira] [Commented] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policies

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061543#comment-17061543 ] Kostas Kloudas commented on FLINK-11499: Thanks for moving the discussion forward [~pnowojski]!

[jira] [Commented] (FLINK-15852) Job is submitted to the wrong session cluster

[ https://issues.apache.org/jira/browse/FLINK-15852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061127#comment-17061127 ] Kostas Kloudas commented on FLINK-15852: I will fix this by simply changing the custom command

[jira] [Assigned] (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 reassigned FLINK-10114: -- Assignee: Sivaprasanna Sethuraman (was: vinoyang) > Support Orc for

[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=17060959#comment-17060959 ] Kostas Kloudas commented on FLINK-10114: Oh ok, I can do that then :) > Support Orc for

[jira] [Commented] (FLINK-16629) Streaming bucketing end-to-end test output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-16629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060905#comment-17060905 ] Kostas Kloudas commented on FLINK-16629: If this is not a big deal for you, then I think that

[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=17060815#comment-17060815 ] Kostas Kloudas commented on FLINK-10114: Thanks a lot [~zenfenan] for the effort. I think it

[jira] [Commented] (FLINK-16629) Streaming bucketing end-to-end test output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-16629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060808#comment-17060808 ] Kostas Kloudas commented on FLINK-16629: [~rmetzger] Only in 2.4.1? This seems to make things

[jira] [Commented] (FLINK-16629) Streaming bucketing end-to-end test output hash mismatch

[ https://issues.apache.org/jira/browse/FLINK-16629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060771#comment-17060771 ] Kostas Kloudas commented on FLINK-16629: [~pnowojski] I think that based on the discussion

[jira] [Commented] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060156#comment-17060156 ] Kostas Kloudas commented on FLINK-16547: I assigned the issue to you [~felixzheng] > Respect

[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=17060155#comment-17060155 ] Kostas Kloudas commented on FLINK-10114: Hi [~zenfenan] and [~gaoyunhaii] and thanks for looking

[jira] [Assigned] (FLINK-15852) Job is submitted to the wrong session cluster

[ https://issues.apache.org/jira/browse/FLINK-15852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-15852: -- Assignee: Kostas Kloudas > Job is submitted to the wrong session cluster >

[jira] [Assigned] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-16547: -- Assignee: Canbin Zheng (was: Kostas Kloudas) > Respect the config option of

[jira] [Updated] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16547: --- Affects Version/s: 1.10.0 > Respect the config option of

[jira] [Assigned] (FLINK-16547) Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-16547: -- Assignee: Kostas Kloudas > Respect the config option of

[jira] [Comment Edited] (FLINK-16547) Correct the order to write temporary files in YarnClusterDescriptor#startAppMaster

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060010#comment-17060010 ] Kostas Kloudas edited comment on FLINK-16547 at 3/16/20, 7:56 AM: -- Hi

[jira] [Commented] (FLINK-16547) Correct the order to write temporary files in YarnClusterDescriptor#startAppMaster

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060010#comment-17060010 ] Kostas Kloudas commented on FLINK-16547: Hi [~felixzheng], you may be right. If we have it as an

[jira] [Commented] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

[ https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057876#comment-17057876 ] Kostas Kloudas commented on FLINK-16533: [~aljoscha] and [~godfreyhe] I would be up for removing

[jira] [Comment Edited] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

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

[jira] [Commented] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

[ https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057841#comment-17057841 ] Kostas Kloudas commented on FLINK-16533: In general, we avoid adding methods to public APIs,

[jira] [Comment Edited] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

[ https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057841#comment-17057841 ] Kostas Kloudas edited comment on FLINK-16533 at 3/12/20, 11:31 AM: --- In

[jira] [Commented] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

[ https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057816#comment-17057816 ] Kostas Kloudas commented on FLINK-16533: Hi [~godfreyhe]! FLIP-84 seems to be under discussion,

[jira] [Commented] (FLINK-16547) Correct the order to write temporary files in YarnClusterDescriptor#startAppMaster

[ https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057792#comment-17057792 ] Kostas Kloudas commented on FLINK-16547: Thanks for reporting this [~felixzheng]. I agree that

[jira] [Commented] (FLINK-16488) Logging issues when running through K8s

[ https://issues.apache.org/jira/browse/FLINK-16488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057703#comment-17057703 ] Kostas Kloudas commented on FLINK-16488: [~jmathews3773] One thing that may be interesting to

[jira] [Updated] (FLINK-15782) Rework JDBC sinks

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

[jira] [Closed] (FLINK-15782) Rework JDBC sinks

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

[jira] [Updated] (FLINK-15782) Rework JDBC sinks

[ https://issues.apache.org/jira/browse/FLINK-15782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-15782: --- Affects Version/s: 1.10.0 > Rework JDBC sinks > - > > Key:

[jira] [Closed] (FLINK-16371) HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException'

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

[jira] [Updated] (FLINK-16371) HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException'

[ https://issues.apache.org/jira/browse/FLINK-16371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16371: --- Fix Version/s: 1.11.0 1.10.1 > HadoopCompressionBulkWriter fails with

[jira] [Closed] (FLINK-16447) Non serializable field on CompressWriterFactory

[ https://issues.apache.org/jira/browse/FLINK-16447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-16447. -- Resolution: Duplicate > Non serializable field on CompressWriterFactory >

[jira] [Commented] (FLINK-16447) Non serializable field on CompressWriterFactory

[ https://issues.apache.org/jira/browse/FLINK-16447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053202#comment-17053202 ] Kostas Kloudas commented on FLINK-16447: Yes, I will do it now. > Non serializable field on

[jira] [Updated] (FLINK-16371) HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException'

[ https://issues.apache.org/jira/browse/FLINK-16371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16371: --- Component/s: Connectors / FileSystem > HadoopCompressionBulkWriter fails with

[jira] [Commented] (FLINK-16447) Non serializable field on CompressWriterFactory

[ https://issues.apache.org/jira/browse/FLINK-16447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052416#comment-17052416 ] Kostas Kloudas commented on FLINK-16447: Hi [~eskabetxe] this seems to be a duplicate issue with

[jira] [Commented] (FLINK-16279) Per job Yarn application leak in normal execution mode.

[ https://issues.apache.org/jira/browse/FLINK-16279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051363#comment-17051363 ] Kostas Kloudas commented on FLINK-16279: I agree with [~aljoscha] that this would be the

[jira] [Commented] (FLINK-11546) Add option to manually set job ID in CLI

[ https://issues.apache.org/jira/browse/FLINK-11546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17051191#comment-17051191 ] Kostas Kloudas commented on FLINK-11546: I think that in some context, static {{JobId}}s are

[jira] [Commented] (FLINK-16279) Per job Yarn application leak in normal execution mode.

[ https://issues.apache.org/jira/browse/FLINK-16279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049092#comment-17049092 ] Kostas Kloudas commented on FLINK-16279: If I understand the usecase correctly, we have a job

[jira] [Commented] (FLINK-15805) StreamingFileSink on S3 fails when firing processing time timers after recovery.

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

[jira] [Created] (FLINK-16369) Allow the StreamingFileSink to restore from a previous (old) savepoint.

Kostas Kloudas created FLINK-16369: -- Summary: Allow the StreamingFileSink to restore from a previous (old) savepoint. Key: FLINK-16369 URL: https://issues.apache.org/jira/browse/FLINK-16369 Project:

[jira] [Closed] (FLINK-15805) StreamingFileSink on S3 fails when firing processing time timers after recovery.

[ https://issues.apache.org/jira/browse/FLINK-15805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-15805. -- Resolution: Incomplete > StreamingFileSink on S3 fails when firing processing time timers

[jira] [Commented] (FLINK-15805) StreamingFileSink on S3 fails when firing processing time timers after recovery.

[ https://issues.apache.org/jira/browse/FLINK-15805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048883#comment-17048883 ] Kostas Kloudas commented on FLINK-15805: I will close this issue, as the behaviour of failing

[jira] [Commented] (FLINK-16306) Validate YARN session state before job submission

[ https://issues.apache.org/jira/browse/FLINK-16306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046695#comment-17046695 ] Kostas Kloudas commented on FLINK-16306: Super! > Validate YARN session state before job

[jira] [Comment Edited] (FLINK-16305) FlinkYarnSessionClI ignores target executor and uses yarn-session if YARN properties file is present

[ https://issues.apache.org/jira/browse/FLINK-16305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046663#comment-17046663 ] Kostas Kloudas edited comment on FLINK-16305 at 2/27/20 2:14 PM: -

[jira] [Commented] (FLINK-16305) FlinkYarnSessionClI ignores target executor and uses yarn-session if YARN properties file is present

[ https://issues.apache.org/jira/browse/FLINK-16305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046662#comment-17046662 ] Kostas Kloudas commented on FLINK-16305: [~dmagyar] and [~gyfora] do you have something in mind

[jira] [Commented] (FLINK-16305) FlinkYarnSessionClI ignores target executor and uses yarn-session if YARN properties file is present

[ https://issues.apache.org/jira/browse/FLINK-16305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046663#comment-17046663 ] Kostas Kloudas commented on FLINK-16305: [~fly_in_gis] yes, I agree. > FlinkYarnSessionClI

[jira] [Commented] (FLINK-16306) Validate YARN session state before job submission

[ https://issues.apache.org/jira/browse/FLINK-16306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046660#comment-17046660 ] Kostas Kloudas commented on FLINK-16306: I see. I agree that add a sanity check that the session

[jira] [Commented] (FLINK-16306) Validate YARN session state before job submission

[ https://issues.apache.org/jira/browse/FLINK-16306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046620#comment-17046620 ] Kostas Kloudas commented on FLINK-16306: [~gyfora] and [~dmagyar] I am not against a fix for it

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