[GitHub] [flink] ifndef-SleePy commented on a change in pull request #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig

ifndef-SleePy commented on a change in pull request #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig URL: https://github.com/apache/flink/pull/8931#discussion_r299391317 ## File path: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java

[GitHub] [flink] StephanEwen commented on issue #8917: [FLINK-13017][docs] do not mount local $HOME into docker

StephanEwen commented on issue #8917: [FLINK-13017][docs] do not mount local $HOME into docker URL: https://github.com/apache/flink/pull/8917#issuecomment-507599277 Looks good to me, merging this... This is an automated

[GitHub] [flink] zhijiangW commented on a change in pull request #8704: [FLINK-12812][runtime] Set resource profiles for task slots

zhijiangW commented on a change in pull request #8704: [FLINK-12812][runtime] Set resource profiles for task slots URL: https://github.com/apache/flink/pull/8704#discussion_r299390967 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r299389758 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r299389758 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r299389758 ## File path:

[jira] [Updated] (FLINK-13055) Leverage JM side partition state to improve region failover experience

[ https://issues.apache.org/jira/browse/FLINK-13055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-13055: Affects Version/s: (was: 1.8.1) 1.9.0 > Leverage JM side partition state to

[GitHub] [flink] JingsongLi commented on a change in pull request #8854: [FLINK-12959][table-planner-blink] Use BoundedInput and InputSelectable in blink and implement hash join

JingsongLi commented on a change in pull request #8854: [FLINK-12959][table-planner-blink] Use BoundedInput and InputSelectable in blink and implement hash join URL: https://github.com/apache/flink/pull/8854#discussion_r299387488 ## File path:

[GitHub] [flink] wuchong closed pull request #8695: [FLINK-12805][FLINK-12808][FLINK-12809][table-api] Introduce PartitionableTableSource and PartitionableTableSink and OverwritableTableSink

wuchong closed pull request #8695: [FLINK-12805][FLINK-12808][FLINK-12809][table-api] Introduce PartitionableTableSource and PartitionableTableSink and OverwritableTableSink URL: https://github.com/apache/flink/pull/8695

[GitHub] [flink] wuchong commented on issue #8695: [FLINK-12805][FLINK-12808][FLINK-12809][table-api] Introduce PartitionableTableSource and PartitionableTableSink and OverwritableTableSink

wuchong commented on issue #8695: [FLINK-12805][FLINK-12808][FLINK-12809][table-api] Introduce PartitionableTableSource and PartitionableTableSink and OverwritableTableSink URL: https://github.com/apache/flink/pull/8695#issuecomment-507595708 Merged with -

[GitHub] [flink] StephanEwen commented on issue #8914: [FLINK-12929] Pass TypeInformation in addSource

StephanEwen commented on issue #8914: [FLINK-12929] Pass TypeInformation in addSource URL: https://github.com/apache/flink/pull/8914#issuecomment-507595118 @aljoscha What is the overall contract in the Scala API for which type information is used: Consider this case: ```scala

[jira] [Closed] (FLINK-12809) Introduce PartitionableTableSink for support writing data into partitions

[ https://issues.apache.org/jira/browse/FLINK-12809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12809. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: c3f2ad8c8c10097dc7f680ccdf2e9b99babc349c >

[jira] [Closed] (FLINK-12808) Introduce OverwritableTableSink for supporting insert overwrite

[ https://issues.apache.org/jira/browse/FLINK-12808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12808. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: fb111ef22b8f87dd25e61160678fc8857dffcfe0 >

[jira] [Closed] (FLINK-12805) Introduce PartitionableTableSource for partition pruning

[ https://issues.apache.org/jira/browse/FLINK-12805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12805. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: 6e4805673739fa1f8e85389d38ef6f3de20fc005 >

[GitHub] [flink] zhuzhurk commented on a change in pull request #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig

zhuzhurk commented on a change in pull request #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig URL: https://github.com/apache/flink/pull/8931#discussion_r299384922 ## File path: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig

zhuzhurk commented on a change in pull request #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig URL: https://github.com/apache/flink/pull/8931#discussion_r299384770 ## File path: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java

[GitHub] [flink] KurtYoung closed pull request #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner

KurtYoung closed pull request #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner URL: https://github.com/apache/flink/pull/8832 This is an automated message from the Apache Git

[jira] [Closed] (FLINK-12937) Introduce join reorder planner rules in blink planner

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

[jira] [Created] (FLINK-13055) Leverage JM side partition state to improve region failover experience

Zhu Zhu created FLINK-13055: --- Summary: Leverage JM side partition state to improve region failover experience Key: FLINK-13055 URL: https://issues.apache.org/jira/browse/FLINK-13055 Project: Flink

[GitHub] [flink] wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299374856 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299322870 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299372066 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299324996 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299368725 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299370467 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299309387 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

wuchong commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r299323271 ## File path:

[jira] [Commented] (FLINK-13037) Translate "Concepts -> Glossary" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876798#comment-16876798 ] Konstantin Knauf commented on FLINK-13037: -- [~jark] Sure, done! > Translate "Concepts ->

[jira] [Commented] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876799#comment-16876799 ] Till Rohrmann commented on FLINK-12889: --- Thanks for reporting this issue [~xinpu] and the analysis

[jira] [Assigned] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-12889: - Assignee: Till Rohrmann > Job keeps in FAILING state > -- > >

[GitHub] [flink] NicoK commented on issue #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

NicoK commented on issue #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215#issuecomment-507588394 Thanks @tillrohrmann, yes, I must have mixed things up there - you are right about setting

[GitHub] [flink] StephanEwen commented on issue #8593: Distinguish the method of using NC on Linux and Windows in doc comments.

StephanEwen commented on issue #8593: Distinguish the method of using NC on Linux and Windows in doc comments. URL: https://github.com/apache/flink/pull/8593#issuecomment-507588216 Look good, thanks. Merging this...

[GitHub] [flink] StephanEwen commented on a change in pull request #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter

StephanEwen commented on a change in pull request #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter URL: https://github.com/apache/flink/pull/8621#discussion_r299375079 ## File path:

[GitHub] [flink] NicoK commented on a change in pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

NicoK commented on a change in pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215#discussion_r299376398 ## File path:

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-12889: -- Priority: Critical (was: Minor) > Job keeps in FAILING state > -- >

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-12889: -- Affects Version/s: 1.9.0 1.7.2 1.8.1 > Job

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-12889: -- Component/s: (was: Runtime / Coordination) Runtime / Task > Job keeps in

[jira] [Updated] (FLINK-12889) Job keeps in FAILING state

[ https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-12889: -- Fix Version/s: 1.9.0 1.8.2 1.7.3 > Job keeps in FAILING

[GitHub] [flink] GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

GJL commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r299373397 ## File path:

[GitHub] [flink] StephanEwen commented on issue #8665: [FLINK-12781] [Runtime/REST] include the whole stack trace in response payload

StephanEwen commented on issue #8665: [FLINK-12781] [Runtime/REST] include the whole stack trace in response payload URL: https://github.com/apache/flink/pull/8665#issuecomment-507584861 Having the stack trace is indeed helpful. The response can however still fail due to messages

[GitHub] [flink] NicoK commented on a change in pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

NicoK commented on a change in pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215#discussion_r299372827 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem

tillrohrmann commented on a change in pull request #8215: [FLINK-8801][yarn/s3] Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem URL: https://github.com/apache/flink/pull/8215#discussion_r299367608 ## File path:

[GitHub] [flink] aljoscha commented on a change in pull request #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig

aljoscha commented on a change in pull request #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig URL: https://github.com/apache/flink/pull/8931#discussion_r299368867 ## File path:

[GitHub] [flink] StephanEwen commented on issue #8711: [FLINK-12817][docs]Correct the import in Processing function example.

StephanEwen commented on issue #8711: [FLINK-12817][docs]Correct the import in Processing function example. URL: https://github.com/apache/flink/pull/8711#issuecomment-507581214 The Scala imports still have the same issue as Chesnay mentioned for the Java imports...

[GitHub] [flink] aljoscha commented on a change in pull request #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig

aljoscha commented on a change in pull request #8931: [FLINK-13041] Make ScheduleMode configurable via ExecutionConfig URL: https://github.com/apache/flink/pull/8931#discussion_r299368009 ## File path: flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java

[GitHub] [flink] flinkbot edited a comment on issue #8714: [FLINK-12820][Connectors / Cassandra] Support ignoring writing nulls

flinkbot edited a comment on issue #8714: [FLINK-12820][Connectors / Cassandra] Support ignoring writing nulls URL: https://github.com/apache/flink/pull/8714#issuecomment-501259555 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] StephanEwen commented on issue #8714: [FLINK-12820][Connectors / Cassandra] Support ignoring writing nulls

StephanEwen commented on issue #8714: [FLINK-12820][Connectors / Cassandra] Support ignoring writing nulls URL: https://github.com/apache/flink/pull/8714#issuecomment-507579228 Overall approach looks good. I would ask you to switch to use primitive booleans rather than boxed

[jira] [Updated] (FLINK-13054) [Java] Support compact fixed-width vectors

[ https://issues.apache.org/jira/browse/FLINK-13054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu updated FLINK-13054: --- Description: was: In shuffle stage of some applications, FixedWitdhVectors may have very little

[GitHub] [flink] StephanEwen commented on issue #8714: [FLINK-12820][Connectors / Cassandra] Support ignoring writing nulls

StephanEwen commented on issue #8714: [FLINK-12820][Connectors / Cassandra] Support ignoring writing nulls URL: https://github.com/apache/flink/pull/8714#issuecomment-507578722 @flinkbot approve-until architecture This is

[jira] [Closed] (FLINK-13054) [Java] Support compact fixed-width vectors

[ https://issues.apache.org/jira/browse/FLINK-13054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ji Liu closed FLINK-13054. -- Resolution: Invalid > [Java] Support compact fixed-width vectors > --

[jira] [Created] (FLINK-13054) [Java] Support compact fixed-width vectors

Ji Liu created FLINK-13054: -- Summary: [Java] Support compact fixed-width vectors Key: FLINK-13054 URL: https://issues.apache.org/jira/browse/FLINK-13054 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot edited a comment on issue #8734: [FLINK-12840] fix network utils to work with ipv6 correctly

flinkbot edited a comment on issue #8734: [FLINK-12840] fix network utils to work with ipv6 correctly URL: https://github.com/apache/flink/pull/8734#issuecomment-501899832 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] StephanEwen commented on issue #8734: [FLINK-12840] fix network utils to work with ipv6 correctly

StephanEwen commented on issue #8734: [FLINK-12840] fix network utils to work with ipv6 correctly URL: https://github.com/apache/flink/pull/8734#issuecomment-507576316 @flinkbot approve all This is an automated message from

[GitHub] [flink] StephanEwen commented on issue #8734: [FLINK-12840] fix network utils to work with ipv6 correctly

StephanEwen commented on issue #8734: [FLINK-12840] fix network utils to work with ipv6 correctly URL: https://github.com/apache/flink/pull/8734#issuecomment-507576371 Thanks for reporting this. The fix looks good and correct, the tests make sense. Will merge this...

[jira] [Commented] (FLINK-12869) Add yarn acls capability to flink containers

[ https://issues.apache.org/jira/browse/FLINK-12869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876774#comment-16876774 ] Nicolas Fraison commented on FLINK-12869: - [~azagrebin] thanks for the feedback. So my proposal

[jira] [Commented] (FLINK-12840) Problems with ipv6 addresses

[ https://issues.apache.org/jira/browse/FLINK-12840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876775#comment-16876775 ] Stephan Ewen commented on FLINK-12840: -- Thanks, that is a good diagnosis and the right fix! I will

[jira] [Assigned] (FLINK-12840) Problems with ipv6 addresses

[ https://issues.apache.org/jira/browse/FLINK-12840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-12840: Assignee: Stephan Ewen > Problems with ipv6 addresses > > >

[GitHub] [flink] StephanEwen commented on issue #8877: [FLINK-12984][metrics] only call Histogram#getStatistics() once where possible

StephanEwen commented on issue #8877: [FLINK-12984][metrics] only call Histogram#getStatistics() once where possible URL: https://github.com/apache/flink/pull/8877#issuecomment-507571804 Couldn't we move these classes into the metrics modules? Both the test base and the

[jira] [Closed] (FLINK-12703) Introduce metadata handlers on SEMI/ANTI join and lookup join

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

[GitHub] [flink] flinkbot commented on issue #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

flinkbot commented on issue #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943#issuecomment-507569912 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] KurtYoung closed pull request #8588: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join

KurtYoung closed pull request #8588: [FLINK-12703] [table-planner-blink] Introduce metadata handlers on SEMI/ANTI join and lookup join URL: https://github.com/apache/flink/pull/8588 This is an automated message from the

[GitHub] [flink] StephanEwen commented on issue #8805: [FLINK-12902][hadoop] Remove flink-shaded-yarn-tests

StephanEwen commented on issue #8805: [FLINK-12902][hadoop] Remove flink-shaded-yarn-tests URL: https://github.com/apache/flink/pull/8805#issuecomment-507569537 How about rethinking the Hadoop/Yarn dependencies a bit? If we want a hadoop-free Flink, then no module should bundle

[jira] [Updated] (FLINK-11637) Translate "Checkpoints" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11637: --- Labels: pull-request-available (was: ) > Translate "Checkpoints" page into Chinese >

[GitHub] [flink] R-CodeBoy opened a new pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese

R-CodeBoy opened a new pull request #8943: [FLINK-11637][doc-zh]Translate Checkpoints page into Chinese URL: https://github.com/apache/flink/pull/8943 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server,

[GitHub] [flink] godfreyhe commented on a change in pull request #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner

godfreyhe commented on a change in pull request #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner URL: https://github.com/apache/flink/pull/8832#discussion_r299350051 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner

godfreyhe commented on a change in pull request #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner URL: https://github.com/apache/flink/pull/8832#discussion_r299350051 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner

godfreyhe commented on a change in pull request #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner URL: https://github.com/apache/flink/pull/8832#discussion_r299350051 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #8895: [FLINK-12536][Runtime/Network]Make BufferOrEventSequence#getNext non blocking

StephanEwen commented on a change in pull request #8895: [FLINK-12536][Runtime/Network]Make BufferOrEventSequence#getNext non blocking URL: https://github.com/apache/flink/pull/8895#discussion_r299347129 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #8895: [FLINK-12536][Runtime/Network]Make BufferOrEventSequence#getNext non blocking

StephanEwen commented on a change in pull request #8895: [FLINK-12536][Runtime/Network]Make BufferOrEventSequence#getNext non blocking URL: https://github.com/apache/flink/pull/8895#discussion_r299346369 ## File path:

[GitHub] [flink] StephanEwen commented on a change in pull request #8895: [FLINK-12536][Runtime/Network]Make BufferOrEventSequence#getNext non blocking

StephanEwen commented on a change in pull request #8895: [FLINK-12536][Runtime/Network]Make BufferOrEventSequence#getNext non blocking URL: https://github.com/apache/flink/pull/8895#discussion_r299343554 ## File path: flink-core/src/main/java/org/apache/flink/util/IOUtils.java

[GitHub] [flink] c4emmmm commented on issue #8872: [FLINK-12977][table]Port CsvTableSource to api-java-bridge

c4e commented on issue #8872: [FLINK-12977][table]Port CsvTableSource to api-java-bridge URL: https://github.com/apache/flink/pull/8872#issuecomment-507564412 @wuchong A test case for lookup join has been added, please take a look when you have time. Before this is merged,

[GitHub] [flink] liyafan82 commented on a change in pull request #8854: [FLINK-12959][table-planner-blink] Use BoundedInput and InputSelectable in blink and implement hash join

liyafan82 commented on a change in pull request #8854: [FLINK-12959][table-planner-blink] Use BoundedInput and InputSelectable in blink and implement hash join URL: https://github.com/apache/flink/pull/8854#discussion_r299346655 ## File path:

[GitHub] [flink] liyafan82 commented on a change in pull request #8854: [FLINK-12959][table-planner-blink] Use BoundedInput and InputSelectable in blink and implement hash join

liyafan82 commented on a change in pull request #8854: [FLINK-12959][table-planner-blink] Use BoundedInput and InputSelectable in blink and implement hash join URL: https://github.com/apache/flink/pull/8854#discussion_r299342932 ## File path:

[GitHub] [flink] StephanEwen commented on issue #8908: [hotfix][docs] Update IDE setup instructions for latest IntelliJ IDEA

StephanEwen commented on issue #8908: [hotfix][docs] Update IDE setup instructions for latest IntelliJ IDEA URL: https://github.com/apache/flink/pull/8908#issuecomment-507560428 Thanks for updating this. Looks good to me. Merging this...

[GitHub] [flink] morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299341591 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@

[GitHub] [flink] morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299341432 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@

[GitHub] [flink] StephanEwen commented on issue #8870: [FLINK-12974][checkstyle] Bump checkstyle to 8.14

StephanEwen commented on issue #8870: [FLINK-12974][checkstyle] Bump checkstyle to 8.14 URL: https://github.com/apache/flink/pull/8870#issuecomment-507558261 Thanks for fixing this, I tried 8.14 on my setup and it worked as expected. Merging this...

[GitHub] [flink] morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299339210 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@

[GitHub] [flink] morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299339210 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@

[GitHub] [flink] dawidwys commented on a change in pull request #8929: [FLINK-13028][table] Move expression resolver to flink-table-api-java

dawidwys commented on a change in pull request #8929: [FLINK-13028][table] Move expression resolver to flink-table-api-java URL: https://github.com/apache/flink/pull/8929#discussion_r299327183 ## File path:

[GitHub] [flink] morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299339210 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@

[GitHub] [flink] dawidwys commented on a change in pull request #8929: [FLINK-13028][table] Move expression resolver to flink-table-api-java

dawidwys commented on a change in pull request #8929: [FLINK-13028][table] Move expression resolver to flink-table-api-java URL: https://github.com/apache/flink/pull/8929#discussion_r299327183 ## File path:

[jira] [Updated] (FLINK-13053) Vectorization Support in Flink

[ https://issues.apache.org/jira/browse/FLINK-13053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13053: - Description: Vectorization is a popular technique in SQL engines today. Compared with traditional

[jira] [Updated] (FLINK-13053) Vectorization Support in Flink

[ https://issues.apache.org/jira/browse/FLINK-13053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13053: - Description: Vectorization is a popular technique in SQL engines today. Compared with traditional

[GitHub] [flink] morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r29933 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@

[jira] [Created] (FLINK-13053) Vectorization Support in Flink

Liya Fan created FLINK-13053: Summary: Vectorization Support in Flink Key: FLINK-13053 URL: https://issues.apache.org/jira/browse/FLINK-13053 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-13042) Make slot sharing configurable on StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-13042: - Description: There is a requirement of Blink batch planner that providing a global setting that

[jira] [Updated] (FLINK-13042) Make slot sharing configurable on StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-13042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-13042: - Summary: Make slot sharing configurable on StreamExecutionEnvironment (was: Make slot sharing

[GitHub] [flink] morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299336734 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@

[GitHub] [flink] morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299336232 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@

[jira] [Created] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

chaiyongqiang created FLINK-13052: - Summary: Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource Key: FLINK-13052 URL: https://issues.apache.org/jira/browse/FLINK-13052

[GitHub] [flink] morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

morsapaes commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r299331860 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,243 @@

[GitHub] [flink] twalthr commented on a change in pull request #8929: [FLINK-13028][table] Move expression resolver to flink-table-api-java

twalthr commented on a change in pull request #8929: [FLINK-13028][table] Move expression resolver to flink-table-api-java URL: https://github.com/apache/flink/pull/8929#discussion_r299330024 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8937: [FLINK-13040] promote blink table config and add to document

zentol commented on a change in pull request #8937: [FLINK-13040] promote blink table config and add to document URL: https://github.com/apache/flink/pull/8937#discussion_r299329390 ## File path:

[jira] [Commented] (FLINK-12979) Sending data to kafka with CsvRowSerializationSchema always adding a "\n", "\r","\r\n" at the end of the message

[ https://issues.apache.org/jira/browse/FLINK-12979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876735#comment-16876735 ] chaiyongqiang commented on FLINK-12979: --- When i check

[GitHub] [flink] XuPingyong commented on a change in pull request #8937: [FLINK-13040] promote blink table config and add to document

XuPingyong commented on a change in pull request #8937: [FLINK-13040] promote blink table config and add to document URL: https://github.com/apache/flink/pull/8937#discussion_r299327232 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #8929: [FLINK-13028][table] Move expression resolver to flink-table-api-java

dawidwys commented on a change in pull request #8929: [FLINK-13028][table] Move expression resolver to flink-table-api-java URL: https://github.com/apache/flink/pull/8929#discussion_r299327183 ## File path:

[GitHub] [flink] becketqin commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

becketqin commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-507544552 @Xeli Just to let you know, I am reviewing the patch. Hopefully we can check this in

[jira] [Updated] (FLINK-13051) Drop the non-selectable two-input StreamTask and Processor

[ https://issues.apache.org/jira/browse/FLINK-13051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun updated FLINK-13051: -- Description: After `StreamTwoInputSelectableProcessor` supports `CheckpointBarrierHandler`, we should

[GitHub] [flink] XuPingyong commented on a change in pull request #8937: [FLINK-13040] promote blink table config and add to document

XuPingyong commented on a change in pull request #8937: [FLINK-13040] promote blink table config and add to document URL: https://github.com/apache/flink/pull/8937#discussion_r299323887 ## File path:

<    1   2   3   4   5   >