[
https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931080#comment-16931080
]
liupengcheng edited comment on FLINK-14037 at 9/17/19 4:42 AM:
---
[~zhuzh]
[
https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931080#comment-16931080
]
liupengcheng commented on FLINK-14037:
--
[~zhuzh]
>However, I'm not sure whether this should be
[
https://issues.apache.org/jira/browse/FLINK-13300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chan resolved FLINK-13300.
Resolution: Done
> Add OverwritableTableSink bridge logic to flink planner
>
[
https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931076#comment-16931076
]
Zhu Zhu commented on FLINK-14037:
-
Hi [~liupengcheng], the unification of class loader resolving order
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931068#comment-16931068
]
Zijie Lu commented on FLINK-992:
[~fhueske], I am new here. What's the status of this issue now? If no one
yanghua commented on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and
deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation
URL: https://github.com/apache/flink/pull/9691#issuecomment-532046435
@tillrohrmann Can you review this PR? thanks.
[
https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-14092:
--
Assignee: (was: Daniel Schwager)
> Upgrade Calcite version to 1.21 for Flink SQL
>
[
https://issues.apache.org/jira/browse/FLINK-14092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-14092:
--
Assignee: Daniel Schwager
> Upgrade Calcite version to 1.21 for Flink SQL
>
Danny Chan created FLINK-14092:
--
Summary: Upgrade Calcite version to 1.21 for Flink SQL
Key: FLINK-14092
URL: https://issues.apache.org/jira/browse/FLINK-14092
Project: Flink
Issue Type:
flinkbot edited a comment on issue #9683: [FLINK-14037]Use same
userCodeClassLoader as jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778
## CI report:
* ba87beba470b132b99ed606411ffc43847a72d8f : SUCCESS
[
https://issues.apache.org/jira/browse/FLINK-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931044#comment-16931044
]
Peng Wang commented on FLINK-14091:
---
{{SharedCountConnectionStateListener already handle it(as shown
[
https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931043#comment-16931043
]
Zijie Lu commented on FLINK-13746:
--
Do you mean the test class of Elasticsearch6SinkExample? And do
[
https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zijie Lu updated FLINK-13746:
-
Comment: was deleted
(was: Do you mean the test class of Elasticsearch6SinkExample?)
> Elasticsearch
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python]
Introduce PythonScalarFunctionRunner to handle the communication with Python
worker for Python ScalarFunction execution
URL: https://github.com/apache/flink/pull/9653#discussion_r324685855
##
File path:
hequn8128 commented on a change in pull request #9653: [FLINK-14014][python]
Introduce PythonScalarFunctionRunner to handle the communication with Python
worker for Python ScalarFunction execution
URL: https://github.com/apache/flink/pull/9653#discussion_r324949146
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931032#comment-16931032
]
Zijie Lu commented on FLINK-13746:
--
Do you mean the test class of Elasticsearch6SinkExample?
>
[
https://issues.apache.org/jira/browse/FLINK-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931030#comment-16931030
]
Yun Tang commented on FLINK-14091:
--
>From the error description, I think
flinkbot edited a comment on issue #9683: [FLINK-14037]Use same
userCodeClassLoader as jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778
## CI report:
* ba87beba470b132b99ed606411ffc43847a72d8f : SUCCESS
TisonKun commented on a change in pull request #9686: [FLINK-14069] [core]
Enable TimeUtils for all time units labels supported by scala Duration
URL: https://github.com/apache/flink/pull/9686#discussion_r324958917
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931022#comment-16931022
]
Yang Shen commented on FLINK-14091:
---
Same problem！
> Job can not trigger checkpoint forever after
TisonKun commented on a change in pull request #9686: [FLINK-14069] [core]
Enable TimeUtils for all time units labels supported by scala Duration
URL: https://github.com/apache/flink/pull/9686#discussion_r324958440
##
File path:
flinkbot edited a comment on issue #9683: [FLINK-14037]Use same
userCodeClassLoader as jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778
## CI report:
* ba87beba470b132b99ed606411ffc43847a72d8f : SUCCESS
zhuzhurk commented on a change in pull request #9686: [FLINK-14069] [core]
Enable TimeUtils for all time units labels supported by scala Duration
URL: https://github.com/apache/flink/pull/9686#discussion_r324956726
##
File path:
zhuzhurk commented on a change in pull request #9686: [FLINK-14069] [core]
Enable TimeUtils for all time units labels supported by scala Duration
URL: https://github.com/apache/flink/pull/9686#discussion_r324956726
##
File path:
zhuzhurk commented on a change in pull request #9686: [FLINK-14069] [core]
Enable TimeUtils for all time units labels supported by scala Duration
URL: https://github.com/apache/flink/pull/9686#discussion_r324956426
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-13975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931016#comment-16931016
]
Zijie Lu commented on FLINK-13975:
--
I have interested in this issue. I want to try it out.
> Translate
flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys
and deprecatedKeys methods in ConfigOption and mark it with @Deprecated
annotation
URL: https://github.com/apache/flink/pull/9691#issuecomment-531758345
## CI report:
*
[
https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931014#comment-16931014
]
Zijie Lu commented on FLINK-13682:
--
I want to try it out. Can you assign this issue to me?[~jark]
>
liupc commented on a change in pull request #9683: [FLINK-14037]Use same
userCodeClassLoader as jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683#discussion_r324954953
##
File path:
liupc commented on a change in pull request #9683: [FLINK-14037]Use same
userCodeClassLoader as jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683#discussion_r324954939
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931009#comment-16931009
]
Zijie Lu edited comment on FLINK-13278 at 9/17/19 2:09 AM:
---
I want to try it
[
https://issues.apache.org/jira/browse/FLINK-13278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931009#comment-16931009
]
Zijie Lu commented on FLINK-13278:
--
I want to try it out. Can you assign this issue to me?
> add
Peng Wang created FLINK-14091:
-
Summary: Job can not trigger checkpoint forever after zookeeper
change leader
Key: FLINK-14091
URL: https://issues.apache.org/jira/browse/FLINK-14091
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-13900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931002#comment-16931002
]
Jun Zhang commented on FLINK-13900:
---
I suggest that we should control the output speed of the stream
TisonKun commented on a change in pull request #9686: [FLINK-14069] [core]
Enable TimeUtils for all time units labels supported by scala Duration
URL: https://github.com/apache/flink/pull/9686#discussion_r324947333
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Zhang closed FLINK-14077.
-
Fix Version/s: 1.9.0
Resolution: Fixed
> get java.util.ConcurrentModificationException when
TisonKun commented on a change in pull request #9686: [FLINK-14069] [core]
Enable TimeUtils for all time units labels supported by scala Duration
URL: https://github.com/apache/flink/pull/9686#discussion_r324947333
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930995#comment-16930995
]
Jun Zhang commented on FLINK-14077:
---
I excluded the kafka-clients in flink-connector-kafka and added
TisonKun commented on a change in pull request #9686: [FLINK-14069] [core]
Enable TimeUtils for all time units labels supported by scala Duration
URL: https://github.com/apache/flink/pull/9686#discussion_r324947202
##
File path:
yiduwangkai closed pull request #9163: [FLINK-13086]add Chinese documentation
for catalogs
URL: https://github.com/apache/flink/pull/9163
This is an automated message from the Apache Git Service.
To respond to the message,
yiduwangkai closed pull request #9164:
[FLINK-12894][doc][Chinese-translation]add Chinese documentation of how to
configure and use catalogs in SQL CLI
URL: https://github.com/apache/flink/pull/9164
This is an automated
TisonKun commented on a change in pull request #9598:
[FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to
cluster-id subdirectory of high-availability storage
URL: https://github.com/apache/flink/pull/9598#discussion_r324946522
##
File path:
flinkbot edited a comment on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys
and deprecatedKeys methods in ConfigOption and mark it with @Deprecated
annotation
URL: https://github.com/apache/flink/pull/9691#issuecomment-531758345
## CI report:
*
yanghua commented on issue #9691: [FLINK-13965] Keep hasDeprecatedKeys and
deprecatedKeys methods in ConfigOption and mark it with @Deprecated annotation
URL: https://github.com/apache/flink/pull/9691#issuecomment-532013384
@flinkbot run travis
Bowen Li created FLINK-14090:
Summary: FLIP-57 Rework FunctionCatalog
Key: FLINK-14090
URL: https://issues.apache.org/jira/browse/FLINK-14090
Project: Flink
Issue Type: Improvement
flinkbot edited a comment on issue #9694: [hotfix] [docs] Fixes in glossar
URL: https://github.com/apache/flink/pull/9694#issuecomment-531879431
## CI report:
* 74b0c2b6e8460230a39f2a01c132d5102bd338d7 : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/127880973)
flinkbot edited a comment on issue #9598: [FLINK-13633][coordination] Move
submittedJobGraph and completedCheckpoint to cluster-id subdirectory of
high-availability storage
URL: https://github.com/apache/flink/pull/9598#issuecomment-527343788
## CI report:
*
flinkbot edited a comment on issue #9598: [FLINK-13633][coordination] Move
submittedJobGraph and completedCheckpoint to cluster-id subdirectory of
high-availability storage
URL: https://github.com/apache/flink/pull/9598#issuecomment-527343788
## CI report:
*
flinkbot edited a comment on issue #9694: [hotfix] [docs] Fixes in glossar
URL: https://github.com/apache/flink/pull/9694#issuecomment-531879431
## CI report:
* 74b0c2b6e8460230a39f2a01c132d5102bd338d7 : PENDING
[Build](https://travis-ci.com/flink-ci/flink/builds/127880973)
tillrohrmann commented on issue #9598: [FLINK-13633][coordination] Move
submittedJobGraph and completedCheckpoint to cluster-id subdirectory of
high-availability storage
URL: https://github.com/apache/flink/pull/9598#issuecomment-531884842
I've pushed an update which simplifies the test
flinkbot commented on issue #9694: [hotfix] [docs] Fixes in glossar
URL: https://github.com/apache/flink/pull/9694#issuecomment-531879431
## CI report:
* 74b0c2b6e8460230a39f2a01c132d5102bd338d7 : UNKNOWN
This
flinkbot commented on issue #9694: [hotfix] [docs] Fixes in glossar
URL: https://github.com/apache/flink/pull/9694#issuecomment-531874391
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this
afedulov opened a new pull request #9694: [hotfix] [docs] Fixes in glossar
URL: https://github.com/apache/flink/pull/9694
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
walterddr commented on issue #8468: [FLINK-12399][table][table-planner] Fix
FilterableTableSource does not change after applyPredicate
URL: https://github.com/apache/flink/pull/8468#issuecomment-531871165
@KurtYoung can you help take another look on the approach? thanks
[
https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930672#comment-16930672
]
Elias Levy commented on FLINK-12122:
What is the status of this issue? It's has a serious negative
flinkbot edited a comment on issue #9693: Flink 13984
URL: https://github.com/apache/flink/pull/9693#issuecomment-531808855
## CI report:
* 62ad65e31df8f36747991513ab89504126758af6 : CANCELED
[Build](https://travis-ci.com/flink-ci/flink/builds/127816671)
*
fhueske commented on issue #9210: [FLINK-12746][docs] Getting Started -
DataStream Example Walkthrough
URL: https://github.com/apache/flink/pull/9210#issuecomment-531845829
Thanks for the update @sjwiesman.
This looks good! I'll make some minor fixes and improvements and will merge
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324753757
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324749553
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324748387
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324748387
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324748387
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
flinkbot edited a comment on issue #9693: Flink 13984
URL: https://github.com/apache/flink/pull/9693#issuecomment-531808855
## CI report:
* 62ad65e31df8f36747991513ab89504126758af6 : CANCELED
[Build](https://travis-ci.com/flink-ci/flink/builds/127816671)
*
[
https://issues.apache.org/jira/browse/FLINK-14002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930650#comment-16930650
]
Elias Levy commented on FLINK-14002:
I am for that. Alternatively, {{KafkaSerializationSchema}} and
flinkbot edited a comment on issue #9693: Flink 13984
URL: https://github.com/apache/flink/pull/9693#issuecomment-531808855
## CI report:
* 62ad65e31df8f36747991513ab89504126758af6 : CANCELED
[Build](https://travis-ci.com/flink-ci/flink/builds/127816671)
*
flinkbot edited a comment on issue #9693: Flink 13984
URL: https://github.com/apache/flink/pull/9693#issuecomment-531808855
## CI report:
* 62ad65e31df8f36747991513ab89504126758af6 : PENDING
[Build](https://travis-ci.com/flink-ci/flink/builds/127816671)
*
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381
## CI report:
* 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED
flinkbot commented on issue #9693: Flink 13984
URL: https://github.com/apache/flink/pull/9693#issuecomment-531808855
## CI report:
* 62ad65e31df8f36747991513ab89504126758af6 : UNKNOWN
This is an automated
flinkbot edited a comment on issue #9692: [FLINK-13896]make scala-maven-plugin
compile target jvm version consistent with java version
URL: https://github.com/apache/flink/pull/9692#issuecomment-531777035
## CI report:
* 60b01f1245e2c797f7e7182e871ded83f6831ed7 : SUCCESS
[
https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930613#comment-16930613
]
Guowei Ma commented on FLINK-13993:
---
I will do it. thanks. [~till.rohrmann]
> Using
flinkbot commented on issue #9693: Flink 13984
URL: https://github.com/apache/flink/pull/9693#issuecomment-531804621
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
azagrebin commented on issue #9693: Flink 13984
URL: https://github.com/apache/flink/pull/9693#issuecomment-531803716
cc @xintongsong
This is an automated message from the Apache Git Service.
To respond to the message,
azagrebin opened a new pull request #9693: Flink 13984
URL: https://github.com/apache/flink/pull/9693
## What is the purpose of the change
This does some refactoring to prepare and then changes the MemoryManager to
serve both types of memory at the same time: HEAP and OFF_HEAP.
TisonKun commented on issue #9684: [FLINK-13992][coordination] Refactor
Optional parameter in InputGateWithMetrics#updateMetrics
URL: https://github.com/apache/flink/pull/9684#issuecomment-531803145
Thanks for your review @azagrebin!
I'm not very sure about your addition. IMO it is
[
https://issues.apache.org/jira/browse/FLINK-13840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-13840:
--
Fix Version/s: (was: 1.10.0)
> Let StandaloneJobClusterEntrypoint use user code class
[
https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-13993:
-
Assignee: Guowei Ma
> Using FlinkUserCodeClassLoaders to load the user class in the
flinkbot edited a comment on issue #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#issuecomment-526487220
## CI report:
*
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381
## CI report:
* 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED
flinkbot edited a comment on issue #9655: [FLINK-14017][python] Support to
start up Python worker in process mode.
URL: https://github.com/apache/flink/pull/9655#issuecomment-529754597
## CI report:
* e02c8a291f5c82505750e200dda9b07d5e8b2fca : FAILURE
piyushnarang commented on issue #9652: [FLINK-14029][mesos] Update Mesos
scheduling behavior to reject all expired offers
URL: https://github.com/apache/flink/pull/9652#issuecomment-531788604
Thanks @tillrohrmann I'll spin up a new jira on the Mesos / Fenzo config
knob settings after
flinkbot edited a comment on issue #9692: [FLINK-13896]make scala-maven-plugin
compile target jvm version consistent with java version
URL: https://github.com/apache/flink/pull/9692#issuecomment-531777035
## CI report:
* 60b01f1245e2c797f7e7182e871ded83f6831ed7 : PENDING
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381
## CI report:
* 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED
flinkbot edited a comment on issue #9655: [FLINK-14017][python] Support to
start up Python worker in process mode.
URL: https://github.com/apache/flink/pull/9655#issuecomment-529754597
## CI report:
* e02c8a291f5c82505750e200dda9b07d5e8b2fca : FAILURE
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324680109
##
File path:
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324679781
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324679781
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324679085
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324678917
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324678064
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime]
Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r32462
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
WeiZhong94 commented on issue #9655: [FLINK-14017][python] Support to start up
Python worker in process mode.
URL: https://github.com/apache/flink/pull/9655#issuecomment-531778168
@dianfu Thanks for your review! I have addressed your comments and remove
the code of dependency management
flinkbot commented on issue #9692: [FLINK-13896]make scala-maven-plugin compile
target jvm version consistent with java version
URL: https://github.com/apache/flink/pull/9692#issuecomment-531777035
## CI report:
* 60b01f1245e2c797f7e7182e871ded83f6831ed7 : UNKNOWN
flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement
DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381
## CI report:
* 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED
WeiZhong94 commented on a change in pull request #9655: [FLINK-14017][python]
Support to start up Python worker in process mode.
URL: https://github.com/apache/flink/pull/9655#discussion_r324672167
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352
WeiZhong94 commented on a change in pull request #9655: [FLINK-14017][python]
Support to start up Python worker in process mode.
URL: https://github.com/apache/flink/pull/9655#discussion_r324672223
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352
WeiZhong94 commented on a change in pull request #9655: [FLINK-14017][python]
Support to start up Python worker in process mode.
URL: https://github.com/apache/flink/pull/9655#discussion_r324672090
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352
WeiZhong94 commented on a change in pull request #9655: [FLINK-14017][python]
Support to start up Python worker in process mode.
URL: https://github.com/apache/flink/pull/9655#discussion_r324671540
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352
WeiZhong94 commented on a change in pull request #9655: [FLINK-14017][python]
Support to start up Python worker in process mode.
URL: https://github.com/apache/flink/pull/9655#discussion_r324671540
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352
flinkbot commented on issue #9692: [FLINK-13896]make scala-maven-plugin compile
target jvm version consistent with java version
URL: https://github.com/apache/flink/pull/9692#issuecomment-531774126
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help
[
https://issues.apache.org/jira/browse/FLINK-13896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13896:
---
Labels: pull-request-available (was: )
> Scala 2.11 maven compile should target Java 1.8
>
1 - 100 of 324 matches
Mail list logo
