[GitHub] flinkbot commented on issue #7872: [FLINK-11420][core] Fixed duplicate method of TraversableSerializer

2019-02-28 Thread GitBox
flinkbot commented on issue #7872: [FLINK-11420][core] Fixed duplicate method of TraversableSerializer URL: https://github.com/apache/flink/pull/7872#issuecomment-468577664 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] dawidwys opened a new pull request #7872: [FLINK-11420][core] Fixed duplicate method of TraversableSerializer

2019-02-28 Thread GitBox
dawidwys opened a new pull request #7872: [FLINK-11420][core] Fixed duplicate method of TraversableSerializer URL: https://github.com/apache/flink/pull/7872 ## What is the purpose of the change The duplicate method of TypeSerializer used an equality check rather than reference

[jira] [Updated] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal

2019-02-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-9685: -- Component/s: Runtime / Coordination > Flink should support hostname-substitution for >

[jira] [Updated] (FLINK-11783) Deadlock during Join operation

2019-02-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-11783: --- Component/s: API / DataSet > Deadlock during Join operation >

[GitHub] libenchao commented on issue #7867: [hotfix][datastream] Fix typos in DataStream

2019-02-28 Thread GitBox
libenchao commented on issue #7867: [hotfix][datastream] Fix typos in DataStream URL: https://github.com/apache/flink/pull/7867#issuecomment-468576409 Thanks for the review @zentol , will do the merge. This is an automated

[jira] [Updated] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

2019-02-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4387: -- Release Note: (was: Thank you for your assessment. I've closed it.) Thank you for your

[jira] [Closed] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

2019-02-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-4387. - Resolution: Fixed Release Note: Thank you for your assessment. I've closed it. >

[jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

2019-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781394#comment-16781394 ] Ufuk Celebi commented on FLINK-4387: I think as [~yunta] says, this should have been fixed when Netty

[jira] [Closed] (FLINK-1833) Refactor partition availability notification in ExecutionGraph

2019-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-1833. -- Resolution: Won't Do > Refactor partition availability notification in ExecutionGraph >

[jira] [Updated] (FLINK-11533) Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever

2019-02-28 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11533: Fix Version/s: 1.9.0 > Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever >

[GitHub] uce merged pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName

2019-02-28 Thread GitBox
uce merged pull request #7717: [FLINK-11533] [container] Add option parse JAR manifest for jobClassName URL: https://github.com/apache/flink/pull/7717 This is an automated message from the Apache Git Service. To respond to

[GitHub] zentol commented on issue #7867: [hotfix][datastream] Fix typos in DataStream

2019-02-28 Thread GitBox
zentol commented on issue #7867: [hotfix][datastream] Fix typos in DataStream URL: https://github.com/apache/flink/pull/7867#issuecomment-468570565 please merge all of your PRs into a single one. #7867, #7868, #7869, #7870, #7871

[GitHub] JingsongLi commented on a change in pull request #7816: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
JingsongLi commented on a change in pull request #7816: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261499804 ## File path:

[jira] [Commented] (FLINK-11335) Kafka consumer can not commit offset at checkpoint

2019-02-28 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781360#comment-16781360 ] Dawid Wysakowicz commented on FLINK-11335: -- Unfortunately the {{repeated.log}} is not very

[jira] [Closed] (FLINK-10585) RestServerEndpoint responds with wrong Content-Type in Integration Test.

2019-02-28 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-10585. Resolution: Fixed Fixed via 1.8: {{a6902cef6281f06bc54592d9a3bd6e4362dd0dc3}}

[GitHub] asfgit closed pull request #7839: [FLINK-10585][tests] Fix RestServerEndpointITCase instability

2019-02-28 Thread GitBox
asfgit closed pull request #7839: [FLINK-10585][tests] Fix RestServerEndpointITCase instability URL: https://github.com/apache/flink/pull/7839 This is an automated message from the Apache Git Service. To respond to the

[GitHub] libenchao opened a new pull request #7871: [hotfix][datastream] Fix wrong javadoc for TwoInputTransformation

2019-02-28 Thread GitBox
libenchao opened a new pull request #7871: [hotfix][datastream] Fix wrong javadoc for TwoInputTransformation URL: https://github.com/apache/flink/pull/7871 This is an automated message from the Apache Git Service.

[GitHub] flinkbot commented on issue #7871: [hotfix][datastream] Fix wrong javadoc for TwoInputTransformation

2019-02-28 Thread GitBox
flinkbot commented on issue #7871: [hotfix][datastream] Fix wrong javadoc for TwoInputTransformation URL: https://github.com/apache/flink/pull/7871#issuecomment-468562164 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] flinkbot commented on issue #7870: [hotfix][datastream] Fix wrong javadoc for OneInputTransformation.getOperator()

2019-02-28 Thread GitBox
flinkbot commented on issue #7870: [hotfix][datastream] Fix wrong javadoc for OneInputTransformation.getOperator() URL: https://github.com/apache/flink/pull/7870#issuecomment-468561090 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] libenchao opened a new pull request #7870: [hotfix][datastream] Fix wrong javadoc for OneInputTransformation.getOperator()

2019-02-28 Thread GitBox
libenchao opened a new pull request #7870: [hotfix][datastream] Fix wrong javadoc for OneInputTransformation.getOperator() URL: https://github.com/apache/flink/pull/7870 This is an automated message from the Apache Git

[GitHub] flinkbot commented on issue #7869: [hotfix][datastream] Fix typo in WindowedStream

2019-02-28 Thread GitBox
flinkbot commented on issue #7869: [hotfix][datastream] Fix typo in WindowedStream URL: https://github.com/apache/flink/pull/7869#issuecomment-468560143 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[GitHub] libenchao opened a new pull request #7869: [hotfix][datastream] Fix typo in WindowedStream

2019-02-28 Thread GitBox
libenchao opened a new pull request #7869: [hotfix][datastream] Fix typo in WindowedStream URL: https://github.com/apache/flink/pull/7869 This is an automated message from the Apache Git Service. To respond to the

[GitHub] flinkbot commented on issue #7868: [hotfix][datastream] Fix typo in JoinedStreams

2019-02-28 Thread GitBox
flinkbot commented on issue #7868: [hotfix][datastream] Fix typo in JoinedStreams URL: https://github.com/apache/flink/pull/7868#issuecomment-468559798 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[GitHub] libenchao opened a new pull request #7868: [hotfix][datastream] Fix typo in JoinedStreams

2019-02-28 Thread GitBox
libenchao opened a new pull request #7868: [hotfix][datastream] Fix typo in JoinedStreams URL: https://github.com/apache/flink/pull/7868 ## What is the purpose of the change *Fix typo* ## Brief change log - *Fix typo* ## Verifying this change

[GitHub] flinkbot commented on issue #7867: [hotfix][datastream] Fix typos in DataStream

2019-02-28 Thread GitBox
flinkbot commented on issue #7867: [hotfix][datastream] Fix typos in DataStream URL: https://github.com/apache/flink/pull/7867#issuecomment-468559265 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We

[GitHub] libenchao opened a new pull request #7867: [hotfix][datastream] Fix typos in DataStream

2019-02-28 Thread GitBox
libenchao opened a new pull request #7867: [hotfix][datastream] Fix typos in DataStream URL: https://github.com/apache/flink/pull/7867 ## What is the purpose of the change *Fix typos and outdated javadocs in DataStream* ## Brief change log - *Fix a few

[GitHub] godfreyhe commented on a change in pull request #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common

2019-02-28 Thread GitBox
godfreyhe commented on a change in pull request #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common URL: https://github.com/apache/flink/pull/7642#discussion_r261476403 ## File path:

[GitHub] godfreyhe commented on a change in pull request #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common

2019-02-28 Thread GitBox
godfreyhe commented on a change in pull request #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common URL: https://github.com/apache/flink/pull/7642#discussion_r261487835 ## File path:

[GitHub] godfreyhe commented on a change in pull request #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common

2019-02-28 Thread GitBox
godfreyhe commented on a change in pull request #7642: [FLINK-11516][table] Port and move some Descriptor classes to flink-table-common URL: https://github.com/apache/flink/pull/7642#discussion_r261485410 ## File path:

[GitHub] zhijiangW commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions

2019-02-28 Thread GitBox
zhijiangW commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#issuecomment-468555786 @tillrohrmann also mentioned this issue in discussion of proposed shuffle manager. The life cycle of `Task` and

[jira] [Assigned] (FLINK-11560) Translate "Flink Applications" page into Chinese

2019-02-28 Thread YE QIAN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YE QIAN reassigned FLINK-11560: --- Assignee: YE QIAN (was: xueyu) > Translate "Flink Applications" page into Chinese >

[jira] [Commented] (FLINK-10388) RestClientTest sometimes fails with AssertionError

2019-02-28 Thread Chunhui Shi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781312#comment-16781312 ] Chunhui Shi commented on FLINK-10388: - Since this could fail in a valid network environment ( I am

[jira] [Commented] (FLINK-11560) Translate "Flink Applications" page into Chinese

2019-02-28 Thread Stephen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781311#comment-16781311 ] Stephen commented on FLINK-11560: - I'll start the translation in the next few days. > Translate "Flink

[jira] [Commented] (FLINK-10658) org.apache.flink.util.FlinkException: Releasing shared slot parent.

2019-02-28 Thread Xingbin Sun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781305#comment-16781305 ] Xingbin Sun commented on FLINK-10658: - I have two jobs, jobA and jobB. When I cancel jobA, jobB

[jira] [Updated] (FLINK-11764) Update BucketingSinkMigrationTest for Flink 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11764: - Component/s: Connectors / FileSystem > Update BucketingSinkMigrationTest for Flink 1.8 >

[jira] [Updated] (FLINK-11767) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11767: - Component/s: API / Type Serialization System > Update TypeSerializerSnapshotMigrationTestBase and

[jira] [Commented] (FLINK-11756) Update migration tests for Flink 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781290#comment-16781290 ] vinoyang commented on FLINK-11756: -- [~rmetzger] I have tried to specify the component for each sub

[GitHub] desiam commented on issue #7861: [FLINK-11747] [ Connectors / ElasticSearch] Expose RestHighLevelClient to allow for custom sniffing

2019-02-28 Thread GitBox
desiam commented on issue #7861: [FLINK-11747] [ Connectors / ElasticSearch] Expose RestHighLevelClient to allow for custom sniffing URL: https://github.com/apache/flink/pull/7861#issuecomment-468543014 @tzulitai From

[jira] [Updated] (FLINK-11770) Update FlinkKinesisConsumerMigrationTest for 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11770: - Component/s: Connectors / Kinesis > Update FlinkKinesisConsumerMigrationTest for 1.8 >

[jira] [Updated] (FLINK-11768) Update TypeSerializerSnapshotMigrationITCase for Flink 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11768: - Component/s: API / Type Serialization System > Update TypeSerializerSnapshotMigrationITCase for Flink

[jira] [Updated] (FLINK-11766) Update Java / Scala StatefulJobSavepointMigrationITCase for 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11766: - Component/s: Runtime / Checkpointing > Update Java / Scala StatefulJobSavepointMigrationITCase for 1.8

[jira] [Updated] (FLINK-11765) Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11765: - Component/s: API / DataStream > Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.8 >

[jira] [Updated] (FLINK-11763) Update AbstractKeyedOperatorRestoreTestBase for 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11763: - Component/s: API / DataStream > Update AbstractKeyedOperatorRestoreTestBase for 1.8 >

[jira] [Updated] (FLINK-11761) Update FlinkKafkaConsumerBaseMigrationTest for 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11761: - Component/s: Connectors / Kafka > Update FlinkKafkaConsumerBaseMigrationTest for 1.8 >

[jira] [Updated] (FLINK-11762) Update WindowOperatorMigrationTest for 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11762: - Component/s: API / DataStream > Update WindowOperatorMigrationTest for 1.8 >

[jira] [Closed] (FLINK-11485) Migrate PojoSerializer to use new serialization compatibility abstractions

2019-02-28 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-11485. --- Resolution: Fixed > Migrate PojoSerializer to use new serialization compatibility

[jira] [Updated] (FLINK-11760) Update CEPMigrationTest for 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11760: - Component/s: Library / CEP > Update CEPMigrationTest for 1.8 > --- > >

[jira] [Updated] (FLINK-11758) Update ContinuousFileProcessingMigrationTest for 1.8

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-11758: - Component/s: Connectors / FileSystem > Update ContinuousFileProcessingMigrationTest for 1.8 >

[GitHub] carp84 commented on issue #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern

2019-02-28 Thread GitBox
carp84 commented on issue #7866: [FLINK-11730] [State Backends] Make HeapKeyedStateBackend follow the builder pattern URL: https://github.com/apache/flink/pull/7866#issuecomment-468540097 Note: now restore is included in backend building/constructing process, so we need to make sure each

[GitHub] Tom-Goong commented on a change in pull request #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance"

2019-02-28 Thread GitBox
Tom-Goong commented on a change in pull request #7820: [FLINK-11742][Metrics]Push metrics to Pushgateway without "instance" URL: https://github.com/apache/flink/pull/7820#discussion_r261476961 ## File path:

[GitHub] zhijiangW commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions

2019-02-28 Thread GitBox
zhijiangW commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#issuecomment-468538365 @azagrebin , you pointed out a very good question which I have not thought before. :) Currently app/flink

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

2019-02-28 Thread Alex Vinnik (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781273#comment-16781273 ] Alex Vinnik commented on FLINK-11143: - [~Tony0421] tried  {code:java} $ java -version java version

[GitHub] KurtYoung closed pull request #7834: [FLINK-11715][table-planner-blink] Add optimize program to organize optimization phases

2019-02-28 Thread GitBox
KurtYoung closed pull request #7834: [FLINK-11715][table-planner-blink] Add optimize program to organize optimization phases URL: https://github.com/apache/flink/pull/7834 This is an automated message from the Apache Git

[jira] [Closed] (FLINK-11715) Add optimize program to organize optimization phases

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-11715. -- Resolution: Implemented Fix Version/s: 1.9.0 > Add optimize program to organize optimization

[jira] [Commented] (FLINK-11715) Add optimize program to organize optimization phases

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781267#comment-16781267 ] Kurt Young commented on FLINK-11715: implemented in 2328ff3a45b889f5bf2c4e8873944980cd904721 > Add

[GitHub] KurtYoung commented on issue #7834: [FLINK-11715][table-planner-blink] Add optimize program to organize optimization phases

2019-02-28 Thread GitBox
KurtYoung commented on issue #7834: [FLINK-11715][table-planner-blink] Add optimize program to organize optimization phases URL: https://github.com/apache/flink/pull/7834#issuecomment-468536342 merging this... This is an

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261473138 ## File path:

[GitHub] Myasuka commented on issue #7281: [FLINK-11107][state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

2019-02-28 Thread GitBox
Myasuka commented on issue #7281: [FLINK-11107][state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured URL: https://github.com/apache/flink/pull/7281#issuecomment-468532245 Since Flink-1.8 is about to release, @StephanEwen

[GitHub] godfreyhe commented on a change in pull request #7834: [FLINK-11715][table-planner-blink] Add optimize program to organize optimization phases

2019-02-28 Thread GitBox
godfreyhe commented on a change in pull request #7834: [FLINK-11715][table-planner-blink] Add optimize program to organize optimization phases URL: https://github.com/apache/flink/pull/7834#discussion_r261471649 ## File path:

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

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781250#comment-16781250 ] vinoyang commented on FLINK-9650: - [~amalakar]  In fact, I have not applied the flink style for the IDE.

[GitHub] JingsongLi commented on a change in pull request #7816: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
JingsongLi commented on a change in pull request #7816: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261471313 ## File path:

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261470974 ## File path:

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

2019-02-28 Thread Arup Malakar (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781237#comment-16781237 ] Arup Malakar commented on FLINK-9650: - Hey [~yanghua], in the current PR I would see if I can get the

[GitHub] JingsongLi commented on issue #7816: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
JingsongLi commented on issue #7816: [FLINK-11701][table-runtime-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#issuecomment-468528599 Fix comments This is an automated

[GitHub] tzulitai edited a comment on issue #7861: [FLINK-11747] [ Connectors / ElasticSearch] Expose RestHighLevelClient to allow for custom sniffing

2019-02-28 Thread GitBox
tzulitai edited a comment on issue #7861: [FLINK-11747] [ Connectors / ElasticSearch] Expose RestHighLevelClient to allow for custom sniffing URL: https://github.com/apache/flink/pull/7861#issuecomment-468524319 This would not work. The client is only created in the `open` method, and

[GitHub] tzulitai commented on issue #7861: [FLINK-11747] [ Connectors / ElasticSearch] Expose RestHighLevelClient to allow for custom sniffing

2019-02-28 Thread GitBox
tzulitai commented on issue #7861: [FLINK-11747] [ Connectors / ElasticSearch] Expose RestHighLevelClient to allow for custom sniffing URL: https://github.com/apache/flink/pull/7861#issuecomment-468524553 @flinkbot disapprove architecture

[GitHub] tzulitai commented on issue #7861: [FLINK-11747] [ Connectors / ElasticSearch] Expose RestHighLevelClient to allow for custom sniffing

2019-02-28 Thread GitBox
tzulitai commented on issue #7861: [FLINK-11747] [ Connectors / ElasticSearch] Expose RestHighLevelClient to allow for custom sniffing URL: https://github.com/apache/flink/pull/7861#issuecomment-468524319 @flinkbot disapprove architecture This would not work. The client is only

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261458610 ## File path:

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261457655 ## File path:

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261457262 ## File path:

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261457344 ## File path:

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261457026 ## File path:

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261456634 ## File path:

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

2019-02-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781186#comment-16781186 ] vinoyang commented on FLINK-9650: - [~amalakar] Thank you for the excellent work you have done. If you

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

2019-02-28 Thread GitBox
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-468511247 @sunjincheng121 Thanks a lot for the review. I will rebase the PR after all the commits

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261456020 ## File path:

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261455698 ## File path:

[GitHub] KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats

2019-02-28 Thread GitBox
KurtYoung commented on a change in pull request #7816: [FLINK-11701][table-planner-blink] Introduce an abstract set of data formats URL: https://github.com/apache/flink/pull/7816#discussion_r261455452 ## File path:

[jira] [Updated] (FLINK-11679) Create Blink SQL planner and runtime modules

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11679: --- Component/s: (was: API / Table SQL) SQL / Planner > Create Blink SQL planner

[jira] [Updated] (FLINK-11724) Add copyToUnsafe, method to MemorySegment

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11724: --- Summary: Add copyToUnsafe, method to MemorySegment (was: Add util method to MemorySegment) > Add

[jira] [Updated] (FLINK-11702) Introduce a new table type system: InternalType

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11702: --- Component/s: (was: API / Table SQL) SQL / Planner > Introduce a new table type

[jira] [Updated] (FLINK-11714) Add cost model for both batch and streaming

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11714: --- Component/s: (was: API / Table SQL) SQL / Planner > Add cost model for both

[jira] [Updated] (FLINK-11711) Add table and column stats

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11711: --- Component/s: (was: API / Table SQL) SQL / Planner > Add table and column stats

[jira] [Updated] (FLINK-11715) Add optimize program to organize optimization phases

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11715: --- Component/s: (was: API / Table SQL) SQL / Planner > Add optimize program to

[jira] [Updated] (FLINK-11703) Add a basic framework for Blink SQL

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11703: --- Component/s: (was: API / Table SQL) SQL / Planner > Add a basic framework for

[jira] [Updated] (FLINK-11680) Make query plan easier to read

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11680: --- Component/s: (was: API / Table SQL) SQL / Planner > Make query plan easier to

[jira] [Updated] (FLINK-11685) Add plan test infrastructure

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11685: --- Component/s: (was: API / Table SQL) SQL / Planner > Add plan test

[jira] [Updated] (FLINK-11701) Introduce an abstract set of data formats

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11701: --- Component/s: (was: API / Table SQL) Runtime / Operators > Introduce an

[jira] [Updated] (FLINK-11488) Add a basic Blink planner framework

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11488: --- Component/s: (was: API / Table SQL) SQL / Planner > Add a basic Blink planner

[jira] [Commented] (FLINK-11724) Add copyToUnsafe, copyFromUnsafe and equalTo to MemorySegment

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781173#comment-16781173 ] Kurt Young commented on FLINK-11724: implemented in 492d1d40100b1297281408bf0d83b6db5378b9cb > Add

[jira] [Updated] (FLINK-11724) Add copyToUnsafe, copyFromUnsafe and equalTo to MemorySegment

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11724: --- Summary: Add copyToUnsafe, copyFromUnsafe and equalTo to MemorySegment (was: Add copyToUnsafe,

[jira] [Resolved] (FLINK-11724) Add copyToUnsafe, copyFromUnsafe and equalTo to MemorySegment

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young resolved FLINK-11724. Resolution: Implemented Fix Version/s: 1.9.0 > Add copyToUnsafe, copyFromUnsafe and

[jira] [Updated] (FLINK-11724) Add copyToUnsafe, copyFromUnsafe and equalTo method to MemorySegment

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11724: --- Summary: Add copyToUnsafe, copyFromUnsafe and equalTo method to MemorySegment (was: Add

[GitHub] KurtYoung closed pull request #7847: [FLINK-11724][core] Add util method to MemorySegment

2019-02-28 Thread GitBox
KurtYoung closed pull request #7847: [FLINK-11724][core] Add util method to MemorySegment URL: https://github.com/apache/flink/pull/7847 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] KurtYoung commented on issue #7847: [FLINK-11724][core] Add util method to MemorySegment

2019-02-28 Thread GitBox
KurtYoung commented on issue #7847: [FLINK-11724][core] Add util method to MemorySegment URL: https://github.com/apache/flink/pull/7847#issuecomment-468506183 merging this... This is an automated message from the Apache Git

[GitHub] flinkbot edited a comment on issue #7848: [FLINK-10755][table] Port external catalogs in Table API extension points to flink-table-common

2019-02-28 Thread GitBox
flinkbot edited a comment 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-467855282 Thanks a lot for your contribution to the Apache Flink project. I'm the

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

2019-02-28 Thread GitBox
sunjincheng121 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-468505635 @flinkbot approve description @flinkbot approve consensus Should be

[jira] [Closed] (FLINK-11379) "java.lang.OutOfMemoryError: Direct buffer memory" when TM loads a large size TDD

2019-02-28 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-11379. --- Resolution: Fixed Fixed in master: 1f5359a5259987b3c9d506d559b6421af961ab0a Fixed in release-1.8: 

[jira] [Updated] (FLINK-11788) Support Code Generation for RexNode

2019-02-28 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-11788: --- Component/s: (was: API / Table SQL) SQL / Planner > Support Code Generation

[GitHub] asfgit closed pull request #7797: [FLINK-11379] Fix OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD

2019-02-28 Thread GitBox
asfgit closed pull request #7797: [FLINK-11379] Fix OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD URL: https://github.com/apache/flink/pull/7797 This is an automated message from the Apache

  1   2   3   4   5   6   7   8   9   >