flinkbot commented on issue #9684: [FLINK-13992][coordination] Refactor
Optional parameter in InputGateWithMetrics#updateMetrics
URL: https://github.com/apache/flink/pull/9684#issuecomment-531713590
## CI report:
* c378433c3a478702087ba46f397acd27bc23fa13 : UNKNOWN
-
flinkbot edited a comment on issue #9681: [FLINK-13450][test] Use StrictMath
instead of Math
URL: https://github.com/apache/flink/pull/9681#issuecomment-531682914
## CI report:
* 41a6a987d8a5ea52e0b2104a552c2bd38a0af3aa : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/buil
flinkbot edited a comment on issue #9677: [FLINK-13979] [docs-zh] Translate new
streamfilesink docs to chinese
URL: https://github.com/apache/flink/pull/9677#issuecomment-531181543
## CI report:
* 016d4bd7b25c6b0e2eeab6a995706f8f5c6fb816 : SUCCESS
[Build](https://travis-ci.com/f
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_r324588222
##
File path:
f
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_r324574290
##
File path:
f
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_r324562782
##
File path:
f
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_r324565978
##
File path:
f
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_r324566426
##
File path:
f
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_r324581086
##
File path:
f
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_r324569499
##
File path:
f
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_r324554848
##
File path:
f
flinkbot commented on issue #9687: [hotfix][docs] Fix some typos in Hive docs
URL: https://github.com/apache/flink/pull/9687#issuecomment-531712666
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
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_r324572045
##
File path:
f
yangjf2019 opened a new pull request #9687: [hotfix][docs] Fix some typos in
Hive docs
URL: https://github.com/apache/flink/pull/9687
## What is the purpose of the change
* Fix some typos in Hive docs.
## Brief change log
*I modified the "docs/dev/table/hive/ind
[
https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-14065.
---
Resolution: Done
Done via 67030031e712c732c864d91321afa3cd2cb466de
> Log metric name when t
tillrohrmann closed pull request #9680: [FLINK-14065] Log metric name when the
metric fails on registration/unregistration
URL: https://github.com/apache/flink/pull/9680
This is an automated message from the Apache Git Servi
[
https://issues.apache.org/jira/browse/FLINK-13461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-13461:
-
Priority: Major (was: Blocker)
> Distinguish between temporary tables and persisted tab
[
https://issues.apache.org/jira/browse/FLINK-13461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930380#comment-16930380
]
Aljoscha Krettek commented on FLINK-13461:
--
I moved this from "Blocker" to "Maj
flinkbot commented on issue #9686: [FLINK-14069] [core] Enable TimeUtils for
all time units labels supported by scala Duration
URL: https://github.com/apache/flink/pull/9686#issuecomment-531709298
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
[
https://issues.apache.org/jira/browse/FLINK-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930379#comment-16930379
]
Till Rohrmann commented on FLINK-14077:
---
[~zhangjun] please close this issue once
[
https://issues.apache.org/jira/browse/FLINK-14069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14069:
---
Labels: pull-request-available (was: )
> Enable TimeUtils to parse all time units labels su
flinkbot edited a comment on issue #9583: [hotfix][configuration] Remove usages
of deprecated options TASK_MANAGER_HEAP_MEMORY_MB and JOB_MANAGER_HEAP_MEMORY_MB
URL: https://github.com/apache/flink/pull/9583#issuecomment-526715510
## CI report:
* 6e904b5c61931e1cc84215ac297d1
[
https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930378#comment-16930378
]
Aljoscha Krettek commented on FLINK-14068:
--
I moved this from "Blocker" to "Maj
[
https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luojiangyu updated FLINK-14087:
---
Description:
There is the condition the RecordWriter sharing the ChannelSelector instance.
When two
zhuzhurk opened a new 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
## What is the purpose of the change
*Currently we are using scala Duration to parse duration configs.
[
https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-13417:
-
Priority: Major (was: Blocker)
> Bump Zookeeper to 3.5.5
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930377#comment-16930377
]
Aljoscha Krettek commented on FLINK-13417:
--
I moved this from "Blocker" to "Maj
[
https://issues.apache.org/jira/browse/FLINK-14068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-14068:
-
Priority: Major (was: Blocker)
> Use Java's Duration instead of Flink's Time
>
tillrohrmann commented on a change in pull request #9663:
[WIP][FLINK-12433][runtime] Implement DefaultScheduler stub
URL: https://github.com/apache/flink/pull/9663#discussion_r324585687
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultSchedulerFa
[
https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930376#comment-16930376
]
luojiangyu commented on FLINK-14087:
[~zjwang]
> throws java.lang.ArrayIndexOutOfBo
flinkbot edited a comment on issue #9681: [FLINK-13450][test] Use StrictMath
instead of Math
URL: https://github.com/apache/flink/pull/9681#issuecomment-531682914
## CI report:
* 41a6a987d8a5ea52e0b2104a552c2bd38a0af3aa : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/buil
[
https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luojiangyu updated FLINK-14087:
---
Description:
There is the condition the RecordWriter sharing the ChannelSelector instance.
When two
TisonKun commented on issue #9681: [FLINK-13450][test] Use StrictMath instead
of Math
URL: https://github.com/apache/flink/pull/9681#issuecomment-531708070
Hi @wangxiyuan I revoke my change request above. After taking a look at the
corresponding issue I know the root cause of this pull req
TisonKun commented on issue #9681: [FLINK-13450][test] Use StrictMath instead
of Math
URL: https://github.com/apache/flink/pull/9681#issuecomment-531708289
@flinkbot run travis
This is an automated message from the Apache Git
flinkbot commented on issue #9685: [hotfix][runtime] Change return type for
methods Execution#processFail(...)
URL: https://github.com/apache/flink/pull/9685#issuecomment-531707655
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
[
https://issues.apache.org/jira/browse/FLINK-13999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930374#comment-16930374
]
Aljoscha Krettek commented on FLINK-13999:
--
I quickly talked to [~dawidwys] abo
flinkbot commented on issue #9684: [FLINK-13992][coordination] Refactor
Optional parameter in InputGateWithMetrics#updateMetrics
URL: https://github.com/apache/flink/pull/9684#issuecomment-531707663
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help t
[
https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luojiangyu updated FLINK-14087:
---
Description:
There is the condition the RecordWriter sharing the ChannelSelector instance.
When two
GJL opened a new pull request #9685: [hotfix][runtime] Change return type for
methods Execution#processFail(...)
URL: https://github.com/apache/flink/pull/9685
## What is the purpose of the change
*Change return types of above methods to void.*
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-14087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luojiangyu updated FLINK-14087:
---
Attachment: (was: image-2019-09-16-17-17-55-097.png)
> throws java.lang.ArrayIndexOutOfBoundsExc
[
https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13992:
---
Labels: pull-request-available (was: )
> Refactor Optional parameter in InputGateWithMetric
TisonKun opened a new pull request #9684: [FLINK-13992][coordination] Refactor
Optional parameter in InputGateWithMetrics#updateMetrics
URL: https://github.com/apache/flink/pull/9684
## What is the purpose of the change
As consensus from community code style discussion, in
`InputGat
luojiangyu created FLINK-14087:
--
Summary: throws java.lang.ArrayIndexOutOfBoundsException when
emiting the data using RebalancePartitioner.
Key: FLINK-14087
URL: https://issues.apache.org/jira/browse/FLINK-14087
TisonKun commented on issue #9583: [hotfix][configuration] Remove usages of
deprecated options TASK_MANAGER_HEAP_MEMORY_MB and JOB_MANAGER_HEAP_MEMORY_MB
URL: https://github.com/apache/flink/pull/9583#issuecomment-531706119
@flinkbot run travis
-
[
https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-6949.
Resolution: Duplicate
> Add ability to ship custom resource files to YARN cluster
> ---
[
https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930357#comment-16930357
]
Aljoscha Krettek commented on FLINK-13025:
--
[~yanghua] I'll help you get this i
[
https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930358#comment-16930358
]
Till Rohrmann commented on FLINK-6949:
--
Great to hear, then I'll close this issue.
[
https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930355#comment-16930355
]
TisonKun commented on FLINK-13992:
--
Thanks for your clarification [~azagrebin]! Now I u
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 : PENDING
[Build](https://
flinkbot edited a comment on issue #9682: [FLINK-14041][tests] Refactor
LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils
URL: https://github.com/apache/flink/pull/9682#issuecomment-531697742
## CI report:
* 1513bd9a28bd35cc176554c957a61329fb0cabf4 : PENDING
wangxiyuan commented on issue #9681: [FLINK-13450][test] Use StrictMath instead
of Math
URL: https://github.com/apache/flink/pull/9681#issuecomment-531702209
@TisonKun, hi, thanks for your comment. I don't know what scope is better,
since this pr changed many modules. any suggestion? Than
dianfu 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_r324557279
##
File path: flink-dist/src/main/flink-bin/bin/pyflink-udf-runner.sh
##
@@ -0,
dianfu 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_r324575806
##
File path: flink-python/pyflink/fn_execution/tests/test_process_mode_boot.py
dianfu 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_r324568387
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352 @@
+#
dianfu 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_r324573030
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352 @@
+#
dianfu 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_r324559723
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352 @@
+#
dianfu 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_r324570969
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352 @@
+#
dianfu 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_r324565952
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352 @@
+#
dianfu 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_r324574654
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352 @@
+#
dianfu 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_r324576320
##
File path: flink-python/pyflink/fn_execution/tests/test_process_mode_boot.py
dianfu 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_r324570432
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352 @@
+#
dianfu 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_r324573350
##
File path: flink-python/pyflink/fn_execution/boot.py
##
@@ -0,0 +1,352 @@
+#
[
https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930349#comment-16930349
]
Andrey Zagrebin commented on FLINK-13992:
-
True, IDE detection can be useful. I
[
https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930345#comment-16930345
]
liupengcheng commented on FLINK-14037:
--
I enabled `-verbose:class` and this followi
flinkbot commented 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 : UNKNOWN
---
flinkbot commented on issue #9682: [FLINK-14041][tests] Refactor
LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils
URL: https://github.com/apache/flink/pull/9682#issuecomment-531697742
## CI report:
* 1513bd9a28bd35cc176554c957a61329fb0cabf4 : UNKNOWN
-
[
https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930343#comment-16930343
]
liupengcheng commented on FLINK-14037:
--
[~zhuzh] Yes, the version of the libs you m
flinkbot commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as
jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683#issuecomment-531694429
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the communi
[
https://issues.apache.org/jira/browse/FLINK-14081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-14081:
-
Description: Now blink/flink planner only support TimeType with precision
zero. We need support
flinkbot commented on issue #9682: [FLINK-14041][tests] Refactor
LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils
URL: https://github.com/apache/flink/pull/9682#issuecomment-531693859
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot.
[
https://issues.apache.org/jira/browse/FLINK-14037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14037:
---
Labels: pull-request-available (was: )
> Deserializing the input/output formats failed: unr
liupc opened a new pull request #9683: [FLINK-14037]Use same
userCodeClassLoader as jobManager in jobClient to fix input/…
URL: https://github.com/apache/flink/pull/9683
## What is the purpose of the change
When user include flink-shaded-hadoop-2 classes into user jar, and use a
cus
TisonKun opened a new pull request #9682: [FLINK-14041][tests] Refactor
LeaderRetrievalServiceHostnameResolutionTest and remove StandaloneUtils
URL: https://github.com/apache/flink/pull/9682
## What is the purpose of the change
StandaloneUtils is a poor utility that can be just repla
[
https://issues.apache.org/jira/browse/FLINK-14041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14041:
---
Labels: pull-request-available (was: )
> Refactor LeaderRetrievalServiceHostnameResolutionT
[
https://issues.apache.org/jira/browse/FLINK-14041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun reassigned FLINK-14041:
Assignee: TisonKun
> Refactor LeaderRetrievalServiceHostnameResolutionTest and remove
> Standalo
[
https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930336#comment-16930336
]
TisonKun commented on FLINK-13992:
--
Thank [~azagrebin] for your updates. Now it works a
catkint commented on issue #9677: [FLINK-13979] [docs-zh] Translate new
streamfilesink docs to chinese
URL: https://github.com/apache/flink/pull/9677#issuecomment-531689682
I will modify it asap. thx.
This is an automated mes
flinkbot edited a comment on issue #9681: [FLINK-13450][test] Use StrictMath
instead of Math
URL: https://github.com/apache/flink/pull/9681#issuecomment-531682914
## CI report:
* 41a6a987d8a5ea52e0b2104a552c2bd38a0af3aa : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/buil
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_r324559191
##
File path: flink-tests/po
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_r324558621
##
File path:
flink-runtime
[
https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930325#comment-16930325
]
Andrey Zagrebin edited comment on FLINK-13992 at 9/16/19 8:34 AM:
[
https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930325#comment-16930325
]
Andrey Zagrebin commented on FLINK-13992:
-
[~Tison], please, try again to assign
wangyang0918 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_r324551994
##
File path: flink-test
xintongsong commented on a change in pull request #9677: [FLINK-13979]
[docs-zh] Translate new streamfilesink docs to chinese
URL: https://github.com/apache/flink/pull/9677#discussion_r324549631
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -28,80 +28,69 @@
xintongsong commented on a change in pull request #9677: [FLINK-13979]
[docs-zh] Translate new streamfilesink docs to chinese
URL: https://github.com/apache/flink/pull/9677#discussion_r324540876
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -28,80 +28,69 @@
xintongsong commented on a change in pull request #9677: [FLINK-13979]
[docs-zh] Translate new streamfilesink docs to chinese
URL: https://github.com/apache/flink/pull/9677#discussion_r324547289
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -28,80 +28,69 @@
xintongsong commented on a change in pull request #9677: [FLINK-13979]
[docs-zh] Translate new streamfilesink docs to chinese
URL: https://github.com/apache/flink/pull/9677#discussion_r324544533
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -28,80 +28,69 @@
xintongsong commented on a change in pull request #9677: [FLINK-13979]
[docs-zh] Translate new streamfilesink docs to chinese
URL: https://github.com/apache/flink/pull/9677#discussion_r324548381
##
File path: docs/dev/connectors/streamfile_sink.zh.md
##
@@ -28,80 +28,69 @@
wangyang0918 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_r324554365
##
File path:
flink-run
flinkbot commented on issue #9681: [FLINK-13450][test] Use StrictMath instead
of Math
URL: https://github.com/apache/flink/pull/9681#issuecomment-531682914
## CI report:
* 41a6a987d8a5ea52e0b2104a552c2bd38a0af3aa : UNKNOWN
wangyang0918 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_r324551994
##
File path: flink-test
wangxiyuan created FLINK-14086:
--
Summary: PrometheusReporterEndToEndITCase doesn't support ARM arch
Key: FLINK-14086
URL: https://issues.apache.org/jira/browse/FLINK-14086
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-13838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930308#comment-16930308
]
Yang Wang commented on FLINK-13838:
---
[~Zentol]
Yes, it is supported by all hadoop vers
flinkbot commented on issue #9681: [FLINK-13450][test] Use StrictMath instead
of Math
URL: https://github.com/apache/flink/pull/9681#issuecomment-531678149
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request
wangxiyuan opened a new pull request #9681: [FLINK-13448][test] Use StrictMath
instead of Math
URL: https://github.com/apache/flink/pull/9681
## What is the purpose of the change
`math.log` and `math.pow` can actually return slightly different results
across platforms becaus
[
https://issues.apache.org/jira/browse/FLINK-13448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13448:
---
Labels: pull-request-available (was: )
> Support ARM architecture
> ---
[
https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930302#comment-16930302
]
Yang Wang commented on FLINK-14033:
---
Seems that UserArtifacts is not added to yarn dis
[
https://issues.apache.org/jira/browse/FLINK-13979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930288#comment-16930288
]
Xintong Song commented on FLINK-13979:
--
I'm taking a look at the PR. Will get back
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_r324535361
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java
[
https://issues.apache.org/jira/browse/FLINK-14085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junling updated FLINK-14085:
Description:
Assume there are two tables in the running environment of the flink sql client.
One is abc12
201 - 300 of 306 matches
Mail list logo