[jira] [Commented] (FLINK-20235) Missing Hive dependencies

2020-11-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237173#comment-17237173 ] Robert Metzger commented on FLINK-20235: Shouldn't this ticket be a blocker? I would like to

[jira] [Commented] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

2020-11-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237172#comment-17237172 ] Dian Fu commented on FLINK-20221: - I have downgraded this issue to Critical. Feel free to set it back if

[jira] [Updated] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

2020-11-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20221: Priority: Critical (was: Blocker) > DelimitedInputFormat does not restore compressed filesplits

[GitHub] [flink] flinkbot commented on pull request #14164: [FLINK-20278][Python] Throw a meaningful exception if the Python DataStream API job executes in batch mode.

2020-11-22 Thread GitBox
flinkbot commented on pull request #14164: URL: https://github.com/apache/flink/pull/14164#issuecomment-731986480 ## CI report: * 8e32013740da2349001a08f807c1ef7f398e9ee0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14163: [FLINK-20282][runtime] Improve error messages for invalid managed memory fraction

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #14163: URL: https://github.com/apache/flink/pull/14163#issuecomment-731977706 ## CI report: * ccf1b22d8807727c2f78fa49871ccc620fe126e7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14162: [FLINK-19687][table] Support to get execution plan in `Flink SQL 1.11`

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #14162: URL: https://github.com/apache/flink/pull/14162#issuecomment-731977185 ## CI report: * 4dec15772cc7558155d8d8b164e7adc14798bb3a Azure:

[jira] [Updated] (FLINK-20265) Extend invocation protocol to allow functions to indicate incomplete invocation context

2020-11-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20265: --- Labels: pull-request-available (was: ) > Extend invocation protocol to allow functions to

[GitHub] [flink] AHeise commented on pull request #14140: [FLINK-19864][tests] Fix unpredictable Thread.getState in StreamTaskTestHarness due to concurrent class loading

2020-11-22 Thread GitBox
AHeise commented on pull request #14140: URL: https://github.com/apache/flink/pull/14140#issuecomment-731984069 > @AHeise I am getting confused. We probably have essential divergences on what `StreamTaskTestHarness.waitForInputProcessing` should do. From my understanding, it should wait

[GitHub] [flink-statefun] tzulitai opened a new pull request #177: [FLINK-20265] [core] Extend remote invocation protocol with IncompleteInvocationContext response type

2020-11-22 Thread GitBox
tzulitai opened a new pull request #177: URL: https://github.com/apache/flink-statefun/pull/177 This PR extends the current remote invocation request-reply protocol to allow functions to reply with a `IncompleteInvocationContext` response. The end goal for this protocol extension is

[jira] [Commented] (FLINK-20157) SourceCoordinatorProvider kills JobManager with IllegalStateException on job submission

2020-11-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237169#comment-17237169 ] Dian Fu commented on FLINK-20157: - It seems that this issue depends on several other tickets. If we see

[GitHub] [flink] wuchong commented on pull request #14162: [FLINK-19687][table] Support to get execution plan in `Flink SQL 1.11`

2020-11-22 Thread GitBox
wuchong commented on pull request #14162: URL: https://github.com/apache/flink/pull/14162#issuecomment-731983804 Hi @V1ncentzzZ , I think this introduces a new API so it is not a bugfix. The Flink community doesn't allow a new feature merged into the bugfix versions, e.g. `1.11.3`.

[jira] [Closed] (FLINK-20229) duplicate "for" security-kerberos doc

2020-11-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20229. --- Fix Version/s: 1.12.0 Resolution: Fixed Fixed in master (1.12.0):

[GitHub] [flink] wuchong merged pull request #14124: [FLINK-20229][docs]remove duplicate "for"

2020-11-22 Thread GitBox
wuchong merged pull request #14124: URL: https://github.com/apache/flink/pull/14124 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] azagrebin commented on pull request #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager

2020-11-22 Thread GitBox
azagrebin commented on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-731982120 @HuangZhenQiu ok, I have reopened the PR Please, rebase it on master This is an automated message from

[jira] [Assigned] (FLINK-20229) duplicate "for" security-kerberos doc

2020-11-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20229: --- Assignee: zhouyongjin > duplicate "for" security-kerberos doc >

[GitHub] [flink] HuangZhenQiu opened a new pull request #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager

2020-11-22 Thread GitBox
HuangZhenQiu opened a new pull request #8952: URL: https://github.com/apache/flink/pull/8952 ## What is the purpose of the change Add failure rate for resource manager, so that every type of Resource Managers can handle with maximum failed executers. ## Brief change log -

[jira] [Updated] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload

2020-11-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20220: --- Component/s: (was: Runtime / Coordination) API / DataSet >

[jira] [Updated] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload

2020-11-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20220: --- Component/s: Runtime / Coordination > DataSet.collect() uses TaskExecutionState for

[jira] [Commented] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload

2020-11-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237164#comment-17237164 ] Robert Metzger commented on FLINK-20220: Thanks a lot [~zhuzh]! I will close this ticket, since

[jira] [Closed] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload

2020-11-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20220. -- Resolution: Won't Fix > DataSet.collect() uses TaskExecutionState for transferring

[GitHub] [flink] YongjinZhou commented on pull request #14124: [FLINK-20229][docs]remove duplicate "for"

2020-11-22 Thread GitBox
YongjinZhou commented on pull request #14124: URL: https://github.com/apache/flink/pull/14124#issuecomment-731979327 @wuchong @dianfu Have time to review it? thanks. This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-20267) JaasModule prevents Flink from starting if working directory is a symbolic link

2020-11-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237163#comment-17237163 ] Dian Fu commented on FLINK-20267: - [~karmagyz] Could you help to take a look at this issue? >

[jira] [Commented] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

2020-11-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237161#comment-17237161 ] Dian Fu commented on FLINK-20221: - I'm also in favor of downgrading the priority to Critical and trying

[GitHub] [flink] flinkbot commented on pull request #14163: [FLINK-20282][runtime] Improve error messages for invalid managed memory fraction

2020-11-22 Thread GitBox
flinkbot commented on pull request #14163: URL: https://github.com/apache/flink/pull/14163#issuecomment-731977706 ## CI report: * ccf1b22d8807727c2f78fa49871ccc620fe126e7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14162: [FLINK-19687][table] Support to get execution plan in `Flink SQL 1.11`

2020-11-22 Thread GitBox
flinkbot commented on pull request #14162: URL: https://github.com/apache/flink/pull/14162#issuecomment-731977185 ## CI report: * 4dec15772cc7558155d8d8b164e7adc14798bb3a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14160: [FLINK-19795][table-blink] Fix Flink SQL throws exception when changelog source contains duplicate change events

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #14160: URL: https://github.com/apache/flink/pull/14160#issuecomment-731775317 ## CI report: * 040aeb255189647566ce8417e135c8a9d6fc13aa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #14161: URL: https://github.com/apache/flink/pull/14161#issuecomment-731917055 ## CI report: * adb4d262c3bf03ef0abe97cd68adf540521ff68c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14132: [FLINK-20214][k8s] Fix the unnecessary warning logs when Hadoop environment is not set

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #14132: URL: https://github.com/apache/flink/pull/14132#issuecomment-730290775 ## CI report: * 71f8e69ff40b4e2bc382ddeacf24b0e975c35cbe Azure:

[GitHub] [flink] flinkbot commented on pull request #14164: [FLINK-20278][Python] Throw a meaningful exception if the Python DataStream API job executes in batch mode.

2020-11-22 Thread GitBox
flinkbot commented on pull request #14164: URL: https://github.com/apache/flink/pull/14164#issuecomment-731976203 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

[jira] [Updated] (FLINK-20278) Throw a meaningful exception if the Python DataStream API job executes in batch mode

2020-11-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20278: --- Labels: pull-request-available (was: ) > Throw a meaningful exception if the Python

[GitHub] [flink] flinkbot edited a comment on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-723574143 ## CI report: * a4b291d58c664776ac81ace1f3b020239993f893 Azure:

[GitHub] [flink] shuiqiangchen opened a new pull request #14164: [FLINK-20278][Python] Throw a meaningful exception if the Python DataStream API job executes in batch mode.

2020-11-22 Thread GitBox
shuiqiangchen opened a new pull request #14164: URL: https://github.com/apache/flink/pull/14164 ## What is the purpose of the change *Currently, the Python DataStream job still doesn't support batch mode. We should thrown a meaningful exception if it runs in batch mode.*

[jira] [Comment Edited] (FLINK-20281) Window aggregation supports changelog stream input

2020-11-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237160#comment-17237160 ] Shengkai Fang edited comment on FLINK-20281 at 11/23/20, 7:16 AM: -- We

[GitHub] [flink] dianfu commented on pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
dianfu commented on pull request #14161: URL: https://github.com/apache/flink/pull/14161#issuecomment-731974012 @zhuzhurk Thanks a lot for the review. Will merge once the tests passed. This is an automated message from the

[jira] [Commented] (FLINK-20281) Window aggregation supports changelog stream input

2020-11-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237160#comment-17237160 ] Shengkai Fang commented on FLINK-20281: --- We are also can't do window agg on upsert-kafka. Because

[jira] [Updated] (FLINK-20180) Translation the FileSink Document into Chinese

2020-11-22 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-20180: Fix Version/s: 1.12.0 > Translation the FileSink Document into Chinese >

[GitHub] [flink] flinkbot commented on pull request #14163: [FLINK-20282][runtime] Improve error messages for invalid managed memory fraction

2020-11-22 Thread GitBox
flinkbot commented on pull request #14163: URL: https://github.com/apache/flink/pull/14163#issuecomment-731969606 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

[GitHub] [flink] zhuzhurk commented on a change in pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
zhuzhurk commented on a change in pull request #14161: URL: https://github.com/apache/flink/pull/14161#discussion_r528500411 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java ## @@ -250,7 +250,10 @@

[jira] [Updated] (FLINK-20282) Make invalid managed memory fraction errors more advisory in MemoryManager

2020-11-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20282: --- Labels: pull-request-available (was: ) > Make invalid managed memory fraction errors more

[GitHub] [flink] xintongsong commented on pull request #14163: [FLINK-20282][runtime] Improve error messages for invalid managed memory fraction

2020-11-22 Thread GitBox
xintongsong commented on pull request #14163: URL: https://github.com/apache/flink/pull/14163#issuecomment-731968607 cc @zhuzhurk This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] xintongsong opened a new pull request #14163: [FLINK-20282][runtime] Improve error messages for invalid managed memory fraction

2020-11-22 Thread GitBox
xintongsong opened a new pull request #14163: URL: https://github.com/apache/flink/pull/14163 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink-statefun] wangzzu commented on pull request #131: [FLINK-18968] Translate README.md to Chinese

2020-11-22 Thread GitBox
wangzzu commented on pull request #131: URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-731966327 @tzulitai @klion26 I have submitted the new PR: https://github.com/apache/flink-statefun/pull/176

[GitHub] [flink-statefun] wangzzu opened a new pull request #176: [FLINK-18968] Translate README.md to Chinese

2020-11-22 Thread GitBox
wangzzu opened a new pull request #176: URL: https://github.com/apache/flink-statefun/pull/176 Translate README.md to Chinese. New file is named README.zh.md Methodology: Google Translate on HTML + Manual Correction This

[GitHub] [flink] flinkbot edited a comment on pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #14161: URL: https://github.com/apache/flink/pull/14161#issuecomment-731917055 ## CI report: * adb4d262c3bf03ef0abe97cd68adf540521ff68c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-723574143 ## CI report: * a4b291d58c664776ac81ace1f3b020239993f893 Azure:

[GitHub] [flink] flinkbot commented on pull request #14162: [FLINK-19687][table] Support to introduce the json format execution plan by `StatementSet#explain`

2020-11-22 Thread GitBox
flinkbot commented on pull request #14162: URL: https://github.com/apache/flink/pull/14162#issuecomment-731964807 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

[jira] [Updated] (FLINK-19687) Support to get execution plan in `StatementSet`

2020-11-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19687: --- Labels: pull-request-available (was: ) > Support to get execution plan in `StatementSet` >

[GitHub] [flink] V1ncentzzZ opened a new pull request #14162: [FLINK-19687][table] Support to introduce the json format execution plan by `StatementSet#explain`

2020-11-22 Thread GitBox
V1ncentzzZ opened a new pull request #14162: URL: https://github.com/apache/flink/pull/14162 ## What is the purpose of the change Support to introduce the json execution plan by `StatementSet#explain`. ## Brief change log *(for example:)* - Add an enum

[GitHub] [flink] SteNicholas commented on pull request #13983: [FLINK-19989][python] Add collect operation in Python DataStream API

2020-11-22 Thread GitBox
SteNicholas commented on pull request #13983: URL: https://github.com/apache/flink/pull/13983#issuecomment-731962821 @shuiqiangchen @dianfu , could you please help to review this pull request? This is an automated message

[jira] [Commented] (FLINK-20285) LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices

2020-11-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237151#comment-17237151 ] Xintong Song commented on FLINK-20285: -- Thanks for the update. Sounds good to me. >

[GitHub] [flink] flinkbot edited a comment on pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #14161: URL: https://github.com/apache/flink/pull/14161#issuecomment-731917055 ## CI report: * adb4d262c3bf03ef0abe97cd68adf540521ff68c Azure:

[GitHub] [flink] dianfu commented on a change in pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
dianfu commented on a change in pull request #14161: URL: https://github.com/apache/flink/pull/14161#discussion_r528491975 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java ## @@ -250,7 +250,10 @@ public

[jira] [Commented] (FLINK-20285) LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237144#comment-17237144 ] Zhu Zhu commented on FLINK-20285: - I'd like to fix it by changing

[GitHub] [flink] zhuzhurk commented on a change in pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
zhuzhurk commented on a change in pull request #14161: URL: https://github.com/apache/flink/pull/14161#discussion_r528491131 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java ## @@ -250,7 +250,10 @@

[GitHub] [flink] zhuzhurk commented on a change in pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
zhuzhurk commented on a change in pull request #14161: URL: https://github.com/apache/flink/pull/14161#discussion_r528491085 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java ## @@ -250,7 +250,10 @@

[jira] [Created] (FLINK-20288) Correct documentation about savepoint self-contained

2020-11-22 Thread Yun Tang (Jira)
Yun Tang created FLINK-20288: Summary: Correct documentation about savepoint self-contained Key: FLINK-20288 URL: https://issues.apache.org/jira/browse/FLINK-20288 Project: Flink Issue Type: Bug

[GitHub] [flink] godfreyhe commented on a change in pull request #14154: [FLINK-19878][table-planner-blink] Fix WatermarkAssigner shouldn't be after ChangelogNormalize

2020-11-22 Thread GitBox
godfreyhe commented on a change in pull request #14154: URL: https://github.com/apache/flink/pull/14154#discussion_r528490059 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/TableScanTest.xml ## @@ -556,10

[jira] [Commented] (FLINK-20277) flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure

2020-11-22 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237143#comment-17237143 ] 谢波 commented on FLINK-20277: Sorry, I'll pay attention next time. I have a job that needs to read the Hive

[jira] [Updated] (FLINK-20277) flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure

2020-11-22 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20277: --- Description: 流式消费Hive表,出现失败时,任务无法正常恢复,一直重启。 一直报错:The ContinuousFileMonitoringFunction has already restored from a

[jira] [Created] (FLINK-20287) Add documentation of how to switch memory allocator in Flink docker image

2020-11-22 Thread Yun Tang (Jira)
Yun Tang created FLINK-20287: Summary: Add documentation of how to switch memory allocator in Flink docker image Key: FLINK-20287 URL: https://issues.apache.org/jira/browse/FLINK-20287 Project: Flink

[jira] [Commented] (FLINK-20256) UDAF type inference will fail if accumulator contains MapView with Pojo value type

2020-11-22 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237139#comment-17237139 ] Caizhi Weng commented on FLINK-20256: - Indeed, if I make the test more complex, for example if I'm

[jira] [Updated] (FLINK-19125) Avoid memory fragmentation when running flink docker image

2020-11-22 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-19125: -- Release Note: After FLINK-19125 Jemalloc is adopted as the default memory allocator in flink docker image to

[GitHub] [flink] dianfu commented on pull request #8532: [FLINK-12541][REST] Support to submit Python Table API jobs via REST API

2020-11-22 Thread GitBox
dianfu commented on pull request #8532: URL: https://github.com/apache/flink/pull/8532#issuecomment-731950941 @elanv The REST API is still not supported as we want to add support of client based submission as the first step. However, it makes sense to consider the REST API support now as

[jira] [Commented] (FLINK-20285) LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices

2020-11-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237136#comment-17237136 ] Xintong Song commented on FLINK-20285: -- [~zhuzh] Thanks for reporting this issue. This indeed

[jira] [Commented] (FLINK-20278) Throw a meaningful exception if the Python DataStream API job executes in batch mode

2020-11-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237129#comment-17237129 ] Dian Fu commented on FLINK-20278: - cc [~csq] > Throw a meaningful exception if the Python DataStream

[jira] [Commented] (FLINK-19864) TwoInputStreamTaskTest.testWatermarkMetrics failed with "expected:<1> but was:<-9223372036854775808>"

2020-11-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237122#comment-17237122 ] Dian Fu commented on FLINK-19864: - Another instance:

[jira] [Created] (FLINK-20286) Support streaming source for filesystem SQL connector

2020-11-22 Thread Jark Wu (Jira)
Jark Wu created FLINK-20286: --- Summary: Support streaming source for filesystem SQL connector Key: FLINK-20286 URL: https://issues.apache.org/jira/browse/FLINK-20286 Project: Flink Issue Type: New

[GitHub] [flink] flinkbot edited a comment on pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #14161: URL: https://github.com/apache/flink/pull/14161#issuecomment-731917055 ## CI report: * adb4d262c3bf03ef0abe97cd68adf540521ff68c Azure:

[GitHub] [flink] godfreyhe commented on pull request #14103: [FLINK-18545] Introduce `pipeline.name` to allow users to specify job name by configuration

2020-11-22 Thread GitBox
godfreyhe commented on pull request #14103: URL: https://github.com/apache/flink/pull/14103#issuecomment-731919518 @twalthr @dawidwys could you take a look at this pr, thanks so much This is an automated message from the

[jira] [Assigned] (FLINK-20285) LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-20285: --- Assignee: Zhu Zhu > LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices

[jira] [Updated] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-20220: Fix Version/s: (was: 1.11.3) (was: 1.12.0) > DataSet.collect() uses

[jira] [Updated] (FLINK-20285) LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-20285: Description: LazyFromSourcesSchedulingStrategy is possible to schedule vertices which are not in CREATED

[jira] [Assigned] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-20220: --- Assignee: (was: Zhu Zhu) > DataSet.collect() uses TaskExecutionState for transferring

[jira] [Updated] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-20220: Affects Version/s: (was: 1.11.0) > DataSet.collect() uses TaskExecutionState for transferring

[jira] [Commented] (FLINK-20220) DataSet.collect() uses TaskExecutionState for transferring user-payload

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237113#comment-17237113 ] Zhu Zhu commented on FLINK-20220: - FLINK-20285 is opened for the fatal error problem. >

[GitHub] [flink] zhuzhurk commented on a change in pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
zhuzhurk commented on a change in pull request #14161: URL: https://github.com/apache/flink/pull/14161#discussion_r528464485 ## File path: flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java ## @@ -250,7 +250,10 @@

[GitHub] [flink] flinkbot commented on pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
flinkbot commented on pull request #14161: URL: https://github.com/apache/flink/pull/14161#issuecomment-731917055 ## CI report: * adb4d262c3bf03ef0abe97cd68adf540521ff68c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-20277) flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure

2020-11-22 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20277: -- Assignee: godfrey he > flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from

[jira] [Commented] (FLINK-20277) flink-1.11.2 ContinuousFileMonitoringFunction cannot restore from failure

2020-11-22 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237112#comment-17237112 ] godfrey he commented on FLINK-20277: [~hiscat] Thanks for reporting this, I would like to take this

[jira] [Commented] (FLINK-20282) Make invalid managed memory fraction errors more advisory in MemoryManager

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237111#comment-17237111 ] Zhu Zhu commented on FLINK-20282: - Sounds good to me. > Make invalid managed memory fraction errors

[GitHub] [flink] flinkbot commented on pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
flinkbot commented on pull request #14161: URL: https://github.com/apache/flink/pull/14161#issuecomment-731915698 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

[jira] [Created] (FLINK-20285) LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices

2020-11-22 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-20285: --- Summary: LazyFromSourcesSchedulingStrategy is possible to schedule non-CREATED vertices Key: FLINK-20285 URL: https://issues.apache.org/jira/browse/FLINK-20285 Project: Flink

[jira] [Updated] (FLINK-20283) Make invalid managed memory fraction errors of python udf more user friendly

2020-11-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20283: --- Labels: pull-request-available (was: ) > Make invalid managed memory fraction errors of

[GitHub] [flink] dianfu commented on pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
dianfu commented on pull request #14161: URL: https://github.com/apache/flink/pull/14161#issuecomment-731915323 cc @zhuzhurk This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] dianfu opened a new pull request #14161: [FLINK-20283][python] Provide a meaningful exception message when managed memory fraction of Python worker process is invalid

2020-11-22 Thread GitBox
dianfu opened a new pull request #14161: URL: https://github.com/apache/flink/pull/14161 ## What is the purpose of the change *This pull request improves the exception message when managed memory fraction of Python worker process is invalid* ## Verifying this

[jira] [Commented] (FLINK-20282) Make invalid managed memory fraction errors more advisory in MemoryManager

2020-11-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237110#comment-17237110 ] Xintong Song commented on FLINK-20282: -- Thanks for reporting this, [~zhuzh]. I think you are

[jira] [Comment Edited] (FLINK-20116) Test Intra-Slot Managed Memory Sharing

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237107#comment-17237107 ] Zhu Zhu edited comment on FLINK-20116 at 11/23/20, 3:59 AM: Test is done and

[jira] [Comment Edited] (FLINK-20116) Test Intra-Slot Managed Memory Sharing

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237107#comment-17237107 ] Zhu Zhu edited comment on FLINK-20116 at 11/23/20, 3:57 AM: Test is done and

[jira] [Commented] (FLINK-20116) Test Intra-Slot Managed Memory Sharing

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237107#comment-17237107 ] Zhu Zhu commented on FLINK-20116: - Test is done and no blocker issue is found. {{Details:}} Test jobs:

[jira] [Updated] (FLINK-20284) Error happens in TaskExecutor when closing JobMaster connection if there was a python UDF

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-20284: Component/s: Runtime / Coordination > Error happens in TaskExecutor when closing JobMaster connection if

[jira] [Commented] (FLINK-20284) Error happens in TaskExecutor when closing JobMaster connection if there was a python UDF

2020-11-22 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237105#comment-17237105 ] Dian Fu commented on FLINK-20284: - [~hxbks2ks] Could you help to take a look at this issue? > Error

[jira] [Commented] (FLINK-20059) Outdated SQL docs on aggregate functions' merge

2020-11-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237101#comment-17237101 ] Jark Wu commented on FLINK-20059: - Fixed in master (1.12.0): -

[jira] [Comment Edited] (FLINK-20199) PyFlink e2e DataStream test failed during stopping kafka services

2020-11-22 Thread Shuiqiang Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237087#comment-17237087 ] Shuiqiang Chen edited comment on FLINK-20199 at 11/23/20, 3:38 AM: ---

[jira] [Commented] (FLINK-20284) Error happens in TaskExecutor when closing JobMaster connection if there was a python UDF

2020-11-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237102#comment-17237102 ] Zhu Zhu commented on FLINK-20284: - cc [~dian.fu] > Error happens in TaskExecutor when closing JobMaster

[jira] [Closed] (FLINK-20059) Outdated SQL docs on aggregate functions' merge

2020-11-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20059. --- Resolution: Fixed > Outdated SQL docs on aggregate functions' merge >

[GitHub] [flink] flinkbot edited a comment on pull request #14160: [FLINK-19795][table-blink] Fix Flink SQL throws exception when changelog source contains duplicate change events

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #14160: URL: https://github.com/apache/flink/pull/14160#issuecomment-731775317 ## CI report: * 44ff14a0d30e454dc2502d1f644fdb94bf6e64bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14132: [FLINK-20214][k8s] Fix the unnecessary warning logs when Hadoop environment is not set

2020-11-22 Thread GitBox
flinkbot edited a comment on pull request #14132: URL: https://github.com/apache/flink/pull/14132#issuecomment-730290775 ## CI report: * 6c498db9839dea282cf02b7629039d829f14d08c Azure:

[jira] [Issue Comment Deleted] (FLINK-20059) Outdated SQL docs on aggregate functions' merge

2020-11-22 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20059: Comment: was deleted (was: Fixed in master (1.12.0): 3a066d6ec3fe46716b12e8d2756ba5f0e463fe43) >

[jira] [Created] (FLINK-20284) Error happens in TaskExecutor when closing JobMaster connection if there was a python UDF

2020-11-22 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-20284: --- Summary: Error happens in TaskExecutor when closing JobMaster connection if there was a python UDF Key: FLINK-20284 URL: https://issues.apache.org/jira/browse/FLINK-20284

[jira] [Commented] (FLINK-20236) flink-dist.jar and hive-exec.jar have conflict with protobuf-java.jar

2020-11-22 Thread CloseRiver (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237099#comment-17237099 ] CloseRiver commented on FLINK-20236: Hi [~trohrmann],i didn't verify 1.12-SNAPSHOT,so i'm not sure

  1   2   3   >