[jira] [Assigned] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-15533: -- Assignee: Kostas Kloudas > Writing DataStream as text file fails due to output path a

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012633#comment-17012633 ] Kostas Kloudas commented on FLINK-15533: Hi [~lirui], I tried it on the {{master

[jira] [Comment Edited] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012633#comment-17012633 ] Kostas Kloudas edited comment on FLINK-15533 at 1/10/20 9:45 AM: -

[jira] [Comment Edited] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012633#comment-17012633 ] Kostas Kloudas edited comment on FLINK-15533 at 1/10/20 9:58 AM: -

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012822#comment-17012822 ] Kostas Kloudas commented on FLINK-15533: I think I get the problem. Before 1.10

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012832#comment-17012832 ] Kostas Kloudas commented on FLINK-15533: Sorry I just saw your message, I think

[jira] [Commented] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

[ https://issues.apache.org/jira/browse/FLINK-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014126#comment-17014126 ] Kostas Kloudas commented on FLINK-15533: Thanks for the feedback [~lirui]! I ope

[jira] [Closed] (FLINK-15292) Rename Executor interface to PipelineExecutor

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

[jira] [Closed] (FLINK-15533) Writing DataStream as text file fails due to output path already exists

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

[jira] [Assigned] (FLINK-15278) Update StreamingFileSink documentation

[ https://issues.apache.org/jira/browse/FLINK-15278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-15278: -- Assignee: Kostas Kloudas > Update StreamingFileSink documentation > -

[jira] [Updated] (FLINK-15278) Update StreamingFileSink documentation

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

[jira] [Updated] (FLINK-15278) Update StreamingFileSink documentation

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

[jira] [Closed] (FLINK-15278) Update StreamingFileSink documentation

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

[jira] [Closed] (FLINK-15535) Add usage of ProcessFunctionTestHarnesses for testing documentation

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

[jira] [Updated] (FLINK-15535) Add usage of ProcessFunctionTestHarnesses for testing documentation

[ https://issues.apache.org/jira/browse/FLINK-15535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-15535: --- Issue Type: Bug (was: Wish) > Add usage of ProcessFunctionTestHarnesses for testing documen

[jira] [Updated] (FLINK-15535) Add usage of ProcessFunctionTestHarnesses for testing documentation

[ https://issues.apache.org/jira/browse/FLINK-15535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-15535: --- Affects Version/s: 1.10.0 > Add usage of ProcessFunctionTestHarnesses for testing documentat

[jira] [Closed] (FLINK-14843) Streaming bucketing end-to-end test can fail with Output hash mismatch

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

[jira] [Assigned] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-14742: -- Assignee: Kostas Kloudas > Unstable tests TaskExecutorTest#testSubmitTaskBeforeAccept

[jira] [Commented] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016912#comment-17016912 ] Kostas Kloudas commented on FLINK-14742: If you run it in a loop until failure (

[jira] [Commented] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016929#comment-17016929 ] Kostas Kloudas commented on FLINK-14742: Or this: {code:java} Caught exception

[jira] [Updated] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-14742: --- Priority: Blocker (was: Critical) > Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcc

[jira] [Commented] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016971#comment-17016971 ] Kostas Kloudas commented on FLINK-14742: I upgraded it to a blocker until we kno

[jira] [Comment Edited] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016971#comment-17016971 ] Kostas Kloudas edited comment on FLINK-14742 at 1/16/20 2:06 PM: -

[jira] [Commented] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017059#comment-17017059 ] Kostas Kloudas commented on FLINK-14742: Ok it seems to be a test instability so

[jira] [Updated] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-14742: --- Priority: Critical (was: Blocker) > Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcc

[jira] [Comment Edited] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017059#comment-17017059 ] Kostas Kloudas edited comment on FLINK-14742 at 1/16/20 4:01 PM: -

[jira] [Comment Edited] (FLINK-14742) Unstable tests TaskExecutorTest#testSubmitTaskBeforeAcceptSlot

[ https://issues.apache.org/jira/browse/FLINK-14742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017059#comment-17017059 ] Kostas Kloudas edited comment on FLINK-14742 at 1/16/20 4:01 PM: -

[jira] [Updated] (FLINK-15476) Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy

[ https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-15476: --- Affects Version/s: 1.10.0 > Update StreamingFileSink documentation -- bulk encoded writer no

[jira] [Commented] (FLINK-15476) Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy

[ https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017831#comment-17017831 ] Kostas Kloudas commented on FLINK-15476: Hi [~yxu-apache], the documentation on

[jira] [Updated] (FLINK-15476) Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy

[ https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-15476: --- Component/s: Connectors / FileSystem > Update StreamingFileSink documentation -- bulk encode

[jira] [Assigned] (FLINK-15476) Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy

[ https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-15476: -- Assignee: Ying Xu > Update StreamingFileSink documentation -- bulk encoded writer now

[jira] [Closed] (FLINK-15615) Docs: wrong guarantees stated for the file sink

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

[jira] [Created] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

Kostas Kloudas created FLINK-15687: -- Summary: Potential test instabilities due to concurrent access to TaskSlotTable. Key: FLINK-15687 URL: https://issues.apache.org/jira/browse/FLINK-15687 Project:

[jira] [Updated] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-15687: --- Priority: Critical (was: Major) > Potential test instabilities due to concurrent access to

[jira] [Updated] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-15687: --- Issue Type: Task (was: Improvement) > Potential test instabilities due to concurrent access

[jira] [Updated] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

[ https://issues.apache.org/jira/browse/FLINK-15687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-15687: --- Labels: test-stability (was: ) > Potential test instabilities due to concurrent access to T

[jira] [Closed] (FLINK-13758) failed to submit JobGraph when registered hdfs file in DistributedCache

[ https://issues.apache.org/jira/browse/FLINK-13758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-13758. -- Resolution: Fixed Merged on master with 8bb83c7fed2142aba5e7f3188a69c32ee04f2761 1.10 with 2f9

[jira] [Commented] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022084#comment-17022084 ] Kostas Kloudas commented on FLINK-14807: I have to think about the whole issue m

[jira] [Comment Edited] (FLINK-14807) Add Table#collect api for fetching data to client

[ https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022084#comment-17022084 ] Kostas Kloudas edited comment on FLINK-14807 at 1/23/20 3:45 PM: -

[jira] [Commented] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022938#comment-17022938 ] Kostas Kloudas commented on FLINK-2646: --- Hi [~maguowei], and thanks for the warming

[jira] [Commented] (FLINK-15611) KafkaITCase.testOneToOneSources fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-15611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17023055#comment-17023055 ] Kostas Kloudas commented on FLINK-15611: Another issue that can be related is  [

[jira] [Commented] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17023164#comment-17023164 ] Kostas Kloudas commented on FLINK-2646: --- For [~sewen]'s comment, I totally agree th

[jira] [Comment Edited] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17023164#comment-17023164 ] Kostas Kloudas edited comment on FLINK-2646 at 1/24/20 6:37 PM: ---

[jira] [Comment Edited] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17023164#comment-17023164 ] Kostas Kloudas edited comment on FLINK-2646 at 1/27/20 8:53 AM: ---

[jira] [Commented] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024185#comment-17024185 ] Kostas Kloudas commented on FLINK-2646: --- Hi [~maguowei], one of the problems I see

[jira] [Commented] (FLINK-15777) Truncate not working with plugins (as expected)

[ https://issues.apache.org/jira/browse/FLINK-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024385#comment-17024385 ] Kostas Kloudas commented on FLINK-15777: [~arvid heise] well the checks existed

[jira] [Assigned] (FLINK-15777) Truncate not working with plugins (as expected)

[ https://issues.apache.org/jira/browse/FLINK-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-15777: -- Assignee: Arvid Heise > Truncate not working with plugins (as expected) > ---

[jira] [Comment Edited] (FLINK-15777) Truncate not working with plugins (as expected)

[ https://issues.apache.org/jira/browse/FLINK-15777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17024385#comment-17024385 ] Kostas Kloudas edited comment on FLINK-15777 at 1/27/20 9:05 PM: -

[jira] [Commented] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17025065#comment-17025065 ] Kostas Kloudas commented on FLINK-2646: --- I think that the discussion deviates a bit

[jira] [Updated] (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 updated FLINK-15805: --- Priority: Critical (was: Major) > StreamingFileSink on S3 fails when firing processing time

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

Kostas Kloudas created FLINK-15805: -- Summary: StreamingFileSink on S3 fails when firing processing time timers after recovery. Key: FLINK-15805 URL: https://issues.apache.org/jira/browse/FLINK-15805

[jira] [Closed] (FLINK-15768) Consolidate executor related class into same module in flink-clients

[ https://issues.apache.org/jira/browse/FLINK-15768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-15768. -- Fix Version/s: 1.10.0 Resolution: Fixed Merged on release-1.10 with 14a29a4621d8181c918

[jira] [Assigned] (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 reassigned FLINK-15805: -- Assignee: Kostas Kloudas > StreamingFileSink on S3 fails when firing processing time

[jira] [Updated] (FLINK-13940) S3RecoverableWriter causes job to get stuck in recovery

[ https://issues.apache.org/jira/browse/FLINK-13940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-13940: --- Fix Version/s: 1.8.2 > S3RecoverableWriter causes job to get stuck in recovery > ---

[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&focusedCommentId=17028782#comment-17028782 ] Kostas Kloudas commented on FLINK-15852: Yes this seems to be problematic and it

[jira] [Commented] (FLINK-15476) Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy

[ https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029943#comment-17029943 ] Kostas Kloudas commented on FLINK-15476: Any news on this [~yxu-apache]? > Upda

[jira] [Created] (FLINK-15926) Add DataStream.broadcast(StateDescriptor) to available transformations docs

Kostas Kloudas created FLINK-15926: -- Summary: Add DataStream.broadcast(StateDescriptor) to available transformations docs Key: FLINK-15926 URL: https://issues.apache.org/jira/browse/FLINK-15926 Proje

[jira] [Commented] (FLINK-15476) Update StreamingFileSink documentation -- bulk encoded writer now supports customized checkpoint policy

[ https://issues.apache.org/jira/browse/FLINK-15476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17032205#comment-17032205 ] Kostas Kloudas commented on FLINK-15476: Yes no problem! I wanted just to verify

[jira] [Closed] (FLINK-15273) Complete and Update Documentation for 1.10

[ https://issues.apache.org/jira/browse/FLINK-15273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-15273. -- Resolution: Implemented > Complete and Update Documentation for 1.10 > ---

[jira] [Commented] (FLINK-16013) List config option could not be parsed correctly

[ https://issues.apache.org/jira/browse/FLINK-16013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17035202#comment-17035202 ] Kostas Kloudas commented on FLINK-16013: [~fly_in_gis] thanks for reporting this

[jira] [Assigned] (FLINK-16013) List config option could not be parsed correctly

[ https://issues.apache.org/jira/browse/FLINK-16013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-16013: -- Assignee: Yang Wang > List config option could not be parsed correctly >

[jira] [Updated] (FLINK-16013) List config option could not be parsed correctly

[ https://issues.apache.org/jira/browse/FLINK-16013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-16013: --- Affects Version/s: 1.10.0 > List config option could not be parsed correctly > -

[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&focusedCommentId=17083038#comment-17083038 ] Kostas Kloudas commented on FLINK-17110: Hi [~wenlong.lwl], from the JIRA and th

[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: FLI

[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: FLINK-1

[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 > > > Key:

[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&focusedCommentId=17084834#comment-17084834 ] Kostas Kloudas commented on FLINK-16662: Thanks for reporting and debugging all

[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&focusedCommentId=17084834#comment-17084834 ] Kostas Kloudas edited comment on FLINK-16662 at 4/16/20, 12:50 PM: ---

[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&focusedCommentId=17085573#comment-17085573 ] Kostas Kloudas commented on FLINK-10114: I added this dependency after the discu

[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&focusedCommentId=17085596#comment-17085596 ] Kostas Kloudas commented on FLINK-17110: I agree that the two configurations sho

[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] [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. > Int

[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&focusedCommentId=17088047#comment-17088047 ] Kostas Kloudas commented on FLINK-16662: Hi [~zhanglibing1...@126.com], and than

[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&focusedCommentId=17088051#comment-17088051 ] Kostas Kloudas commented on FLINK-16662: [~NicoK] could you please verify that t

[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 > Intr

[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 > Intr

[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 > Wire

[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 releas

[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] [Commented] (FLINK-17364) Support StreamingFileSink in PrestoS3FileSystem

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

[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-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 681b2113845c879e058512d3b

[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 manda

[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 config

[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 configu

[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 classp

[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 configurati

[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] [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&focusedCommentId=17110346#comment-17110346 ] Kostas Kloudas commented on FLINK-17444: This is the documentation issue https:

[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 releas

[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' extractedTempL

[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 b

[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 m

[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' extrac

[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&focusedCommentId=17111007#comment-17111007 ] Kostas Kloudas commented on FLINK-17745: Hi all, from the removed code in the PR

[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&focusedCommentId=17111007#comment-17111007 ] Kostas Kloudas edited comment on FLINK-17745 at 5/19/20, 9:27 AM:

[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] [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

<    4   5   6   7   8   9   10   11   12   13   >