[
https://issues.apache.org/jira/browse/FLINK-1892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14499252#comment-14499252
]
Jeff Zhang commented on FLINK-1892:
---
[~ktzoumas] This issue is resolved in TEZ-1661
Jeff Zhang created FLINK-9555:
-
Summary: Support table api in scala shell
Key: FLINK-9555
URL: https://issues.apache.org/jira/browse/FLINK-9555
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505781#comment-16505781
]
Jeff Zhang commented on FLINK-9555:
---
I will work on it
> Support table api in scala shell
>
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505791#comment-16505791
]
Jeff Zhang commented on FLINK-9555:
---
I mean to support it natively so that user don't need to specify
Jeff Zhang created FLINK-9554:
-
Summary: flink scala shell doesn't work in yarn mode
Key: FLINK-9554
URL: https://issues.apache.org/jira/browse/FLINK-9554
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505619#comment-16505619
]
Jeff Zhang commented on FLINK-9554:
---
FLINK-8795 is about scala shell hangs when running flink job in
Jeff Zhang created FLINK-9699:
-
Summary: Add api to replace table
Key: FLINK-9699
URL: https://issues.apache.org/jira/browse/FLINK-9699
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-9699:
--
Summary: Add api to replace registered table (was: Add api to replace
table)
> Add api to replace
[
https://issues.apache.org/jira/browse/FLINK-9698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16529406#comment-16529406
]
Jeff Zhang commented on FLINK-9698:
---
Could anyone let me know why flink require case class must be
Jeff Zhang created FLINK-9698:
-
Summary: "case class must be static and globally accessible" is
too constrained
Key: FLINK-9698
URL: https://issues.apache.org/jira/browse/FLINK-9698
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16531027#comment-16531027
]
Jeff Zhang commented on FLINK-9699:
---
Thanks [~fhueske], let's hold this ticket for now. I will try to
[
https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530922#comment-16530922
]
Jeff Zhang commented on FLINK-9699:
---
[~fhueske] I don't know much about the internal mechanism of flink
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-9554:
--
Fix Version/s: 1.5.1
> flink scala shell doesn't work in yarn mode
>
[
https://issues.apache.org/jira/browse/FLINK-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-9554:
--
Priority: Blocker (was: Major)
> flink scala shell doesn't work in yarn mode
>
Jeff Zhang created FLINK-9718:
-
Summary: Add enviroment variable in start-scala-shell.sh to enable
remote debug
Key: FLINK-9718
URL: https://issues.apache.org/jira/browse/FLINK-9718
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16575696#comment-16575696
]
Jeff Zhang commented on FLINK-10119:
[~CrestOfWave] Please use English to create ticket.
>
[
https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-9718:
-
Assignee: Jeff Zhang
> Add enviroment variable in start-scala-shell.sh & flink to enable remote
[
https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-9718:
--
Summary: Add enviroment variable in start-scala-shell.sh & flink to enable
remote debug (was: Add
[
https://issues.apache.org/jira/browse/FLINK-10702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-10702:
--
Assignee: Jeff Zhang
> Yarn app is not killed when scala shell is terminated
>
Jeff Zhang created FLINK-10702:
--
Summary: Yarn app is not killed when scala shell is terminated
Key: FLINK-10702
URL: https://issues.apache.org/jira/browse/FLINK-10702
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688099#comment-16688099
]
Jeff Zhang commented on FLINK-10873:
Thanks [~fhueske] for the comment, I am a little confused in
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688986#comment-16688986
]
Jeff Zhang commented on FLINK-9555:
---
Thanks [~csq] Basically, this is what I'd like to achieve, could
[
https://issues.apache.org/jira/browse/FLINK-9699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-9699:
-
Assignee: Jeff Zhang
> Add api to replace registered table
>
Jeff Zhang created FLINK-10871:
--
Summary: ExecutionEnvironment & TableEnvironment should be
singleton
Key: FLINK-10871
URL: https://issues.apache.org/jira/browse/FLINK-10871
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686150#comment-16686150
]
Jeff Zhang commented on FLINK-10871:
Thanks [~hequn8128], I link FLINK-10873 which is related to
Jeff Zhang created FLINK-10873:
--
Summary: Remove tableEnv in DataSetConversions#toTable and
DataStreamConversions#toTable
Key: FLINK-10873
URL: https://issues.apache.org/jira/browse/FLINK-10873
Project:
Jeff Zhang created FLINK-10889:
--
Summary: Semantic inconsistency between DataSet#print and
DataStream#print
Key: FLINK-10889
URL: https://issues.apache.org/jira/browse/FLINK-10889
Project: Flink
Jeff Zhang created FLINK-10892:
--
Summary: Flink Yarn app name is hard coded
Key: FLINK-10892
URL: https://issues.apache.org/jira/browse/FLINK-10892
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-10892:
---
Description:
It is always "Flink session cluster", this is not convenient for users to
figure out
[
https://issues.apache.org/jira/browse/FLINK-10889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688004#comment-16688004
]
Jeff Zhang commented on FLINK-10889:
Thanks [~fhueske] for the comment. I understand that it may not
[
https://issues.apache.org/jira/browse/FLINK-10871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-10871:
---
Description: For now, ExecutionEnvironment.getExecutionEnvironment and
[
https://issues.apache.org/jira/browse/FLINK-11253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732688#comment-16732688
]
Jeff Zhang commented on FLINK-11253:
I think this is a bug that needs to be fixed if ctrl+c doesn't
[
https://issues.apache.org/jira/browse/FLINK-11255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16732687#comment-16732687
]
Jeff Zhang commented on FLINK-11255:
[~btleedev] Thanks for reporting this issue, community has some
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729307#comment-16729307
]
Jeff Zhang commented on FLINK-11222:
[~hequn8128] This would introduce incompatibility, we should be
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729342#comment-16729342
]
Jeff Zhang commented on FLINK-11222:
I think we need to reach consensus in community first, I will
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729358#comment-16729358
]
Jeff Zhang commented on FLINK-11222:
[~dian.fu] Oh, maybe my misunderstanding, I thought it was
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729371#comment-16729371
]
Jeff Zhang commented on FLINK-11222:
I see, thanks [~dian.fu] then I think it makes sense to do this
Jeff Zhang created FLINK-11224:
--
Summary: Log is missing in scala-shell
Key: FLINK-11224
URL: https://issues.apache.org/jira/browse/FLINK-11224
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-11224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-11224:
--
Assignee: Jeff Zhang
> Log is missing in scala-shell
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-11161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11161:
---
Attachment: (was: image-2018-12-14-09-56-18-275.png)
> Unable to import java packages in
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722161#comment-16722161
]
Jeff Zhang commented on FLINK-9555:
---
[~Zentol] Do you mean the bug of FLINK-11161 ?
> Support table
[
https://issues.apache.org/jira/browse/FLINK-11161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11161:
---
Attachment: (was: image-2018-12-14-09-55-29-523.png)
> Unable to import java packages in
Jeff Zhang created FLINK-11161:
--
Summary: Unable to import java packages in scala-shell
Key: FLINK-11161
URL: https://issues.apache.org/jira/browse/FLINK-11161
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710061#comment-16710061
]
Jeff Zhang commented on FLINK-11078:
[~Tison] Do you mean dynamic allocation via specifying the
[
https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11060:
---
Summary: Unable to set number of task manager and slot per task manager in
scala shell local mode
[
https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11060:
---
Description: In scala-shell, I can not change the number of task manager
and slot per task manager,
[
https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-11060:
--
Assignee: Jeff Zhang
> Unable to set number of task manager and slot per task manager in
[
https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11060:
---
Description: In scala-shell, I can not change the number of task manager
and slot per task number
Jeff Zhang created FLINK-11060:
--
Summary: Unable to set number of task manager and slot per task
number in scala shell local mode
Key: FLINK-11060
URL: https://issues.apache.org/jira/browse/FLINK-11060
[
https://issues.apache.org/jira/browse/FLINK-11049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16712947#comment-16712947
]
Jeff Zhang commented on FLINK-11049:
[~till.rohrmann] IIUC, there're 2 kinds of executions in flink,
[
https://issues.apache.org/jira/browse/FLINK-11049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11049:
---
Description:
{code}
val benv = ExecutionEnvironment.getExecutionEnvironment
val btEnv =
Jeff Zhang created FLINK-11049:
--
Summary: Unable to execute partial DAG
Key: FLINK-11049
URL: https://issues.apache.org/jira/browse/FLINK-11049
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-11049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-11049:
--
Assignee: Jeff Zhang
> Unable to execute partial DAG
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692701#comment-16692701
]
Jeff Zhang commented on FLINK-10892:
We don't need to set it as an yarn app name in api level, but
[
https://issues.apache.org/jira/browse/FLINK-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692609#comment-16692609
]
Jeff Zhang commented on FLINK-10892:
[~yanghua] Shouldn't we expose it in ExecutionEnvironment,
[
https://issues.apache.org/jira/browse/FLINK-11264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11264:
---
Component/s: Scala Shell
> Fail to start scala shell
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-11264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11264:
---
Affects Version/s: 1.7.1
> Fail to start scala shell
> -
>
>
Jeff Zhang created FLINK-11264:
--
Summary: Fail to start scala shell
Key: FLINK-11264
URL: https://issues.apache.org/jira/browse/FLINK-11264
Project: Flink
Issue Type: Bug
Reporter:
Jeff Zhang created FLINK-11305:
--
Summary: Allow developer to test flink without building the whole
flink project
Key: FLINK-11305
URL: https://issues.apache.org/jira/browse/FLINK-11305
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11305:
---
Description:
As a flink developer, each time I make some changes in flink, I would like to
test it
[
https://issues.apache.org/jira/browse/FLINK-11305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-11305:
--
Assignee: Jeff Zhang
> Allow developer to test flink without building the whole flink
[
https://issues.apache.org/jira/browse/FLINK-11305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11305:
---
Description:
As a flink developer, each time I make some changes in flink, I would like to
test it
[
https://issues.apache.org/jira/browse/FLINK-11305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang resolved FLINK-11305.
Resolution: Won't Fix
> Allow developer to test flink without building the whole flink project
>
[
https://issues.apache.org/jira/browse/FLINK-11305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16741815#comment-16741815
]
Jeff Zhang commented on FLINK-11305:
Thanks [~Zentol] for the approach, it's my misunderstanding.
[
https://issues.apache.org/jira/browse/FLINK-10341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-10341:
--
Assignee: Jeff Zhang
> Add option to print flink command when running bin/flink
>
Jeff Zhang created FLINK-10341:
--
Summary: Add option to print flink command when running bin/flink
Key: FLINK-10341
URL: https://issues.apache.org/jira/browse/FLINK-10341
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-11204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16724997#comment-16724997
]
Jeff Zhang commented on FLINK-11204:
Do you run kinit before starting scala-shell ?
> flink
[
https://issues.apache.org/jira/browse/FLINK-12002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801504#comment-16801504
]
Jeff Zhang commented on FLINK-12002:
This is a very useful features, specially for session mode
[
https://issues.apache.org/jira/browse/FLINK-12002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16801504#comment-16801504
]
Jeff Zhang edited comment on FLINK-12002 at 3/26/19 9:17 AM:
-
This is a very
[
https://issues.apache.org/jira/browse/FLINK-12027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16804507#comment-16804507
]
Jeff Zhang commented on FLINK-12027:
Oops, I didn't there's such api
[
https://issues.apache.org/jira/browse/FLINK-12027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16804512#comment-16804512
]
Jeff Zhang commented on FLINK-12027:
Unfortunately, web ui is still not accessible even when I use
[
https://issues.apache.org/jira/browse/FLINK-12027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16804708#comment-16804708
]
Jeff Zhang commented on FLINK-12027:
[~Zentol] I don't see RestServerEndpoint, but only see
Jeff Zhang created FLINK-12027:
--
Summary: Flink Web UI is not accessible in local mode
Key: FLINK-12027
URL: https://issues.apache.org/jira/browse/FLINK-12027
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-12027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12027:
---
Description:
When I use flink in local mode (LocalEnvironment), I can not access flink web
ui.
Jeff Zhang created FLINK-11970:
--
Summary: TableEnvironment#registerFunction should overwrite if the
same name function existed.
Key: FLINK-11970
URL: https://issues.apache.org/jira/browse/FLINK-11970
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-12214:
--
Assignee: Jeff Zhang
> Add JobListener to capture job submission process
>
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Description: Third party library would like to add some hook when
submitting jobs. So it would be
Jeff Zhang created FLINK-12214:
--
Summary: Add JobListener to capture job submission process
Key: FLINK-12214
URL: https://issues.apache.org/jira/browse/FLINK-12214
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Attachment: image-2019-04-17-00-13-15-999.png
> Add JobListener to capture job submission process
>
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819215#comment-16819215
]
Jeff Zhang edited comment on FLINK-12214 at 4/16/19 4:18 PM:
-
Thanks for the
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Description:
Third party library would like to add some hook when submitting jobs. So it
would be
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Attachment: image-2019-04-17-00-11-00-020.png
> Add JobListener to capture job submission process
>
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Description:
Third party library would like to add some hook when submitting jobs. So it
would be
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Description:
Third party library would like to add some hook when submitting jobs. So it
would be
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819215#comment-16819215
]
Jeff Zhang edited comment on FLINK-12214 at 4/16/19 4:22 PM:
-
Thanks for the
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Description:
Third party library would like to add some hook when submitting jobs. So it
would be
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819215#comment-16819215
]
Jeff Zhang commented on FLINK-12214:
Thanks for the comment, [~till.rohrmann]. The background is
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Attachment: image-2019-04-17-00-15-16-750.png
> Add JobListener to capture job submission process
>
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Description:
Third party library would like to add some hook when submitting jobs. So it
would be
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819578#comment-16819578
]
Jeff Zhang commented on FLINK-12214:
[~till.rohrmann] I think this issue is orthogonal with
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Summary: Add JobListener (hook) in flink job lifecycle (was: Add
JobListener (hook) to in job
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Summary: Add JobListener(hook) in flink job lifecycle (was: Add
JobListener (hook) in flink job
[
https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-12214:
---
Summary: Add JobListener (hook) to in job lifecycle (was: Add JobListener
to capture job
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-1:
--
Assignee: Jeff Zhang
> No way to ship custom jars to yarn cluster in scala-shell
>
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-1:
---
Component/s: Deployment / YARN
> No way to ship custom jars to yarn cluster in scala-shell
>
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-1:
---
Affects Version/s: 1.8.0
> No way to ship custom jars to yarn cluster in scala-shell
>
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-1:
---
Summary: `start-scala-shell -a ` doesn't ship jars to yarn container
(was: No way to ship custom
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-1:
---
Description: If user use `flink run` to submit flink jars, he could build
uber jar to include all
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-1:
---
Issue Type: Bug (was: New Feature)
> No way to ship custom jars to yarn cluster in scala-shell
>
Jeff Zhang created FLINK-1:
--
Summary: No way to ship custom jars to yarn cluster in scala-shell
Key: FLINK-1
URL: https://issues.apache.org/jira/browse/FLINK-1
Project: Flink
Issue
1 - 100 of 314 matches
Mail list logo
