[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis: [SUCCESS](https://travis-ci.com/flink

[GitHub] [flink] flinkbot edited a comment on issue #10772: [FLINK-15338][python] Cherry-pick NETTY#8955 to fix the TM Metaspace memory leak problem in shaded netty when submitting PyFlink UDF jobs mu

flinkbot edited a comment on issue #10772: [FLINK-15338][python] Cherry-pick NETTY#8955 to fix the TM Metaspace memory leak problem in shaded netty when submitting PyFlink UDF jobs multiple times. URL: https://github.com/apache/flink/pull/10772#issuecomment-571035348 ## CI report:

[GitHub] [flink] flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-XXXXX][client] Executor inheritance cleanup

flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-X][client] Executor inheritance cleanup URL: https://github.com/apache/flink/pull/10773#issuecomment-571035373 ## CI report: * 93322f33658ab3c8dabedcb8b3d31bb71ed7e7e5 Travis: [FAILURE](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #10771: [FLINK-14572][test] Print the root cause if job fails in BlobsCleanupITCase

flinkbot edited a comment on issue #10771: [FLINK-14572][test] Print the root cause if job fails in BlobsCleanupITCase URL: https://github.com/apache/flink/pull/10771#issuecomment-571027824 ## CI report: * d95e12bdcb570c4cbe5a37a9670d7427e8c461a1 Travis: [SUCCESS](https://travis

[jira] [Commented] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008606#comment-17008606 ] Zhu Zhu commented on FLINK-14163: - Thanks [~zjwang] for the feedbacks. I think partition

[jira] [Commented] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008608#comment-17008608 ] Arvid Heise commented on FLINK-15355: - Like I said before, option 4 assumes that no

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#discussion_r363191628 ## File path: flink-runtime/src/main/java/org/apache/flink

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#discussion_r363191715 ## File path: flink-runtime/src/main/java/org/apache/flink

[GitHub] [flink] flinkbot edited a comment on issue #10637: [FLINK-15319][e2e] flink-end-to-end-tests-common-kafka fails due to t…

flinkbot edited a comment on issue #10637: [FLINK-15319][e2e] flink-end-to-end-tests-common-kafka fails due to t… URL: https://github.com/apache/flink/pull/10637#issuecomment-567778216 ## CI report: * eec2a87ddc2fa8bd32e598d4f715259e09792a73 Travis: [SUCCESS](https://travis-ci.c

[jira] [Commented] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008610#comment-17008610 ] Arvid Heise commented on FLINK-15355: - Btw concerning why *{{org.apache.hadoop}}* is

[jira] [Commented] (FLINK-15032) Remove the eager serialization from `RemoteRpcInvocation`

[ https://issues.apache.org/jira/browse/FLINK-15032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008617#comment-17008617 ] Guowei Ma commented on FLINK-15032: --- Thanks [~trohrmann] and [~SleePy] for your concer

[jira] [Closed] (FLINK-15032) Remove the eager serialization from `RemoteRpcInvocation`

[ https://issues.apache.org/jira/browse/FLINK-15032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-15032. - Resolution: Won't Fix > Remove the eager serialization from `RemoteRpcInvocation` > ---

[GitHub] [flink] ifndef-SleePy commented on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

ifndef-SleePy commented on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-571048592 Hi @pnowojski , thanks for reviewing! Please check my response inline. BTW, I d

[GitHub] [flink] flinkbot edited a comment on issue #10737: [FLINK-15430][table-planner-blink] Fix Java 64K method compiling limi…

flinkbot edited a comment on issue #10737: [FLINK-15430][table-planner-blink] Fix Java 64K method compiling limi… URL: https://github.com/apache/flink/pull/10737#issuecomment-570066864 ## CI report: * fdd885648d4585ef6a77fc71584aef144c99af64 Travis: [FAILURE](https://travis-ci.c

[jira] [Commented] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008630#comment-17008630 ] zhijiang commented on FLINK-10462: -- [~kevin.cyj] I think there are two requirements fro

[GitHub] [flink] flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-XXXXX][client] Executor inheritance cleanup

flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-X][client] Executor inheritance cleanup URL: https://github.com/apache/flink/pull/10773#issuecomment-571035373 ## CI report: * 93322f33658ab3c8dabedcb8b3d31bb71ed7e7e5 Travis: [FAILURE](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis: [SUCCESS](https://travis-ci.com/flink

[jira] [Created] (FLINK-15483) Support to set environment variables for jobmanager pod

Yang Wang created FLINK-15483: - Summary: Support to set environment variables for jobmanager pod Key: FLINK-15483 URL: https://issues.apache.org/jira/browse/FLINK-15483 Project: Flink Issue Type:

[jira] [Commented] (FLINK-15150) ZooKeeperLeaderElectionITCase.testJobExecutionOnClusterWithLeaderChange failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-15150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008633#comment-17008633 ] Yangze Guo commented on FLINK-15150: Another instance https://travis-ci.org/apache/f

[jira] [Commented] (FLINK-13632) Update serializer upgrade tests to restore from 1.8 and beyond

[ https://issues.apache.org/jira/browse/FLINK-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008637#comment-17008637 ] Aljoscha Krettek commented on FLINK-13632: -- By the way, I think this is more of

[GitHub] [flink] flinkbot edited a comment on issue #10666: [FLINK-15214] Introduce multiple submission e2e test

flinkbot edited a comment on issue #10666: [FLINK-15214] Introduce multiple submission e2e test URL: https://github.com/apache/flink/pull/10666#issuecomment-568454903 ## CI report: * cc596f96fc38ff0235c6195fb39cab43d57861e4 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot edited a comment on issue #10737: [FLINK-15430][table-planner-blink] Fix Java 64K method compiling limi…

flinkbot edited a comment on issue #10737: [FLINK-15430][table-planner-blink] Fix Java 64K method compiling limi… URL: https://github.com/apache/flink/pull/10737#issuecomment-570066864 ## CI report: * fdd885648d4585ef6a77fc71584aef144c99af64 Travis: [FAILURE](https://travis-ci.c

[GitHub] [flink] Myasuka commented on issue #10767: [hotfix][docs] Align the documentation of checkpoint directory to the actual implementation

Myasuka commented on issue #10767: [hotfix][docs] Align the documentation of checkpoint directory to the actual implementation URL: https://github.com/apache/flink/pull/10767#issuecomment-571057386 The travis CI failed due to a known issue: [FLINK-14894](https://issues.apache.org/jira/brow

[jira] [Commented] (FLINK-15436) Add a hook of deserialized for pojo state object.

[ https://issues.apache.org/jira/browse/FLINK-15436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008642#comment-17008642 ] Yun Tang commented on FLINK-15436: -- [~xiemeilong] what do you think of my suggestion? I

[jira] [Closed] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15103. -- Resolution: Won't Do I've spent sometime bisecting this issue on the remote machine. For one t

[jira] [Commented] (FLINK-12462) Classloading fails in 1.8.0 when Scalatest is loaded first

[ https://issues.apache.org/jira/browse/FLINK-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008643#comment-17008643 ] Gaël Renoux commented on FLINK-12462: - Yes. We migrated to 1.9.1, stayed on Scala 2.

[jira] [Comment Edited] (FLINK-12462) Classloading fails in 1.8.0 when Scalatest is loaded first

[ https://issues.apache.org/jira/browse/FLINK-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008643#comment-17008643 ] Gaël Renoux edited comment on FLINK-12462 at 1/6/20 8:56 AM: -

[jira] [Comment Edited] (FLINK-15355) Nightly streaming file sink fails with unshaded hadoop

[ https://issues.apache.org/jira/browse/FLINK-15355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17005159#comment-17005159 ] Yu Li edited comment on FLINK-15355 at 1/6/20 9:00 AM: --- 'Shaded Ha

[jira] [Updated] (FLINK-15482) Hive functions should use TypeInfoDataTypeConverter to convert data type to type info

[ https://issues.apache.org/jira/browse/FLINK-15482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-15482: --- Description: Calling a Hive function with decimal return type will get: {noformat} java.lang.ClassCastExcept

[GitHub] [flink] flinkbot edited a comment on issue #10771: [FLINK-14572][test] Print the root cause if job fails in BlobsCleanupITCase

flinkbot edited a comment on issue #10771: [FLINK-14572][test] Print the root cause if job fails in BlobsCleanupITCase URL: https://github.com/apache/flink/pull/10771#issuecomment-571027824 ## CI report: * d95e12bdcb570c4cbe5a37a9670d7427e8c461a1 Travis: [SUCCESS](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-XXXXX][client] Executor inheritance cleanup

flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-X][client] Executor inheritance cleanup URL: https://github.com/apache/flink/pull/10773#issuecomment-571035373 ## CI report: * 93322f33658ab3c8dabedcb8b3d31bb71ed7e7e5 Travis: [FAILURE](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #10772: [FLINK-15338][python] Cherry-pick NETTY#8955 and BEAM-9006(#10462) to fix the TM Metaspace memory leak problem when submitting PyFlink UDF j

flinkbot edited a comment on issue #10772: [FLINK-15338][python] Cherry-pick NETTY#8955 and BEAM-9006(#10462) to fix the TM Metaspace memory leak problem when submitting PyFlink UDF jobs multiple times. URL: https://github.com/apache/flink/pull/10772#issuecomment-571035348 ## CI report

[jira] [Updated] (FLINK-15482) Failed to call Hive functions returning decimal type

[ https://issues.apache.org/jira/browse/FLINK-15482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-15482: --- Summary: Failed to call Hive functions returning decimal type (was: Hive functions should use TypeInfoDataT

[GitHub] [flink] sjwiesman commented on a change in pull request #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation

sjwiesman commented on a change in pull request #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation URL: https://github.com/apache/flink/pull/10502#discussion_r363209178 ## File path: docs/dev/libs/state_processor_api.md ## @@ -239,11

[GitHub] [flink] Myracle commented on issue #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors

Myracle commented on issue #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors URL: https://github.com/apache/flink/pull/6734#issuecomment-571062231 @tillrohrmann Hello, I am confused with you code. Before your code, YarnResourceManager's requestYarnContainer will addCon

[GitHub] [flink] Myracle edited a comment on issue #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors

Myracle edited a comment on issue #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors URL: https://github.com/apache/flink/pull/6734#issuecomment-571062231 @tillrohrmann Hello, I am confused with you code. Before your code, YarnResourceManager's requestYarnContainer will

[jira] [Commented] (FLINK-15438) Counter metrics are incorrectly reported as total counts to DataDog

[ https://issues.apache.org/jira/browse/FLINK-15438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008657#comment-17008657 ] Jörn Kottmann commented on FLINK-15438: --- I am still working on the issue. I exten

[GitHub] [flink] flinkbot edited a comment on issue #10637: [FLINK-15319][e2e] flink-end-to-end-tests-common-kafka fails due to t…

flinkbot edited a comment on issue #10637: [FLINK-15319][e2e] flink-end-to-end-tests-common-kafka fails due to t… URL: https://github.com/apache/flink/pull/10637#issuecomment-567778216 ## CI report: * eec2a87ddc2fa8bd32e598d4f715259e09792a73 Travis: [SUCCESS](https://travis-ci.c

[jira] [Commented] (FLINK-15463) export table sql jar ,meet error: java.lang.ClassNotFoundException: org.apache.flink.calcite.shaded.com.google.protobuf.MessageOrBuilder

[ https://issues.apache.org/jira/browse/FLINK-15463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008663#comment-17008663 ] chenchencc commented on FLINK-15463: I resolve it just now by recompile flink 1.9.1

[jira] [Created] (FLINK-15484) How does the CEP of flink compare the current data of yesterday with the reference data? Is there a better way to get it continuously from ES

smallyin created FLINK-15484: Summary: How does the CEP of flink compare the current data of yesterday with the reference data? Is there a better way to get it continuously from ES Key: FLINK-15484 URL: https://issue

[jira] [Reopened] (FLINK-14311) Streaming File Sink end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reopened FLINK-14311: --- Reopen since this reproduces in latest master nightly build: https://api.travis-ci.org/v3/job/632927348/log.txt

[jira] [Updated] (FLINK-14311) Streaming File Sink end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14311: -- Fix Version/s: (was: 1.10.0) Affects Version/s: (was: 1.10.0) 1.11.0 >

[GitHub] [flink] dawidwys commented on a change in pull request #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

dawidwys commented on a change in pull request #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#discussion_r363214928 ## File path: flink-table/flink-table-planner-bl

[GitHub] [flink] dawidwys commented on a change in pull request #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

dawidwys commented on a change in pull request #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#discussion_r363209651 ## File path: flink-table/flink-table-planner-bl

[GitHub] [flink] dawidwys commented on a change in pull request #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

dawidwys commented on a change in pull request #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#discussion_r363215985 ## File path: flink-table/flink-table-planner-bl

[GitHub] [flink] dawidwys commented on a change in pull request #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

dawidwys commented on a change in pull request #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#discussion_r363202235 ## File path: flink-table/flink-table-planner-bl

[jira] [Commented] (FLINK-15484) How does the CEP of flink compare the current data of yesterday with the reference data? Is there a better way to get it continuously from ES

[ https://issues.apache.org/jira/browse/FLINK-15484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008673#comment-17008673 ] Dawid Wysakowicz commented on FLINK-15484: -- Hi [~smallyin] A user mailling list

[jira] [Closed] (FLINK-15484) How does the CEP of flink compare the current data of yesterday with the reference data? Is there a better way to get it continuously from ES

[ https://issues.apache.org/jira/browse/FLINK-15484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-15484. Resolution: Invalid > How does the CEP of flink compare the current data of yesterday with

[GitHub] [flink] flinkbot edited a comment on issue #10772: [FLINK-15338][python] Cherry-pick NETTY#8955 and BEAM-9006(#10462) to fix the TM Metaspace memory leak problem when submitting PyFlink UDF j

flinkbot edited a comment on issue #10772: [FLINK-15338][python] Cherry-pick NETTY#8955 and BEAM-9006(#10462) to fix the TM Metaspace memory leak problem when submitting PyFlink UDF jobs multiple times. URL: https://github.com/apache/flink/pull/10772#issuecomment-571035348 ## CI report

[GitHub] [flink] flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-XXXXX][client] Executor inheritance cleanup

flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-X][client] Executor inheritance cleanup URL: https://github.com/apache/flink/pull/10773#issuecomment-571035373 ## CI report: * 93322f33658ab3c8dabedcb8b3d31bb71ed7e7e5 Travis: [FAILURE](https://travis-ci.com/flin

[jira] [Updated] (FLINK-15327) 'Walkthrough DataStream Scala nightly' sometimes fails with InterruptedException

[ https://issues.apache.org/jira/browse/FLINK-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-15327: - Component/s: Runtime / Task > 'Walkthrough DataStream Scala nightly' sometimes fails wit

[jira] [Commented] (FLINK-15399) Join with a LookupableTableSource：java.lang.RuntimeException: while converting XXXX Caused by: java.lang.AssertionError: Field ordinal 26 is invalid for type

[ https://issues.apache.org/jira/browse/FLINK-15399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008679#comment-17008679 ] Danny Chen commented on FLINK-15399: The bug has been fixed in CALCITE-3575, the roo

[jira] [Commented] (FLINK-15335) add-dependencies-for-IDEA not working anymore and dangerous in general

[ https://issues.apache.org/jira/browse/FLINK-15335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008680#comment-17008680 ] Aljoscha Krettek commented on FLINK-15335: -- I agree! [~NicoK] do you maybe want

[jira] [Commented] (FLINK-15230) flink1.9.1 table API JSON schema array type exception

[ https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008682#comment-17008682 ] wenyuan138 commented on FLINK-15230: [~jark] try as below, still got the same error

[GitHub] [flink] flinkbot edited a comment on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation

flinkbot edited a comment on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation URL: https://github.com/apache/flink/pull/10502#issuecomment-563465099 ## CI report: * 0904024ed3b34e27bc8e98c92b162024d5f40d95 Travis: [SUCCESS](https:/

[jira] [Commented] (FLINK-15343) Add Watermarks options for TwoInputStreamOperator

[ https://issues.apache.org/jira/browse/FLINK-15343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008685#comment-17008685 ] Aljoscha Krettek commented on FLINK-15343: -- One alternative to this is that use

[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008688#comment-17008688 ] Aljoscha Krettek commented on FLINK-15362: -- Will this have similar issues as FL

[jira] [Assigned] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15362: Assignee: vinoyang (was: Aljoscha Krettek) > Bump Kafka client version to 2.4.0

[jira] [Assigned] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15362: Assignee: Aljoscha Krettek > Bump Kafka client version to 2.4.0 for universal Kaf

[jira] [Commented] (FLINK-15399) Join with a LookupableTableSource：java.lang.RuntimeException: while converting XXXX Caused by: java.lang.AssertionError: Field ordinal 26 is invalid for type

[ https://issues.apache.org/jira/browse/FLINK-15399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008689#comment-17008689 ] Danny Chen commented on FLINK-15399: I have link this issue with FLINK-14338. > Joi

[jira] [Commented] (FLINK-15384) Allow to pass ExecutionEnvironment/StreamExecutionEnvironment to TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008694#comment-17008694 ] Aljoscha Krettek commented on FLINK-15384: -- {{JobListener}} is not a DataStream

[GitHub] [flink] flinkbot edited a comment on issue #10737: [FLINK-15430][table-planner-blink] Fix Java 64K method compiling limi…

flinkbot edited a comment on issue #10737: [FLINK-15430][table-planner-blink] Fix Java 64K method compiling limi… URL: https://github.com/apache/flink/pull/10737#issuecomment-570066864 ## CI report: * fdd885648d4585ef6a77fc71584aef144c99af64 Travis: [FAILURE](https://travis-ci.c

[jira] [Created] (FLINK-15485) Reopen tests like 'ignore TODO/when FLINK-xx is closed/when FLINK-xx is merged' has been finished

Leonard Xu created FLINK-15485: -- Summary: Reopen tests like 'ignore TODO/when FLINK-xx is closed/when FLINK-xx is merged' has been finished Key: FLINK-15485 URL: https://issues.apache.org/jira/browse/FLINK-15485

[jira] [Commented] (FLINK-15424) Make all AppendingState#add respect the java doc

[ https://issues.apache.org/jira/browse/FLINK-15424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008700#comment-17008700 ] Aljoscha Krettek commented on FLINK-15424: -- This is a good catch! We have to t

[jira] [Commented] (FLINK-15406) The savepoint is writted by "State Processor API" can't be restore by map or flatmap

[ https://issues.apache.org/jira/browse/FLINK-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008701#comment-17008701 ] Seth Wiesman commented on FLINK-15406: -- The issue is the `KeyedStateBootstrapOperat

[GitHub] [flink] flinkbot edited a comment on issue #10772: [FLINK-15338][python] Cherry-pick NETTY#8955 and BEAM-9006(#10462) to fix the TM Metaspace memory leak problem when submitting PyFlink UDF j

flinkbot edited a comment on issue #10772: [FLINK-15338][python] Cherry-pick NETTY#8955 and BEAM-9006(#10462) to fix the TM Metaspace memory leak problem when submitting PyFlink UDF jobs multiple times. URL: https://github.com/apache/flink/pull/10772#issuecomment-571035348 ## CI report

[GitHub] [flink] flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-XXXXX][client] Executor inheritance cleanup

flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-X][client] Executor inheritance cleanup URL: https://github.com/apache/flink/pull/10773#issuecomment-571035373 ## CI report: * 93322f33658ab3c8dabedcb8b3d31bb71ed7e7e5 Travis: [FAILURE](https://travis-ci.com/flin

[jira] [Assigned] (FLINK-15406) The savepoint is writted by "State Processor API" can't be restore by map or flatmap

[ https://issues.apache.org/jira/browse/FLINK-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15406: Assignee: Seth Wiesman > The savepoint is writted by "State Processor API" can't

[jira] [Updated] (FLINK-15485) Reopen tests when blocking issue has been resolved

[ https://issues.apache.org/jira/browse/FLINK-15485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15485: --- Summary: Reopen tests when blocking issue has been resolved (was: Reopen tests like 'ignore TODO/wh

[jira] [Updated] (FLINK-15406) The savepoint is writted by "State Processor API" can't be restore by map or flatmap

[ https://issues.apache.org/jira/browse/FLINK-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-15406: - Affects Version/s: 1.11.0 1.10.0 > The savepoint is writted by "State Pro

[GitHub] [flink] flinkbot edited a comment on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation

flinkbot edited a comment on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation URL: https://github.com/apache/flink/pull/10502#issuecomment-563465099 ## CI report: * 0904024ed3b34e27bc8e98c92b162024d5f40d95 Travis: [SUCCESS](https:/

[GitHub] [flink] leonardBang opened a new pull request #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved.

leonardBang opened a new pull request #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved. URL: https://github.com/apache/flink/pull/10774 [FLINK-15485][tests] Reopen tests when blocking issue has been resolved. ## What is the purpose of the change

[jira] [Updated] (FLINK-15485) Reopen tests when blocking issue has been resolved

[ https://issues.apache.org/jira/browse/FLINK-15485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15485: --- Labels: pull-request-available (was: ) > Reopen tests when blocking issue has been resolved

[GitHub] [flink] flinkbot commented on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved.

flinkbot commented on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved. URL: https://github.com/apache/flink/pull/10774#issuecomment-571086714 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Commented] (FLINK-15362) Bump Kafka client version to 2.4.0 for universal Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-15362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008713#comment-17008713 ] vinoyang commented on FLINK-15362: -- [~aljoscha] If Kafka client did not do the big chan

[GitHub] [flink] wuchong commented on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

wuchong commented on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#issuecomment-571089235 Thanks @dawidwys for the reviewing. Comments are addressed. ---

[GitHub] [flink] tillrohrmann commented on issue #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors

tillrohrmann commented on issue #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors URL: https://github.com/apache/flink/pull/6734#issuecomment-571091774 Hi @Myracle, the problem was that Flink did not take the number of pending slots into account (one TaskExecutor can be

[GitHub] [flink] flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#issuecomment-570630824 ## CI report: * 19e2bf9244667af4490f1463bdf48ba40d02e5ed T

[GitHub] [flink] flinkbot commented on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved.

flinkbot commented on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved. URL: https://github.com/apache/flink/pull/10774#issuecomment-571093161 ## CI report: * bf30d45bc7c1faa05786f6c7b2aca46a49cbf1dd UNKNOWN Bot commands The @f

[GitHub] [flink] flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-XXXXX][client] Executor inheritance cleanup

flinkbot edited a comment on issue #10773: DO NOT MERGE [FLINK-X][client] Executor inheritance cleanup URL: https://github.com/apache/flink/pull/10773#issuecomment-571035373 ## CI report: * 93322f33658ab3c8dabedcb8b3d31bb71ed7e7e5 Travis: [FAILURE](https://travis-ci.com/flin

[GitHub] [flink] lirui-apache opened a new pull request #10775: [FLINK-15482][hive] Failed to call Hive functions returning decimal type

lirui-apache opened a new pull request #10775: [FLINK-15482][hive] Failed to call Hive functions returning decimal type URL: https://github.com/apache/flink/pull/10775 ## What is the purpose of the change Fix the issue of calling Hive functions that return decimals

[jira] [Updated] (FLINK-15482) Failed to call Hive functions returning decimal type

[ https://issues.apache.org/jira/browse/FLINK-15482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15482: --- Labels: pull-request-available (was: ) > Failed to call Hive functions returning decimal ty

[GitHub] [flink] flinkbot commented on issue #10775: [FLINK-15482][hive] Failed to call Hive functions returning decimal type

flinkbot commented on issue #10775: [FLINK-15482][hive] Failed to call Hive functions returning decimal type URL: https://github.com/apache/flink/pull/10775#issuecomment-571094465 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Commented] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008722#comment-17008722 ] Aljoscha Krettek commented on FLINK-15290: -- I don't think {{GlobalConfiguration

[GitHub] [flink] flinkbot edited a comment on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation

flinkbot edited a comment on issue #10502: [FLINK-14825][state-processor-api][docs] Rework state processor api documentation URL: https://github.com/apache/flink/pull/10502#issuecomment-563465099 ## CI report: * 0904024ed3b34e27bc8e98c92b162024d5f40d95 Travis: [SUCCESS](https:/

[GitHub] [flink] wangyang0918 edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

wangyang0918 edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-570588137 @tillrohrmann I take a serious consideration and tend to remove the windows escape code. Since t

[GitHub] [flink] wangyang0918 edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager

wangyang0918 edited a comment on issue #10532: [FLINK-15053][runtime] Escape all dynamical property values for taskmanager URL: https://github.com/apache/flink/pull/10532#issuecomment-570588137 @tillrohrmann I take a serious consideration and tend to remove the windows escape code. Since t

[GitHub] [flink] tillrohrmann commented on a change in pull request #10716: [FLINK-15367][runtime] Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups

tillrohrmann commented on a change in pull request #10716: [FLINK-15367][runtime] Handle backwards compatibility of "taskmanager.heap.size" differently for standalone / active setups URL: https://github.com/apache/flink/pull/10716#discussion_r363245985 ## File path: flink-runtime/

[jira] [Commented] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008727#comment-17008727 ] Xintong Song commented on FLINK-15103: -- Thanks for spending time investigating the

[GitHub] [flink] flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type…

flinkbot edited a comment on issue #10745: [FLINK-15445][connectors/jdbc] JDBC Table Source didn't work for Type… URL: https://github.com/apache/flink/pull/10745#issuecomment-570165880 ## CI report: * 862f3c5fd9e77184af08aea1231cf3a00e03b193 Travis: [CANCELED](https://travis-ci.

[jira] [Updated] (FLINK-15384) Expose JobListener API on TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-15384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-15384: --- Summary: Expose JobListener API on TableEnvironment (was: Allow to pass ExecutionEnvironment/Stream

[GitHub] [flink] Myracle commented on issue #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors

Myracle commented on issue #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors URL: https://github.com/apache/flink/pull/6734#issuecomment-571100737 @tillrohrmann Thank you for your reply. Before your change, Flink calculate pendingTaskManagerSlots(==numPendingContainerRe

[jira] [Commented] (FLINK-15406) The savepoint is writted by "State Processor API" can't be restore by map or flatmap

[ https://issues.apache.org/jira/browse/FLINK-15406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008734#comment-17008734 ] Seth Wiesman commented on FLINK-15406: -- [~lintingbin] The issue only surfaces when

[jira] [Commented] (FLINK-15290) Need a way to turn off vectorized orc reader for SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-15290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008735#comment-17008735 ] Rui Li commented on FLINK-15290: Hi [~aljoscha], thanks for the inputs. The merged PR on

[GitHub] [flink] GJL closed pull request #10116: [FLINK-14655] Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList

GJL closed pull request #10116: [FLINK-14655] Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList URL: https://github.com/apache/flink/pull/10116 This is an automated message from the Apache Git Se

[GitHub] [flink] flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source

flinkbot edited a comment on issue #10763: [FLINK-14200][table] Fix NPE for Temporal Table Function Join when left side is a query instead of a source URL: https://github.com/apache/flink/pull/10763#issuecomment-570630824 ## CI report: * 19e2bf9244667af4490f1463bdf48ba40d02e5ed T

[jira] [Updated] (FLINK-14655) Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList

[ https://issues.apache.org/jira/browse/FLINK-14655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14655: - Fix Version/s: 1.11.0 > Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList >

[jira] [Closed] (FLINK-14655) Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList

[ https://issues.apache.org/jira/browse/FLINK-14655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-14655. Resolution: Fixed master: a5ef1437e6501dc596911aeea5057a0a55191fc9 > Change Type of Field jobStatusListen

[GitHub] [flink] flinkbot commented on issue #10775: [FLINK-15482][hive] Failed to call Hive functions returning decimal type

flinkbot commented on issue #10775: [FLINK-15482][hive] Failed to call Hive functions returning decimal type URL: https://github.com/apache/flink/pull/10775#issuecomment-571103452 ## CI report: * 230118fe22abdfa2adae7fabcd4ce6577c92bceb UNKNOWN Bot commands The @f

[GitHub] [flink] flinkbot edited a comment on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved.

flinkbot edited a comment on issue #10774: [FLINK-15485][tests] Reopen tests when blocking issue has been resolved. URL: https://github.com/apache/flink/pull/10774#issuecomment-571093161 ## CI report: * bf30d45bc7c1faa05786f6c7b2aca46a49cbf1dd Travis: [PENDING](https://travis-ci

  1   2   3   4   5   >