[jira] [Updated] (FLINK-5018) Make source idle timeout user configurable

[ https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5018: -- Labels: pull-request-available (was: ) > Make source idle timeout user configurable >

[GitHub] [flink] flinkbot commented on issue #7990: [FLINK-5018] Make source idle timeout user configurable

flinkbot commented on issue #7990: [FLINK-5018] Make source idle timeout user configurable URL: https://github.com/apache/flink/pull/7990#issuecomment-473178532 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull re

[GitHub] [flink] yanghua opened a new pull request #7990: [FLINK-5018] Make source idle timeout user configurable

yanghua opened a new pull request #7990: [FLINK-5018] Make source idle timeout user configurable URL: https://github.com/apache/flink/pull/7990 ## What is the purpose of the change *This pull request makes source idle timeout user configurable* ## Brief change log - *

[jira] [Commented] (FLINK-9048) LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793370#comment-16793370 ] Paul Lin commented on FLINK-9048: - [~yuzhih...@gmail.com] Hi, I'm running into the same i

[GitHub] [flink] wuchong commented on a change in pull request #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes

wuchong commented on a change in pull request #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes URL: https://github.com/apache/flink/pull/7969#discussion_r265862974 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/pl

[GitHub] [flink] zhijiangW commented on issue #7989: [hotfix] Deduplicate the common codes in RecordWriterTest

zhijiangW commented on issue #7989: [hotfix] Deduplicate the common codes in RecordWriterTest URL: https://github.com/apache/flink/pull/7989#issuecomment-473173520 @pnowojski , I extracted this commit separately from [#7713](https://github.com/apache/flink/pull/7713).

[GitHub] [flink] sunjincheng121 commented on a change in pull request #7985: [FLINK-11918][table] Deprecated Window and Rename it to GroupWindow

sunjincheng121 commented on a change in pull request #7985: [FLINK-11918][table] Deprecated Window and Rename it to GroupWindow URL: https://github.com/apache/flink/pull/7985#discussion_r265860587 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/a

[GitHub] [flink] flinkbot commented on issue #7989: [hotfix] Deduplicate the common codes in RecordWriterTest

flinkbot commented on issue #7989: [hotfix] Deduplicate the common codes in RecordWriterTest URL: https://github.com/apache/flink/pull/7989#issuecomment-473172666 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] zhijiangW opened a new pull request #7989: [hotfix] Deduplicate the common codes in RecordWriterTest

zhijiangW opened a new pull request #7989: [hotfix] Deduplicate the common codes in RecordWriterTest URL: https://github.com/apache/flink/pull/7989 ## What is the purpose of the change *Extract a common method in tests for easy reuse and maintenance.* ## Brief change log

[GitHub] [flink] scott-mitchell commented on a change in pull request #7968: [FLINK-11692] [Datadog Reporter] added proxy to datadog reporter

scott-mitchell commented on a change in pull request #7968: [FLINK-11692] [Datadog Reporter] added proxy to datadog reporter URL: https://github.com/apache/flink/pull/7968#discussion_r265858382 ## File path: flink-metrics/flink-metrics-datadog/src/test/java/org/apache/flink/metrics

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type

HuangZhenQiu commented on a change in pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#discussion_r265857779 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java

[GitHub] [flink] zhijiangW commented on a change in pull request #7911: [FLINK-11082][network] Fix the logic of getting backlog in sub partition

zhijiangW commented on a change in pull request #7911: [FLINK-11082][network] Fix the logic of getting backlog in sub partition URL: https://github.com/apache/flink/pull/7911#discussion_r265856906 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti

[GitHub] [flink] godfreyhe edited a comment on issue #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes

godfreyhe edited a comment on issue #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes URL: https://github.com/apache/flink/pull/7969#issuecomment-473149388 Thanks for your suggestion @wuchong. I have updated this PR based on comments ---

[jira] [Created] (FLINK-11925) KryoSerializerSnapshot doesn't completely capture state / configuration of Kryo instance

Tzu-Li (Gordon) Tai created FLINK-11925: --- Summary: KryoSerializerSnapshot doesn't completely capture state / configuration of Kryo instance Key: FLINK-11925 URL: https://issues.apache.org/jira/browse/FLINK-1

[GitHub] [flink] JingsongLi commented on issue #7961: [FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg

JingsongLi commented on issue #7961: [FLINK-11882][table-runtime-blink] Introduce BytesHashMap to batch hash agg URL: https://github.com/apache/flink/pull/7961#issuecomment-473164513 Thanks for your suggestion @KurtYoung . I have update this PR based on comments --

[GitHub] [flink] KurtYoung commented on a change in pull request #7982: [FLINK-11788][table-planner-blink] Support Code Generation for RexNode

KurtYoung commented on a change in pull request #7982: [FLINK-11788][table-planner-blink] Support Code Generation for RexNode URL: https://github.com/apache/flink/pull/7982#discussion_r265826579 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/tab

[GitHub] [flink] godfreyhe removed a comment on issue #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes

godfreyhe removed a comment on issue #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes URL: https://github.com/apache/flink/pull/7969#issuecomment-473149397 Thanks for your suggestion @wuchong. I have update this PR based on comments ---

[GitHub] [flink] zhijiangW commented on a change in pull request #7911: [FLINK-11082][network] Fix the logic of getting backlog in sub partition

zhijiangW commented on a change in pull request #7911: [FLINK-11082][network] Fix the logic of getting backlog in sub partition URL: https://github.com/apache/flink/pull/7911#discussion_r265845525 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti

[GitHub] [flink] chummyhe89 commented on issue #7971: [FLINK-11897][tests] should wait all submitTask methods executed,befo…

chummyhe89 commented on issue #7971: [FLINK-11897][tests] should wait all submitTask methods executed,befo… URL: https://github.com/apache/flink/pull/7971#issuecomment-473149607 @TisonKun thanks for your review! This is an au

[GitHub] [flink] godfreyhe commented on issue #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes

godfreyhe commented on issue #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes URL: https://github.com/apache/flink/pull/7969#issuecomment-473149397 Thanks for your suggestion @wuchong. I have update this PR based on comments ---

[GitHub] [flink] godfreyhe commented on issue #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes

godfreyhe commented on issue #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes URL: https://github.com/apache/flink/pull/7969#issuecomment-473149388 Thanks for your suggestion @wuchong. I have update this PR based on comments ---

[GitHub] [flink] chummyhe89 commented on a change in pull request #7971: [FLINK-11897][tests] should wait all submitTask methods executed,befo…

chummyhe89 commented on a change in pull request #7971: [FLINK-11897][tests] should wait all submitTask methods executed,befo… URL: https://github.com/apache/flink/pull/7971#discussion_r265841511 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/Inte

[GitHub] [flink] chummyhe89 commented on a change in pull request #7971: [FLINK-11897][tests] should wait all submitTask methods executed,befo…

chummyhe89 commented on a change in pull request #7971: [FLINK-11897][tests] should wait all submitTask methods executed,befo… URL: https://github.com/apache/flink/pull/7971#discussion_r265841440 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/Inte

[jira] [Updated] (FLINK-11860) Remove all the usage of deprecated unit-provided memory options in docs and scripts

[ https://issues.apache.org/jira/browse/FLINK-11860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11860: --- Labels: pull-request-available (was: ) > Remove all the usage of deprecated unit-provided m

[jira] [Comment Edited] (FLINK-10705) Rework Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793272#comment-16793272 ] Yadong Xie edited comment on FLINK-10705 at 3/15/19 3:13 AM: -

[GitHub] [flink] flinkbot commented on issue #7988: [FLINK-11860] Remove all the usage of deprecated unit-provided memory options in docs and scripts

flinkbot commented on issue #7988: [FLINK-11860] Remove all the usage of deprecated unit-provided memory options in docs and scripts URL: https://github.com/apache/flink/pull/7988#issuecomment-473145149 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I he

[jira] [Commented] (FLINK-10705) Rework Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793272#comment-16793272 ] Yadong Xie commented on FLINK-10705: Hi [~rmetzger], sorry for the late response Cu

[GitHub] [flink] Myasuka opened a new pull request #7988: [FLINK-11860] Remove all the usage of deprecated unit-provided memory options in docs and scripts

Myasuka opened a new pull request #7988: [FLINK-11860] Remove all the usage of deprecated unit-provided memory options in docs and scripts URL: https://github.com/apache/flink/pull/7988 ## What is the purpose of the change Currently, options with unit provided ,e.g. `jobmanager.heap.

[jira] [Commented] (FLINK-11919) Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "FROM user" at line 1, column 17.

[ https://issues.apache.org/jira/browse/FLINK-11919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793226#comment-16793226 ] thinktothings commented on FLINK-11919: ---  some string combinations are already res

[GitHub] [flink] godfreyhe commented on a change in pull request #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes

godfreyhe commented on a change in pull request #7969: [FLINK-11896] [table-planner-blink] Introduce stream physical nodes URL: https://github.com/apache/flink/pull/7969#discussion_r265836012 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/

[jira] [Created] (FLINK-11924) Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "EXISTS" at line 1, column 40.

thinktothings created FLINK-11924: - Summary: Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "EXISTS" at line 1, column 40. Key: FLINK-11924 URL: https://is

[GitHub] [flink] dianfu commented on issue #7848: [FLINK-10755][table] Port external catalogs in Table API extension points to flink-table-common

dianfu commented on issue #7848: [FLINK-10755][table] Port external catalogs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7848#issuecomment-473129098 @sunjincheng121 @twalthr I have rebased the PR since FLINK-11449 has been merged. Could you

[jira] [Commented] (FLINK-9650) Support Protocol Buffers formats

[ https://issues.apache.org/jira/browse/FLINK-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793231#comment-16793231 ] Arup Malakar commented on FLINK-9650: - Thanks [~yanghua] , and that sounds great!  Ju

[GitHub] [flink] flinkbot edited a comment on issue #7940: [hotfix][docs] fix error in functions example

flinkbot edited a comment on issue #7940: [hotfix][docs] fix error in functions example URL: https://github.com/apache/flink/pull/7940#issuecomment-470805294 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull requ

[GitHub] [flink] leesf commented on issue #7940: [hotfix][docs] fix error in functions example

leesf commented on issue #7940: [hotfix][docs] fix error in functions example URL: https://github.com/apache/flink/pull/7940#issuecomment-473125200 @flinkbot attention @twalthr @zentol This is an automated message from the A

[GitHub] [flink] leesf removed a comment on issue #7940: [hotfix][docs] fix error in functions example

leesf removed a comment on issue #7940: [hotfix][docs] fix error in functions example URL: https://github.com/apache/flink/pull/7940#issuecomment-471980702 cc @twalthr @zentol This is an automated message from the Apache Gi

[jira] [Resolved] (FLINK-11919) Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "FROM user" at line 1, column 17.

[ https://issues.apache.org/jira/browse/FLINK-11919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] thinktothings resolved FLINK-11919. --- Resolution: Fixed Fix Version/s: 1.7.2 Release Note: some string combinations ar

[jira] [Commented] (FLINK-9477) Support SQL 2016 JSON functions in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793224#comment-16793224 ] vinoyang commented on FLINK-9477: - [~suez1224] [~twalthr] I suggest that we could split a

[jira] [Assigned] (FLINK-7237) Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14

[ https://issues.apache.org/jira/browse/FLINK-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-7237: --- Assignee: vinoyang > Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14 >

[jira] [Assigned] (FLINK-11895) Allow FileSystem Configs to be altered at Runtime

[ https://issues.apache.org/jira/browse/FLINK-11895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11895: Assignee: vinoyang > Allow FileSystem Configs to be altered at Runtime >

[jira] [Commented] (FLINK-9650) Support Protocol Buffers formats

[ https://issues.apache.org/jira/browse/FLINK-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793218#comment-16793218 ] vinoyang commented on FLINK-9650: - [~amalakar] yes, I am. But, I need some time to proces

[GitHub] [flink] klion26 commented on a change in pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type

klion26 commented on a change in pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#discussion_r265810303 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java ###

[jira] [Commented] (FLINK-11914) Expose a REST endpoint in JobManager to kill specific TaskManager

[ https://issues.apache.org/jira/browse/FLINK-11914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793176#comment-16793176 ] Shuyi Chen commented on FLINK-11914: [~gjy], thanks a lot for the quick reply. Yes,

[jira] [Commented] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793092#comment-16793092 ] Alex Vinnik commented on FLINK-11143: - [~Zentol] is there a repo with 1.8/1.9 build

[jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793092#comment-16793092 ] Alex Vinnik edited comment on FLINK-11143 at 3/14/19 9:51 PM:

[jira] [Commented] (FLINK-11143) AskTimeoutException is thrown during job submission and completion

[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16793059#comment-16793059 ] Alex Vinnik commented on FLINK-11143: - [~Zentol] still seeing this problem using fli

[jira] [Commented] (FLINK-10705) Rework Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792904#comment-16792904 ] Robert Metzger commented on FLINK-10705: [~vthinkxie] Do you have a rough timeli

[jira] [Closed] (FLINK-10994) The bug of timestampadd handles time

[ https://issues.apache.org/jira/browse/FLINK-10994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong closed FLINK-10994. - Resolution: Duplicate > The bug of timestampadd handles time > > >

[jira] [Assigned] (FLINK-10076) Upgrade Calcite dependency to 1.18

[ https://issues.apache.org/jira/browse/FLINK-10076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-10076: - Assignee: Rong Rong (was: Shuyi Chen) > Upgrade Calcite dependency to 1.18 > -

[jira] [Commented] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792841#comment-16792841 ] Rong Rong commented on FLINK-7235: -- Yes I can take a look :-) > Backport CALCITE-1884 t

[jira] [Assigned] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-7235: Assignee: Rong Rong (was: Haohui Mai) > Backport CALCITE-1884 to the Flink repository before Calc

[GitHub] [flink] hequn8128 commented on issue #7976: [FLINK-11908][table] Port window classes into flink-api-java

hequn8128 commented on issue #7976: [FLINK-11908][table] Port window classes into flink-api-java URL: https://github.com/apache/flink/pull/7976#issuecomment-472939243 @sunjincheng121 Thanks a lot for your review. I have addressed all your comments. @twalthr @sunjincheng121 I have al

[GitHub] [flink] zhijiangW commented on a change in pull request #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode

zhijiangW commented on a change in pull request #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r265632723 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime

[GitHub] [flink] zhijiangW commented on a change in pull request #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode

zhijiangW commented on a change in pull request #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r265627063 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime

[jira] [Updated] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version

[ https://issues.apache.org/jira/browse/FLINK-11910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-11910: -- Attachment: Screen Shot 2019-03-14 at 8.17.18 AM.png > Make Yarn Application Type Customizable

[jira] [Commented] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version

[ https://issues.apache.org/jira/browse/FLINK-11910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792787#comment-16792787 ] Zhenqiu Huang commented on FLINK-11910: --- !Screen Shot 2019-03-14 at 8.17.18 AM.png

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type

HuangZhenQiu commented on a change in pull request #7978: [FLINK-11910] [Yarn] add customizable yarn application type URL: https://github.com/apache/flink/pull/7978#discussion_r265620892 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java

[GitHub] [flink] zhijiangW commented on a change in pull request #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode

zhijiangW commented on a change in pull request #7713: [FLINK-10995][network] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r265620648 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] hequn8128 commented on issue #7985: [FLINK-11918][table] Deprecated Window and Rename it to GroupWindow

hequn8128 commented on issue #7985: [FLINK-11918][table] Deprecated Window and Rename it to GroupWindow URL: https://github.com/apache/flink/pull/7985#issuecomment-472907627 @twalthr @sunjincheng121 I have addressed all your comments and updated the PR. Would be nice if you can take anothe

[GitHub] [flink] SuXingLee commented on issue #7966: [FLINK-11887][metrics] Fixed latency metrics drift apart

SuXingLee commented on issue #7966: [FLINK-11887][metrics] Fixed latency metrics drift apart URL: https://github.com/apache/flink/pull/7966#issuecomment-472906062 Thank for your comment. We don't use ```System.nanoTime``` for compute latency metrics directly. Because, when a shuffle h

[jira] [Created] (FLINK-11923) Move reporter instantiation into MetricRegistryConfiguration

Chesnay Schepler created FLINK-11923: Summary: Move reporter instantiation into MetricRegistryConfiguration Key: FLINK-11923 URL: https://issues.apache.org/jira/browse/FLINK-11923 Project: Flink

[jira] [Closed] (FLINK-11814) Changes of FLINK-11516 causes compilation failure

[ https://issues.apache.org/jira/browse/FLINK-11814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-11814. --- Resolution: Cannot Reproduce > Changes of FLINK-11516 causes compilation failure > -

[jira] [Updated] (FLINK-917) Rename netty IO Thread count parameters

[ https://issues.apache.org/jira/browse/FLINK-917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-917: - Component/s: Runtime / Network > Rename netty IO Thread count parameters > ---

[jira] [Updated] (FLINK-7237) Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14

[ https://issues.apache.org/jira/browse/FLINK-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7237: Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-10076) > Remove DateTimeUtils from

[jira] [Updated] (FLINK-11894) AbstractRowSerializer.serializeToPages return type should be void

[ https://issues.apache.org/jira/browse/FLINK-11894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11894: --- Component/s: (was: API / Table SQL) Runtime / Operators > AbstractRowSerializer

[jira] [Updated] (FLINK-11864) Let compressed channel reader/writer reuse the logic of AsynchronousFileIOChannel

[ https://issues.apache.org/jira/browse/FLINK-11864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11864: --- Component/s: (was: Runtime / Network) Runtime / Operators > Let compressed chan

[jira] [Updated] (FLINK-11878) Implement the runtime handling of BoundedOneInput and BoundedTwoInput

[ https://issues.apache.org/jira/browse/FLINK-11878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11878: --- Component/s: Runtime / Operators > Implement the runtime handling of BoundedOneInput and Bou

[jira] [Closed] (FLINK-11905) BlockCompressionTest does not compile with Java 9

[ https://issues.apache.org/jira/browse/FLINK-11905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11905. -- Resolution: Fixed Fix Version/s: 1.9.0 fixed in c6878aca6c5aeee46581b4d6744b31049db9de95 > Blo

[jira] [Updated] (FLINK-11864) Let compressed channel reader/writer reuse the logic of AsynchronousFileIOChannel

[ https://issues.apache.org/jira/browse/FLINK-11864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11864: --- Component/s: Runtime / Network > Let compressed channel reader/writer reuse the logic of >

[GitHub] [flink] KurtYoung merged pull request #7981: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9

KurtYoung merged pull request #7981: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9 URL: https://github.com/apache/flink/pull/7981 This is an automated message from the Apache Git Se

[GitHub] [flink] KurtYoung commented on issue #7981: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9

KurtYoung commented on issue #7981: [FLINK-11905][table-runtime-blink] Fix BlockCompressionTest does not compile with Java 9 URL: https://github.com/apache/flink/pull/7981#issuecomment-472857887 Thanks @zentol for the reviewing, i will merge this now. --

[jira] [Updated] (FLINK-261) JDBC Input and Output format for Stratosphere

[ https://issues.apache.org/jira/browse/FLINK-261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-261: - Component/s: Connectors / JDBC > JDBC Input and Output format for Stratosphere > -

[jira] [Closed] (FLINK-11881) Introduce code generated typed sort to blink table

[ https://issues.apache.org/jira/browse/FLINK-11881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11881. -- Resolution: Implemented Fix Version/s: 1.9.0 fixed in e20a9f8947244315f7732c719ebf8f77e7699a57

[GitHub] [flink] KurtYoung merged pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

KurtYoung merged pull request #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958 This is an automated message from the Apache Git Servi

[GitHub] [flink] KurtYoung commented on issue #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table

KurtYoung commented on issue #7958: [FLINK-11881][table-planner-blink] Introduce code generated typed sort to blink table URL: https://github.com/apache/flink/pull/7958#issuecomment-472856770 LGTM, merging this... This is an

[jira] [Commented] (FLINK-9477) Support SQL 2016 JSON functions in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792647#comment-16792647 ] Timo Walther commented on FLINK-9477: - [~suez1224] the Calcite version is now at 1.18

[jira] [Created] (FLINK-11922) Support MetricReporter factories

Chesnay Schepler created FLINK-11922: Summary: Support MetricReporter factories Key: FLINK-11922 URL: https://issues.apache.org/jira/browse/FLINK-11922 Project: Flink Issue Type: New Feat

[jira] [Closed] (FLINK-10076) Upgrade Calcite dependency to 1.18

[ https://issues.apache.org/jira/browse/FLINK-10076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-10076. Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: flink-table-planner: 93a2c79188b7fa

[jira] [Updated] (FLINK-11877) Implement the runtime handling of TwoInputSelectable

[ https://issues.apache.org/jira/browse/FLINK-11877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11877: --- Component/s: Runtime / Operators > Implement the runtime handling of TwoInputSelectable > --

[jira] [Updated] (FLINK-11915) DataInputViewStream skip returns wrong value

[ https://issues.apache.org/jira/browse/FLINK-11915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11915: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > DataInputViewStream skip ret

[jira] [Updated] (FLINK-7237) Remove DateTimeUtils from Flink once Calcite is upgraded to 1.14

[ https://issues.apache.org/jira/browse/FLINK-7237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7237: Issue Type: Sub-task (was: Bug) Parent: FLINK-11921 > Remove DateTimeUtils from Flink once

[jira] [Updated] (FLINK-11915) DataInputViewStream skip returns wrong value

[ https://issues.apache.org/jira/browse/FLINK-11915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11915: --- Component/s: Runtime / Operators > DataInputViewStream skip returns wrong value > --

[jira] [Updated] (FLINK-11900) Flink on Kubernetes sensitive about arguments placement

[ https://issues.apache.org/jira/browse/FLINK-11900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11900: --- Component/s: Deployment / Kubernetes > Flink on Kubernetes sensitive about arguments placeme

[jira] [Updated] (FLINK-11895) Allow FileSystem Configs to be altered at Runtime

[ https://issues.apache.org/jira/browse/FLINK-11895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11895: --- Component/s: Connectors / FileSystem > Allow FileSystem Configs to be altered at Runtime > -

[jira] [Updated] (FLINK-11876) Introduce the new interfaces TwoInputSelectable, BoundedOneInput and BoundedTwoInput

[ https://issues.apache.org/jira/browse/FLINK-11876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11876: --- Component/s: Runtime / Operators > Introduce the new interfaces TwoInputSelectable, BoundedO

[jira] [Commented] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792644#comment-16792644 ] Timo Walther commented on FLINK-7235: - [~walterddr] could you take a look at this? Ou

[jira] [Updated] (FLINK-11879) Add JobGraph validators for the uses of TwoInputSelectable, BoundedOneInput and BoundedTwoInput

[ https://issues.apache.org/jira/browse/FLINK-11879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11879: --- Component/s: Runtime / Operators > Add JobGraph validators for the uses of TwoInputSelectabl

[jira] [Updated] (FLINK-11894) AbstractRowSerializer.serializeToPages return type should be void

[ https://issues.apache.org/jira/browse/FLINK-11894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11894: --- Component/s: API / Table SQL > AbstractRowSerializer.serializeToPages return type should be

[jira] [Updated] (FLINK-11918) Deprecated Window and Rename it to GroupWindow

[ https://issues.apache.org/jira/browse/FLINK-11918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11918: --- Component/s: API / DataStream > Deprecated Window and Rename it to GroupWindow > ---

[jira] [Updated] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7235: Issue Type: Sub-task (was: Bug) Parent: FLINK-11921 > Backport CALCITE-1884 to the Flink r

[jira] [Updated] (FLINK-11859) Improve SpanningRecordSerializer performance by serializing record length to serialization buffer directly

[ https://issues.apache.org/jira/browse/FLINK-11859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11859: --- Component/s: Runtime / Network > Improve SpanningRecordSerializer performance by serializing

[jira] [Updated] (FLINK-11814) Changes of FLINK-11516 causes compilation failure

[ https://issues.apache.org/jira/browse/FLINK-11814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11814: --- Component/s: Connectors / Kafka > Changes of FLINK-11516 causes compilation failure > --

[jira] [Updated] (FLINK-7235) Backport CALCITE-1884 to the Flink repository before Calcite 1.14

[ https://issues.apache.org/jira/browse/FLINK-7235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-7235: Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-10076) > Backport CALCITE-1884 to

[jira] [Updated] (FLINK-11120) The bug of timestampadd handles time

[ https://issues.apache.org/jira/browse/FLINK-11120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11120: - Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-10076) > The bug of timestampad

[jira] [Updated] (FLINK-261) JDBC Input and Output format for Stratosphere

[ https://issues.apache.org/jira/browse/FLINK-261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-261: - Component/s: (was: Connectors / JDBC) > JDBC Input and Output format for Stratosphere > --

[GitHub] [flink] KurtYoung commented on issue #7952: [FLINK-11872][table-runtime-blink] update lz4 license file.

KurtYoung commented on issue #7952: [FLINK-11872][table-runtime-blink] update lz4 license file. URL: https://github.com/apache/flink/pull/7952#issuecomment-472854272 Thanks @zentol for pointing this out. I was wondering how can i tell whether a dependent jar is packaged in flink's jar? --

[jira] [Created] (FLINK-11921) Upgrade Calcite dependency to 1.19

Timo Walther created FLINK-11921: Summary: Upgrade Calcite dependency to 1.19 Key: FLINK-11921 URL: https://issues.apache.org/jira/browse/FLINK-11921 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-10076) Upgrade Calcite dependency to 1.18

[ https://issues.apache.org/jira/browse/FLINK-10076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10076: - Component/s: (was: API / Table SQL) SQL / Planner > Upgrade Calcite depende

[GitHub] [flink] asfgit closed pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18

asfgit closed pull request #7607: [FLINK-10076][table] Upgrade Calcite dependency to 1.18 URL: https://github.com/apache/flink/pull/7607 This is an automated message from the Apache Git Service. To respond to the message, pl

[jira] [Commented] (FLINK-9650) Support Protocol Buffers formats

[ https://issues.apache.org/jira/browse/FLINK-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16792629#comment-16792629 ] Arup Malakar commented on FLINK-9650: - Hey [~yanghua] do let me know if you are still

  1   2   3   >